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 |