| Index: net/tools/flip_server/sm_connection.h
|
| diff --git a/net/tools/flip_server/sm_connection.h b/net/tools/flip_server/sm_connection.h
|
| deleted file mode 100644
|
| index 189344adc5cc2ee03c12ce7c489411aedb3b4b17..0000000000000000000000000000000000000000
|
| --- a/net/tools/flip_server/sm_connection.h
|
| +++ /dev/null
|
| @@ -1,163 +0,0 @@
|
| -// Copyright (c) 2011 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#ifndef NET_TOOLS_FLIP_SERVER_SM_CONNECTION_H_
|
| -#define NET_TOOLS_FLIP_SERVER_SM_CONNECTION_H_
|
| -
|
| -#include <arpa/inet.h> // in_addr_t
|
| -#include <stddef.h>
|
| -#include <time.h>
|
| -
|
| -#include <list>
|
| -#include <string>
|
| -
|
| -#include "base/compiler_specific.h"
|
| -#include "net/spdy/spdy_protocol.h"
|
| -#include "net/tools/epoll_server/epoll_server.h"
|
| -#include "net/tools/flip_server/mem_cache.h"
|
| -#include "net/tools/flip_server/ring_buffer.h"
|
| -#include "net/tools/flip_server/sm_interface.h"
|
| -#include "openssl/ssl.h"
|
| -
|
| -namespace net {
|
| -
|
| -class FlipAcceptor;
|
| -class MemoryCache;
|
| -struct SSLState;
|
| -class SpdySM;
|
| -
|
| -// A frame of data to be sent.
|
| -class DataFrame {
|
| - public:
|
| - const char* data;
|
| - size_t size;
|
| - bool delete_when_done;
|
| - size_t index;
|
| - DataFrame() : data(NULL), size(0), delete_when_done(false), index(0) {}
|
| - virtual ~DataFrame();
|
| -};
|
| -
|
| -typedef std::list<DataFrame*> OutputList;
|
| -
|
| -class SMConnection : public SMConnectionInterface,
|
| - public EpollCallbackInterface,
|
| - public NotifierInterface {
|
| - public:
|
| - ~SMConnection() override;
|
| -
|
| - static SMConnection* NewSMConnection(EpollServer* epoll_server,
|
| - SSLState* ssl_state,
|
| - MemoryCache* memory_cache,
|
| - FlipAcceptor* acceptor,
|
| - std::string log_prefix);
|
| -
|
| - // TODO(mbelshe): Make these private.
|
| - time_t last_read_time_;
|
| - std::string server_ip_;
|
| - std::string server_port_;
|
| -
|
| - EpollServer* epoll_server() override;
|
| - OutputList* output_list() { return &output_list_; }
|
| - MemoryCache* memory_cache() { return memory_cache_; }
|
| - void ReadyToSend() override;
|
| - void EnqueueDataFrame(DataFrame* df);
|
| -
|
| - int fd() const { return fd_; }
|
| - bool initialized() const { return initialized_; }
|
| - std::string client_ip() const { return client_ip_; }
|
| -
|
| - virtual void InitSMConnection(SMConnectionPoolInterface* connection_pool,
|
| - SMInterface* sm_interface,
|
| - EpollServer* epoll_server,
|
| - int fd,
|
| - std::string server_ip,
|
| - std::string server_port,
|
| - std::string remote_ip,
|
| - bool use_ssl);
|
| -
|
| - void CorkSocket();
|
| - void UncorkSocket();
|
| -
|
| - int Send(const char* data, int len, int flags);
|
| -
|
| - // EpollCallbackInterface interface.
|
| - void OnRegistration(EpollServer* eps, int fd, int event_mask) override;
|
| - void OnModification(int fd, int event_mask) override {}
|
| - void OnEvent(int fd, EpollEvent* event) override;
|
| - void OnUnregistration(int fd, bool replaced) override;
|
| - void OnShutdown(EpollServer* eps, int fd) override;
|
| -
|
| - // NotifierInterface interface.
|
| - void Notify() override {}
|
| -
|
| - void Cleanup(const char* cleanup);
|
| -
|
| - // Flag indicating if we should force spdy on all connections.
|
| - static bool force_spdy() { return force_spdy_; }
|
| - static void set_force_spdy(bool value) { force_spdy_ = value; }
|
| -
|
| - private:
|
| - // Decide if SPDY was negotiated.
|
| - bool WasSpdyNegotiated();
|
| -
|
| - // Initialize the protocol interfaces we'll need for this connection.
|
| - // Returns true if successful, false otherwise.
|
| - bool SetupProtocolInterfaces();
|
| -
|
| - bool DoRead();
|
| - bool DoWrite();
|
| - bool DoConsumeReadData();
|
| - void Reset();
|
| -
|
| - void HandleEvents();
|
| - void HandleResponseFullyRead();
|
| -
|
| - protected:
|
| - friend std::ostream& operator<<(std::ostream& os, const SMConnection& c) {
|
| - os << &c << "\n";
|
| - return os;
|
| - }
|
| -
|
| - SMConnection(EpollServer* epoll_server,
|
| - SSLState* ssl_state,
|
| - MemoryCache* memory_cache,
|
| - FlipAcceptor* acceptor,
|
| - std::string log_prefix);
|
| -
|
| - private:
|
| - int fd_;
|
| - int events_;
|
| -
|
| - bool registered_in_epoll_server_;
|
| - bool initialized_;
|
| - bool protocol_detected_;
|
| - bool connection_complete_;
|
| -
|
| - SMConnectionPoolInterface* connection_pool_;
|
| -
|
| - EpollServer* epoll_server_;
|
| - SSLState* ssl_state_;
|
| - MemoryCache* memory_cache_;
|
| - FlipAcceptor* acceptor_;
|
| - std::string client_ip_;
|
| -
|
| - RingBuffer read_buffer_;
|
| -
|
| - OutputList output_list_;
|
| - SpdySM* sm_spdy_interface_;
|
| - SMInterface* sm_http_interface_;
|
| - SMInterface* sm_streamer_interface_;
|
| - SMInterface* sm_interface_;
|
| - std::string log_prefix_;
|
| -
|
| - size_t max_bytes_sent_per_dowrite_;
|
| -
|
| - SSL* ssl_;
|
| -
|
| - static bool force_spdy_;
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_TOOLS_FLIP_SERVER_SM_CONNECTION_H_
|
|
|