blob: 981a089035d98982eb1ced8accfdf157fffd85e1 [file] [log] [blame]
// 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.
#include <list>
#include <string>
#include <vector>
#include "base/compiler_specific.h"
#include "base/threading/simple_thread.h"
#include "net/tools/epoll_server/epoll_server.h"
#include "net/tools/flip_server/sm_interface.h"
#include "openssl/ssl.h"
struct sockaddr_in;
namespace net {
class FlipAcceptor;
class MemoryCache;
class SMConnection;
struct SSLState;
// TODO(mbelshe): Get rid of this class; we don't need a lock just to set
// a bool cross threads - especially one which only is set once...
class Notification {
explicit Notification(bool value) : value_(value) {}
void Notify() {
base::AutoLock al(lock_);
value_ = true;
bool HasBeenNotified() {
base::AutoLock al(lock_);
return value_;
bool value_;
base::Lock lock_;
class SMAcceptorThread : public base::SimpleThread,
public EpollCallbackInterface,
public SMConnectionPoolInterface {
SMAcceptorThread(FlipAcceptor* acceptor, MemoryCache* memory_cache);
~SMAcceptorThread() override;
// EpollCallbackInteface 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 {}
// SMConnectionPool interface
void SMConnectionDone(SMConnection* sc) override;
// TODO(mbelshe): figure out if we can move these to private functions.
SMConnection* NewConnection();
SMConnection* FindOrMakeNewSMConnection();
void InitWorker();
void HandleConnection(int server_fd, struct sockaddr_in* remote_addr);
void AcceptFromListenFD();
// Notify the Accept thread that it is time to terminate.
void Quit() { quitting_.Notify(); }
// Iterates through a list of active connections expiring any that have been
// idle longer than the configured timeout.
void HandleConnectionIdleTimeout();
void Run() override;
EpollServer epoll_server_;
FlipAcceptor* acceptor_;
SSLState* ssl_state_;
bool use_ssl_;
int idle_socket_timeout_s_;
std::vector<SMConnection*> unused_server_connections_;
std::vector<SMConnection*> tmp_unused_server_connections_;
std::vector<SMConnection*> allocated_server_connections_;
std::list<SMConnection*> active_server_connections_;
Notification quitting_;
MemoryCache* memory_cache_;
} // namespace net