diff --git a/src/shrpx.h b/src/shrpx.h index c7e050fb..7466df37 100644 --- a/src/shrpx.h +++ b/src/shrpx.h @@ -29,10 +29,21 @@ # include #endif // HAVE_CONFIG_H +#include +#include + #include #include "shrpx_log.h" +#ifndef SOCK_NONBLOCK +#define SOCK_NONBLOCK 0 +#endif // !SOCK_NONBLOCK + +#ifndef SOCK_CLOEXEC +#define SOCK_CLOEXEC 0 +#endif // !SOCK_CLOEXEC + #define DIE() \ assert(0); diff --git a/src/shrpx_listen_handler.cc b/src/shrpx_listen_handler.cc index 19c4a6f4..b19a479f 100644 --- a/src/shrpx_listen_handler.cc +++ b/src/shrpx_listen_handler.cc @@ -75,6 +75,7 @@ void ListenHandler::worker_reopen_log_files() } } +#ifndef NOTHREADS namespace { void worker_writecb(bufferevent *bev, void *ptr) { @@ -96,9 +97,11 @@ void worker_writecb(bufferevent *bev, void *ptr) bufferevent_disable(bev, EV_READ | EV_WRITE); } } // namespace +#endif // NOTHREADS void ListenHandler::create_worker_thread(size_t num) { +#ifndef NOTHREADS workers_.resize(0); for(size_t i = 0; i < num; ++i) { int rv; @@ -137,10 +140,12 @@ void ListenHandler::create_worker_thread(size_t num) LLOG(INFO, this) << "Created thread #" << workers_.size() - 1; } } +#endif // NOTHREADS } void ListenHandler::join_worker() { +#ifndef NOTHREADS int n = 0; if(LOG_ENABLED(INFO)) { @@ -155,6 +160,7 @@ void ListenHandler::join_worker() } ++n; } +#endif // NOTHREADS } void ListenHandler::graceful_shutdown_worker() diff --git a/src/shrpx_listen_handler.h b/src/shrpx_listen_handler.h index 8a1e7fb7..e599f742 100644 --- a/src/shrpx_listen_handler.h +++ b/src/shrpx_listen_handler.h @@ -32,7 +32,9 @@ #include #include +#ifndef NOTHREADS #include +#endif // NOTHREADS #include @@ -43,7 +45,9 @@ namespace shrpx { struct WorkerInfo { +#ifndef NOTHREADS std::future fut; +#endif // NOTHREADS SSL_CTX *sv_ssl_ctx; SSL_CTX *cl_ssl_ctx; bufferevent *bev;