X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=server.h;h=0f93b7f0b034caa1eb88a276f3b2aa40fa78fc83;hp=dea24d894e4cf9e5c9ea5ab7d3e96fa77f861a08;hb=f3e2d52ccf79454ee157917f9017263a8f4c50c3;hpb=5f72b6466cca4da0b8de29f4526a6cde23c5368e diff --git a/server.h b/server.h index dea24d8..0f93b7f 100644 --- a/server.h +++ b/server.h @@ -57,14 +57,24 @@ public: // Start a new thread that handles clients. void run(); + + // Stop the thread. + void stop(); + void add_client(int sock); void add_stream(const std::string &stream_id); void set_header(const std::string &stream_id, const std::string &header); void add_data(const std::string &stream_id, const char *data, size_t bytes); private: + pthread_t worker_thread; + + // All variables below this line are protected by the mutex. pthread_mutex_t mutex; + // If the thread should stop or not. + bool should_stop; + // Map from stream ID to stream. std::map streams;