Rename all files from flip* to spdy*.

I haven't yet renamed the classes.

BUG=30747
TEST=none

Review URL: http://codereview.chromium.org/582001

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@38315 0039d316-1c4b-4281-b951-d872f2087c98

1 files changed, 121 insertions, 0 deletions

diff --git a/net/spdy/spdy_session_pool.cc b/net/spdy/spdy_session_pool.cc
new file mode 100644
index 0000000..13d9942
--- /dev/null
+++ b/net/spdy/spdy_session_pool.cc
@@ -0,0 +1,121 @@
+// Copyright (c) 2009 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 "net/spdy/spdy_session_pool.h"
+
+#include "base/logging.h"
+#include "net/spdy/spdy_session.h"
+
+namespace net {
+
+// The maximum number of sessions to open to a single domain.
+static const size_t kMaxSessionsPerDomain = 1;
+
+FlipSessionPool::FlipSessionPool() {}
+FlipSessionPool::~FlipSessionPool() {
+  CloseAllSessions();
+}
+
+scoped_refptr<FlipSession> FlipSessionPool::Get(
+    const HostResolver::RequestInfo& info, HttpNetworkSession* session) {
+  const std::string& domain = info.hostname();
+  scoped_refptr<FlipSession> flip_session;
+  FlipSessionList* list = GetSessionList(domain);
+  if (list) {
+    if (list->size() >= kMaxSessionsPerDomain) {
+      flip_session = list->front();
+      list->pop_front();
+    }
+  } else {
+    list = AddSessionList(domain);
+  }
+
+  DCHECK(list);
+  if (!flip_session)
+    flip_session = new FlipSession(domain, session);
+
+  DCHECK(flip_session);
+  list->push_back(flip_session);
+  DCHECK(list->size() <= kMaxSessionsPerDomain);
+  return flip_session;
+}
+
+scoped_refptr<FlipSession> FlipSessionPool::GetFlipSessionFromSocket(
+    const HostResolver::RequestInfo& info,
+    HttpNetworkSession* session,
+    ClientSocketHandle* connection) {
+  const std::string& domain = info.hostname();
+  FlipSessionList* list = GetSessionList(domain);
+  if (!list)
+    list = AddSessionList(domain);
+  DCHECK(list->empty());
+  scoped_refptr<FlipSession> flip_session(new FlipSession(domain, session));
+  flip_session->InitializeWithSocket(connection);
+  list->push_back(flip_session);
+  return flip_session;
+}
+
+bool FlipSessionPool::HasSession(const HostResolver::RequestInfo& info) const {
+  const std::string& domain = info.hostname();
+  if (GetSessionList(domain))
+    return true;
+  return false;
+}
+
+void FlipSessionPool::Remove(const scoped_refptr<FlipSession>& session) {
+  std::string domain = session->domain();
+  FlipSessionList* list = GetSessionList(domain);
+  CHECK(list);
+  list->remove(session);
+  if (list->empty())
+    RemoveSessionList(domain);
+}
+
+FlipSessionPool::FlipSessionList*
+    FlipSessionPool::AddSessionList(const std::string& domain) {
+  DCHECK(sessions_.find(domain) == sessions_.end());
+  return sessions_[domain] = new FlipSessionList();
+}
+
+FlipSessionPool::FlipSessionList*
+    FlipSessionPool::GetSessionList(const std::string& domain) {
+  FlipSessionsMap::iterator it = sessions_.find(domain);
+  if (it == sessions_.end())
+    return NULL;
+  return it->second;
+}
+
+const FlipSessionPool::FlipSessionList*
+    FlipSessionPool::GetSessionList(const std::string& domain) const {
+  FlipSessionsMap::const_iterator it = sessions_.find(domain);
+  if (it == sessions_.end())
+    return NULL;
+  return it->second;
+}
+
+void FlipSessionPool::RemoveSessionList(const std::string& domain) {
+  FlipSessionList* list = GetSessionList(domain);
+  if (list) {
+    delete list;
+    sessions_.erase(domain);
+  } else {
+    DCHECK(false) << "removing orphaned session list";
+  }
+}
+
+void FlipSessionPool::CloseAllSessions() {
+  while (sessions_.size()) {
+    FlipSessionList* list = sessions_.begin()->second;
+    DCHECK(list);
+    sessions_.erase(sessions_.begin()->first);
+    while (list->size()) {
+      scoped_refptr<FlipSession> session = list->front();
+      list->pop_front();
+      session->CloseAllStreams(net::ERR_ABORTED);
+    }
+    delete list;
+  }
+}
+
+}  // namespace net