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_HTTP_INTERFACE_H_ | 5 #ifndef NET_TOOLS_FLIP_SERVER_HTTP_INTERFACE_H_ |
6 #define NET_TOOLS_FLIP_SERVER_HTTP_INTERFACE_H_ | 6 #define NET_TOOLS_FLIP_SERVER_HTTP_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/output_ordering.h" | 16 #include "net/tools/flip_server/output_ordering.h" |
14 #include "net/tools/flip_server/sm_connection.h" | 17 #include "net/tools/flip_server/sm_connection.h" |
15 #include "net/tools/flip_server/sm_interface.h" | 18 #include "net/tools/flip_server/sm_interface.h" |
16 | 19 |
17 namespace net { | 20 namespace net { |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
65 void HandleError(); | 68 void HandleError(); |
66 | 69 |
67 public: | 70 public: |
68 void AddToOutputOrder(const MemCacheIter& mci); | 71 void AddToOutputOrder(const MemCacheIter& mci); |
69 BalsaFrame* spdy_framer() { return http_framer_; } | 72 BalsaFrame* spdy_framer() { return http_framer_; } |
70 void set_is_request() override {} | 73 void set_is_request() override {} |
71 const OutputOrdering& output_ordering() const { return output_ordering_; } | 74 const OutputOrdering& output_ordering() const { return output_ordering_; } |
72 | 75 |
73 // SMInterface: | 76 // SMInterface: |
74 void InitSMInterface(SMInterface* sm_spdy_interface, | 77 void InitSMInterface(SMInterface* sm_spdy_interface, |
75 int32 server_idx) override; | 78 int32_t server_idx) override; |
76 void InitSMConnection(SMConnectionPoolInterface* connection_pool, | 79 void InitSMConnection(SMConnectionPoolInterface* connection_pool, |
77 SMInterface* sm_interface, | 80 SMInterface* sm_interface, |
78 EpollServer* epoll_server, | 81 EpollServer* epoll_server, |
79 int fd, | 82 int fd, |
80 std::string server_ip, | 83 std::string server_ip, |
81 std::string server_port, | 84 std::string server_port, |
82 std::string remote_ip, | 85 std::string remote_ip, |
83 bool use_ssl) override; | 86 bool use_ssl) override; |
84 size_t ProcessReadInput(const char* data, size_t len) override; | 87 size_t ProcessReadInput(const char* data, size_t len) override; |
85 size_t ProcessWriteInput(const char* data, size_t len) override; | 88 size_t ProcessWriteInput(const char* data, size_t len) override; |
86 bool MessageFullyRead() const override; | 89 bool MessageFullyRead() const override; |
87 void SetStreamID(uint32 stream_id) override; | 90 void SetStreamID(uint32_t stream_id) override; |
88 bool Error() const override; | 91 bool Error() const override; |
89 const char* ErrorAsString() const override; | 92 const char* ErrorAsString() const override; |
90 void Reset() override; | 93 void Reset() override; |
91 void ResetForNewInterface(int32 server_idx) override {} | 94 void ResetForNewInterface(int32_t server_idx) override {} |
92 void ResetForNewConnection() override; | 95 void ResetForNewConnection() override; |
93 void Cleanup() override; | 96 void Cleanup() override; |
94 int PostAcceptHook() override; | 97 int PostAcceptHook() override; |
95 | 98 |
96 void NewStream(uint32 stream_id, | 99 void NewStream(uint32_t stream_id, |
97 uint32 priority, | 100 uint32_t priority, |
98 const std::string& filename) override; | 101 const std::string& filename) override; |
99 void SendEOF(uint32 stream_id) override; | 102 void SendEOF(uint32_t stream_id) override; |
100 void SendErrorNotFound(uint32 stream_id) override; | 103 void SendErrorNotFound(uint32_t stream_id) override; |
101 size_t SendSynStream(uint32 stream_id, const BalsaHeaders& headers) override; | 104 size_t SendSynStream(uint32_t stream_id, |
102 size_t SendSynReply(uint32 stream_id, const BalsaHeaders& headers) override; | 105 const BalsaHeaders& headers) override; |
103 void SendDataFrame(uint32 stream_id, | 106 size_t SendSynReply(uint32_t stream_id, const BalsaHeaders& headers) override; |
| 107 void SendDataFrame(uint32_t stream_id, |
104 const char* data, | 108 const char* data, |
105 int64 len, | 109 int64_t len, |
106 uint32 flags, | 110 uint32_t flags, |
107 bool compress) override; | 111 bool compress) override; |
108 | 112 |
109 private: | 113 private: |
110 void SendEOFImpl(uint32 stream_id); | 114 void SendEOFImpl(uint32_t stream_id); |
111 void SendErrorNotFoundImpl(uint32 stream_id); | 115 void SendErrorNotFoundImpl(uint32_t stream_id); |
112 void SendOKResponseImpl(uint32 stream_id, const std::string& output); | 116 void SendOKResponseImpl(uint32_t stream_id, const std::string& output); |
113 size_t SendSynReplyImpl(uint32 stream_id, const BalsaHeaders& headers); | 117 size_t SendSynReplyImpl(uint32_t stream_id, const BalsaHeaders& headers); |
114 size_t SendSynStreamImpl(uint32 stream_id, const BalsaHeaders& headers); | 118 size_t SendSynStreamImpl(uint32_t stream_id, const BalsaHeaders& headers); |
115 void SendDataFrameImpl(uint32 stream_id, | 119 void SendDataFrameImpl(uint32_t stream_id, |
116 const char* data, | 120 const char* data, |
117 int64 len, | 121 int64_t len, |
118 uint32 flags, | 122 uint32_t flags, |
119 bool compress); | 123 bool compress); |
120 void EnqueueDataFrame(DataFrame* df); | 124 void EnqueueDataFrame(DataFrame* df); |
121 void GetOutput() override; | 125 void GetOutput() override; |
122 | 126 |
123 private: | 127 private: |
124 BalsaFrame* http_framer_; | 128 BalsaFrame* http_framer_; |
125 BalsaHeaders headers_; | 129 BalsaHeaders headers_; |
126 uint32 stream_id_; | 130 uint32_t stream_id_; |
127 int32 server_idx_; | 131 int32_t server_idx_; |
128 | 132 |
129 SMConnection* connection_; | 133 SMConnection* connection_; |
130 SMInterface* sm_spdy_interface_; | 134 SMInterface* sm_spdy_interface_; |
131 OutputList* output_list_; | 135 OutputList* output_list_; |
132 OutputOrdering output_ordering_; | 136 OutputOrdering output_ordering_; |
133 MemoryCache* memory_cache_; | 137 MemoryCache* memory_cache_; |
134 FlipAcceptor* acceptor_; | 138 FlipAcceptor* acceptor_; |
135 }; | 139 }; |
136 | 140 |
137 } // namespace net | 141 } // namespace net |
138 | 142 |
139 #endif // NET_TOOLS_FLIP_SERVER_HTTP_INTERFACE_H_ | 143 #endif // NET_TOOLS_FLIP_SERVER_HTTP_INTERFACE_H_ |
OLD | NEW |