| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef NET_TOOLS_FLIP_SERVER_STREAMER_INTERFACE_H_ | 5 #ifndef NET_TOOLS_FLIP_SERVER_STREAMER_INTERFACE_H_ |
| 6 #define NET_TOOLS_FLIP_SERVER_STREAMER_INTERFACE_H_ | 6 #define NET_TOOLS_FLIP_SERVER_STREAMER_INTERFACE_H_ |
| 7 | 7 |
| 8 #include <stddef.h> |
| 9 #include <stdint.h> |
| 10 |
| 8 #include <string> | 11 #include <string> |
| 9 | 12 |
| 10 #include "base/compiler_specific.h" | 13 #include "base/compiler_specific.h" |
| 11 #include "net/tools/balsa/balsa_headers.h" | 14 #include "net/tools/balsa/balsa_headers.h" |
| 12 #include "net/tools/balsa/balsa_visitor_interface.h" | 15 #include "net/tools/balsa/balsa_visitor_interface.h" |
| 13 #include "net/tools/flip_server/sm_interface.h" | 16 #include "net/tools/flip_server/sm_interface.h" |
| 14 | 17 |
| 15 namespace net { | 18 namespace net { |
| 16 | 19 |
| 17 class BalsaFrame; | 20 class BalsaFrame; |
| 18 class FlipAcceptor; | 21 class FlipAcceptor; |
| 19 class MemCacheIter; | 22 class MemCacheIter; |
| 20 class SMConnection; | 23 class SMConnection; |
| 21 class EpollServer; | 24 class EpollServer; |
| 22 | 25 |
| 23 class StreamerSM : public BalsaVisitorInterface, public SMInterface { | 26 class StreamerSM : public BalsaVisitorInterface, public SMInterface { |
| 24 public: | 27 public: |
| 25 StreamerSM(SMConnection* connection, | 28 StreamerSM(SMConnection* connection, |
| 26 SMInterface* sm_other_interface, | 29 SMInterface* sm_other_interface, |
| 27 EpollServer* epoll_server, | 30 EpollServer* epoll_server, |
| 28 FlipAcceptor* acceptor); | 31 FlipAcceptor* acceptor); |
| 29 ~StreamerSM() override; | 32 ~StreamerSM() override; |
| 30 | 33 |
| 31 void AddToOutputOrder(const MemCacheIter& mci) {} | 34 void AddToOutputOrder(const MemCacheIter& mci) {} |
| 32 | 35 |
| 33 void InitSMInterface(SMInterface* sm_other_interface, | 36 void InitSMInterface(SMInterface* sm_other_interface, |
| 34 int32 server_idx) override; | 37 int32_t server_idx) override; |
| 35 void InitSMConnection(SMConnectionPoolInterface* connection_pool, | 38 void InitSMConnection(SMConnectionPoolInterface* connection_pool, |
| 36 SMInterface* sm_interface, | 39 SMInterface* sm_interface, |
| 37 EpollServer* epoll_server, | 40 EpollServer* epoll_server, |
| 38 int fd, | 41 int fd, |
| 39 std::string server_ip, | 42 std::string server_ip, |
| 40 std::string server_port, | 43 std::string server_port, |
| 41 std::string remote_ip, | 44 std::string remote_ip, |
| 42 bool use_ssl) override; | 45 bool use_ssl) override; |
| 43 | 46 |
| 44 size_t ProcessReadInput(const char* data, size_t len) override; | 47 size_t ProcessReadInput(const char* data, size_t len) override; |
| 45 size_t ProcessWriteInput(const char* data, size_t len) override; | 48 size_t ProcessWriteInput(const char* data, size_t len) override; |
| 46 bool MessageFullyRead() const override; | 49 bool MessageFullyRead() const override; |
| 47 void SetStreamID(uint32 stream_id) override {} | 50 void SetStreamID(uint32_t stream_id) override {} |
| 48 bool Error() const override; | 51 bool Error() const override; |
| 49 const char* ErrorAsString() const override; | 52 const char* ErrorAsString() const override; |
| 50 void Reset() override; | 53 void Reset() override; |
| 51 void ResetForNewInterface(int32 server_idx) override {} | 54 void ResetForNewInterface(int32_t server_idx) override {} |
| 52 void ResetForNewConnection() override; | 55 void ResetForNewConnection() override; |
| 53 void Cleanup() override; | 56 void Cleanup() override; |
| 54 int PostAcceptHook() override; | 57 int PostAcceptHook() override; |
| 55 void NewStream(uint32 stream_id, | 58 void NewStream(uint32_t stream_id, |
| 56 uint32 priority, | 59 uint32_t priority, |
| 57 const std::string& filename) override {} | 60 const std::string& filename) override {} |
| 58 void SendEOF(uint32 stream_id) override {} | 61 void SendEOF(uint32_t stream_id) override {} |
| 59 void SendErrorNotFound(uint32 stream_id) override {} | 62 void SendErrorNotFound(uint32_t stream_id) override {} |
| 60 virtual void SendOKResponse(uint32 stream_id, const std::string& output) {} | 63 virtual void SendOKResponse(uint32_t stream_id, const std::string& output) {} |
| 61 size_t SendSynStream(uint32 stream_id, const BalsaHeaders& headers) override; | 64 size_t SendSynStream(uint32_t stream_id, |
| 62 size_t SendSynReply(uint32 stream_id, const BalsaHeaders& headers) override; | 65 const BalsaHeaders& headers) override; |
| 63 void SendDataFrame(uint32 stream_id, | 66 size_t SendSynReply(uint32_t stream_id, const BalsaHeaders& headers) override; |
| 67 void SendDataFrame(uint32_t stream_id, |
| 64 const char* data, | 68 const char* data, |
| 65 int64 len, | 69 int64_t len, |
| 66 uint32 flags, | 70 uint32_t flags, |
| 67 bool compress) override {} | 71 bool compress) override {} |
| 68 void set_is_request() override; | 72 void set_is_request() override; |
| 69 static std::string forward_ip_header() { return forward_ip_header_; } | 73 static std::string forward_ip_header() { return forward_ip_header_; } |
| 70 static void set_forward_ip_header(const std::string& value) { | 74 static void set_forward_ip_header(const std::string& value) { |
| 71 forward_ip_header_ = value; | 75 forward_ip_header_ = value; |
| 72 } | 76 } |
| 73 | 77 |
| 74 private: | 78 private: |
| 75 void SendEOFImpl(uint32 stream_id) {} | 79 void SendEOFImpl(uint32_t stream_id) {} |
| 76 void SendErrorNotFoundImpl(uint32 stream_id) {} | 80 void SendErrorNotFoundImpl(uint32_t stream_id) {} |
| 77 void SendOKResponseImpl(uint32 stream_id, std::string* output) {} | 81 void SendOKResponseImpl(uint32_t stream_id, std::string* output) {} |
| 78 size_t SendSynReplyImpl(uint32 stream_id, const BalsaHeaders& headers) { | 82 size_t SendSynReplyImpl(uint32_t stream_id, const BalsaHeaders& headers) { |
| 79 return 0; | 83 return 0; |
| 80 } | 84 } |
| 81 size_t SendSynStreamImpl(uint32 stream_id, const BalsaHeaders& headers) { | 85 size_t SendSynStreamImpl(uint32_t stream_id, const BalsaHeaders& headers) { |
| 82 return 0; | 86 return 0; |
| 83 } | 87 } |
| 84 void SendDataFrameImpl(uint32 stream_id, | 88 void SendDataFrameImpl(uint32_t stream_id, |
| 85 const char* data, | 89 const char* data, |
| 86 int64 len, | 90 int64_t len, |
| 87 uint32 flags, | 91 uint32_t flags, |
| 88 bool compress) {} | 92 bool compress) {} |
| 89 void GetOutput() override {} | 93 void GetOutput() override {} |
| 90 | 94 |
| 91 void ProcessBodyInput(const char* input, size_t size) override; | 95 void ProcessBodyInput(const char* input, size_t size) override; |
| 92 void MessageDone() override; | 96 void MessageDone() override; |
| 93 void ProcessHeaders(const BalsaHeaders& headers) override; | 97 void ProcessHeaders(const BalsaHeaders& headers) override; |
| 94 void ProcessBodyData(const char* input, size_t size) override {} | 98 void ProcessBodyData(const char* input, size_t size) override {} |
| 95 void ProcessHeaderInput(const char* input, size_t size) override {} | 99 void ProcessHeaderInput(const char* input, size_t size) override {} |
| 96 void ProcessTrailerInput(const char* input, size_t size) override {} | 100 void ProcessTrailerInput(const char* input, size_t size) override {} |
| 97 void ProcessRequestFirstLine(const char* line_input, | 101 void ProcessRequestFirstLine(const char* line_input, |
| (...skipping 27 matching lines...) Expand all Loading... |
| 125 FlipAcceptor* acceptor_; | 129 FlipAcceptor* acceptor_; |
| 126 bool is_request_; | 130 bool is_request_; |
| 127 BalsaFrame* http_framer_; | 131 BalsaFrame* http_framer_; |
| 128 BalsaHeaders headers_; | 132 BalsaHeaders headers_; |
| 129 static std::string forward_ip_header_; | 133 static std::string forward_ip_header_; |
| 130 }; | 134 }; |
| 131 | 135 |
| 132 } // namespace net | 136 } // namespace net |
| 133 | 137 |
| 134 #endif // NET_TOOLS_FLIP_SERVER_STREAMER_INTERFACE_H_ | 138 #endif // NET_TOOLS_FLIP_SERVER_STREAMER_INTERFACE_H_ |
| OLD | NEW |