http_interface.h revision dc0f95d653279beabeb9817299e2902918ba123e 
1// Copyright (c) 2009 The Chromium Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
5#ifndef NET_TOOLS_FLIP_SERVER_HTTP_INTERFACE_
6#define NET_TOOLS_FLIP_SERVER_HTTP_INTERFACE_
7
8#include <string>
9
10#include "net/tools/flip_server/balsa_headers.h"
11#include "net/tools/flip_server/balsa_visitor_interface.h"
12#include "net/tools/flip_server/output_ordering.h"
13#include "net/tools/flip_server/sm_connection.h"
14#include "net/tools/flip_server/sm_interface.h"
15
16namespace net {
17
18class BalsaFrame;
19class DataFrame;
20class EpollServer;
21class FlipAcceptor;
22class MemoryCache;
23
24class HttpSM : public BalsaVisitorInterface,
25               public SMInterface {
26 public:
27  HttpSM(SMConnection* connection,
28         SMInterface* sm_spdy_interface,
29         EpollServer* epoll_server,
30         MemoryCache* memory_cache,
31         FlipAcceptor* acceptor);
32  virtual ~HttpSM();
33
34 private:
35  // BalsaVisitorInterface:
36  virtual void ProcessBodyInput(const char *input, size_t size) {}
37  virtual void ProcessBodyData(const char *input, size_t size);
38  virtual void ProcessHeaderInput(const char *input, size_t size) {}
39  virtual void ProcessTrailerInput(const char *input, size_t size) {}
40  virtual void ProcessHeaders(const BalsaHeaders& headers);
41  virtual void ProcessRequestFirstLine(const char* line_input,
42                                       size_t line_length,
43                                       const char* method_input,
44                                       size_t method_length,
45                                       const char* request_uri_input,
46                                       size_t request_uri_length,
47                                       const char* version_input,
48                                       size_t version_length) {}
49  virtual void ProcessResponseFirstLine(const char *line_input,
50                                        size_t line_length,
51                                        const char *version_input,
52                                        size_t version_length,
53                                        const char *status_input,
54                                        size_t status_length,
55                                        const char *reason_input,
56                                        size_t reason_length) {}
57  virtual void ProcessChunkLength(size_t chunk_length) {}
58  virtual void ProcessChunkExtensions(const char *input, size_t size) {}
59  virtual void HeaderDone() {}
60  virtual void MessageDone();
61  virtual void HandleHeaderError(BalsaFrame* framer);
62  virtual void HandleHeaderWarning(BalsaFrame* framer) {}
63  virtual void HandleChunkingError(BalsaFrame* framer);
64  virtual void HandleBodyError(BalsaFrame* framer);
65
66  void HandleError();
67
68 public:
69  void AddToOutputOrder(const MemCacheIter& mci);
70  void SendOKResponse(uint32 stream_id, std::string* output);
71  BalsaFrame* spdy_framer() { return http_framer_; }
72  virtual void set_is_request() {}
73
74  // SMInterface:
75  virtual void InitSMInterface(SMInterface* sm_spdy_interface,
76                               int32 server_idx);
77  virtual void InitSMConnection(SMConnectionPoolInterface* connection_pool,
78                                SMInterface* sm_interface,
79                                EpollServer* epoll_server,
80                                int fd,
81                                std::string server_ip,
82                                std::string server_port,
83                                std::string remote_ip,
84                                bool use_ssl);
85  virtual size_t ProcessReadInput(const char* data, size_t len);
86  virtual size_t ProcessWriteInput(const char* data, size_t len);
87  virtual bool MessageFullyRead() const;
88  virtual void SetStreamID(uint32 stream_id);
89  virtual bool Error() const;
90  virtual const char* ErrorAsString() const;
91  virtual void Reset();
92  virtual void ResetForNewInterface(int32 server_idx) {}
93  virtual void ResetForNewConnection();
94  virtual void Cleanup();
95  virtual int PostAcceptHook();
96
97  virtual void NewStream(uint32 stream_id, uint32 priority,
98                         const std::string& filename);
99  virtual void SendEOF(uint32 stream_id);
100  virtual void SendErrorNotFound(uint32 stream_id);
101  virtual size_t SendSynStream(uint32 stream_id, const BalsaHeaders& headers);
102  virtual size_t SendSynReply(uint32 stream_id, const BalsaHeaders& headers);
103  virtual void SendDataFrame(uint32 stream_id, const char* data, int64 len,
104                             uint32 flags, bool compress);
105
106 private:
107  void SendEOFImpl(uint32 stream_id);
108  void SendErrorNotFoundImpl(uint32 stream_id);
109  void SendOKResponseImpl(uint32 stream_id, std::string* output);
110  size_t SendSynReplyImpl(uint32 stream_id, const BalsaHeaders& headers);
111  size_t SendSynStreamImpl(uint32 stream_id, const BalsaHeaders& headers);
112  void SendDataFrameImpl(uint32 stream_id, const char* data, int64 len,
113                         uint32 flags, bool compress);
114  void EnqueueDataFrame(DataFrame* df);
115  virtual void GetOutput();
116
117 private:
118  uint64 seq_num_;
119  BalsaFrame* http_framer_;
120  BalsaHeaders headers_;
121  uint32 stream_id_;
122  int32 server_idx_;
123
124  SMConnection* connection_;
125  SMInterface* sm_spdy_interface_;
126  OutputList* output_list_;
127  OutputOrdering output_ordering_;
128  MemoryCache* memory_cache_;
129  FlipAcceptor* acceptor_;
130};
131
132}  // namespace
133
134#endif  // NET_TOOLS_FLIP_SERVER_HTTP_INTERFACE_
135
136