Index: talk/examples/peerconnection/server/data_socket.h |
diff --git a/talk/examples/peerconnection/server/data_socket.h b/talk/examples/peerconnection/server/data_socket.h |
deleted file mode 100644 |
index b3ca2c691a5cac9f53d1487d8e996806fcc28b46..0000000000000000000000000000000000000000 |
--- a/talk/examples/peerconnection/server/data_socket.h |
+++ /dev/null |
@@ -1,170 +0,0 @@ |
-/* |
- * libjingle |
- * Copyright 2011 Google Inc. |
- * |
- * Redistribution and use in source and binary forms, with or without |
- * modification, are permitted provided that the following conditions are met: |
- * |
- * 1. Redistributions of source code must retain the above copyright notice, |
- * this list of conditions and the following disclaimer. |
- * 2. Redistributions in binary form must reproduce the above copyright notice, |
- * this list of conditions and the following disclaimer in the documentation |
- * and/or other materials provided with the distribution. |
- * 3. The name of the author may not be used to endorse or promote products |
- * derived from this software without specific prior written permission. |
- * |
- * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED |
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF |
- * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO |
- * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, |
- * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; |
- * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, |
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR |
- * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF |
- * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
- */ |
- |
-#ifndef TALK_EXAMPLES_PEERCONNECTION_SERVER_DATA_SOCKET_H_ |
-#define TALK_EXAMPLES_PEERCONNECTION_SERVER_DATA_SOCKET_H_ |
-#pragma once |
- |
-#ifdef WIN32 |
-#include <winsock2.h> |
-typedef int socklen_t; |
-typedef SOCKET NativeSocket; |
-#else |
-#include <netinet/in.h> |
-#include <sys/select.h> |
-#include <sys/socket.h> |
-#define closesocket close |
-typedef int NativeSocket; |
- |
-#ifndef SOCKET_ERROR |
-#define SOCKET_ERROR (-1) |
-#endif |
- |
-#ifndef INVALID_SOCKET |
-#define INVALID_SOCKET static_cast<NativeSocket>(-1) |
-#endif |
-#endif |
- |
-#include <string> |
- |
-class SocketBase { |
- public: |
- SocketBase() : socket_(INVALID_SOCKET) { } |
- explicit SocketBase(NativeSocket socket) : socket_(socket) { } |
- ~SocketBase() { Close(); } |
- |
- NativeSocket socket() const { return socket_; } |
- bool valid() const { return socket_ != INVALID_SOCKET; } |
- |
- bool Create(); |
- void Close(); |
- |
- protected: |
- NativeSocket socket_; |
-}; |
- |
-// Represents an HTTP server socket. |
-class DataSocket : public SocketBase { |
- public: |
- enum RequestMethod { |
- INVALID, |
- GET, |
- POST, |
- OPTIONS, |
- }; |
- |
- explicit DataSocket(NativeSocket socket) |
- : SocketBase(socket), |
- method_(INVALID), |
- content_length_(0) { |
- } |
- |
- ~DataSocket() { |
- } |
- |
- static const char kCrossOriginAllowHeaders[]; |
- |
- bool headers_received() const { return method_ != INVALID; } |
- |
- RequestMethod method() const { return method_; } |
- |
- const std::string& request_path() const { return request_path_; } |
- std::string request_arguments() const; |
- |
- const std::string& data() const { return data_; } |
- |
- const std::string& content_type() const { return content_type_; } |
- |
- size_t content_length() const { return content_length_; } |
- |
- bool request_received() const { |
- return headers_received() && (method_ != POST || data_received()); |
- } |
- |
- bool data_received() const { |
- return method_ != POST || data_.length() >= content_length_; |
- } |
- |
- // Checks if the request path (minus arguments) matches a given path. |
- bool PathEquals(const char* path) const; |
- |
- // Called when we have received some data from clients. |
- // Returns false if an error occurred. |
- bool OnDataAvailable(bool* close_socket); |
- |
- // Send a raw buffer of bytes. |
- bool Send(const std::string& data) const; |
- |
- // Send an HTTP response. The |status| should start with a valid HTTP |
- // response code, followed by a string. E.g. "200 OK". |
- // If |connection_close| is set to true, an extra "Connection: close" HTTP |
- // header will be included. |content_type| is the mime content type, not |
- // including the "Content-Type: " string. |
- // |extra_headers| should be either empty or a list of headers where each |
- // header terminates with "\r\n". |
- // |data| is the body of the message. It's length will be specified via |
- // a "Content-Length" header. |
- bool Send(const std::string& status, bool connection_close, |
- const std::string& content_type, |
- const std::string& extra_headers, const std::string& data) const; |
- |
- // Clears all held state and prepares the socket for receiving a new request. |
- void Clear(); |
- |
- protected: |
- // A fairly relaxed HTTP header parser. Parses the method, path and |
- // content length (POST only) of a request. |
- // Returns true if a valid request was received and no errors occurred. |
- bool ParseHeaders(); |
- |
- // Figures out whether the request is a GET or POST and what path is |
- // being requested. |
- bool ParseMethodAndPath(const char* begin, size_t len); |
- |
- // Determines the length of the body and it's mime type. |
- bool ParseContentLengthAndType(const char* headers, size_t length); |
- |
- protected: |
- RequestMethod method_; |
- size_t content_length_; |
- std::string content_type_; |
- std::string request_path_; |
- std::string request_headers_; |
- std::string data_; |
-}; |
- |
-// The server socket. Accepts connections and generates DataSocket instances |
-// for each new connection. |
-class ListeningSocket : public SocketBase { |
- public: |
- ListeningSocket() {} |
- |
- bool Listen(unsigned short port); |
- DataSocket* Accept() const; |
-}; |
- |
-#endif // TALK_EXAMPLES_PEERCONNECTION_SERVER_DATA_SOCKET_H_ |