X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=server.h;h=68e72c4d543165e938a3e63810395727629c85ae;hp=dfcac0b0414d4addc9dacbabce40234c037f7cec;hb=50651c954803c1941e6ad1bb494712891c18f7d2;hpb=f0621e41fdb96ce1bd58e7561e0aa76345072ba3 diff --git a/server.h b/server.h index dfcac0b..68e72c4 100644 --- a/server.h +++ b/server.h @@ -1,7 +1,6 @@ #ifndef _SERVER_H #define _SERVER_H 1 -#include #include #include #include @@ -9,6 +8,7 @@ #include #include #include +#include #include #include #include @@ -71,24 +71,24 @@ public: private: // Mutex protecting queued_add_clients. - // Note that if you want to hold both this and below, - // you will need to take before this one. - mutable pthread_mutex_t queued_clients_mutex; + // Note that if you want to hold both this and below, + // you will need to take before this one. + mutable std::mutex queued_clients_mutex; // Deferred commands that should be run from the do_work() thread as soon as possible. // We defer these for two reasons: // // - We only want to fiddle with epoll from one thread at any given time, // and doing add_client() from the acceptor thread would violate that. - // - We don't want the input thread(s) hanging on when doing - // add_data(), since they want to do add_data() rather often, and + // - We don't want the input thread(s) hanging on when doing + // add_data(), since they want to do add_data() rather often, and // can be taken a lot of the time. // // Protected by . std::vector> queued_add_clients; // All variables below this line are protected by the mutex. - mutable pthread_mutex_t mutex; + mutable std::mutex mu; // All streams. std::vector> streams;