X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=server.h;fp=server.h;h=7297fd7797daf3adaf73738da93eb861fca89ad6;hp=cfc9d25160413a5ede6408213971a9d6bebed98f;hb=4934a0983fee26765a3c1a5b6bf5834ba6e7e52c;hpb=38a2bb28fd8dcb5bb1e0cb56028936a35f20f503 diff --git a/server.h b/server.h index cfc9d25..7297fd7 100644 --- a/server.h +++ b/server.h @@ -61,6 +61,7 @@ public: void set_backlog_size(int stream_index, size_t new_size); void set_prebuffering_bytes(int stream_index, size_t new_amount); void set_encoding(int stream_index, Stream::Encoding encoding); + void add_ping(const std::string &url, const std::string &allow_origin); private: // Mutex protecting queued_add_clients. @@ -87,7 +88,10 @@ private: std::vector streams; // Map from URL to index into . - std::map url_map; + std::map stream_url_map; + + // Map from URL to CORS Allow-Origin header (or empty string). + std::map ping_url_map; // Map from file descriptor to client. std::map clients; @@ -130,7 +134,8 @@ private: // Close a given client socket, and clean up after it. void close_client(Client *client); - // Parse the HTTP request. Returns a HTTP status code (200/400/404). + // Parse the HTTP request. Returns a HTTP status code (200/400/404), + // or -200 for a pong (which should be answered with 200). int parse_request(Client *client); // Construct the HTTP header, and set the client into @@ -141,6 +146,9 @@ private: // the SENDING_SHORT_RESPONSE state. void construct_error(Client *client, int error_code); + // Construct a pong, and set the client into the SENDING_SHORT_RESPONSE state. + void construct_pong(Client *client); + void process_queued_data(); void skip_lost_data(Client *client);