Merge branch 'mjpeg'

[nageru] / shared / httpd.cpp

diff --git a/httpd.cpp b/shared/httpd.cpp
similarity index 95%
rename from httpd.cpp
rename to shared/httpd.cpp
index 8d33e75a4f6b5bde8e6f8b79aa23ffa007e8351f..a2668f5987c352d2d3c7c501a86cd86828ffe682 100644 (file)
--- a/httpd.cpp
+++ b/shared/httpd.cpp
@@ -1,22 +1,22 @@
-#include "httpd.h"
+#include "shared/httpd.h"
 
 #include <assert.h>
 #include <byteswap.h>
 #include <endian.h>
+#include <memory>
 #include <microhttpd.h>
 #include <netinet/in.h>
 #include <stdio.h>
 #include <string.h>
 #include <sys/time.h>
 #include <time.h>
-#include <memory>
 extern "C" {
 #include <libavutil/avutil.h>
 }
 
-#include "defs.h"
-#include "metacube2.h"
-#include "metrics.h"
+#include "shared/shared_defs.h"
+#include "shared/metacube2.h"
+#include "shared/metrics.h"
 
 struct MHD_Connection;
 struct MHD_Response;
@@ -79,8 +79,8 @@ int HTTPD::answer_to_connection_thunk(void *cls, MHD_Connection *connection,
 
 int HTTPD::answer_to_connection(MHD_Connection *connection,
                                 const char *url, const char *method,
-                               const char *version, const char *upload_data,
-                               size_t *upload_data_size, void **con_cls)
+                                const char *version, const char *upload_data,
+                                size_t *upload_data_size, void **con_cls)
 {
        // See if the URL ends in “.metacube”.
        HTTPD::Stream::Framing framing;
@@ -173,7 +173,7 @@ ssize_t HTTPD::Stream::reader_callback_thunk(void *cls, uint64_t pos, char *buf,
 ssize_t HTTPD::Stream::reader_callback(uint64_t pos, char *buf, size_t max)
 {
        unique_lock<mutex> lock(buffer_mutex);
-       has_buffered_data.wait(lock, [this]{ return should_quit || !buffered_data.empty(); });
+       has_buffered_data.wait(lock, [this] { return should_quit || !buffered_data.empty(); });
        if (should_quit) {
                return 0;
        }
@@ -272,7 +272,7 @@ void HTTPD::Stream::add_data(const char *buf, size_t buf_size, HTTPD::Stream::Da
                buffered_data.emplace_back((char *)&packet, sizeof(packet));
        }
 
-       has_buffered_data.notify_all(); 
+       has_buffered_data.notify_all();
 }
 
 void HTTPD::Stream::stop()