X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=server.h;h=7297fd7797daf3adaf73738da93eb861fca89ad6;hb=4934a0983fee26765a3c1a5b6bf5834ba6e7e52c;hp=79c35f82e8bf065a9fe9e7f6bff33ef8eb3b6a23;hpb=d72af7eae68766b62560bdb171302bcc44d98ec2;p=cubemap diff --git a/server.h b/server.h index 79c35f8..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 @@ -138,9 +143,12 @@ private: void construct_header(Client *client); // Construct a generic error with the given line, and set the client into - // the SENDING_ERROR state. + // 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);