summaryrefslogtreecommitdiffstats
path: root/net
diff options
context:
space:
mode:
authorRicardo Cerqueira <cyanogenmod@cerqueira.org>2012-11-19 14:53:55 +0000
committerRicardo Cerqueira <cyanogenmod@cerqueira.org>2012-11-19 14:53:55 +0000
commit657fb1c9269ce235b66a0f32c9bf0afc64fa7c77 (patch)
tree396a4bc17c30655c78fd62fe34778900c40a97cc /net
parent4ec08dd85e9e4584f1bb0cd6110590f367d8b258 (diff)
downloadexternal_chromium-657fb1c9269ce235b66a0f32c9bf0afc64fa7c77.zip
external_chromium-657fb1c9269ce235b66a0f32c9bf0afc64fa7c77.tar.gz
external_chromium-657fb1c9269ce235b66a0f32c9bf0afc64fa7c77.tar.bz2
Revert "net: networking optimizations"
This reverts commit 5fbe95affc8eeed93c678b1d271f64dcc4dd919b.
Diffstat (limited to 'net')
-rw-r--r--net/base/host_resolver.h16
-rw-r--r--net/base/host_resolver_impl.cc49
-rw-r--r--net/base/host_resolver_impl.h9
-rw-r--r--net/base/net_error_list.h4
-rw-r--r--net/base/request_priority.cc67
-rw-r--r--net/base/request_priority.h6
-rw-r--r--net/disk_cache/hostres_plugin_bridge.cc76
-rw-r--r--net/disk_cache/hostres_plugin_bridge.h40
-rwxr-xr-xnet/disk_cache/stat_hub.cc480
-rwxr-xr-xnet/disk_cache/stat_hub.h268
-rwxr-xr-xnet/disk_cache/stat_hub_api.cc377
-rwxr-xr-xnet/disk_cache/stat_hub_api.h118
-rw-r--r--net/disk_cache/stat_hub_cmd_api.h74
-rw-r--r--net/host_resolver_helper/dyn_lib_loader.cc76
-rw-r--r--net/host_resolver_helper/dyn_lib_loader.h103
-rw-r--r--net/host_resolver_helper/dyn_lib_loader_decl.h51
-rw-r--r--net/host_resolver_helper/host_resolver_helper.cc157
-rw-r--r--net/host_resolver_helper/host_resolver_helper.h105
-rw-r--r--net/host_resolver_helper/hosts_provider.h44
-rw-r--r--net/http/http_basic_stream.cc3
-rw-r--r--net/http/http_cache.cc36
-rw-r--r--net/http/http_cache.h10
-rw-r--r--net/http/http_cache_transaction.cc11
-rw-r--r--net/http/http_getzip_bridge.cc142
-rw-r--r--net/http/http_getzip_bridge.h66
-rw-r--r--net/http/http_getzip_factory.cc127
-rw-r--r--net/http/http_getzip_factory.h137
-rw-r--r--net/http/http_network_layer.cc3
-rw-r--r--net/http/http_network_session.cc4
-rw-r--r--net/http/http_network_transaction.cc114
-rw-r--r--net/http/http_network_transaction.h26
-rw-r--r--net/http/http_proxy_client_socket_pool.cc7
-rw-r--r--net/http/http_proxy_client_socket_pool.h5
-rw-r--r--net/http/http_request_headers.cc2
-rw-r--r--net/http/http_request_headers.h2
-rw-r--r--net/http/http_stream_parser.cc39
-rw-r--r--net/http/http_stream_parser.h9
-rw-r--r--net/http/net-plugin-bridge-exports.h44
-rw-r--r--net/http/net-plugin-bridge.cc95
-rw-r--r--net/http/net-plugin-bridge.h37
-rw-r--r--net/http/preconnect.cc70
-rw-r--r--net/http/preconnect.h66
-rw-r--r--net/http/tcp-connections-bridge-exports.h39
-rw-r--r--net/http/tcp-connections-bridge.cc79
-rw-r--r--net/http/tcp-connections-bridge.h41
-rw-r--r--net/socket/client_socket_pool_base.cc119
-rw-r--r--net/socket/client_socket_pool_base.h105
-rw-r--r--net/socket/client_socket_pool_manager.cc31
-rw-r--r--net/socket/client_socket_pool_manager.h6
-rw-r--r--net/socket/socks_client_socket_pool.cc7
-rw-r--r--net/socket/socks_client_socket_pool.h4
-rw-r--r--net/socket/ssl_client_socket_pool.cc7
-rw-r--r--net/socket/ssl_client_socket_pool.h4
-rw-r--r--net/socket/tcp_client_socket_libevent.cc4
-rw-r--r--net/socket/tcp_client_socket_pool.cc7
-rw-r--r--net/socket/tcp_client_socket_pool.h4
-rw-r--r--net/socket/tcp_fin_aggregation.h52
-rw-r--r--net/socket/tcp_fin_aggregation_bridge.h46
-rw-r--r--net/socket/tcp_fin_aggregation_factory.cc88
-rw-r--r--net/socket/tcp_fin_aggregation_factory.h71
-rw-r--r--net/socket/transport_client_socket_pool.cc7
-rw-r--r--net/socket/transport_client_socket_pool.h4
-rw-r--r--net/url_request/url_request_http_job.cc12
63 files changed, 120 insertions, 3792 deletions
diff --git a/net/base/host_resolver.h b/net/base/host_resolver.h
index 004e49f..8f53b6b 100644
--- a/net/base/host_resolver.h
+++ b/net/base/host_resolver.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -17,8 +16,6 @@
#include "net/base/net_export.h"
#include "net/base/request_priority.h"
-class MessageLoop;
-
namespace net {
class AddressList;
@@ -127,13 +124,6 @@ class NET_EXPORT HostResolver {
virtual void OnCancelResolution(int id, const RequestInfo& info) = 0;
};
- class HostnameResolverExt {
- public:
- virtual ~HostnameResolverExt() {}
- virtual void Resolve()=0;
- };
-
- virtual void SetResolverExt(HostnameResolverExt* preresolver) {};
// Opaque type used to cancel a request.
typedef void* RequestHandle;
@@ -255,12 +245,6 @@ NET_EXPORT HostResolver* CreateSystemHostResolver(size_t max_concurrent_resolves
HostResolverProc* resolver_proc,
NetLog* net_log);
-// If specified |net_notification_messageloop| provides a message loop
-// to be used for network notifications.
-HostResolver* CreateSystemHostResolver(size_t max_concurrent_resolves,
- HostResolverProc* resolver_proc,
- NetLog* net_log,
- MessageLoop* net_notification_messageloop);
} // namespace net
#endif // NET_BASE_HOST_RESOLVER_H_
diff --git a/net/base/host_resolver_impl.cc b/net/base/host_resolver_impl.cc
index 7fd04fc..1f33369 100644
--- a/net/base/host_resolver_impl.cc
+++ b/net/base/host_resolver_impl.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -36,6 +35,7 @@
#include "net/base/net_errors.h"
#include "net/base/net_log.h"
#include "net/base/net_util.h"
+
#if defined(OS_WIN)
#include "net/base/winsock_init.h"
#endif
@@ -74,17 +74,6 @@ HostCache* CreateDefaultCache() {
HostResolver* CreateSystemHostResolver(size_t max_concurrent_resolves,
HostResolverProc* resolver_proc,
NetLog* net_log) {
-return CreateSystemHostResolver(max_concurrent_resolves,
- resolver_proc,
- net_log,
- NULL);
-}
-
-HostResolver* CreateSystemHostResolver(size_t max_concurrent_resolves,
- HostResolverProc* resolver_proc,
- NetLog* net_log,
- MessageLoop* net_notification_messageloop
- ) {
// Maximum of 8 concurrent resolver threads.
// Some routers (or resolvers) appear to start to provide host-not-found if
// too many simultaneous resolutions are pending. This number needs to be
@@ -96,7 +85,7 @@ HostResolver* CreateSystemHostResolver(size_t max_concurrent_resolves,
HostResolverImpl* resolver =
new HostResolverImpl(resolver_proc, CreateDefaultCache(),
- max_concurrent_resolves, net_log,net_notification_messageloop);
+ max_concurrent_resolves, net_log);
return resolver;
}
@@ -915,9 +904,7 @@ HostResolverImpl::HostResolverImpl(
HostResolverProc* resolver_proc,
HostCache* cache,
size_t max_jobs,
- NetLog* net_log,
- MessageLoop* net_notification_messageloop
- )
+ NetLog* net_log)
: cache_(cache),
max_jobs_(max_jobs),
next_request_id_(0),
@@ -927,10 +914,7 @@ HostResolverImpl::HostResolverImpl(
shutdown_(false),
ipv6_probe_monitoring_(false),
additional_resolver_flags_(0),
- net_log_(net_log),
- net_notification_messageloop_(net_notification_messageloop),
- resolverext_(NULL)
-{
+ net_log_(net_log) {
DCHECK_GT(max_jobs, 0u);
// It is cumbersome to expose all of the constraints in the constructor,
@@ -944,17 +928,7 @@ HostResolverImpl::HostResolverImpl(
if (HaveOnlyLoopbackAddresses())
additional_resolver_flags_ |= HOST_RESOLVER_LOOPBACK_ONLY;
#endif
-
- //register to network notifications via the current thread message loop (if exsits)
- //or use the message loop provided in the constructor parameter
- if (NULL==net_notification_messageloop_) {
- net_notification_messageloop_ = MessageLoop::current();
- }
- //add this class as observer for NetworkChangeNotifier
- if (net_notification_messageloop_) {
- net_notification_messageloop_->PostTask(FROM_HERE,
- NewRunnableFunction( &NetworkChangeNotifier::AddIPAddressObserver,this));
- }
+ NetworkChangeNotifier::AddIPAddressObserver(this);
}
HostResolverImpl::~HostResolverImpl() {
@@ -968,10 +942,7 @@ HostResolverImpl::~HostResolverImpl() {
if (cur_completing_job_)
cur_completing_job_->Cancel();
- if (net_notification_messageloop_) {
- net_notification_messageloop_->PostTask(FROM_HERE,
- NewRunnableFunction( &NetworkChangeNotifier::RemoveIPAddressObserver,this));
- }
+ NetworkChangeNotifier::RemoveIPAddressObserver(this);
// Delete the job pools.
for (size_t i = 0u; i < arraysize(job_pools_); ++i)
@@ -1500,14 +1471,6 @@ void HostResolverImpl::OnIPAddressChanged() {
#endif
AbortAllInProgressJobs();
// |this| may be deleted inside AbortAllInProgressJobs().
-
- if (resolverext_) {
- resolverext_->Resolve();
- }
}
-void HostResolverImpl::SetResolverExt(HostnameResolverExt* resolverext) {
- LOG(INFO)<<"HostResolverImpl::SetPreresolver preresolver:"<<resolverext;
- resolverext_ = resolverext;
- }
} // namespace net
diff --git a/net/base/host_resolver_impl.h b/net/base/host_resolver_impl.h
index 904d896..54e0b9e 100644
--- a/net/base/host_resolver_impl.h
+++ b/net/base/host_resolver_impl.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -81,9 +80,7 @@ class HostResolverImpl : public HostResolver,
HostResolverImpl(HostResolverProc* resolver_proc,
HostCache* cache,
size_t max_jobs,
- NetLog* net_log,
- MessageLoop* net_notification_messageloop=NULL
- );
+ NetLog* net_log);
// If any completion callbacks are pending when the resolver is destroyed,
// the host resolutions are cancelled, and the completion callbacks will not
@@ -131,7 +128,6 @@ class HostResolverImpl : public HostResolver,
// TODO(eroman): hack for http://crbug.com/15513
virtual void Shutdown();
- virtual void SetResolverExt(HostnameResolverExt* preresolver);
private:
class Job;
class JobPool;
@@ -281,9 +277,6 @@ class HostResolverImpl : public HostResolver,
NetLog* net_log_;
- MessageLoop* net_notification_messageloop_;
- HostnameResolverExt* resolverext_;
-
DISALLOW_COPY_AND_ASSIGN(HostResolverImpl);
};
diff --git a/net/base/net_error_list.h b/net/base/net_error_list.h
index e96690d..9e9a980 100644
--- a/net/base/net_error_list.h
+++ b/net/base/net_error_list.h
@@ -1,5 +1,4 @@
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -445,9 +444,6 @@ NET_ERROR(RESPONSE_HEADERS_MULTIPLE_CONTENT_LENGTH, -346)
// headers are missing, so we're expecting additional frames to complete them.
NET_ERROR(INCOMPLETE_SPDY_HEADERS, -347)
-// GETzip failure - server advices to retry the HTTP request
-NET_ERROR(GETZIP, -348)
-
// SPDY server didn't respond to the PING message.
NET_ERROR(SPDY_PING_FAILED, -352)
diff --git a/net/base/request_priority.cc b/net/base/request_priority.cc
deleted file mode 100644
index dfe083c..0000000
--- a/net/base/request_priority.cc
+++ /dev/null
@@ -1,67 +0,0 @@
-// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. 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/base/request_priority.h"
-#include "base/logging.h"
-
-namespace net {
-
-RequestPriority DetermineRequestPriority(ResourceType::Type type)
-{
- //__android_log_print(ANDROID_LOG_VERBOSE, "Preload", "DetermineRequestPriority, type = %d", type);
-
- // Determine request priority based on how critical this resource typically
- // is to user-perceived page load performance. Important considerations are:
- // * Can this resource block the download of other resources.
- // * Can this resource block the rendering of the page.
- // * How useful is the page to the user if this resource is not loaded yet.
- switch (type) {
- // Main frames are the highest priority because they can block nearly every
- // type of other resource and there is no useful display without them.
- // Sub frames are a close second, however it is a common pattern to wrap
- // ads in an iframe or even in multiple nested iframes. It is worth
- // investigating if there is a better priority for them.
- case ResourceType::MAIN_FRAME:
- case ResourceType::SUB_FRAME:
- return HIGHEST;
-
- // Stylesheets and scripts can block rendering and loading of other
- // resources. Fonts can block text from rendering.
- case ResourceType::STYLESHEET:
- case ResourceType::SCRIPT:
- case ResourceType::FONT_RESOURCE:
- return MEDIUM;
-
- // Sub resources, objects and media are lower priority than potentially
- // blocking stylesheets, scripts and fonts, but are higher priority than
- // images because if they exist they are probably more central to the page
- // focus than images on the page.
- case ResourceType::SUB_RESOURCE:
- case ResourceType::OBJECT:
- case ResourceType::MEDIA:
- case ResourceType::WORKER:
- case ResourceType::SHARED_WORKER:
- return LOW;
-
- // Images are the "lowest" priority because they typically do not block
- // downloads or rendering and most pages have some useful content without
- // them.
- case ResourceType::IMAGE:
- return LOWEST;
-
- // Prefetches are at a lower priority than even LOWEST, since they
- // are not even required for rendering of the current page.
- case ResourceType::PREFETCH:
- return IDLE;
-
- default:
- // When new resource types are added, their priority must be considered.
- NOTREACHED();
- return LOW;
- }
-}
-
-} // namespace net
-
diff --git a/net/base/request_priority.h b/net/base/request_priority.h
index ca454bf..ca7a1ec 100644
--- a/net/base/request_priority.h
+++ b/net/base/request_priority.h
@@ -1,6 +1,4 @@
// Copyright (c) 2009 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-//
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -8,8 +6,6 @@
#define NET_BASE_REQUEST_PRIORITY_H__
#pragma once
-#include "webkit/glue/resource_type.h"
-
namespace net {
// Prioritization used in various parts of the networking code such
@@ -23,8 +19,6 @@ enum RequestPriority {
NUM_PRIORITIES,
};
-RequestPriority DetermineRequestPriority(ResourceType::Type type);
-
} // namespace net
#endif // NET_BASE_REQUEST_PRIORITY_H__
diff --git a/net/disk_cache/hostres_plugin_bridge.cc b/net/disk_cache/hostres_plugin_bridge.cc
deleted file mode 100644
index 7b50245..0000000
--- a/net/disk_cache/hostres_plugin_bridge.cc
+++ /dev/null
@@ -1,76 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-#include "hostres_plugin_bridge.h"
-#include "net/disk_cache/stat_hub.h"
-#include "net/host_resolver_helper/dyn_lib_loader.h"
-#include "base/logging.h"
-
-class HostResProcessor : public stat_hub::StatProcessorGenericPlugin {
-public:
- HostResProcessor(const char* name):StatProcessorGenericPlugin(name) {
- }
-
- virtual ~HostResProcessor() {
- }
-
-private:
- DISALLOW_COPY_AND_ASSIGN(HostResProcessor);
-};
-
-const char* hostres_plugin_name = "libdnshostprio.so";
-
-stat_hub::StatProcessor* StatHubCreateHostResPlugin()
-{
- static bool initialized = false;
- if (!initialized) {
- LOG(INFO) << "StatHubCreateHostResPlugin initializing...";
- initialized = true;
- HostResProcessor* hp = new HostResProcessor(hostres_plugin_name);
- void* fh = LibraryManager::GetLibraryHandle(hostres_plugin_name);
- if (fh) {
- LOG(INFO) << "StatHubCreateHostResPlugin lib loaded";
- const char* fn = NULL;
- bool dll_ok = false;
-
- dll_ok = hp->OpenPlugin(fh);
- if (dll_ok) {
- LOG(INFO) << "StatHubCreateHostResPlugin plugin connected";;
- return hp;
- }
- }
- else {
- LOG(INFO) << "netstack: Failed to open plugin:" << hostres_plugin_name;
- }
- delete hp;
- }
-
- LOG(INFO) << "netstack: Failed to find symbols in plugin: " << hostres_plugin_name;
- return NULL;
-}
-
diff --git a/net/disk_cache/hostres_plugin_bridge.h b/net/disk_cache/hostres_plugin_bridge.h
deleted file mode 100644
index a45da56..0000000
--- a/net/disk_cache/hostres_plugin_bridge.h
+++ /dev/null
@@ -1,40 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-
-#ifndef HOSTRES_PLUGIN_BRIDGE_H_
-#define HOSTRES_PLUGIN_BRIDGE_H_
-
-
-namespace stat_hub {
- class StatProcessor;
-}
-
-extern stat_hub::StatProcessor* StatHubCreateHostResPlugin();
-
-#endif /* HOSTRES_PLUGIN_BRIDGE_H_ */
diff --git a/net/disk_cache/stat_hub.cc b/net/disk_cache/stat_hub.cc
deleted file mode 100755
index 1169528..0000000
--- a/net/disk_cache/stat_hub.cc
+++ /dev/null
@@ -1,480 +0,0 @@
-/** ---------------------------------------------------------------------------
-Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
-
-Redistribution and use in source and binary forms, with or without
-modification, are permitted provided that the following conditions are
-met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
-THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
------------------------------------------------------------------------------**/
-
-#include <fcntl.h>
-#include <stdlib.h>
-#include <stdio.h>
-#include <errno.h>
-#include <unistd.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <sys/queue.h>
-#include <sys/time.h>
-#include <sys/prctl.h>
-#include <cutils/properties.h>
-
-#include "app/sql/statement.h"
-#include "app/sql/transaction.h"
-#include "base/command_line.h"
-#include "base/file_util.h"
-#include "base/time.h"
-#include "base/string_util.h"
-#include "base/utf_string_conversions.h"
-#include "base/task.h"
-#include "base/threading/thread.h"
-#include "net/disk_cache/hash.h"
-
-#include "stat_hub.h"
-
-namespace stat_hub {
-
-#define FLUSH_DB_TIMEOUT_THRESHOLD_DEF 30000
-
-typedef enum {
- INPUT_STATE_READ_MARKER,
- INPUT_STATE_READ_CMD,
- INPUT_STATE_READ_STRING_LEN,
- INPUT_STATE_READ_STRING_DATA,
- INPUT_STATE_READ_INT32,
-} InputState;
-
-const char* kPropNameEnabled = "stathub.enabled";
-const char* kPropNameDbpath = "stathub.dbpath";
-const char* kPropNameVerbose = "stathub.verbose";
-const char* kPropNameFlushDelay = "stathub.flushdelay";
-const char* kPropNameEnabledAppName = "stathub.appname";
-const char* kPropNamePlugin = "stathub.plugin";
-
-const char* kEnabledAppName = "com.android.browser";
-
-void DoFlushDB(StatHub* database) {
- database->FlushDBrequest();
-}
-
-// Version number of the database.
-static const int kCurrentVersionNumber = 1;
-static const int kCompatibleVersionNumber = 1;
-
-StatHub* StatHub::GetInstance() {
- static StatHub hub;
- return &hub;
-}
-
-StatHub::StatHub() :
- db_(NULL),
- ready_(false),
- flush_db_required_(false),
- flush_db_scheduled_(false),
- first_processor_(NULL),
- thread_(NULL),
- flush_delay_(FLUSH_DB_TIMEOUT_THRESHOLD_DEF),
- verbose_level_(STAT_HUB_VERBOSE_LEVEL_DISABLED) {
-
- cmd_mask_ |= (1<<INPUT_CMD_WK_MMC_CLEAR);
- cmd_mask_ |= (1<<INPUT_CMD_WK_MAIN_URL_LOADED);
-}
-
-StatHub::~StatHub() {
- Release();
-}
-
-bool StatHub::LoadPlugin(const char* name) {
- if (IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::Init - Load plugin: " << name;
- }
- StatProcessorGenericPlugin* plugin = new StatProcessorGenericPlugin(name);
- if( plugin->OpenPlugin()) {
- RegisterProcessor(plugin);
- LOG(INFO) << "netstack: succeeded to load StatHub plugin: " << name;
- return true;
- }
-
- LOG(INFO) << "netstack: failed to load StatHub plugin: " << name;
- return false;
-}
-
-void StatHub::RegisterProcessor(StatProcessor* processor) {
- if (NULL!=processor) {
- processor->next_ = first_processor_;
- first_processor_ = processor;
- }
-}
-
-StatProcessor* StatHub::DeleteProcessor(StatProcessor* processor) {
- if (NULL!=processor) {
- StatProcessor* next = processor->next_;
- if (first_processor_==processor) {
- first_processor_ = next;
- }
- else {
- for (StatProcessor* tmp_processor=first_processor_; tmp_processor!=NULL; tmp_processor=tmp_processor->next_ ) {
- if (tmp_processor->next_==processor) {
- tmp_processor->next_=next;
- break;
- }
- }
- }
- delete processor;
- return next;
- }
- return NULL;
-}
-
-bool StatHub::IsProcReady(const char* name) {
- if (IsReady()) {
- std::string proc_name;
-
- for (StatProcessor* processor=first_processor_; processor!=NULL; processor=processor->next_) {
- if (processor->OnGetProcName(proc_name)) {
- //if (proc_name==name) {
- size_t found = proc_name.find(name);
- if (found != std::string::npos) {
- if (IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::IsProcReady:(true) for:" << name;
- }
- return true;
- }
- }
- }
- }
- if (IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::(false) for:" << name;
- }
- return false;
-}
-
-bool StatHub::Init(const std::string& db_path, MessageLoop* message_loop, net::HttpCache* http_cache) {
- char value[PROPERTY_VALUE_MAX] = {'\0'};
-
- if (ready_) {
- LOG(INFO) << "StatHub::Init - Already initializes";
- return false;
- }
-
- if (db_path.empty() || NULL==message_loop) {
- LOG(ERROR) << "StatHub::Init - Bad parameters";
- return false;
- }
-
- property_get(kPropNameEnabled, value, "1"); //!!!!!!!!! ENABLED by default !!!!!!!!!
- if (!atoi(value)) {
- LOG(INFO) << "StatHub::Init - Disabled";
- return false;
- }
-
- property_get(kPropNameVerbose, value, "0"); //STAT_HUB_VERBOSE_LEVEL_DISABLED - 0
- verbose_level_ = (StatHubVerboseLevel)atoi(value);
- if (IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::Init - Verbose Level: " << verbose_level_;
- }
-
- //Check application restriction
- property_get(kPropNameEnabledAppName, value, kEnabledAppName);
- enabled_app_name_ = value;
-
- char path[128] = {'\0'};
- pid_t pid = getpid();
- snprintf(path, sizeof(path), "/proc/%d/cmdline", pid);
- int fd = open(path, O_RDONLY);
- int rd_len = read(fd, path , sizeof(path)-1);
- if (0 > rd_len) {
- rd_len = 0;
- }
- path[rd_len] = 0;
- close(fd);
-
- if(IsVerboseEnabled()) {
- LOG(INFO) << "CacheDatabase::Init - Prc Name: " << path << "(" << (int)pid << ")";
- }
- if (strcmp(path, enabled_app_name_.c_str())) {
- LOG(ERROR) << "StatHub::Init - App " << path << " isn't supported.";
- return false;
- }
-
- base::Time start(StatHubGetSystemTime());
-
- property_get(kPropNameFlushDelay, value, PROP_VAL_TO_STR(FLUSH_DB_TIMEOUT_THRESHOLD_DEF));
- flush_delay_ = atoi(value);
- if (flush_delay_<=0) {
- flush_delay_ = FLUSH_DB_TIMEOUT_THRESHOLD_DEF;
- }
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::Init - Flush delay: " << flush_delay_;
- }
-
- std::string db_path_def = db_path + "/db.sql";
- property_get(kPropNameDbpath, value, db_path_def.c_str());
- db_path_ = value;
-
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::Init - DB path: " << db_path.c_str();
- LOG(INFO) << "StatHub::Init - Finale DB path: " << db_path_.c_str();
- }
-
- message_loop_ = message_loop;
- http_cache_ = http_cache;
-
- #if defined(NOT_NOW)
- db_->set_page_size(2048);
- db_->set_cache_size(32);
- //Run the database in exclusive mode. Nobody else should be accessing the
- //database while we're running, and this will give somewhat improved perf.
- db_->set_exclusive_locking();
- #endif //defined(NOT_NOW)
- db_ = new sql::Connection();
- if (!db_->Open(FilePath(db_path_.c_str()))) {
- LOG(ERROR) << "StatHub::Init - Unable to open DB " << db_path_.c_str();
- Release();
- return false;
- }
-
- // Scope initialization in a transaction so we can't be partially initialized.
- if (!StatHubBeginTransaction(db_)) {
- LOG(ERROR) << "StatHub::Init - Unable to start transaction";
- Release();
- return false;
- }
-
- // Create tables.
- if (!InitTables()) {
- LOG(ERROR) << "StatHub::Init - Unable to initialize DB tables";
- Release();
- return false;
- }
-
- //load mandatory plugins
- LoadPlugin("pp_proc_plugin.so");
- LoadPlugin("pageload_proc_plugin.so");
-
-#ifdef STAT_HUB_DYNAMIC_BIND_ON
- //load arbitrary plugins
- for(int index=1; ; index++) {
- std::ostringstream index_str;
- index_str << "." << index;
- std::string plugin_prop_name = kPropNamePlugin + index_str.str();
- property_get(plugin_prop_name.c_str(), value, "");
- if (!value[0]) {
- break;
- }
- LoadPlugin(value);
- }
-#endif // STAT_HUB_DYNAMIC_BIND_ON
-
- std::string proc_name;
- for (StatProcessor* processor=first_processor_; processor!=NULL;) {
- if (!processor->OnGetProcName(proc_name)) {
- proc_name = "Undefined";
- }
- if(!processor->OnInit(db_, message_loop_)) {
- LOG(INFO) << "StatHub::Init - processor " << proc_name.c_str() << " initialization failed!";
- processor = DeleteProcessor(processor);
- } else {
- LOG(INFO) << "StatHub::Init - processor " << proc_name.c_str() << " is ready.";
- unsigned int cmd_mask;
- if (processor->OnGetCmdMask(cmd_mask)) {
- cmd_mask_ |= cmd_mask;
- }
- processor=processor->next_ ;
- }
- }
-
- // Initialization is complete.
- if (!StatHubCommitTransaction(db_)) {
- LOG(ERROR) << "StatHub::Init - Unable to commist transaction";
- Release();
- return false;
- }
-
- for (StatProcessor* processor=first_processor_; processor!=NULL; processor=processor->next_ ) {
- processor->OnFetchDb(db_);
- }
-
- thread_ = new base::Thread("event_handler");
- if (!thread_->StartWithOptions(base::Thread::Options(MessageLoop::TYPE_IO, 0))) {
- LOG(ERROR) << "StatHub::Init event thread start error";
- Release();
- return false;
- }
-
- ready_ = true;
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::Init: Init DB Time: " << StatHubGetTimeDeltaInMs(start, StatHubGetSystemTime());
- }
-
- LOG(INFO) << "netstack: StatHub was initialized";
- return true;
-}
-
-void StatHub::Release() {
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::Release";
- }
-
- //thread
- if(NULL!=thread_) {
- delete thread_;
- thread_ = NULL;
- }
-
- //processors
- StatProcessor* next_processor;
- for (StatProcessor* processor=first_processor_; processor!=NULL; processor=next_processor ) {
- next_processor = processor->next_;
- delete processor;
- }
- first_processor_ = NULL;
-
- //DataBase
- if (NULL!=db_) {
- db_->Close();
- delete db_;
- db_ = NULL;
- }
-
- //Rest
- flush_db_required_ = false;
- flush_db_scheduled_ = false;
- ready_ = false;
-}
-
-bool StatHub::InitTables() {
- if (!StatHubDoesTableExist(db_, "meta")) {
- if (!StatHubExecute(db_, "CREATE TABLE meta ("
- "key LONGVARCHAR NOT NULL UNIQUE PRIMARY KEY,"
- "value LONGVARCHAR"
- ")")) {
- return false;
- }
- }
- return true;
-}
-
-bool StatHub::GetDBmetaData(const char* key, std::string& val) {
- bool ret = false;
-
- sql::Statement* statement = StatHubGetStatement(db_, SQL_FROM_HERE,
- "SELECT * FROM meta WHERE key=?");
- StatHubStatementBindCString(statement, 0 , key);
- if(StatHubStatementStep(statement)) {
- ret = true;
- val = StatHubStatementColumnString(statement, 1);
- }
- StatHubReleaseStatement(statement);
- return ret;
-}
-
-bool StatHub::SetDBmetaData(const char* key, const char* val) {
- bool ret = true;
-
- sql::Statement* statement = StatHubGetStatement(db_, SQL_FROM_HERE,
- "INSERT OR REPLACE INTO meta "
- "(key, value) "
- "VALUES (?,?)");
- StatHubStatementBindCString(statement, 0 , key);
- StatHubStatementBindCString(statement, 1 , val);
- ret = StatHubStatementRun(statement);
- StatHubReleaseStatement(statement);
- return ret;
-}
-
-void StatHub::MainUrlLoaded(const char* url) {
- flush_db_request_time_ = StatHubGetSystemTime();
- flush_db_required_ = true;
- if (!flush_db_scheduled_) {
- flush_db_scheduled_ = true;
- if(IsVerboseEnabled()) {
- LOG(INFO) << "CacheDatabase::MainUrlLoaded : Request DB flush (" << flush_delay_ << ")";
- }
- message_loop_->PostDelayedTask(FROM_HERE, NewRunnableFunction(&DoFlushDB, this), flush_delay_);
- }
-}
-
-void StatHub::Cmd(StatHubTimeStamp timestamp, unsigned short cmd, void* param1, int sizeofparam1, void* param2, int sizeofparam2) {
- switch (cmd) {
- case INPUT_CMD_WK_MMC_CLEAR:
- for (StatProcessor* processor=first_processor_; processor!=NULL; processor=processor->next_ ) {
- processor->OnClearDb(db_);
- }
- break;
- default:
- for (StatProcessor* processor=first_processor_; processor!=NULL; processor=processor->next_ ) {
- processor->OnCmd(timestamp, cmd, param1, sizeofparam1, param2, sizeofparam2);
- }
- break;
- }
- if (INPUT_CMD_WK_MAIN_URL_LOADED==cmd) {
- MainUrlLoaded((const char*)param1);
- }
-}
-
-void StatHub::FlushDBrequest() {
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::FlushDBrequest : Start";
- }
-
- int delta = StatHubGetTimeDeltaInMs(flush_db_request_time_, StatHubGetSystemTime());
- flush_db_scheduled_ = false;
- if (flush_db_required_) {
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::FlushDBrequest : Flush - " << delta;
- }
-
- if (delta>=flush_delay_) {
- FlushDB();
- }
- else {
- if (!flush_db_scheduled_) {
- flush_db_scheduled_ = true;
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::FlushDBrequest : Restart - " << flush_delay_ - delta;
- }
- thread_->message_loop()->PostDelayedTask(FROM_HERE, NewRunnableFunction(&DoFlushDB, this), flush_delay_ - delta);
- }
- }
- }
-}
-
-bool StatHub::FlushDB() {
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::FlushDB: Begin";
- }
- base::Time start(StatHubGetSystemTime());
-
- for (StatProcessor* processor=first_processor_; processor!=NULL; processor=processor->next_ ) {
- processor->OnFlushDb(db_);
- }
-
- if(IsVerboseEnabled()) {
- LOG(INFO) << "StatHub::FlushDB time :" << StatHubGetTimeDeltaInMs(start, StatHubGetSystemTime());
- }
- return true;
-}
-
-} // namespace stat_hub
-
diff --git a/net/disk_cache/stat_hub.h b/net/disk_cache/stat_hub.h
deleted file mode 100755
index 8006544..0000000
--- a/net/disk_cache/stat_hub.h
+++ /dev/null
@@ -1,268 +0,0 @@
-/** ---------------------------------------------------------------------------
-Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
-
-Redistribution and use in source and binary forms, with or without
-modification, are permitted provided that the following conditions are
-met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
-THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
------------------------------------------------------------------------------**/
-
-#ifndef NET_STAT_HUB_H_
-#define NET_STAT_HUB_H_
-#pragma once
-
-#include "googleurl/src/gurl.h"
-#include "app/sql/connection.h"
-#include "app/sql/init_status.h"
-#include <dlfcn.h>
-
-#include "stat_hub_api.h"
-
-class MessageLoop;
-
-namespace base {
- class Time;
- class Thread;
-}
-
-namespace stat_hub {
-
-extern const char* kEnabledAppName;
-
-typedef void(* event_cb)(int fd, short event, void* arg);
-
-class StatProcessor {
-public:
- StatProcessor(): next_(NULL){
- }
-
-virtual ~StatProcessor() {
- }
-
- //Events
-virtual bool OnInit(sql::Connection* db, MessageLoop* message_loop)=0;
-virtual bool OnFetchDb(sql::Connection* db)=0;
-virtual bool OnFlushDb(sql::Connection* db)=0;
-virtual bool OnClearDb(sql::Connection* db)=0;
-virtual bool OnCmd(StatHubTimeStamp timestamp, unsigned short cmd, void* param1, int sizeofparam1, void* param2, int sizeofparam2) {return false;}
-virtual bool OnGetProcName(std::string& name)=0;
-virtual bool OnGetCmdMask(unsigned int& cmd_mask)=0;
-
-private:
- friend class StatHub;
-
- StatProcessor* next_;
-};
-
-#define STAT_PLUGIN_METHOD_0(name, ret) \
- ret (*Do##name)(); \
- virtual ret name() { if(NULL!=Do##name) return Do##name(); return (ret)0;}
-
-#define STAT_PLUGIN_METHOD_1(name, ret, type1, param1) \
- ret (*Do##name)(type1 param1); \
- virtual ret name(type1 param1) { if(NULL!=Do##name) return Do##name(param1); return (ret)0;}
-
-#define STAT_PLUGIN_METHOD_2(name, ret, type1, param1, type2, param2) \
- ret (*Do##name)(type1 param1, type2 param2); \
- virtual ret name(type1 param1,type2 param2) { if(NULL!=Do##name) return Do##name(param1, param2); return (ret)0;}
-
-#define STAT_PLUGIN_METHOD_3(name, ret, type1, param1, type2, param2, type3, param3) \
- ret (*Do##name)(type1 param1, type2 param2, type3 param3); \
- virtual ret name(type1 param1,type2 param2,type3 param3) \
- { if(NULL!=Do##name) return Do##name(param1, param2, param3); return (ret)0;}
-
-#define STAT_PLUGIN_METHOD_4(name, ret, type1, param1, type2, param2, type3, param3, type4, param4) \
- ret (*Do##name)(type1 param1, type2 param2, type3 param3, type4 param4); \
- virtual ret name(type1 param1,type2 param2,type3 param3, type4 param4) \
- { if(NULL!=Do##name) return Do##name(param1, param2, param3, param4); return (ret)0;}
-
-#define STAT_PLUGIN_METHOD_5(name, ret, type1, param1, type2, param2, type3, param3, type4, param4, type5, param5) \
- ret (*Do##name)(type1 param1, type2 param2, type3 param3, type4 param4, type5 param5); \
- virtual ret name(type1 param1,type2 param2,type3 param3, type4 param4, type5 param5) \
- { if(NULL!=Do##name) return Do##name(param1, param2, param3, param4, param5); return (ret)0;}
-
-#define STAT_PLUGIN_METHOD_6(name, ret, type1, param1, type2, param2, type3, param3, type4, param4, type5, param5, type6, param6) \
- ret (*Do##name)(type1 param1, type2 param2, type3 param3, type4 param4, type5 param5, type6 param6); \
- virtual ret name(type1 param1,type2 param2,type3 param3, type4 param4, type5 param5, type6 param6) \
- { if(NULL!=Do##name) return Do##name(param1, param2, param3, param4, param5, param6); return (ret)0;}
-
-#define STAT_PLUGIN_IF_DEFINE(name) \
- Do##name = NULL;
-
-#define STAT_PLUGIN_IMPORT(handle, name) \
- *(void **)(&Do##name) = dlsym(handle, #name);
-
-class StatProcessorGenericPlugin : public StatProcessor {
-public:
- StatProcessorGenericPlugin(const char* name) :
- initialized_(false) {
- if (NULL!=name) {
- name_ = name;
- }
- STAT_PLUGIN_IF_DEFINE(OnInit)
- STAT_PLUGIN_IF_DEFINE(OnFetchDb)
- STAT_PLUGIN_IF_DEFINE(OnFlushDb)
- STAT_PLUGIN_IF_DEFINE(OnClearDb)
- STAT_PLUGIN_IF_DEFINE(OnCmd)
- STAT_PLUGIN_IF_DEFINE(OnGetProcName)
- STAT_PLUGIN_IF_DEFINE(OnGetCmdMask)
- }
-
-virtual ~StatProcessorGenericPlugin() {
- }
-
- STAT_PLUGIN_METHOD_2(OnInit, bool, sql::Connection*, db, MessageLoop*, message_loop)
- STAT_PLUGIN_METHOD_1(OnFetchDb, bool, sql::Connection*, db)
- STAT_PLUGIN_METHOD_1(OnFlushDb, bool, sql::Connection*, db)
- STAT_PLUGIN_METHOD_1(OnClearDb, bool, sql::Connection*, db)
- STAT_PLUGIN_METHOD_6(OnCmd, bool, StatHubTimeStamp, timestamp, unsigned short, cmd, void*, param1, int, sizeofparam1, void*, param2, int, sizeofparam2)
- STAT_PLUGIN_METHOD_1(OnGetProcName, bool, std::string&, name)
- STAT_PLUGIN_METHOD_1(OnGetCmdMask, bool, unsigned int&, cmd_mask)
-
- bool OpenPlugin(void* fh=NULL) {
- if (!initialized_) {
- if (NULL==fh && !name_.empty()) {
- fh = dlopen(name_.c_str(), RTLD_NOW);
- }
- if (fh) {
- initialized_ = true;
- STAT_PLUGIN_IMPORT(fh, OnInit)
- STAT_PLUGIN_IMPORT(fh, OnFetchDb)
- STAT_PLUGIN_IMPORT(fh, OnFlushDb)
- STAT_PLUGIN_IMPORT(fh, OnClearDb)
- STAT_PLUGIN_IMPORT(fh, OnCmd)
- STAT_PLUGIN_IMPORT(fh, OnGetProcName)
- STAT_PLUGIN_IMPORT(fh, OnGetCmdMask)
- }
- else {
- if(!name_.empty()) {
- LOG(INFO) << "Failed to open plugin:" << name_.c_str();
- }
- }
- }
- return initialized_;
- }
-
-private:
- bool initialized_;
- std::string name_;
-};
-
-class StatHub {
-public:
-
-virtual ~StatHub();
-
-static StatHub* GetInstance();
-
- void RegisterProcessor(StatProcessor* processor);
- StatProcessor* DeleteProcessor(StatProcessor* processor);
-
- bool Init(const std::string& db_path, MessageLoop* message_loop, net::HttpCache* http_cache);
- void Release();
- bool LoadPlugin(const char* name);
-
- void UpdateMainUrl(const char* url);
- void UpdateSubUrl(const char* main_url,const char* sub_url);
- void MainUrlLoaded(const char* url);
- void Cmd(StatHubTimeStamp timestamp, unsigned short cmd, void* param1, int sizeofparam1, void* param2, int sizeofparam2);
-
- void FlushDBrequest();
- bool FlushDB();
-
- bool GetDBmetaData(const char* key, std::string& val);
- bool SetDBmetaData(const char* key, const char* val);
-
- bool IsReady() {
- return ready_;
- }
- bool IsProcReady(const char *name);
- MessageLoop* GetMessageLoop() {
- return message_loop_;
- }
-
- net::HttpCache* GetHttpCache() {
- return http_cache_;
- }
-
- sql::Connection* GetDb() {
- return db_;
- }
-
- base::Thread* GetThread() {
- return thread_;
- }
-
- bool IsVerboseEnabled() {
- return (verbose_level_!=STAT_HUB_VERBOSE_LEVEL_DISABLED);
- }
-
- StatHubVerboseLevel GetVerboseLevel() {
- return verbose_level_;
- }
-
- unsigned int GetCmdMask() {
- return cmd_mask_;
- }
-
- private:
-
- StatHub();
-
- #if defined(NOT_NOW)
- // Vacuums the database. This will cause sqlite to defragment and collect
- // unused space in the file. It can be VERY SLOW.
- void Vacuum();
- #endif //defined(NOT_NOW)
-
- // Creates tables, returning true if the table already exists
- // or was successfully created.
- bool InitTables();
-
- sql::Connection* db_;
-
- std::string db_path_;
- bool ready_;
- bool flush_db_required_;
- bool flush_db_scheduled_;
- base::Time flush_db_request_time_;
-
- MessageLoop* message_loop_;
- net::HttpCache* http_cache_;
-
- std::string enabled_app_name_;
-
- StatProcessor* first_processor_;
-
- // Separate thread on which we run blocking read for notify events.
- base::Thread* thread_;
- int flush_delay_;
- StatHubVerboseLevel verbose_level_;
-
- DISALLOW_COPY_AND_ASSIGN(StatHub);
- unsigned int cmd_mask_;
-};
-
-} // namespace stat_hub
-
-#endif // NET_STAT_HUB_H_
diff --git a/net/disk_cache/stat_hub_api.cc b/net/disk_cache/stat_hub_api.cc
deleted file mode 100755
index 47c9dde..0000000
--- a/net/disk_cache/stat_hub_api.cc
+++ /dev/null
@@ -1,377 +0,0 @@
-/** ---------------------------------------------------------------------------
-Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
-
-Redistribution and use in source and binary forms, with or without
-modification, are permitted provided that the following conditions are
-met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
-THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
------------------------------------------------------------------------------**/
-
-#include <unistd.h>
-#include <string>
-#include <cutils/properties.h>
-
-#include "build/build_config.h"
-#include "googleurl/src/gurl.h"
-#include "base/compiler_specific.h"
-#include "base/task.h"
-#include "base/memory/ref_counted.h"
-#include "base/threading/thread.h"
-#include "net/base/completion_callback.h"
-#include "net/base/net_log.h"
-#include "net/base/net_errors.h"
-#include "net/base/request_priority.h"
-#include "net/base/load_flags.h"
-#include "net/base/io_buffer.h"
-#include "net/disk_cache/hash.h"
-#if defined(STAT_HUB_PRECONNECT_ENABLED)
- #include "net/http/preconnect.h"
-#endif //defined(STAT_HUB_PRECONNECT_ENABLED)
-#include "net/http/http_cache_transaction.h"
-#include "net/http/http_request_info.h"
-#include "net/http/http_request_headers.h"
-
-#include "stat_hub.h"
-#include "stat_hub_api.h"
-
-#define READ_BUF_SIZE (50*1024)
-
-class FetchRequest {
- public:
- explicit FetchRequest(std::string& dest, std::string& headers):
- dest_(dest),
- headers_(headers),
- ALLOW_THIS_IN_INITIALIZER_LIST(start_callback_(this, &FetchRequest::OnStartComplete)),
- ALLOW_THIS_IN_INITIALIZER_LIST(read_callback_(this, &FetchRequest::OnReadComplete)),
- read_in_progress_(false),
- buf_(NULL){
- }
-
- void StartFetch(net::HttpCache* cache){
- request_info_.reset(new net::HttpRequestInfo());
- if(StatHubIsVerboseEnabled()) {
- LOG(INFO) << "Fetch: " << dest_.spec().c_str();
- }
- request_info_->url = dest_;
- request_info_->motivation = net::HttpRequestInfo::PRECONNECT_MOTIVATED;
- request_info_->priority = net::LOWEST;
- request_info_->method = net::HttpRequestHeaders::kGetMethod;
- request_info_->load_flags |= net::LOAD_PREFETCH;
- request_info_->extra_headers.AddHeadersFromString(headers_);
- int rv = cache->CreateTransaction(&trans_);
- rv = trans_->Start(request_info_.get(), &start_callback_, net::BoundNetLog());
- if (rv != net::ERR_IO_PENDING) {
- delete this;
- }
- }
-
- private:
-
- virtual ~FetchRequest() {
- }
-
- void Read() {
- int rv = trans_->Read(buf_, READ_BUF_SIZE, &read_callback_);
- if (rv >= 0) {
- delete this;
- }
- else {
- if (rv == net::ERR_IO_PENDING) {
- read_in_progress_ = true;
- }
- else {
- LOG(INFO) << "FetchRequest::Read : ERROR " << rv << ":" << dest_.spec().c_str();
- delete this;
- }
- }
- }
-
- void OnStartComplete(int error_code) {
- if (error_code == net::OK) {
- buf_ = new net::IOBuffer(READ_BUF_SIZE);
-
- Read();
- }
- else {
- LOG(INFO) << "FetchRequest::OnStartComplete : ERROR " << error_code << ":" << dest_.spec().c_str();
- delete this;
- }
- }
-
- void OnReadComplete(int error_code) {
- read_in_progress_ = false;
- if (error_code == net::OK) {
- delete this;
- }
- else {
- Read();
- }
- }
-
- GURL dest_;
- std::string headers_;
- scoped_ptr<net::HttpRequestInfo> request_info_;
- scoped_ptr<net::HttpTransaction> trans_;
-
- net::CompletionCallbackImpl<FetchRequest> start_callback_;
- net::CompletionCallbackImpl<FetchRequest> read_callback_;
-
- bool read_in_progress_;
- scoped_refptr<net::IOBuffer> buf_;
-
- DISALLOW_COPY_AND_ASSIGN(FetchRequest);
-};
-
-static void DoPreconnect(net::HttpCache* cache, std::string* dest, uint32 count) {
- if(StatHubIsVerboseEnabled()) {
- LOG(INFO) << "Preconnect: " << dest->c_str() << " : " << count;
- }
- if (NULL!=cache) {
- net::HttpNetworkSession* session = cache->GetSession();
- if (NULL!=session) {
- #if defined(STAT_HUB_PRECONNECT_ENABLED)
- net::Preconnect::DoPreconnect(session, GURL(*dest), count);
- #endif //defined(STAT_HUB_PRECONNECT_ENABLED)
- }
- }
- delete dest;
-}
-
-static void DoFetch(net::HttpCache* cache, std::string* dest, std::string* headers) {
- FetchRequest* fetch = new FetchRequest(*dest, *headers);
- fetch->StartFetch(cache);
- delete dest;
- delete headers;
-}
-
-
-// ======================================= Exports ==============================================
-
-bool StatHubIsVerboseEnabled() {
- return stat_hub::StatHub::GetInstance()->IsVerboseEnabled();
-}
-
-StatHubVerboseLevel StatHubGetVerboseLevel() {
- return stat_hub::StatHub::GetInstance()->GetVerboseLevel();
-}
-
-base::Time StatHubGetSystemTime() {
- return base::Time::NowFromSystemTime();
-}
-
-int StatHubGetTimeDeltaInMs(const base::Time& start_time, const base::Time& finish_time) {
- base::TimeDelta delta = finish_time - start_time;
- return (int)delta.InMilliseconds(); //int64
-}
-
-const char* StatHubGetHostFromUrl(std::string& url, std::string& host) {
- GURL dest(url);
- host = dest.GetOrigin().spec();
- return host.c_str();
-}
-
-unsigned int StatHubHash(const char* str) {
- return disk_cache::Hash(str, strlen(str));
-}
-
-void StatHubPreconnect(MessageLoop* message_loop, net::HttpCache* cache, const char* url, uint32 count) {
- message_loop->PostTask(FROM_HERE, NewRunnableFunction(&DoPreconnect, cache, new std::string(url), count));
-}
-
-void StatHubFetch(MessageLoop* message_loop, net::HttpCache* cache, const char* url, const char* headers) {
- message_loop->PostTask(FROM_HERE, NewRunnableFunction(&DoFetch, cache, new std::string(url), new std::string(headers)));
-}
-
-bool StatHubGetDBmetaData(const char* key, std::string& val) {
- return stat_hub::StatHub::GetInstance()->GetDBmetaData(key, val);
-}
-
-bool StatHubSetDBmetaData(const char* key, const char* val) {
- return stat_hub::StatHub::GetInstance()->SetDBmetaData(key, val);
-}
-
-net::HttpCache* StatHubGetHttpCache() {
- return stat_hub::StatHub::GetInstance()->GetHttpCache();
-}
-
-// ================================ StatHub SQL Interface ====================================
-
-bool StatHubBeginTransaction(sql::Connection* db) {
- return db->BeginTransaction();
-}
-
-bool StatHubCommitTransaction(sql::Connection* db) {
- return db->CommitTransaction();
-}
-
-bool StatHubDoesTableExist(sql::Connection* db, const char* table_name) {
- return db->DoesTableExist(table_name);
-}
-
-bool StatHubExecute(sql::Connection* db, const char* sql) {
- return db->Execute(sql);
-}
-
-sql::Statement* StatHubGetStatement(sql::Connection* db, const sql::StatementID& id, const char* sql) {
- if(NULL!=db && NULL!=sql) {
- return new sql::Statement(db->GetCachedStatement(id, sql));
- }
- return NULL;
-}
-
-void StatHubReleaseStatement(sql::Statement* st) {
- if (NULL!=st) {
- delete st;
- }
-}
-
-bool StatHubStatementStep(sql::Statement* st) {
- if (NULL!=st) {
- return st->Step();
- }
- return false;
-}
-
-bool StatHubStatementRun(sql::Statement* st) {
- if (NULL!=st) {
- return st->Run();
- }
- return false;
-}
-
-void StatHubStatementReset(sql::Statement* st) {
- if (NULL!=st) {
- st->Reset();
- }
-}
-
-int StatHubStatementColumnInt(sql::Statement* st, int col) {
- if (NULL!=st) {
- return st->ColumnInt(col);
- }
- return 0;
-}
-
-int64 StatHubStatementColumnInt64(sql::Statement* st, int col) {
- if (NULL!=st) {
- return st->ColumnInt64(col);
- }
- return 0;
-}
-
-bool StatHubStatementColumnBool(sql::Statement* st, int col) {
- if (NULL!=st) {
- return st->ColumnBool(col);
- }
- return false;
-}
-
-std::string StatHubStatementColumnString(sql::Statement* st, int col) {
- if (NULL!=st) {
- return st->ColumnString(col);
- }
- return std::string("");
-}
-
-bool StatHubStatementBindInt(sql::Statement* st, int col, int val) {
- if (NULL!=st) {
- return st->BindInt(col, val);
- }
- return false;
-}
-
-bool StatHubStatementBindInt64(sql::Statement* st, int col, int64 val) {
- if (NULL!=st) {
- return st->BindInt64(col, val);
- }
- return false;
-}
-
-bool StatHubStatementBindBool(sql::Statement* st, int col, bool val) {
- if (NULL!=st) {
- return st->BindBool(col, val);
- }
- return false;
-}
-
-bool StatHubStatementBindCString(sql::Statement* st, int col, const char* val) {
- if (NULL!=st) {
- return st->BindCString(col, val);
- }
- return false;
-}
-
-// ============================ StatHub Functional Interface Proxies ===============================
-
-void CmdProxy(StatHubTimeStamp timestamp, unsigned short cmd, void* param1, int sizeofparam1, void* param2, int sizeofparam2) {
- stat_hub::StatHub::GetInstance()->Cmd(timestamp, cmd, param1, sizeofparam1, param2, sizeofparam2);
- if (sizeofparam1) {
- delete (char*)param1;
- }
- if (sizeofparam2) {
- delete (char*)param2;
- }
-}
-
-// ================================ StatHub Functional Interface ====================================
-void StatHubCmd(unsigned short cmd, void* param1, int sizeofparam1, void* param2, int sizeofparam2){
- unsigned int cmd_mask = stat_hub::StatHub::GetInstance()->GetCmdMask();
-
- if ((cmd>INPUT_CMD_USER_DEFINED || (cmd_mask&(1<<cmd))) && stat_hub::StatHub::GetInstance()->IsReady()) {
- // create persistence storage to safely pass data to another thread
- char* tmp_param1 = (char*)param1;
- char* tmp_param2 = (char*)param2;
- if (sizeofparam1) {
- tmp_param1 = new char[sizeofparam1];
- memcpy(tmp_param1, param1, sizeofparam1);
- }
- if (sizeofparam2) {
- tmp_param2 = new char[sizeofparam2];
- memcpy(tmp_param2, param2, sizeofparam2);
- }
- stat_hub::StatHub::GetInstance()->GetThread()->message_loop()->PostTask( FROM_HERE, NewRunnableFunction(
- &CmdProxy, base::Time::NowFromSystemTime(), cmd, (void*)tmp_param1, sizeofparam1, (void*)tmp_param2, sizeofparam2));
- }
-}
-
-void StatHubUpdateMainUrl(const char* url) {
- if(NULL!=url) {
- StatHubCmd(INPUT_CMD_WK_MAIN_URL, (void*)url, strlen(url)+1, NULL, 0);
- }
-}
-
-void StatHubUpdateSubUrl(const char* main_url, const char* sub_url) {
- if(NULL!=main_url && NULL!=sub_url) {
- StatHubCmd(INPUT_CMD_WK_SUB_URL_REQUEST, (void*)main_url, strlen(main_url)+1, (void*)sub_url, strlen(sub_url)+1);
- }
-}
-
-void StatHubMainUrlLoaded(const char* url) {
- if(NULL!=url) {
- StatHubCmd(INPUT_CMD_WK_MAIN_URL_LOADED, (void*)url, strlen(url)+1, NULL, 0);
- }
-}
-
-bool StatHubIsProcReady(const char* name) {
- return stat_hub::StatHub::GetInstance()->IsProcReady(name);
-}
diff --git a/net/disk_cache/stat_hub_api.h b/net/disk_cache/stat_hub_api.h
deleted file mode 100755
index 6fd771a..0000000
--- a/net/disk_cache/stat_hub_api.h
+++ /dev/null
@@ -1,118 +0,0 @@
-/** ---------------------------------------------------------------------------
-Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
-Redistribution and use in source and binary forms, with or without
-modification, are permitted provided that the following conditions are
-met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
-THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
------------------------------------------------------------------------------**/
-
-// API for the network plug-in
-#ifndef STAT_HUB_API_H_
-#define STAT_HUB_API_H_
-
-#include <string>
-#include "base/time.h"
-#include "app/sql/connection.h"
-#include "app/sql/statement.h"
-#include "net/http/http_cache.h"
-#include "stat_hub_cmd_api.h"
-
-#define PROP_VAL_TO_STR(val) PROP_VAL_TO_STR_HELPER(val)
-#define PROP_VAL_TO_STR_HELPER(val) #val
-#define STAT_MAX_PARAM_LEN 2048
-
-#define STAT_HUB_IS_VERBOSE_LEVEL_ERROR (StatHubGetVerboseLevel()>=STAT_HUB_VERBOSE_LEVEL_ERROR)
-#define STAT_HUB_IS_VERBOSE_LEVEL_WARNING (StatHubGetVerboseLevel()>=STAT_HUB_VERBOSE_LEVEL_WARNING)
-#define STAT_HUB_IS_VERBOSE_LEVEL_INFO (StatHubGetVerboseLevel()>=STAT_HUB_VERBOSE_LEVEL_INFO)
-#define STAT_HUB_IS_VERBOSE_LEVEL_DEBUG (StatHubGetVerboseLevel()>=STAT_HUB_VERBOSE_LEVEL_DEBUG)
-
-typedef enum StatHubVerboseLevel {
- STAT_HUB_VERBOSE_LEVEL_DISABLED,// 0
- STAT_HUB_VERBOSE_LEVEL_ERROR, // 1
- STAT_HUB_VERBOSE_LEVEL_WARNING, // 2
- STAT_HUB_VERBOSE_LEVEL_INFO, // 3
- STAT_HUB_VERBOSE_LEVEL_DEBUG // 4
-} StatHubVerboseLevel;
-
-typedef base::Time StatHubTimeStamp;
-class MessageLoop;
-
-extern bool StatHubIsVerboseEnabled()
- __attribute__ ((visibility ("default"), used));
-extern StatHubVerboseLevel StatHubGetVerboseLevel()
- __attribute__ ((visibility ("default"), used));
-extern base::Time StatHubGetSystemTime()
- __attribute__ ((visibility ("default"), used));
-extern int StatHubGetTimeDeltaInMs(const base::Time& start_time, const base::Time& finish_time)
- __attribute__ ((visibility ("default"), used));
-extern const char* StatHubGetHostFromUrl(std::string& url, std::string& host)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubPreconnect(MessageLoop* message_loop, net::HttpCache* cache, const char* url, uint32 count)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubFetch(MessageLoop* message_loop, net::HttpCache* cache, const char* url, const char* headers)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubGetDBmetaData(const char* key, std::string& val)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubSetDBmetaData(const char* key, const char* val)
- __attribute__ ((visibility ("default"), used));
-extern net::HttpCache* StatHubGetHttpCache()
- __attribute__ ((visibility ("default"), used));
-
-// ================================ StatHub SQL Interface ====================================
-extern bool StatHubBeginTransaction(sql::Connection* db)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubCommitTransaction(sql::Connection* db)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubDoesTableExist(sql::Connection* db, const char* table_name)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubExecute(sql::Connection* db, const char* sql)
- __attribute__ ((visibility ("default"), used));
-extern sql::Statement* StatHubGetStatement(sql::Connection* db, const sql::StatementID& id, const char* sql)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubReleaseStatement(sql::Statement* st)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubStatementStep(sql::Statement* st)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubStatementRun(sql::Statement* st)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubStatementReset(sql::Statement* st)
- __attribute__ ((visibility ("default"), used));
-extern int StatHubStatementColumnInt(sql::Statement* st, int col)
- __attribute__ ((visibility ("default"), used));
-extern int64 StatHubStatementColumnInt64(sql::Statement* st, int col)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubStatementColumnBool(sql::Statement* st, int col)
- __attribute__ ((visibility ("default"), used));
-extern std::string StatHubStatementColumnString(sql::Statement* st, int col)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubStatementBindInt(sql::Statement* st, int col, int val)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubStatementBindInt64(sql::Statement* st, int col, int64 val)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubStatementBindBool(sql::Statement* st, int col, bool val)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubStatementBindCString(sql::Statement* st, int col, const char* val)
- __attribute__ ((visibility ("default"), used));
-
-#endif /* STAT_HUB_API_H_ */
diff --git a/net/disk_cache/stat_hub_cmd_api.h b/net/disk_cache/stat_hub_cmd_api.h
deleted file mode 100644
index 71ee934..0000000
--- a/net/disk_cache/stat_hub_cmd_api.h
+++ /dev/null
@@ -1,74 +0,0 @@
-/** ---------------------------------------------------------------------------
-Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
-
-Redistribution and use in source and binary forms, with or without
-modification, are permitted provided that the following conditions are
-met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
-THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
------------------------------------------------------------------------------**/
-
-#ifndef STAT_HUB_CMD_API_H_
-#define STAT_HUB_CMD_API_H_
-
-typedef enum {
- INPUT_CMD_TBD_0, // 0 TBD
- INPUT_CMD_WK_MAIN_URL, // 1
- INPUT_CMD_WK_SUB_URL_REQUEST, // 2
- INPUT_CMD_TBD_3, // 3 TBD
- INPUT_CMD_WK_MAIN_URL_LOADED, // 4
- INPUT_CMD_WK_RES_MMC_STATUS, // 5
- INPUT_CMD_WK_MMC_CLEAR, // 6
- INPUT_CMD_TBD_7, // 7 TBD
- INPUT_CMD_CH_URL_REQUEST, // 8
- INPUT_CMD_WK_RES_LOAD_FINISHED, // 9
- INPUT_CMD_WK_START_PAGE_LOAD, // 10
- INPUT_CMD_WK_FINISH_PAGE_LOAD, // 11
- INPUT_CMD_TBD_12, // 12 TBD
- INPUT_CMD_CH_URL_REQUEST_DONE, // 13
- INPUT_CMD_WK_JS_SEQ, // 14
-
- INPUT_CMD_USER_DEFINED = 32 // 256
-} StatHubInputCmd;
-
-typedef union {
- unsigned value;
- struct bf {
- unsigned cacheable:1; // first bit
- unsigned mime_type:3; // 3 bits: up to 6 types defined in CachedResource.cpp
- } bf;
-} UrlProperty;
-
-// ================================ StatHub CMD Interface ====================================
-extern unsigned int StatHubHash(const char* str)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubUpdateMainUrl(const char* url)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubUpdateSubUrl(const char* main_url, const char* sub_url)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubMainUrlLoaded(const char* url)
- __attribute__ ((visibility ("default"), used));
-extern void StatHubCmd(unsigned short cmd, void* param1, int sizeofparam1, void* param2, int sizeofparam2)
- __attribute__ ((visibility ("default"), used));
-extern bool StatHubIsProcReady(const char* name)
- __attribute__ ((visibility ("default"), used));
-#endif /* STAT_HUB_CMD_API_H_ */
diff --git a/net/host_resolver_helper/dyn_lib_loader.cc b/net/host_resolver_helper/dyn_lib_loader.cc
deleted file mode 100644
index 043e81a..0000000
--- a/net/host_resolver_helper/dyn_lib_loader.cc
+++ /dev/null
@@ -1,76 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-#include "dyn_lib_loader.h"
-
-LibraryManager* LibraryManager::GetInstance() {
- static LibraryManager mgr;
- return &mgr;
-}
-
-LibraryManager::~LibraryManager() {
- for (LibDictionary::iterator it = libdict.begin(); it != libdict.end();
- it++) {
- if (it->second) {
- ReleaseLibraryModule(it->second);
- }
- }
-}
-
-LibraryManager::MODULE_HANDLE_TYPE LibraryManager::GetLibraryHandleInternal(const std::string& libname) {
- LibHandle& handle = libdict[libname];
- if (NULL == handle) {
- //load module
- handle = LoadLibraryModule(libname);
- }
- return handle;
-}
-
-void* LibraryManager::GetSymbolInternal(const std::string& libname, const std::string& symbol) {
- return LoadLibrarySymbol(GetLibraryHandleInternal(libname), symbol);
-}
-
-void * LibraryManager::LoadLibrarySymbol(const MODULE_HANDLE_TYPE& lh,
- const std::string& symname) {
- void* symptr = NULL;
- if (lh) {
- symptr = dlsym(lh, symname.c_str());
- }
- return symptr;
-}
-
-LibraryManager::MODULE_HANDLE_TYPE LibraryManager::LoadLibraryModule(const std::string& libname) {
- return dlopen(libname.c_str(), RTLD_LAZY);
-}
-
-void LibraryManager::ReleaseLibraryModule(const MODULE_HANDLE_TYPE& lh) {
- if (lh) {
- dlclose(lh);
- }
-}
-
diff --git a/net/host_resolver_helper/dyn_lib_loader.h b/net/host_resolver_helper/dyn_lib_loader.h
deleted file mode 100644
index 6e3b0f0..0000000
--- a/net/host_resolver_helper/dyn_lib_loader.h
+++ /dev/null
@@ -1,103 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-#ifndef __DYN_LIB_LOADER_H__
-#define __DYN_LIB_LOADER_H__
-
-#include <map>
-#include <string>
-#include <dlfcn.h>
-#include "dyn_lib_loader_decl.h"
-
-template<class T>
-inline T* GetInterfacePtr(void* funptr) {
- typedef T* (*InterfaceFunPtr)(void);
- if (NULL==funptr) {
- return NULL;
- }
- InterfaceFunPtr fun = (InterfaceFunPtr) (funptr);
- return fun();
-}
-
-//This macro is used by module which wishes to use the interface object exported by some other module
-// libname - is the dynamic library full name, interface_class - is the interface class for which
-// the object will be imported
-// EXAMPLE: Interface* ptr = GET_DYNAMIC_OBJECT_INTERFACE_PTR("libmy.so",Interface);
-#define GET_DYNAMIC_OBJECT_INTERFACE_PTR(__libname__,__interface_class__) \
- GetInterfacePtr<__interface_class__>(LibraryManager::GetFunctionPtr<__interface_class__>(__libname__,"Get" #__interface_class__ "Object"))
-
-//LibraryManager Connects to shared library reusing the lib handle
-//if called from mutiple places. Get retrieve exported functions and library handle.
-//This class is module level singletone.
-class LibraryManager {
-public:
-
- typedef void* MODULE_HANDLE_TYPE;
- template<class RET_TYPE>
- static RET_TYPE* GetFunctionPtr(const char* libname, const char* symbol) {
- return static_cast<RET_TYPE*>(GetInstance()->GetSymbolInternal(libname,
- symbol));
- }
-
- static MODULE_HANDLE_TYPE GetLibraryHandle(const char* libname) {
- return GetInstance()->GetLibraryHandleInternal(libname);
- }
-
-private:
- template<class MODULE_HANDLE_TYPE>
- class LibHandleType {
- public:
- LibHandleType() :
- handle(NULL) {
- }
- LibHandleType(MODULE_HANDLE_TYPE h) :
- handle(h) {
- }
- operator MODULE_HANDLE_TYPE() {
- return handle;
- }
- private:
- MODULE_HANDLE_TYPE handle;
- };
-
- typedef LibHandleType<MODULE_HANDLE_TYPE> LibHandle;
- typedef std::map<std::string, LibHandle> LibDictionary;
-
- static LibraryManager* GetInstance();
- LibraryManager() {}
- ~LibraryManager();
- void* GetSymbolInternal(const std::string& libname, const std::string& symbol);
- MODULE_HANDLE_TYPE GetLibraryHandleInternal(const std::string& libname);
- void * LoadLibrarySymbol(const MODULE_HANDLE_TYPE& lh, const std::string& symname);
- MODULE_HANDLE_TYPE LoadLibraryModule(const std::string& libname);
- void ReleaseLibraryModule(const MODULE_HANDLE_TYPE& lh);
-
- std::map<std::string, LibHandle> libdict;
-};
-
-#endif //__DYN_LIB_LOADER_H__
diff --git a/net/host_resolver_helper/dyn_lib_loader_decl.h b/net/host_resolver_helper/dyn_lib_loader_decl.h
deleted file mode 100644
index a0ca0d6..0000000
--- a/net/host_resolver_helper/dyn_lib_loader_decl.h
+++ /dev/null
@@ -1,51 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-
-#ifndef __DYN_LIB_LOADER_DECL_H__
-#define __DYN_LIB_LOADER_DECL_H__
-
-//This macro should be placed in module which is exporting the interface
-//first parameter is the interface class, second is the function which returns the interface object
-//EXAMPLE: DECLARE_DYNAMIC_OBJECT_INTERFACE(Interface,InterfaceImpl::GetInstance)
-#define DECLARE_DYNAMIC_OBJECT_INTERFACE_EX(__interface_class__, __get_instance_method__) \
- extern "C" void* Get##__interface_class__##Object() \
- __attribute__ ((visibility ("default"))); \
- void* Get##__interface_class__##Object() {\
- __interface_class__* ptr = __get_instance_method__();\
- return static_cast<void*>(ptr);\
- } \
-
-//This macro should be placed in module which is exporting the interface
-//first parameter is the interface class, second is the class implemeting the static
-//GetInstance function to get the interface object
-//EXAMPLE: DECLARE_DYNAMIC_OBJECT_INTERFACE(Interface,InterfaceImpl)
-#define DECLARE_DYNAMIC_OBJECT_INTERFACE(__interface_class__,__impl_class__) \
- DECLARE_DYNAMIC_OBJECT_INTERFACE_EX(__interface_class__,__impl_class__::GetInstance) \
-
-#endif //__DYN_LIB_LOADER_DECL_H__
diff --git a/net/host_resolver_helper/host_resolver_helper.cc b/net/host_resolver_helper/host_resolver_helper.cc
deleted file mode 100644
index 7c60fb5..0000000
--- a/net/host_resolver_helper/host_resolver_helper.cc
+++ /dev/null
@@ -1,157 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-#include "host_resolver_helper.h"
-
-#include <config.h>
-#include <unistd.h>
-
-#include "net/base/address_list.h"
-#include "net/base/host_port_pair.h"
-#include "net/base/completion_callback.h"
-#include "net/base/host_port_pair.h"
-#include "net/base/host_resolver.h"
-#include "net/base/net_errors.h"
-#include "net/base/net_log.h"
-#include <cutils/properties.h>
-#include "dyn_lib_loader.h"
-
-#define NUM_HOSTS_TO_RESOLVE 30
-
-HostResolverHelper::HostResolverHelper(net::HostResolver* hostresolver) :
- num_of_hosts_to_resolve(NUM_HOSTS_TO_RESOLVE), hostresolver_(
- hostresolver), hostname_provider_(NULL)
-{
- char value[PROPERTY_VALUE_MAX] = { '\0' };
- property_get("net.dnshostprio.num_hosts", value, NULL);
- if (NULL != value && value[0] != '\0') {
- int host_num = atol(value);
- if (host_num <= 0) {
- host_num = NUM_HOSTS_TO_RESOLVE;
- }
- num_of_hosts_to_resolve = host_num;
- }
-}
-
-HostResolverHelper::~HostResolverHelper() {
-}
-
-void HostResolverHelper::Init(HostsProvider* provider) {
- hostname_provider_ = provider;
- LOG(INFO) << "DNSPreResolver::Init got hostprovider:" << provider;
- if (hostresolver_)
- hostresolver_->SetResolverExt(this);
-}
-
-void HostResolverHelper::DoResolve(HostResolverHelper* obj) {
- //TODO: Check there is another task like this in the queue and
- // skip execution of the current one
- obj->StartHostsResolution();
-}
-
-void HostResolverHelper::CancelAllRequests() {
- //loop through all requests and cancel those that still pending
- for (unsigned int i = 0; i < hostinfo_list_.size(); i++) {
- if (hostinfo_list_[i]->pending) {
- hostinfo_list_[i]->pending = false;
- hostresolver_->CancelRequest(hostinfo_list_[i]->reqhandle);
- }
- }
-}
-
-void HostResolverHelper::PrepareRequestsData(const std::vector<std::string>& hostnames) {
- const int actual_hosts_num = hostnames.size();
- hostinfo_list_.clear();
- hostinfo_list_.reserve(actual_hosts_num);
- for (int i = 0; i < actual_hosts_num; i++) {
- hostinfo_list_.push_back(new HostInfo(hostnames[i].c_str()));
- }
-}
-
-bool HostResolverHelper::StartHostsResolution() {
- if (NULL == hostresolver_) {
- return false;
- }
- if (NULL == hostname_provider_) {
- return false;
- }
-
- //get hosts from the provider
- std::vector < std::string > hostnames;
- hostname_provider_->GetHosts(num_of_hosts_to_resolve, hostnames);
- if (0 == hostnames.size()) {
- return true;
- }
- //free old requests if any still active
- CancelAllRequests();
- PrepareRequestsData(hostnames);
-
- const int actual_hosts_num = hostnames.size();
- //now issue resolve for each host
- for (int i = 0; i < actual_hosts_num; i++) {
- //TODO: set request priority
- hostinfo_list_[i]->pending = true;
- int rv = hostresolver_->Resolve(hostinfo_list_[i]->reqinfo, &hostinfo_list_[i]->addrlist,
- &hostinfo_list_[i]->completion_callback_, &hostinfo_list_[i]->reqhandle, net::BoundNetLog());
- //in case we got it resolved synchronously (or error) - set as not pending
- if (rv != net::ERR_IO_PENDING) {
- hostinfo_list_[i]->pending = false;
- }
- }
- return true;
-}
-
-void HostResolverHelper::HostInfo::OnLookupFinished(int result) {
- pending = false;
-}
-
-HostResolverHelper::HostInfo::HostInfo(const std::string& hostname) :
- reqinfo(net::HostPortPair(hostname, 80)), reqhandle(NULL), pending(false), completion_callback_(this,
- &HostInfo::OnLookupFinished) {
-}
-
-
-net::HostResolver::HostnameResolverExt* CreateResolverIPObserver(net::HostResolver* hostResolver) {
- char value[PROPERTY_VALUE_MAX] = { '\0' };
- const char* DNS_PRIORITY_EXTERNAL_LIB = "libdnshostprio.so";
-
- if (NULL == hostResolver) {
- return NULL;
- }
- property_get("net.dnshostprio.enable", value, NULL);
- if (NULL != value && value[0] == '0') {
- return NULL;
- }
- HostResolverHelper* dnsPreresolver = new HostResolverHelper(hostResolver);
- if (NULL == dnsPreresolver) {
- return NULL;
- }
- HostsProvider* provider = GET_DYNAMIC_OBJECT_INTERFACE_PTR(DNS_PRIORITY_EXTERNAL_LIB,HostsProvider);
- dnsPreresolver->Init(provider);
- return dnsPreresolver;
-}
diff --git a/net/host_resolver_helper/host_resolver_helper.h b/net/host_resolver_helper/host_resolver_helper.h
deleted file mode 100644
index bc18a21..0000000
--- a/net/host_resolver_helper/host_resolver_helper.h
+++ /dev/null
@@ -1,105 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-#ifndef __DNSRESOLVERHELPER_H__
-#define __DNSRESOLVERHELPER_H__
-
-#include <vector>
-#include <string>
-
-#include "config.h"
-#include "net/base/host_resolver.h"
-#include "net/base/address_list.h"
-#include "net/base/net_log.h"
-#include "net/base/net_errors.h"
-#include "base/message_loop.h"
-#include "net/base/completion_callback.h"
-#include "hosts_provider.h"
-
-//This class does DNS pre-resolution and should be used by net::HostResolver
-//It's lifetime is depending on the host resolver and they should be created and destroyed
-// in the correct order
-//TODO: make sure the resolver is never destroyed before the pre-resolver
-class HostResolverHelper: public net::HostResolver::HostnameResolverExt {
-public:
- HostResolverHelper(net::HostResolver* hostresolver);
- virtual ~HostResolverHelper();
-
- ///////////////////////////////////////////////////////////////////////////////////////
- // net::HostResolver::HostnamePreresolver interface
- virtual void Resolve() {
- MessageLoop::current()->PostDelayedTask(FROM_HERE, NewRunnableFunction(&HostResolverHelper::DoResolve, this),
- 500);
- }
- ///////////////////////////////////////////////////////////////////////////////////////
-
- //task which is executed through the message loop
- static void DoResolve(HostResolverHelper* obj);
-
- //call it to connect with the hostnames provider
- void Init(HostsProvider* provider);
-
-private:
-
- //to be called when hosts pre-resolution is requested (worker function)
- bool StartHostsResolution();
-
-private:
- int num_of_hosts_to_resolve;
- net::HostResolver* hostresolver_;
- HostsProvider* hostname_provider_;
- // Delegate interface, for notification when the ResolveRequest completes.
-
- class HostInfo: public base::RefCounted<HostInfo> {
- public:
- net::AddressList addrlist;
- net::HostResolver::RequestInfo reqinfo;
- net::HostResolver::RequestHandle reqhandle;
- bool pending;
- net::CompletionCallbackImpl<HostInfo> completion_callback_;
-
- HostInfo(const std::string& hostname);
- ~HostInfo() {
- }
-
- void OnLookupFinished(int result);
-
- };
-
- std::vector<scoped_refptr<HostInfo> > hostinfo_list_;
-
- //used to cancel all pending requests before issuing new ones
- void CancelAllRequests();
- void PrepareRequestsData(const std::vector<std::string>& hostnames);
-
-};
-
-//intialization for the webkit
-net::HostResolver::HostnameResolverExt* CreateResolverIPObserver(net::HostResolver* hostResolver);
-
-#endif
diff --git a/net/host_resolver_helper/hosts_provider.h b/net/host_resolver_helper/hosts_provider.h
deleted file mode 100644
index 19b847d..0000000
--- a/net/host_resolver_helper/hosts_provider.h
+++ /dev/null
@@ -1,44 +0,0 @@
-/** ---------------------------------------------------------------------------
- Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
- Redistribution and use in source and binary forms, with or without
- modification, are permitted provided that the following conditions are
- met:
- * Redistributions of source code must retain the above copyright
- notice, this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above
- copyright notice, this list of conditions and the following
- disclaimer in the documentation and/or other materials provided
- with the distribution.
- * Neither the name of Code Aurora Forum, Inc. nor the names of its
- contributors may be used to endorse or promote products derived
- from this software without specific prior written permission.
-
- THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- -----------------------------------------------------------------------------**/
-#ifndef __HOSTSPROVIDER_H_INCL__
-#define __HOSTSPROVIDER_H_INCL__
-
-#include <vector>
-#include <string>
-
-class HostsProvider {
-public:
- virtual bool GetHosts(int max_hosts, std::vector<std::string>& list)=0;
- virtual void ClearStatistics()=0;
- virtual ~HostsProvider() {
- }
- ;
-};
-
-#endif // __HOSTSPROVIDER_H_INCL__
diff --git a/net/http/http_basic_stream.cc b/net/http/http_basic_stream.cc
index f74614b..6501a59 100644
--- a/net/http/http_basic_stream.cc
+++ b/net/http/http_basic_stream.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -34,7 +33,7 @@ int HttpBasicStream::InitializeStream(const HttpRequestInfo* request_info,
DCHECK(!parser_.get());
request_info_ = request_info;
parser_.reset(new HttpStreamParser(connection_.get(), request_info,
- read_buf_, net_log, using_proxy_));
+ read_buf_, net_log));
return OK;
}
diff --git a/net/http/http_cache.cc b/net/http/http_cache.cc
index 4a2313c..d53d525 100644
--- a/net/http/http_cache.cc
+++ b/net/http/http_cache.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -36,9 +35,6 @@
#include "net/http/http_util.h"
#include "net/socket/ssl_host_info.h"
-#include "net/disk_cache/stat_hub.h"
-#include "net/disk_cache/hostres_plugin_bridge.h"
-
namespace net {
namespace {
@@ -89,14 +85,8 @@ HttpCache::BackendFactory* HttpCache::DefaultBackend::InMemory(int max_bytes) {
int HttpCache::DefaultBackend::CreateBackend(NetLog* net_log,
disk_cache::Backend** backend,
- CompletionCallback* callback,
- FilePath** stat_db_path) {
+ CompletionCallback* callback) {
DCHECK_GE(max_bytes_, 0);
- (*stat_db_path) = NULL;
- if (type_ == net::DISK_CACHE) {
- std::string dataPath = "/data/data/";
- (*stat_db_path) = new FilePath(dataPath + stat_hub::kEnabledAppName + "/databases");
- }
return disk_cache::CreateCacheBackend(type_, path_, max_bytes_, true,
thread_, net_log, backend, callback);
}
@@ -349,8 +339,7 @@ HttpCache::HttpCache(HostResolver* host_resolver,
http_auth_handler_factory,
network_delegate,
net_log))),
- ALLOW_THIS_IN_INITIALIZER_LIST(task_factory_(this))
- , stat_db_path_(NULL) {
+ ALLOW_THIS_IN_INITIALIZER_LIST(task_factory_(this)) {
}
@@ -419,10 +408,6 @@ HttpCache::~HttpCache() {
if (delete_pending_op)
delete pending_op;
}
-
- if (NULL!=stat_db_path_) {
- delete stat_db_path_;
- }
}
int HttpCache::GetBackend(disk_cache::Backend** backend,
@@ -533,7 +518,7 @@ int HttpCache::CreateBackend(disk_cache::Backend** backend,
pending_op->callback = my_callback;
int rv = backend_factory_->CreateBackend(net_log_, &pending_op->backend,
- my_callback, &stat_db_path_ );
+ my_callback);
if (rv != ERR_IO_PENDING) {
pending_op->writer->ClearCallback();
my_callback->Run(rv);
@@ -1158,21 +1143,8 @@ void HttpCache::OnBackendCreated(int result, PendingOp* pending_op) {
}
// The cache may be gone when we return from the callback.
- if (!item->DoCallback(result, backend)) {
+ if (!item->DoCallback(result, backend))
item->NotifyTransaction(result, NULL);
- if (NULL!=stat_db_path_) {
- if(!stat_hub::StatHub::GetInstance()->IsReady()) {
- stat_hub::StatProcessor* hp = StatHubCreateHostResPlugin();
- if (NULL!=hp) {
- stat_hub::StatHub::GetInstance()->RegisterProcessor(hp);
- LOG(INFO) << "HttpCache::OnBackendCreated HostStat created";
- }
- if(stat_hub::StatHub::GetInstance()->Init(stat_db_path_->value(), MessageLoop::current(), this)) {
- LOG(INFO) << "HttpCache::OnBackendCreated : StatHub is ready.";
- }
- }
- }
- }
}
} // namespace net
diff --git a/net/http/http_cache.h b/net/http/http_cache.h
index 2ff5eff..0c2dc35 100644
--- a/net/http/http_cache.h
+++ b/net/http/http_cache.h
@@ -1,6 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved
-
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -90,8 +88,7 @@ class NET_EXPORT HttpCache : public HttpTransactionFactory,
// |callback| because the object can be deleted from within the callback.
virtual int CreateBackend(NetLog* net_log,
disk_cache::Backend** backend,
- CompletionCallback* callback,
- FilePath** stat_db_path) = 0;
+ CompletionCallback* callback) = 0;
};
// A default backend factory for the common use cases.
@@ -110,8 +107,7 @@ class NET_EXPORT HttpCache : public HttpTransactionFactory,
// BackendFactory implementation.
virtual int CreateBackend(NetLog* net_log,
disk_cache::Backend** backend,
- CompletionCallback* callback,
- FilePath** stat_db_path);
+ CompletionCallback* callback);
private:
CacheType type_;
@@ -382,8 +378,6 @@ class NET_EXPORT HttpCache : public HttpTransactionFactory,
scoped_ptr<PlaybackCacheMap> playback_cache_map_;
- FilePath* stat_db_path_;
-
DISALLOW_COPY_AND_ASSIGN(HttpCache);
};
diff --git a/net/http/http_cache_transaction.cc b/net/http/http_cache_transaction.cc
index 3fef3a7..a12a64f 100644
--- a/net/http/http_cache_transaction.cc
+++ b/net/http/http_cache_transaction.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -35,8 +34,6 @@
#include "net/http/http_transaction.h"
#include "net/http/http_util.h"
#include "net/http/partial_data.h"
-#include "net/http/preconnect.h"
-#include "net/http/net-plugin-bridge.h"
using base::Time;
@@ -1646,17 +1643,13 @@ bool HttpCache::Transaction::RequiresValidation() {
return true;
if (response_.headers->RequiresValidation(
- response_.request_time, response_.response_time, Time::Now())) {
- ObserveRevalidation(&response_, request_, cache_);
+ response_.request_time, response_.response_time, Time::Now()))
return true;
- }
// Since Vary header computation is fairly expensive, we save it for last.
if (response_.vary_data.is_valid() &&
- !response_.vary_data.MatchesRequest(*request_, *response_.headers)) {
- ObserveRevalidation(&response_, request_, cache_);
+ !response_.vary_data.MatchesRequest(*request_, *response_.headers))
return true;
- }
return false;
}
diff --git a/net/http/http_getzip_bridge.cc b/net/http/http_getzip_bridge.cc
deleted file mode 100644
index 9395c1e..0000000
--- a/net/http/http_getzip_bridge.cc
+++ /dev/null
@@ -1,142 +0,0 @@
-/**
- * Copyright (c) 2012, Code Aurora Forum. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other *materials provided
- * with the distribution.
- * * Neither the name of Code Aurora Forum, Inc. nor the names of its
- * contributors may be used to endorse or promote products derived
- * from this software without specific prior written permission.
-
- * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- **/
-
-#include "net/http/http_getzip_bridge.h"
-#include "net/http/http_request_headers.h"
-#include "net/http/http_response_headers.h"
-
-namespace net
-{
-
-void GetNextHttpRequestHeader( void*& it)
-{
- if (NULL == it)return;
-
- HttpRequestHeaders::Iterator* myIt =
- (static_cast<HttpRequestHeaders::Iterator*> (it));
-
- if (!myIt->GetNext())
- {
- delete myIt;
- it = NULL;
- }
-}
-
-void GetFirstHttpRequestHeader(
- net::HttpRequestHeaders& req, void*& it)
-{
- //create a new Iterator for the req
- it = new net::HttpRequestHeaders::Iterator(req);
- return GetNextHttpRequestHeader( it );
-}
-
-const std::string& GetHttpRequestHeaderName( void*& it )
-{
- net::HttpRequestHeaders::Iterator* myIt =
- (static_cast<net::HttpRequestHeaders::Iterator*> (it));
- return myIt->name();
-}
-
-const std::string& GetHttpRequestHeaderValue( void*& it )
-{
- net::HttpRequestHeaders::Iterator* myIt =
- (static_cast<net::HttpRequestHeaders::Iterator*> (it));
- return myIt->value();
-}
-
-bool GetHttpRequestHeaderByValue(
- net::HttpRequestHeaders& req,
- const std::string& headerName,
- std::string* headerValue)
-{
- return req.GetHeader(headerName, headerValue);
-}
-
-void SetHttpRequestHeader(net::HttpRequestHeaders& req,
- const std::string& headerName, const std::string& value)
-{
- req.SetHeader(headerName, value);
-}
-
-void RemoveHttpRequestHeader(net::HttpRequestHeaders& req,
- const std::string& headerName)
-{
- req.RemoveHeader(headerName);
-}
-
-void RemoveHttpResponseHeader(net::HttpResponseHeaders* res,
- const std::string& headerName)
-{
- if (NULL == res)
- return;
-
- res->RemoveHeader(headerName);
-}
-
-std::string GetHttpResponseHeaderValue(net::HttpResponseHeaders* res,
- const std::string& headerName)
-{
- if (NULL == res)
- return "";
- std::string value;
-
- void* iter = NULL;
- std::string temp;
- while (res->EnumerateHeader(&iter, headerName, &temp)) {
-
- value.append(temp);
- value.append(", ");
- }
- if(value.size() > 2)
- {
- value.erase(value.size() - 2);
- }
-
- return value;
-}
-
-int GetHttpResponseCode(net::HttpResponseHeaders* res)
-{
- if(NULL == res) return -1;
-
- return res->response_code();
-}
-
-bool HasHttpResponseHeader(net::HttpResponseHeaders* res,
- const std::string& headerName)
-{
- if(NULL == res) return false;
-
- return res->HasHeader(headerName);
-}
-
-void initBridge(){ }
-
-}; //end net
-
diff --git a/net/http/http_getzip_bridge.h b/net/http/http_getzip_bridge.h
deleted file mode 100644
index c545b89..0000000
--- a/net/http/http_getzip_bridge.h
+++ /dev/null
@@ -1,66 +0,0 @@
-/**
- * Copyright (c) 2012, Code Aurora Forum. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other *materials provided
- * with the distribution.
- * * Neither the name of Code Aurora Forum, Inc. nor the names of its
- * contributors may be used to endorse or promote products derived
- * from this software without specific prior written permission.
-
- * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- **/
-
-#ifndef HTTP_GETZIP_BRIDGE_H_
-#define HTTP_GETZIP_BRIDGE_H_
-
-
-#include <string>
-#include "net/http/http_request_headers.h"
-#include "net/http/http_response_headers.h"
-
-#define EXPORT __attribute__((visibility("default"), used))
-
-namespace net
-{
- //HttpRequestHeader method delegates
- //@argument it - should be initialized to NULL
- extern void GetFirstHttpRequestHeader(net::HttpRequestHeaders& req, void*& it) EXPORT;
- extern const std::string& GetHttpRequestHeaderName( void*& it ) EXPORT;
- extern const std::string& GetHttpRequestHeaderValue( void*& it ) EXPORT;
- bool GetHttpRequestHeaderByValue( net::HttpRequestHeaders& req,
- const std::string& headerName,
- std::string* headerValue) EXPORT;
- extern void GetNextHttpRequestHeader( void*& it ) EXPORT;
-
- extern void SetHttpRequestHeader(net::HttpRequestHeaders& req, const std::string& headerName,
- const std::string& value) EXPORT;
- extern void RemoveHttpRequestHeader(net::HttpRequestHeaders& req, const std::string& headerName) EXPORT;
-
- ////HttpResponseHeader method delegates
- extern void RemoveHttpResponseHeader(net::HttpResponseHeaders* res, const std::string& headerName) EXPORT;
- extern std::string GetHttpResponseHeaderValue(net::HttpResponseHeaders* res, const std::string& headerName) EXPORT;
- extern int GetHttpResponseCode(net::HttpResponseHeaders* res) EXPORT;
- extern bool HasHttpResponseHeader(net::HttpResponseHeaders* res, const std::string& headerName) EXPORT;
-
- extern void initBridge();
-};
-
-
-#endif /* HTTP_GETZIP_BRIDGE_H_ */
diff --git a/net/http/http_getzip_factory.cc b/net/http/http_getzip_factory.cc
deleted file mode 100644
index 02948d8..0000000
--- a/net/http/http_getzip_factory.cc
+++ /dev/null
@@ -1,127 +0,0 @@
-/**
- * Copyright (c) 2012, Code Aurora Forum. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other *materials provided
- * with the distribution.
- * * Neither the name of Code Aurora Forum, Inc. nor the names of its
- * contributors may be used to endorse or promote products derived
- * from this software without specific prior written permission.
-
- * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- **/
-
-#include "net/http/http_getzip_factory.h"
-#include "net/socket/client_socket.h"
-#include <cutils/log.h>
-#include <dlfcn.h>
-
-namespace net
-{
-
-HttpGetZipFactory* HttpGetZipFactory::s_pFactory = NULL;
-
-typedef IGetZipManager* mngr_create_();
-
-HttpGetZipFactory::HttpGetZipFactory() :
- m_pMngr(NULL), libHandle(NULL)
-{
-}
-
-HttpGetZipFactory::~HttpGetZipFactory()
-{
- delete m_pMngr;
- m_pMngr = NULL;
-
- if (NULL != libHandle)
- {
- ::dlclose(libHandle);
- libHandle = NULL;
- }
-}
-
-void HttpGetZipFactory::InitGETZipManager()
-{
- if (NULL != s_pFactory)
- return;
-
- s_pFactory = new HttpGetZipFactory();
-
- s_pFactory->libHandle = ::dlopen("libgetzip.so", RTLD_NOW);
-
- if (s_pFactory->libHandle)
- {
- SLOGD("%s: libgetzip.so successfully loaded", __FILE__);
- dlerror();
- mngr_create_* mngrCreate = (mngr_create_*) dlsym(s_pFactory->libHandle,
- "createGETZipManager");
-
- if (mngrCreate)
- {
- SLOGD("%s,: GETzip initializing method was found in libgetzip.so",
- __FILE__);
- s_pFactory->m_pMngr = (IGetZipManager*) mngrCreate();
- if( NULL == s_pFactory->m_pMngr)
- {
- s_pFactory->m_pMngr = new GetZipManager();
- }
- return;
- }
- SLOGD("netstack: Failed to find createGETZipManager sybmol in libgetzip.so");
- ::dlclose(s_pFactory->libHandle);
- s_pFactory->libHandle = NULL;
- s_pFactory->m_pMngr = new GetZipManager();
- return;
- }
-
- SLOGD("%s: Failed to construct GETzip manager, didn't find the library!",
- __FILE__);
- s_pFactory->m_pMngr = new GetZipManager();
-}
-
-IGetZipManager* HttpGetZipFactory::GetGETZipManager()
-{
- return s_pFactory->m_pMngr;
-}
-
-void HttpGetZipFactory::StopGETZipManager()
-{
- if (libHandle == NULL)
- return;
-
- delete m_pMngr;
- m_pMngr = new GetZipManager();
- ::dlclose(libHandle);
- libHandle = NULL;
-}
-
-IGetZipManager::IGetZipManager()
-{
-}
-
-IGetZipManager::~IGetZipManager()
-{
-}
-
-GetZipManager::GetZipManager()
-{
-}
-
-}
-; //end network
diff --git a/net/http/http_getzip_factory.h b/net/http/http_getzip_factory.h
deleted file mode 100644
index f7cced0..0000000
--- a/net/http/http_getzip_factory.h
+++ /dev/null
@@ -1,137 +0,0 @@
-/**
- * Copyright (c) 2012, Code Aurora Forum. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other *materials provided
- * with the distribution.
- * * Neither the name of Code Aurora Forum, Inc. nor the names of its
- * contributors may be used to endorse or promote products derived
- * from this software without specific prior written permission.
-
- * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- **/
-
-#ifndef HTTP_GETZIP_FACTORY_H_
-#define HTTP_GETZIP_FACTORY_H_
-
-#include "net/socket/client_socket.h"
-#include <sys/types.h>
-#include "base/basictypes.h"
-
-namespace net
-{
-
-//forward declarations
-class HttpRequestHeaders;
-class HttpResponseHeaders;
-
-typedef enum
-{
- GETZIP_OK = 1,
- REQUEST_RETRY_NEEDED = 2, //GETzip failure that requires last request retry
- NULL_ARGUMENT = 3, //One of the passed argument was NULL
- NO_GETZIP_CONNECTION = 4 //No GETzip connection was found
-} GETZipDecompressionStatus;
-
-//Main GetZip interface
-class IGetZipManager
-{
-public:
- IGetZipManager();
- virtual void CompressRequestHeaders(HttpRequestHeaders&, ClientSocket*) = 0;
- virtual GETZipDecompressionStatus
- DecompressResponseHeaders(HttpResponseHeaders*, ClientSocket*) = 0;
- virtual void StopGetZipConnection(ClientSocket*) = 0;
- virtual void OpenGetZipConnection(ClientSocket*) = 0;
- virtual ~IGetZipManager() = 0;
-
-private:
- DISALLOW_COPY_AND_ASSIGN(IGetZipManager);
-};
-
-//Simple, non private GetZip manager implementation
-class GetZipManager: public IGetZipManager
-{
-public:
-
- GetZipManager();
- virtual ~GetZipManager()
- {
- }
- ;
-
- virtual void CompressRequestHeaders(HttpRequestHeaders&, ClientSocket*)
- {
- }
- ;
- virtual GETZipDecompressionStatus DecompressResponseHeaders(HttpResponseHeaders*, ClientSocket*)
- {
- return NO_GETZIP_CONNECTION;
- }
- ;
- virtual void StopGetZipConnection(ClientSocket*)
- {
- }
- ;
- virtual void OpenGetZipConnection(ClientSocket*)
- {
- }
- ;
-
-private:
- DISALLOW_COPY_AND_ASSIGN(GetZipManager);
-};
-
-//This class is used to initialize GetZip manager
-//First tries to initialize GetZipManager from proprietary library,
-//if the library does not exist, creates GetZipManager
-//Note: In the current implementation of network stack all the actions
-//related to GetZipManager and GetZipFactory are carried out via IOThread
-//hence, the implementation is not synchronized (this might change in the future).
-class HttpGetZipFactory
-{
-
-public:
-
- //GetZipManager is kept within HttpGetZipFactory,
- //which is singleton.
- //This method is used to access the GetZipManager
- //Don't use it before initializing HttpGetZipFactory object.
- static IGetZipManager* GetGETZipManager();
-
- //Initialization must be called before accessing
- //GetZipManager for the first time.
- static void InitGETZipManager();
-
- void StopGETZipManager();
-
-private:
- IGetZipManager* m_pMngr;
- static HttpGetZipFactory* s_pFactory;
-
- void* libHandle;
-
- HttpGetZipFactory();
- ~HttpGetZipFactory();
-
- DISALLOW_COPY_AND_ASSIGN(HttpGetZipFactory);
-};
-
-}; //end network
-#endif /* HTTP_GETZIP_FACTORY_H_ */
diff --git a/net/http/http_network_layer.cc b/net/http/http_network_layer.cc
index 5e212b2..8253eac 100644
--- a/net/http/http_network_layer.cc
+++ b/net/http/http_network_layer.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -11,7 +10,6 @@
#include "base/string_util.h"
#include "net/http/http_network_session.h"
#include "net/http/http_network_transaction.h"
-#include "net/http/http_getzip_factory.h"
#include "net/spdy/spdy_framer.h"
#include "net/spdy/spdy_session.h"
#include "net/spdy/spdy_session_pool.h"
@@ -23,7 +21,6 @@ HttpNetworkLayer::HttpNetworkLayer(HttpNetworkSession* session)
: session_(session),
suspended_(false) {
DCHECK(session_.get());
- HttpGetZipFactory::InitGETZipManager();
}
HttpNetworkLayer::~HttpNetworkLayer() {
diff --git a/net/http/http_network_session.cc b/net/http/http_network_session.cc
index d36f22a..d13ec97 100644
--- a/net/http/http_network_session.cc
+++ b/net/http/http_network_session.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -40,8 +39,7 @@ HttpNetworkSession::HttpNetworkSession(const Params& params)
params.dns_cert_checker,
params.ssl_host_info_factory,
params.proxy_service,
- params.ssl_config_service,
- this),
+ params.ssl_config_service),
spdy_session_pool_(params.host_resolver, params.ssl_config_service),
ALLOW_THIS_IN_INITIALIZER_LIST(http_stream_factory_(
new HttpStreamFactoryImpl(this))) {
diff --git a/net/http/http_network_transaction.cc b/net/http/http_network_transaction.cc
index 7ef80f7..7f0ac4f 100644
--- a/net/http/http_network_transaction.cc
+++ b/net/http/http_network_transaction.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -55,7 +54,6 @@
#include "net/spdy/spdy_http_stream.h"
#include "net/spdy/spdy_session.h"
#include "net/spdy/spdy_session_pool.h"
-#include <cutils/log.h>
using base::Time;
@@ -247,17 +245,8 @@ int HttpNetworkTransaction::RestartWithAuth(
void HttpNetworkTransaction::PrepareForAuthRestart(HttpAuth::Target target) {
DCHECK(HaveAuth(target));
- PrepareForRetry(true);
-}
-
-void HttpNetworkTransaction::PrepareForGetZipRetry()
-{
- PrepareForRetry(false);
-}
-
-void HttpNetworkTransaction::PrepareForRetry(bool isForAuthentication)
-{
DCHECK(!stream_request_.get());
+
bool keep_alive = false;
// Even if the server says the connection is keep-alive, we have to be
// able to find the end of each response in order to reuse the connection.
@@ -265,10 +254,8 @@ void HttpNetworkTransaction::PrepareForRetry(bool isForAuthentication)
stream_->CanFindEndOfResponse()) {
// If the response body hasn't been completely read, we need to drain
// it first.
- // goes to drain body first!!!
if (!stream_->IsResponseBodyComplete()) {
- next_state_ = isForAuthentication ? STATE_DRAIN_BODY_FOR_AUTH_RESTART:
- STATE_DRAIN_BODY_FOR_GETZIP_RETRY;
+ next_state_ = STATE_DRAIN_BODY_FOR_AUTH_RESTART;
read_buf_ = new IOBuffer(kDrainBodyBufferSize); // A bit bucket.
read_buf_len_ = kDrainBodyBufferSize;
return;
@@ -278,58 +265,35 @@ void HttpNetworkTransaction::PrepareForRetry(bool isForAuthentication)
// We don't need to drain the response body, so we act as if we had drained
// the response body.
- isForAuthentication ?
- DidDrainBodyForAuthRestart(keep_alive):
- DidDrainBodyForGetZipRetry(keep_alive);
+ DidDrainBodyForAuthRestart(keep_alive);
}
-void HttpNetworkTransaction::DidDrainBodyForAuthRestart( bool keep_alive )
- {
-
- DidDrainBodyForRetry( keep_alive );
- // Reset the other member variables.
- ResetStateForAuthRestart();
- }
-
-void HttpNetworkTransaction::DidDrainBodyForGetZipRetry( bool keep_alive )
-{
- DidDrainBodyForRetry( keep_alive );
- read_buf_ = NULL;
- read_buf_len_ = 0;
- headers_valid_ = false;
- request_headers_.Clear();
- response_ = HttpResponseInfo();
-}
-
-void HttpNetworkTransaction::DidDrainBodyForRetry( bool keep_alive )
-{
- DCHECK( !stream_request_.get() );
+void HttpNetworkTransaction::DidDrainBodyForAuthRestart(bool keep_alive) {
+ DCHECK(!stream_request_.get());
- if ( stream_.get() )
- {
+ if (stream_.get()) {
HttpStream* new_stream = NULL;
- if ( keep_alive && stream_->IsConnectionReusable() )
- {
+ if (keep_alive && stream_->IsConnectionReusable()) {
// We should call connection_->set_idle_time(), but this doesn't occur
// often enough to be worth the trouble.
stream_->SetConnectionReused();
new_stream = stream_->RenewStreamForAuth();
}
- if ( !new_stream )
- {
+ if (!new_stream) {
// Close the stream and mark it as not_reusable. Even in the
// keep_alive case, we've determined that the stream_ is not
// reusable if new_stream is NULL.
- stream_->Close( true );
+ stream_->Close(true);
next_state_ = STATE_CREATE_STREAM;
- }
- else
- {
+ } else {
next_state_ = STATE_INIT_STREAM;
}
- stream_.reset( new_stream );
+ stream_.reset(new_stream);
}
+
+ // Reset the other member variables.
+ ResetStateForAuthRestart();
}
bool HttpNetworkTransaction::IsReadyToRestartForAuth() {
@@ -595,13 +559,6 @@ int HttpNetworkTransaction::DoLoop(int result) {
net_log_.EndEventWithNetErrorCode(
NetLog::TYPE_HTTP_TRANSACTION_READ_BODY, rv);
break;
- case STATE_DRAIN_BODY_FOR_GETZIP_RETRY:
- DCHECK_EQ(OK, rv);
- rv = DoDrainBodyForGetZipRetry();
- break;
- case STATE_DRAIN_BODY_FOR_GETZIP_RETRY_COMPLETE:
- rv = DoDrainBodyForGetZipRetryComplete(rv);
- break;
case STATE_DRAIN_BODY_FOR_AUTH_RESTART:
DCHECK_EQ(OK, rv);
net_log_.BeginEvent(
@@ -1006,28 +963,9 @@ int HttpNetworkTransaction::DoDrainBodyForAuthRestart() {
return rv;
}
-int HttpNetworkTransaction::DoDrainBodyForGetZipRetry() {
- int rv = DoReadBody();
- DCHECK(next_state_ == STATE_READ_BODY_COMPLETE);
- next_state_ = STATE_DRAIN_BODY_FOR_GETZIP_RETRY_COMPLETE;
- return rv;
-}
-
-int HttpNetworkTransaction::DoDrainBodyForGetZipRetryComplete(int result) {
- DoDrainBodyForRetryComplete( result, false );
- return OK;
-}
-
// TODO(wtc): This method and the DoReadBodyComplete method are almost
// the same. Figure out a good way for these two methods to share code.
int HttpNetworkTransaction::DoDrainBodyForAuthRestartComplete(int result) {
- DoDrainBodyForRetryComplete( result, true );
- return OK;
-}
-
-void HttpNetworkTransaction::DoDrainBodyForRetryComplete( int result,
- bool isForAuthentication )
-{
// keep_alive defaults to true because the very reason we're draining the
// response body is to reuse the connection for auth restart.
bool done = false, keep_alive = true;
@@ -1040,15 +978,13 @@ void HttpNetworkTransaction::DoDrainBodyForRetryComplete( int result,
}
if (done) {
- isForAuthentication ?
- DidDrainBodyForAuthRestart(keep_alive):
- DidDrainBodyForGetZipRetry(keep_alive);
+ DidDrainBodyForAuthRestart(keep_alive);
} else {
// Keep draining.
- next_state_ = isForAuthentication ?
- STATE_DRAIN_BODY_FOR_AUTH_RESTART :
- STATE_DRAIN_BODY_FOR_GETZIP_RETRY ;
+ next_state_ = STATE_DRAIN_BODY_FOR_AUTH_RESTART;
}
+
+ return OK;
}
void HttpNetworkTransaction::LogTransactionConnectedMetrics() {
@@ -1254,12 +1190,8 @@ int HttpNetworkTransaction::HandleIOError(int error) {
// cause SSL handshake errors to be delayed until the first or second Write
// (Snap Start) or the first Read (False & Snap Start) on the underlying
// connection.
- if(error != ERR_GETZIP)
- error = HandleSSLHandshakeError(error);
- else
- {
- SLOGD("%s:%s:: SHUTR protocol failure", __FILE__, __FUNCTION__);
- }
+ error = HandleSSLHandshakeError(error);
+
switch (error) {
// If we try to reuse a connection that the server is in the process of
// closing, we may end up successfully writing out our request (or a
@@ -1277,10 +1209,6 @@ int HttpNetworkTransaction::HandleIOError(int error) {
ResetConnectionAndRequestForResend();
error = OK;
break;
- case ERR_GETZIP:
- PrepareForGetZipRetry();
- error = OK;
- break;
}
return error;
}
@@ -1410,8 +1338,6 @@ std::string HttpNetworkTransaction::DescribeState(State state) {
STATE_CASE(STATE_READ_HEADERS_COMPLETE);
STATE_CASE(STATE_READ_BODY);
STATE_CASE(STATE_READ_BODY_COMPLETE);
- STATE_CASE(STATE_DRAIN_BODY_FOR_GETZIP_RETRY);
- STATE_CASE(STATE_DRAIN_BODY_FOR_GETZIP_RETRY_COMPLETE);
STATE_CASE(STATE_DRAIN_BODY_FOR_AUTH_RESTART);
STATE_CASE(STATE_DRAIN_BODY_FOR_AUTH_RESTART_COMPLETE);
STATE_CASE(STATE_NONE);
diff --git a/net/http/http_network_transaction.h b/net/http/http_network_transaction.h
index 7abfcf9..00e9a65 100644
--- a/net/http/http_network_transaction.h
+++ b/net/http/http_network_transaction.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -103,8 +102,6 @@ class HttpNetworkTransaction : public HttpTransaction,
STATE_READ_HEADERS_COMPLETE,
STATE_READ_BODY,
STATE_READ_BODY_COMPLETE,
- STATE_DRAIN_BODY_FOR_GETZIP_RETRY,
- STATE_DRAIN_BODY_FOR_GETZIP_RETRY_COMPLETE,
STATE_DRAIN_BODY_FOR_AUTH_RESTART,
STATE_DRAIN_BODY_FOR_AUTH_RESTART_COMPLETE,
STATE_NONE
@@ -140,9 +137,6 @@ class HttpNetworkTransaction : public HttpTransaction,
int DoReadBodyComplete(int result);
int DoDrainBodyForAuthRestart();
int DoDrainBodyForAuthRestartComplete(int result);
- int DoDrainBodyForGetZipRetry();
- int DoDrainBodyForGetZipRetryComplete(int result);
- void DoDrainBodyForRetryComplete( int result, bool isForAuthentication );
void BuildRequestHeaders(bool using_proxy);
@@ -188,28 +182,10 @@ class HttpNetworkTransaction : public HttpTransaction,
// Sets up the state machine to restart the transaction with auth.
void PrepareForAuthRestart(HttpAuth::Target target);
- // Sets up the state machine to restart the transaction if
- // GETzip error occurred.
- void PrepareForGetZipRetry();
-
- // Sets up the state machine to restart the transaction.
- void PrepareForRetry(bool isForAuthentication);
-
// Called when we don't need to drain the response body or have drained it.
- // Clears request info for transaction restart for auth.
- // Uses DidDrainBodyForRetry to reset connection if needed and to
- // set next_state_
- void DidDrainBodyForAuthRestart(bool keep_alive);
-
- // Called when we don't need to drain the response body or have drained it.
- // Clears request info for transaction retry caused by GETzip error.
- // Uses DidDrainBodyForRetry to reset connection if needed and to
- // set next_state_
- void DidDrainBodyForGetZipRetry(bool keep_alive);
-
// Resets |connection_| unless |keep_alive| is true, then calls
// ResetStateForRestart. Sets |next_state_| appropriately.
- void DidDrainBodyForRetry( bool keep_alive );
+ void DidDrainBodyForAuthRestart(bool keep_alive);
// Resets the members of the transaction so it can be restarted.
void ResetStateForRestart();
diff --git a/net/http/http_proxy_client_socket_pool.cc b/net/http/http_proxy_client_socket_pool.cc
index 94a51e1..c28d0e6 100644
--- a/net/http/http_proxy_client_socket_pool.cc
+++ b/net/http/http_proxy_client_socket_pool.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -426,8 +425,7 @@ HttpProxyClientSocketPool::HttpProxyClientSocketPool(
HostResolver* host_resolver,
TransportClientSocketPool* transport_pool,
SSLClientSocketPool* ssl_pool,
- NetLog* net_log,
- HttpNetworkSession *network_session)
+ NetLog* net_log)
: transport_pool_(transport_pool),
ssl_pool_(ssl_pool),
base_(max_sockets, max_sockets_per_group, histograms,
@@ -437,8 +435,7 @@ HttpProxyClientSocketPool::HttpProxyClientSocketPool(
new HttpProxyConnectJobFactory(transport_pool,
ssl_pool,
host_resolver,
- net_log),
- network_session) {}
+ net_log)) {}
HttpProxyClientSocketPool::~HttpProxyClientSocketPool() {}
diff --git a/net/http/http_proxy_client_socket_pool.h b/net/http/http_proxy_client_socket_pool.h
index c539ede..2ab331e 100644
--- a/net/http/http_proxy_client_socket_pool.h
+++ b/net/http/http_proxy_client_socket_pool.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -32,7 +31,6 @@ class SpdySessionPool;
class SpdyStream;
class TransportClientSocketPool;
class TransportSocketParams;
-class HttpNetworkSession;
// HttpProxySocketParams only needs the socket params for one of the proxy
// types. The other param must be NULL. When using an HTTP Proxy,
@@ -181,8 +179,7 @@ class HttpProxyClientSocketPool : public ClientSocketPool {
HostResolver* host_resolver,
TransportClientSocketPool* transport_pool,
SSLClientSocketPool* ssl_pool,
- NetLog* net_log,
- HttpNetworkSession *network_session);
+ NetLog* net_log);
virtual ~HttpProxyClientSocketPool();
diff --git a/net/http/http_request_headers.cc b/net/http/http_request_headers.cc
index 9cb3a83..9d523c1 100644
--- a/net/http/http_request_headers.cc
+++ b/net/http/http_request_headers.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -13,7 +12,6 @@
namespace net {
const char HttpRequestHeaders::kGetMethod[] = "GET";
-const char HttpRequestHeaders::kHeadMethod[] = "HEAD";
const char HttpRequestHeaders::kAcceptCharset[] = "Accept-Charset";
const char HttpRequestHeaders::kAcceptEncoding[] = "Accept-Encoding";
const char HttpRequestHeaders::kAcceptLanguage[] = "Accept-Language";
diff --git a/net/http/http_request_headers.h b/net/http/http_request_headers.h
index e130ab1..d574ae4 100644
--- a/net/http/http_request_headers.h
+++ b/net/http/http_request_headers.h
@@ -1,5 +1,4 @@
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
//
@@ -56,7 +55,6 @@ class NET_EXPORT HttpRequestHeaders {
};
static const char kGetMethod[];
- static const char kHeadMethod[];
static const char kAcceptCharset[];
static const char kAcceptEncoding[];
diff --git a/net/http/http_stream_parser.cc b/net/http/http_stream_parser.cc
index 5d0d9ed..0649bce 100644
--- a/net/http/http_stream_parser.cc
+++ b/net/http/http_stream_parser.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -19,15 +18,13 @@
#include "net/http/http_util.h"
#include "net/socket/ssl_client_socket.h"
#include "net/socket/client_socket_handle.h"
-#include "net/http/http_getzip_factory.h"
namespace net {
HttpStreamParser::HttpStreamParser(ClientSocketHandle* connection,
const HttpRequestInfo* request,
GrowableIOBuffer* read_buffer,
- const BoundNetLog& net_log,
- bool using_proxy)
+ const BoundNetLog& net_log)
: io_state_(STATE_NONE),
request_(request),
request_headers_(NULL),
@@ -47,10 +44,7 @@ HttpStreamParser::HttpStreamParser(ClientSocketHandle* connection,
io_callback_(this, &HttpStreamParser::OnIOComplete)),
chunk_length_(0),
chunk_length_without_encoding_(0),
- sent_last_chunk_(false),
- using_proxy_(using_proxy),
- has_to_retry_(false){
-
+ sent_last_chunk_(false) {
DCHECK_EQ(0, read_buffer->offset());
}
@@ -68,7 +62,7 @@ int HttpStreamParser::SendRequest(const std::string& request_line,
DCHECK(!user_callback_);
DCHECK(callback);
DCHECK(response);
- has_to_retry_ = false;
+
if (net_log_.IsLoggingAllEvents()) {
net_log_.AddEvent(
NetLog::TYPE_HTTP_TRANSACTION_SEND_REQUEST_HEADERS,
@@ -84,15 +78,6 @@ int HttpStreamParser::SendRequest(const std::string& request_line,
return result;
response_->socket_address = HostPortPair::FromAddrInfo(address.head());
- //Shutr only for GET/HEAD requests
- if((!(using_proxy_)) && ((request_line.find(HttpRequestHeaders::kGetMethod) == 0) ||
- (request_line.find(HttpRequestHeaders::kHeadMethod) == 0)))
- {
- HttpGetZipFactory::GetGETZipManager()->CompressRequestHeaders(
- const_cast<HttpRequestHeaders &>(headers),
- connection_->socket());
- }
-
std::string request = request_line + headers.ToString();
scoped_refptr<StringIOBuffer> headers_io_buf(new StringIOBuffer(request));
request_headers_ = new DrainableIOBuffer(headers_io_buf,
@@ -176,11 +161,6 @@ void HttpStreamParser::OnIOComplete(int result) {
if (result != ERR_IO_PENDING && user_callback_) {
CompletionCallback* c = user_callback_;
user_callback_ = NULL;
- if(has_to_retry_ )
- {
- result = ERR_GETZIP;
- has_to_retry_ = false;
- }
c->Run(result);
}
}
@@ -221,19 +201,8 @@ int HttpStreamParser::DoLoop(int result) {
break;
case STATE_READ_HEADERS_COMPLETE:
result = DoReadHeadersComplete(result);
- if(!using_proxy_)
- {
- GETZipDecompressionStatus st =
- HttpGetZipFactory::GetGETZipManager()->DecompressResponseHeaders(
- response_->headers.get(),
- connection_->socket());
- if( st == REQUEST_RETRY_NEEDED )
- {
- has_to_retry_ = true;
- }
- }
net_log_.EndEventWithNetErrorCode(
- NetLog::TYPE_HTTP_STREAM_PARSER_READ_HEADERS, result);
+ NetLog::TYPE_HTTP_STREAM_PARSER_READ_HEADERS, result);
break;
case STATE_BODY_PENDING:
DCHECK(result != ERR_IO_PENDING);
diff --git a/net/http/http_stream_parser.h b/net/http/http_stream_parser.h
index fa3e6fc..2192eff 100644
--- a/net/http/http_stream_parser.h
+++ b/net/http/http_stream_parser.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -37,9 +36,7 @@ class HttpStreamParser : public ChunkCallback {
HttpStreamParser(ClientSocketHandle* connection,
const HttpRequestInfo* request,
GrowableIOBuffer* read_buffer,
- const BoundNetLog& net_log,
- bool using_proxy = false);
-
+ const BoundNetLog& net_log);
~HttpStreamParser();
// These functions implement the interface described in HttpStream with
@@ -189,10 +186,6 @@ class HttpStreamParser : public ChunkCallback {
// The underlying socket.
ClientSocketHandle* const connection_;
- bool using_proxy_;
-
- bool has_to_retry_;
-
BoundNetLog net_log_;
// Callback to be used when doing IO.
diff --git a/net/http/net-plugin-bridge-exports.h b/net/http/net-plugin-bridge-exports.h
deleted file mode 100644
index 773602a..0000000
--- a/net/http/net-plugin-bridge-exports.h
+++ /dev/null
@@ -1,44 +0,0 @@
-/*
-* Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-*
-* Redistribution and use in source and binary forms, with or without
-* modification, are permitted provided that the following conditions are
-* met:
-* * Redistributions of source code must retain the above copyright
-* notice, this list of conditions and the following disclaimer.
-* * Redistributions in binary form must reproduce the above
-* copyright notice, this list of conditions and the following
-* disclaimer in the documentation and/or other materials provided
-* with the distribution.
-* * Neither the name of Code Aurora Forum, Inc. nor the names of its
-* contributors may be used to endorse or promote products derived
-* from this software without specific prior written permission.
-*
-* THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-* BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-* OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-* IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-*/
-
-// API for the network plug-in
-#ifndef NET_HTTP_NET_PLUGIN_BRIDGE_EXPORTS_H_
-#define NET_HTTP_NET_PLUGIN_BRIDGE_EXPORTS_H_
-
-// export these functions from libwebcore, may be used by the plug-in
-extern bool HeadersIsRedirect(const net::HttpResponseHeaders* h, std::string& s)
- __attribute__ ((visibility ("default"), used));
-extern GURL GurlResolveOrigin(const net::HttpRequestInfo* req, std::string& s)
- __attribute__ ((visibility ("default"), used));
-extern GURL GurlOrigin(const net::HttpRequestInfo* req)
- __attribute__ ((visibility ("default"), used));
-extern void NetPreconnect(net::HttpNetworkSession*, GURL const&)
- __attribute__ ((visibility ("default"), used));
-
-#endif /* NET_HTTP_NET_PLUGIN_BRIDGE_EXPORTS_H_ */
diff --git a/net/http/net-plugin-bridge.cc b/net/http/net-plugin-bridge.cc
deleted file mode 100644
index 42019ca..0000000
--- a/net/http/net-plugin-bridge.cc
+++ /dev/null
@@ -1,95 +0,0 @@
-/*
-* Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
-*
-* Redistribution and use in source and binary forms, with or without
-* modification, are permitted provided that the following conditions are
-* met:
-* * Redistributions of source code must retain the above copyright
-* notice, this list of conditions and the following disclaimer.
-* * Redistributions in binary form must reproduce the above
-* copyright notice, this list of conditions and the following
-* disclaimer in the documentation and/or other materials provided
-* with the distribution.
-* * Neither the name of Code Aurora Forum, Inc. nor the names of its
-* contributors may be used to endorse or promote products derived
-* from this software without specific prior written permission.
-*
-* THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-* BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-* OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-* IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-*/
-
-#include "net/http/http_cache_transaction.h"
-
-#include "build/build_config.h"
-
-#include <unistd.h>
-
-#include <string>
-
-#include "base/compiler_specific.h"
-#include "net/http/http_response_headers.h"
-#include "net/http/preconnect.h"
-
-#include "net/http/net-plugin-bridge.h"
-#include "net/http/net-plugin-bridge-exports.h"
-#include <dlfcn.h>
-#include <cutils/log.h>
-
-static void (*DoObserveRevalidation)(const net::HttpResponseInfo* resp,
- const net::HttpRequestInfo* req, net::HttpCache* cache) = NULL;
-
-static void InitOnce() {
- static bool initialized = false;
- if (!initialized) {
- initialized = true;
- void* fh = dlopen("qnet-plugin.so", RTLD_LAZY);
- if (fh) {
- const char *error;
-
- dlerror(); //see man dlopen
- *(void **)(&DoObserveRevalidation) = dlsym(fh, "DoObserveRevalidation");
- if (NULL != (error = dlerror())) {
- DoObserveRevalidation = NULL;
- }
- }
- if (NULL == DoObserveRevalidation) {
- SLOGD("Failed to load DoObserveRevalidation symbol in qnet-plugin.so");
- }
- }
-}
-
-void ObserveRevalidation(const net::HttpResponseInfo* resp,
- const net::HttpRequestInfo* req, net::HttpCache* cache) {
- InitOnce();
- if (DoObserveRevalidation) {
- DoObserveRevalidation(resp, req, cache);
- }
-}
-
-
-bool HeadersIsRedirect(const net::HttpResponseHeaders* headers,
- std::string& location) {
- return headers->IsRedirect(&location);
-}
-
-GURL GurlResolveOrigin(const net::HttpRequestInfo* req,
- std::string& location) {
- return req->url.Resolve(location).GetOrigin();
-}
-
-GURL GurlOrigin(const net::HttpRequestInfo* req) {
- return req->url.GetOrigin();
-}
-
-void NetPreconnect(net::HttpNetworkSession* session, GURL const& url) {
- net::Preconnect::DoPreconnect(session, url);
-}
diff --git a/net/http/net-plugin-bridge.h b/net/http/net-plugin-bridge.h
deleted file mode 100644
index 09f45e9..0000000
--- a/net/http/net-plugin-bridge.h
+++ /dev/null
@@ -1,37 +0,0 @@
-/*
-* Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-*
-* Redistribution and use in source and binary forms, with or without
-* modification, are permitted provided that the following conditions are
-* met:
-* * Redistributions of source code must retain the above copyright
-* notice, this list of conditions and the following disclaimer.
-* * Redistributions in binary form must reproduce the above
-* copyright notice, this list of conditions and the following
-* disclaimer in the documentation and/or other materials provided
-* with the distribution.
-* * Neither the name of Code Aurora Forum, Inc. nor the names of its
-* contributors may be used to endorse or promote products derived
-* from this software without specific prior written permission.
-*
-* THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-* BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-* WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-* OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-* IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-*/
-
-#ifndef NET_HTTP_NET_PLUGIN_BRIDGE_H_
-#define NET_HTTP_NET_PLUGIN_BRIDGE_H_
-
-// revalidated cache entries observer
-extern void ObserveRevalidation(const net::HttpResponseInfo* resp,
- const net::HttpRequestInfo* req, net::HttpCache* cache);
-
-#endif /* NET_HTTP_NET_PLUGIN_BRIDGE_H_ */
diff --git a/net/http/preconnect.cc b/net/http/preconnect.cc
deleted file mode 100644
index 929b627..0000000
--- a/net/http/preconnect.cc
+++ /dev/null
@@ -1,70 +0,0 @@
-// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. 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/http/preconnect.h"
-
-#include "base/logging.h"
-#include "net/proxy/proxy_info.h"
-#include "net/http/http_stream_factory.h"
-#include "net/http/http_network_session.h"
-
-namespace net {
-
-
-// static
-void Preconnect::DoPreconnect(HttpNetworkSession* session,
- const GURL& url, int count,
- HttpRequestInfo::RequestMotivation motivation ) {
- Preconnect* preconnect = new Preconnect(session);
- preconnect->Connect(url, count, motivation);
-}
-
-Preconnect::Preconnect(HttpNetworkSession* session)
- : session_(session),
- ALLOW_THIS_IN_INITIALIZER_LIST(
- io_callback_(this, &Preconnect::OnPreconnectComplete)) {}
-
-Preconnect::~Preconnect() {}
-
-void Preconnect::Connect(const GURL& url, int count,
- HttpRequestInfo::RequestMotivation motivation) {
-
- request_info_.reset(new HttpRequestInfo());
- request_info_->url = url;
- request_info_->method = "GET";
- // It almost doesn't matter whether we use net::LOWEST or net::HIGHEST
- // priority here, as we won't make a request, and will surrender the created
- // socket to the pool as soon as we can. However, we would like to mark the
- // speculative socket as such, and IF we use a net::LOWEST priority, and if
- // a navigation asked for a socket (after us) then it would get our socket,
- // and we'd get its later-arriving socket, which might make us record that
- // the speculation didn't help :-/. By using net::HIGHEST, we ensure that
- // a socket is given to us if "we asked first" and this allows us to mark it
- // as speculative, and better detect stats (if it gets used).
- // TODO(jar): histogram to see how often we accidentally use a previously-
- // unused socket, when a previously used socket was available.
- request_info_->priority = HIGHEST;
- request_info_->motivation = motivation;
-
- // Setup the SSL Configuration.
- ssl_config_.reset(new SSLConfig());
- session_->ssl_config_service()->GetSSLConfig(ssl_config_.get());
- if (session_->http_stream_factory()->next_protos())
- ssl_config_->next_protos = *session_->http_stream_factory()->next_protos();
-
- // All preconnects should perform EV certificate verification.
- ssl_config_->verify_ev_cert = true;
-
- proxy_info_.reset(new ProxyInfo());
- HttpStreamFactory* stream_factory = session_->http_stream_factory();
- stream_factory->PreconnectStreams(count, *(request_info_.get()),
- *(ssl_config_.get()), net_log_);
-}
-
-void Preconnect::OnPreconnectComplete(int error_code) {
- delete this;
-}
-
-} // namespace net
diff --git a/net/http/preconnect.h b/net/http/preconnect.h
deleted file mode 100644
index e7e1914..0000000
--- a/net/http/preconnect.h
+++ /dev/null
@@ -1,66 +0,0 @@
-// Copyright (c) 2006-2010 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.
-
-// A Preconnect instance maintains state while a TCP/IP connection is made, and
-// and then released into the pool of available connections for future use.
-
-#ifndef NET_HTTP_PRECONNECT_H__
-#define NET_HTTP_PRECONNECT_H__
-#pragma once
-
-#include "base/scoped_ptr.h"
-#include "net/base/completion_callback.h"
-#include "net/base/net_log.h"
-#include "net/http/http_request_info.h"
-#include "net/http/http_stream_factory.h"
-
-namespace net {
-
-class ProxyInfo;
-struct SSLConfig;
-
-class Preconnect {
- public:
- // Try to preconnect. Typically used by predictor when a subresource probably
- // needs a connection. |count| may be used to request more than one connection
- // be established in parallel.
- static void DoPreconnect(HttpNetworkSession* session, const GURL& url,
- int count = 1, HttpRequestInfo::RequestMotivation motivation =
- HttpRequestInfo::PRECONNECT_MOTIVATED);
-
- private:
- explicit Preconnect(HttpNetworkSession* session);
- virtual ~Preconnect();
-
- void OnPreconnectComplete(int error_code);
-
- // Request actual connection, via interface that tags request as needed for
- // preconnect only (so that they can be merged with connections needed for
- // navigations).
- void Connect(const GURL& url, int count,
- HttpRequestInfo::RequestMotivation motivation);
-
- HttpNetworkSession * session_;
- // HttpRequestInfo used for connecting.
- scoped_ptr<HttpRequestInfo> request_info_;
-
- // SSLConfig used for connecting.
- scoped_ptr<SSLConfig> ssl_config_;
-
- // ProxyInfo used for connecting.
- scoped_ptr<ProxyInfo> proxy_info_;
-
- // A net log to use for this preconnect.
- BoundNetLog net_log_;
-
- // Our preconnect.
- scoped_ptr<HttpStreamRequest> stream_request_;
-
- CompletionCallbackImpl<Preconnect> io_callback_;
-
- DISALLOW_COPY_AND_ASSIGN(Preconnect);
-};
-} // namespace net
-#endif // NET_HTTP_HTTP_REQUEST_INFO_H__
-
diff --git a/net/http/tcp-connections-bridge-exports.h b/net/http/tcp-connections-bridge-exports.h
deleted file mode 100644
index 3d873cd..0000000
--- a/net/http/tcp-connections-bridge-exports.h
+++ /dev/null
@@ -1,39 +0,0 @@
-/*
- * Copyright (C) 2011, Code Aurora Forum. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other materials provided
- * with the distribution.
- * * Neither the name of Code Aurora Forum, Inc. nor the names of its
- * contributors may be used to endorse or promote products derived
- * from this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- *
- */
-
-// API for the network plug-in
-#ifndef NET_HTTP_TCP_CONNECTIONS_BRIDGE_EXPORTS_H_
-#define NET_HTTP_TCP_CONNECTIONS_BRIDGE_EXPORTS_H_
-
-// export these functions from libwebcore, may be used by the plug-in
-extern void NetPreconnect(net::HttpNetworkSession*, GURL const&, int numOfConnections)
- __attribute__ ((visibility ("default"), used));
-
-#endif /* NET_HTTP_NET_PLUGIN_BRIDGE_EXPORTS_H_ */
diff --git a/net/http/tcp-connections-bridge.cc b/net/http/tcp-connections-bridge.cc
deleted file mode 100644
index 3201b3d..0000000
--- a/net/http/tcp-connections-bridge.cc
+++ /dev/null
@@ -1,79 +0,0 @@
-/*
- * Copyright (C) 2011, 2012 Code Aurora Forum. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other materials provided
- * with the distribution.
- * * Neither the name of Code Aurora Forum, Inc. nor the names of its
- * contributors may be used to endorse or promote products derived
- * from this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- *
- */
-
-#include "build/build_config.h"
-
-#include <unistd.h>
-
-#include <string>
-
-#include "base/compiler_specific.h"
-#include "net/http/http_response_headers.h"
-#include "net/http/preconnect.h"
-
-#include "net/http/tcp-connections-bridge.h"
-#include "net/http/tcp-connections-bridge-exports.h"
-#include "net/http/http_network_session.h"
-#include <dlfcn.h>
-#include <cutils/log.h>
-
-static void (*DoObserveConnections)(
- net::HttpNetworkSession* session,
- const GURL& url) = NULL;
-
-static void InitOnce() {
- static bool initialized = false;
- if (!initialized) {
- initialized = true;
- void* fh = dlopen("tcp-connections.so", RTLD_LAZY);
- if (fh) {
- dlerror(); //see man dlopen
- *(void **)(&DoObserveConnections) = dlsym(fh, "DoObserveConnections");
- }
- if (NULL == DoObserveConnections) {
- SLOGD("Failed to load DoObserveConnections symbol in tcp-connections.so");
- }
- }
-}
-
-void ObserveConnections(
- net::HttpNetworkSession *session,
- const GURL& url
-)
-{
- InitOnce();
- if (DoObserveConnections) {
- DoObserveConnections(session, url);
- }
-}
-
-void NetPreconnect(net::HttpNetworkSession* session, GURL const& url, int numOfConnections) {
- net::Preconnect::DoPreconnect(session, url, numOfConnections);
-}
diff --git a/net/http/tcp-connections-bridge.h b/net/http/tcp-connections-bridge.h
deleted file mode 100644
index 94f5501..0000000
--- a/net/http/tcp-connections-bridge.h
+++ /dev/null
@@ -1,41 +0,0 @@
-/*
- * Copyright (C) 2011, Code Aurora Forum. All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are
- * met:
- * * Redistributions of source code must retain the above copyright
- * notice, this list of conditions and the following disclaimer.
- * * Redistributions in binary form must reproduce the above
- * copyright notice, this list of conditions and the following
- * disclaimer in the documentation and/or other materials provided
- * with the distribution.
- * * Neither the name of Code Aurora Forum, Inc. nor the names of its
- * contributors may be used to endorse or promote products derived
- * from this software without specific prior written permission.
- *
- * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
- * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
- * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
- * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
- * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
- * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
- * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
- * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- *
- */
-
-#ifndef NET_HTTP_TCP_CONNECTIONS_BRIDGE_H_
-#define NET_HTTP_TCP_CONNECTIONS_BRIDGE_H_
-
-// revalidated cache entries observer
-extern void ObserveConnections
-(
- net::HttpNetworkSession *session,
- const GURL& url
-);
-
-#endif /* NET_HTTP_NET_PLUGIN_BRIDGE_H_ */
diff --git a/net/socket/client_socket_pool_base.cc b/net/socket/client_socket_pool_base.cc
index f0d9c2c..46cfc45 100644
--- a/net/socket/client_socket_pool_base.cc
+++ b/net/socket/client_socket_pool_base.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011,2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -16,15 +15,6 @@
#include "net/base/net_log.h"
#include "net/base/net_errors.h"
#include "net/socket/client_socket_handle.h"
-#include "net/http/http_network_session.h"
-#include "net/http/preconnect.h"
-#include "net/http/tcp-connections-bridge.h"
-#include "googleurl/src/gurl.h"
-#include <cutils/properties.h>
-#include <cutils/log.h>
-
-// Define Log Tag for this source file.
-#define LOG_TAG "Socket_Pool"
using base::TimeDelta;
@@ -44,23 +34,12 @@ bool g_cleanup_timer_enabled = true;
// Note: It's important to close idle sockets that have received data as soon
// as possible because the received data may cause BSOD on Windows XP under
// some conditions. See http://crbug.com/4606.
-int kCleanupInterval = 2; // DO NOT INCREASE THIS TIMEOUT.
+const int kCleanupInterval = 10; // DO NOT INCREASE THIS TIMEOUT.
// Indicate whether or not we should establish a new transport layer connection
// after a certain timeout has passed without receiving an ACK.
bool g_connect_backup_jobs_enabled = true;
-// Indicate whether or not we should close the unused sockets in the next run
-// of the reaper cleanup thread.
-bool g_close_unused_sockets = false;
-
-// Called to inform that we should close the unused sockets that resides in
-// the idle pool.
-extern "C" void SetCloseUnUsedSocketsFlag()
-{
- g_close_unused_sockets = true;
-}
-
} // namespace
namespace net {
@@ -187,8 +166,7 @@ ClientSocketPoolBaseHelper::ClientSocketPoolBaseHelper(
int max_sockets_per_group,
base::TimeDelta unused_idle_socket_timeout,
base::TimeDelta used_idle_socket_timeout,
- ConnectJobFactory* connect_job_factory,
- HttpNetworkSession *network_session)
+ ConnectJobFactory* connect_job_factory)
: idle_socket_count_(0),
connecting_socket_count_(0),
handed_out_socket_count_(0),
@@ -205,31 +183,6 @@ ClientSocketPoolBaseHelper::ClientSocketPoolBaseHelper(
DCHECK_LE(max_sockets_per_group, max_sockets);
NetworkChangeNotifier::AddIPAddressObserver(this);
-
- network_session_ = network_session;
-
- tcp_fin_aggregation = net::TCPFinAggregationFactory::GetTCPFinFactoryInstance(this)->GetTCPFinAggregation();
- if (NULL == tcp_fin_aggregation) {
- SLOGD("Failed to create TCP Fin Aggregation interface.");
- } else {
- int new_cleanup_interval = tcp_fin_aggregation->GetCleanupInterval(kCleanupInterval);
- kCleanupInterval = new_cleanup_interval;
- }
-
- close_unused_sockets_enabled = false;
- char netCloseUnusedSocketsSystemProperty[PROPERTY_VALUE_MAX];
- if(property_get("net.close.unused.sockets",
- netCloseUnusedSocketsSystemProperty, "1")) {
- close_unused_sockets_enabled = (bool)atoi(netCloseUnusedSocketsSystemProperty);
- }
- SLOGD("netstack: CloseUnusedSockets is %s", close_unused_sockets_enabled?"ON":"OFF");
-
- char net_statistics_enabled_sys_property[PROPERTY_VALUE_MAX];
- if(property_get("net.statistics",
- net_statistics_enabled_sys_property, "0")) {
- net_statistics_enabled = (bool)atoi(net_statistics_enabled_sys_property);
- SLOGD("netstack: system net.statistics value: %d", net_statistics_enabled);
- }
}
ClientSocketPoolBaseHelper::~ClientSocketPoolBaseHelper() {
@@ -276,9 +229,8 @@ int ClientSocketPoolBaseHelper::RequestSocket(
CHECK(request->handle());
// Cleanup any timed-out idle sockets if no timer is used.
- if ((!use_cleanup_timer_) && ((NULL == tcp_fin_aggregation) || (((NULL != tcp_fin_aggregation) && !tcp_fin_aggregation->IsEnabled())))) {
+ if (!use_cleanup_timer_)
CleanupIdleSockets(false);
- }
request->net_log().BeginEvent(NetLog::TYPE_SOCKET_POOL, NULL);
Group* group = GetOrCreateGroup(group_name);
@@ -290,9 +242,6 @@ int ClientSocketPoolBaseHelper::RequestSocket(
delete request;
} else {
InsertRequestIntoQueue(request, group->mutable_pending_requests());
- if (net_statistics_enabled) {
- SLOGD("insertRequestToQueue Host = %s Size = %d", group_name.c_str(), group->mutable_pending_requests()->size());
- }
}
return rv;
}
@@ -305,9 +254,8 @@ void ClientSocketPoolBaseHelper::RequestSockets(
DCHECK(!request.handle());
// Cleanup any timed out idle sockets if no timer is used.
- if ((!use_cleanup_timer_) && ((NULL == tcp_fin_aggregation) || (((NULL != tcp_fin_aggregation) && !tcp_fin_aggregation->IsEnabled())))) {
+ if (!use_cleanup_timer_)
CleanupIdleSockets(false);
- }
if (num_sockets > max_sockets_per_group_) {
num_sockets = max_sockets_per_group_;
@@ -325,7 +273,7 @@ void ClientSocketPoolBaseHelper::RequestSockets(
int rv = OK;
for (int num_iterations_left = num_sockets;
- group->NumActiveSocketSlots() <= num_sockets &&
+ group->NumActiveSocketSlots() < num_sockets &&
num_iterations_left > 0 ; num_iterations_left--) {
rv = RequestSocketInternal(group_name, &request);
if (rv < 0 && rv != ERR_IO_PENDING) {
@@ -434,20 +382,6 @@ int ClientSocketPoolBaseHelper::RequestSocketInternal(
}
}
- if (!preconnecting) {
- std::string url;
- const int ssl_sockets_groupname_prefix_length_ = 4;
- if (0 == group_name.compare(0, ssl_sockets_groupname_prefix_length_ , "ssl/")) {
- url.append("https://");
- }else {
- url.append("http://");
- }
- url.append(group_name);
- GURL gurl = GURL(url);
-
- ObserveConnections(network_session_, gurl);
- }
-
return rv;
}
@@ -486,7 +420,7 @@ bool ClientSocketPoolBaseHelper::AssignIdleSocketToGroup(
if (idle_socket_it != idle_sockets->end()) {
DecrementIdleCount();
base::TimeDelta idle_time =
- base::Time::Now() - idle_socket_it->start_time;
+ base::TimeTicks::Now() - idle_socket_it->start_time;
IdleSocket idle_socket = *idle_socket_it;
idle_sockets->erase(idle_socket_it);
HandOutSocket(
@@ -537,9 +471,6 @@ void ClientSocketPoolBaseHelper::CancelRequest(
scoped_ptr<const Request> req(RemoveRequestFromQueue(it, group));
req->net_log().AddEvent(NetLog::TYPE_CANCELLED, NULL);
req->net_log().EndEvent(NetLog::TYPE_SOCKET_POOL, NULL);
- if (net_statistics_enabled) {
- SLOGD("removeRequestFromQueue Host = %s Size = %d", group_name.c_str(), group->mutable_pending_requests()->size());
- }
// We let the job run, unless we're at the socket limit.
if (group->jobs().size() && ReachedMaxSocketsLimit()) {
@@ -664,8 +595,8 @@ DictionaryValue* ClientSocketPoolBaseHelper::GetInfoAsValue(
return dict;
}
-bool IdleSocket::ShouldCleanup(
- base::Time now,
+bool ClientSocketPoolBaseHelper::IdleSocket::ShouldCleanup(
+ base::TimeTicks now,
base::TimeDelta timeout) const {
bool timed_out = (now - start_time) >= timeout;
if (timed_out)
@@ -676,13 +607,12 @@ bool IdleSocket::ShouldCleanup(
}
void ClientSocketPoolBaseHelper::CleanupIdleSockets(bool force) {
- if (idle_socket_count_ == 0) {
+ if (idle_socket_count_ == 0)
return;
- }
// Current time value. Retrieving it once at the function start rather than
// inside the inner loop, since it shouldn't change by any meaningful amount.
- base::Time now = base::Time::Now();
+ base::TimeTicks now = base::TimeTicks::Now();
GroupMap::iterator i = group_map_.begin();
while (i != group_map_.end()) {
@@ -693,8 +623,7 @@ void ClientSocketPoolBaseHelper::CleanupIdleSockets(bool force) {
base::TimeDelta timeout =
j->socket->WasEverUsed() ?
used_idle_socket_timeout_ : unused_idle_socket_timeout_;
- if (force || j->ShouldCleanup(now, timeout) ||
- ((true == close_unused_sockets_enabled) && (true == g_close_unused_sockets) && !j->socket->WasEverUsed())) {
+ if (force || j->ShouldCleanup(now, timeout)) {
delete j->socket;
j = group->mutable_idle_sockets()->erase(j);
DecrementIdleCount();
@@ -756,21 +685,8 @@ void ClientSocketPoolBaseHelper::IncrementIdleCount() {
}
void ClientSocketPoolBaseHelper::DecrementIdleCount() {
- if (--idle_socket_count_ == 0) {
+ if (--idle_socket_count_ == 0)
timer_.Stop();
- }
-}
-
-void ClientSocketPoolBaseHelper::OnCleanupTimerFired()
-{
- if((NULL != tcp_fin_aggregation) &&
- (tcp_fin_aggregation->IsEnabled())) {
- tcp_fin_aggregation->ReaperCleanup(g_close_unused_sockets);
- }
- else {
- CleanupIdleSockets(false);
- }
- g_close_unused_sockets = false;
}
// static
@@ -898,9 +814,6 @@ void ClientSocketPoolBaseHelper::OnConnectJobComplete(
base::TimeDelta(), group, r->net_log());
r->net_log().EndEvent(NetLog::TYPE_SOCKET_POOL, NULL);
InvokeUserCallbackLater(r->handle(), r->callback(), result);
- if (net_statistics_enabled) {
- SLOGD("removeRequestFromQueue Host = %s Size = %d", group_name.c_str(), group->mutable_pending_requests()->size());
- }
} else {
AddIdleSocket(socket.release(), group);
OnAvailableSocketSlot(group_name, group);
@@ -924,9 +837,6 @@ void ClientSocketPoolBaseHelper::OnConnectJobComplete(
r->net_log().EndEventWithNetErrorCode(NetLog::TYPE_SOCKET_POOL,
result);
InvokeUserCallbackLater(r->handle(), r->callback(), result);
- if (net_statistics_enabled) {
- SLOGD("removeRequestFromQueue Host = %s Size = %d", group_name.c_str(), group->mutable_pending_requests()->size());
- }
} else {
RemoveConnectJob(job, group);
}
@@ -987,9 +897,6 @@ void ClientSocketPoolBaseHelper::ProcessPendingRequest(
request->net_log().EndEventWithNetErrorCode(NetLog::TYPE_SOCKET_POOL, rv);
InvokeUserCallbackLater(request->handle(), request->callback(), rv);
- if (net_statistics_enabled) {
- SLOGD("removeRequestFromQueue Host = %s Size = %d", group_name.c_str(), group->mutable_pending_requests()->size());
- }
}
}
@@ -1026,7 +933,7 @@ void ClientSocketPoolBaseHelper::AddIdleSocket(
DCHECK(socket);
IdleSocket idle_socket;
idle_socket.socket = socket;
- idle_socket.start_time = base::Time::Now();
+ idle_socket.start_time = base::TimeTicks::Now();
group->mutable_idle_sockets()->push_back(idle_socket);
IncrementIdleCount();
diff --git a/net/socket/client_socket_pool_base.h b/net/socket/client_socket_pool_base.h
index ce759a0..bd30a8b 100644
--- a/net/socket/client_socket_pool_base.h
+++ b/net/socket/client_socket_pool_base.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011,2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
//
@@ -19,6 +18,7 @@
// implementing ConnectJob::ConnectInternal(). They can control the parameters
// passed to each new ConnectJob instance via their ConnectJobFactory subclass
// and templated SocketParams parameter.
+//
#ifndef NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_
#define NET_SOCKET_CLIENT_SOCKET_POOL_BASE_H_
#pragma once
@@ -44,15 +44,10 @@
#include "net/base/request_priority.h"
#include "net/socket/client_socket.h"
#include "net/socket/client_socket_pool.h"
-#include "net/base/host_resolver.h"
-#include "tcp_fin_aggregation.h"
-#include "tcp_fin_aggregation_factory.h"
namespace net {
class ClientSocketHandle;
-class HttpNetworkSession;
-class ITCPFinAggregation;
// ConnectJob provides an abstract interface for "connecting" a socket.
// The connection may involve host resolution, tcp connection, ssl connection,
@@ -154,29 +149,6 @@ class ConnectJob {
namespace internal {
- // Entry for a persistent socket which became idle at time |start_time|.
- class IdleSocket {
- public:
- IdleSocket() : socket(NULL) {}
- ClientSocket* socket;
- base::Time start_time;
-
- // An idle socket should be removed if it can't be reused, or has been idle
- // for too long. |now| is the current time value (TimeTicks::Now()).
- // |timeout| is the length of time to wait before timing out an idle socket.
- //
- // An idle socket can't be reused if it is disconnected or has received
- // data unexpectedly (hence no longer idle). The unread data would be
- // mistaken for the beginning of the next response if we were to reuse the
- // socket for a new request.
- bool ShouldCleanup(base::Time now, base::TimeDelta timeout) const;
-
- base::Time StartTime() const
- {
- return start_time;
- }
- };
-
// ClientSocketPoolBaseHelper is an internal class that implements almost all
// the functionality from ClientSocketPoolBase without using templates.
// ClientSocketPoolBase adds templated definitions built on top of
@@ -252,8 +224,7 @@ class ClientSocketPoolBaseHelper
int max_sockets_per_group,
base::TimeDelta unused_idle_socket_timeout,
base::TimeDelta used_idle_socket_timeout,
- ConnectJobFactory* connect_job_factory,
- HttpNetworkSession *network_session);
+ ConnectJobFactory* connect_job_factory);
~ClientSocketPoolBaseHelper();
@@ -287,18 +258,6 @@ class ClientSocketPoolBaseHelper
return idle_socket_count_;
}
- // Called when the number of idle sockets changes.
- void IncrementIdleCount();
- void DecrementIdleCount();
-
- class Group;
- typedef std::map<std::string, Group*> GroupMap;
-
- void RemoveGroup(const std::string& group_name);
- void RemoveGroup(GroupMap::iterator it);
-
- GroupMap group_map_;
-
// See ClientSocketPool::IdleSocketCountInGroup() for documentation on this
// function.
int IdleSocketCountInGroup(const std::string& group_name) const;
@@ -354,9 +313,29 @@ class ClientSocketPoolBaseHelper
// NetworkChangeNotifier::IPAddressObserver methods:
virtual void OnIPAddressChanged();
- typedef std::deque<const Request* > RequestQueue;
+ private:
+ friend class base::RefCounted<ClientSocketPoolBaseHelper>;
- HttpNetworkSession *network_session_;
+ // Entry for a persistent socket which became idle at time |start_time|.
+ struct IdleSocket {
+ IdleSocket() : socket(NULL) {}
+
+ // An idle socket should be removed if it can't be reused, or has been idle
+ // for too long. |now| is the current time value (TimeTicks::Now()).
+ // |timeout| is the length of time to wait before timing out an idle socket.
+ //
+ // An idle socket can't be reused if it is disconnected or has received
+ // data unexpectedly (hence no longer idle). The unread data would be
+ // mistaken for the beginning of the next response if we were to reuse the
+ // socket for a new request.
+ bool ShouldCleanup(base::TimeTicks now, base::TimeDelta timeout) const;
+
+ ClientSocket* socket;
+ base::TimeTicks start_time;
+ };
+
+ typedef std::deque<const Request* > RequestQueue;
+ typedef std::map<const ClientSocketHandle*, const Request*> RequestMap;
// A Group is allocated per group_name when there are idle sockets or pending
// requests. Otherwise, the Group object is removed from the map.
@@ -431,10 +410,7 @@ class ClientSocketPoolBaseHelper
ScopedRunnableMethodFactory<Group> method_factory_;
};
- private:
- friend class base::RefCounted<ClientSocketPoolBaseHelper>;
-
- typedef std::map<const ClientSocketHandle*, const Request*> RequestMap;
+ typedef std::map<std::string, Group*> GroupMap;
typedef std::set<ConnectJob*> ConnectJobSet;
@@ -456,6 +432,12 @@ class ClientSocketPoolBaseHelper
Group* group);
Group* GetOrCreateGroup(const std::string& group_name);
+ void RemoveGroup(const std::string& group_name);
+ void RemoveGroup(GroupMap::iterator it);
+
+ // Called when the number of idle sockets changes.
+ void IncrementIdleCount();
+ void DecrementIdleCount();
// Start cleanup timer for idle sockets.
void StartIdleSocketTimer();
@@ -468,7 +450,9 @@ class ClientSocketPoolBaseHelper
// Called when timer_ fires. This method scans the idle sockets removing
// sockets that timed out or can't be reused.
- void OnCleanupTimerFired();
+ void OnCleanupTimerFired() {
+ CleanupIdleSockets(false);
+ }
// Removes |job| from |connect_job_set_|. Also updates |group| if non-NULL.
void RemoveConnectJob(ConnectJob* job, Group* group);
@@ -542,6 +526,8 @@ class ClientSocketPoolBaseHelper
// in |pending_callback_map_|.
void InvokeUserCallback(ClientSocketHandle* handle);
+ GroupMap group_map_;
+
// Map of the ClientSocketHandles for which we have a pending Task to invoke a
// callback. This is necessary since, before we invoke said callback, it's
// possible that the request is cancelled.
@@ -566,22 +552,9 @@ class ClientSocketPoolBaseHelper
// The maximum number of sockets kept per group.
const int max_sockets_per_group_;
- // Pointer to ITCPFinAggregation interface that implements
- // TCP Fin Aggregation feature.
- ITCPFinAggregation* tcp_fin_aggregation;
-
- // TCP Fin Aggregation feature
- bool net_tcp_fin_aggr_feature_enabled_sys_property_;
-
// Whether to use timer to cleanup idle sockets.
bool use_cleanup_timer_;
- // Whether statistics is enabled.
- bool net_statistics_enabled;
-
- // Whether unused sockets are closed after page load fnished
- bool close_unused_sockets_enabled;
-
// The time to wait until closing idle sockets.
const base::TimeDelta unused_idle_socket_timeout_;
const base::TimeDelta used_idle_socket_timeout_;
@@ -665,13 +638,11 @@ class ClientSocketPoolBase {
ClientSocketPoolHistograms* histograms,
base::TimeDelta unused_idle_socket_timeout,
base::TimeDelta used_idle_socket_timeout,
- ConnectJobFactory* connect_job_factory,
- HttpNetworkSession *network_session)
+ ConnectJobFactory* connect_job_factory)
: histograms_(histograms),
helper_(max_sockets, max_sockets_per_group,
unused_idle_socket_timeout, used_idle_socket_timeout,
- new ConnectJobFactoryAdaptor(connect_job_factory),
- network_session) {}
+ new ConnectJobFactoryAdaptor(connect_job_factory)) {}
virtual ~ClientSocketPoolBase() {}
diff --git a/net/socket/client_socket_pool_manager.cc b/net/socket/client_socket_pool_manager.cc
index 0313db4..182eb18 100644
--- a/net/socket/client_socket_pool_manager.cc
+++ b/net/socket/client_socket_pool_manager.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
//
@@ -254,8 +253,7 @@ ClientSocketPoolManager::ClientSocketPoolManager(
DnsCertProvenanceChecker* dns_cert_checker,
SSLHostInfoFactory* ssl_host_info_factory,
ProxyService* proxy_service,
- SSLConfigService* ssl_config_service,
- HttpNetworkSession *network_session)
+ SSLConfigService* ssl_config_service)
: net_log_(net_log),
socket_factory_(socket_factory),
host_resolver_(host_resolver),
@@ -271,8 +269,7 @@ ClientSocketPoolManager::ClientSocketPoolManager(
&transport_pool_histograms_,
host_resolver,
socket_factory_,
- net_log,
- network_session)),
+ net_log)),
ssl_pool_histograms_("SSL2"),
ssl_socket_pool_(new SSLClientSocketPool(
g_max_sockets, g_max_sockets_per_group,
@@ -287,8 +284,7 @@ ClientSocketPoolManager::ClientSocketPoolManager(
NULL /* no socks proxy */,
NULL /* no http proxy */,
ssl_config_service,
- net_log,
- network_session)),
+ net_log)),
transport_for_socks_pool_histograms_("TCPforSOCKS"),
socks_pool_histograms_("SOCK"),
transport_for_http_proxy_pool_histograms_("TCPforHTTPProxy"),
@@ -421,8 +417,7 @@ SOCKSClientSocketPool* ClientSocketPoolManager::GetSocketPoolForSOCKSProxy(
&transport_for_socks_pool_histograms_,
host_resolver_,
socket_factory_,
- net_log_,
- NULL)));
+ net_log_)));
DCHECK(tcp_ret.second);
std::pair<SOCKSSocketPoolMap::iterator, bool> ret =
@@ -432,8 +427,7 @@ SOCKSClientSocketPool* ClientSocketPoolManager::GetSocketPoolForSOCKSProxy(
&socks_pool_histograms_,
host_resolver_,
tcp_ret.first->second,
- net_log_,
- NULL)));
+ net_log_)));
return ret.first->second;
}
@@ -462,8 +456,7 @@ HttpProxyClientSocketPool* ClientSocketPoolManager::GetSocketPoolForHTTPProxy(
&transport_for_http_proxy_pool_histograms_,
host_resolver_,
socket_factory_,
- net_log_,
- NULL)));
+ net_log_)));
DCHECK(tcp_http_ret.second);
std::pair<TransportSocketPoolMap::iterator, bool> tcp_https_ret =
@@ -475,8 +468,7 @@ HttpProxyClientSocketPool* ClientSocketPoolManager::GetSocketPoolForHTTPProxy(
&transport_for_https_proxy_pool_histograms_,
host_resolver_,
socket_factory_,
- net_log_,
- NULL)));
+ net_log_)));
DCHECK(tcp_https_ret.second);
std::pair<SSLSocketPoolMap::iterator, bool> ssl_https_ret =
@@ -495,8 +487,7 @@ HttpProxyClientSocketPool* ClientSocketPoolManager::GetSocketPoolForHTTPProxy(
tcp_https_ret.first->second /* https proxy */,
NULL /* no socks proxy */,
NULL /* no http proxy */,
- ssl_config_service_, net_log_,
- NULL)));
+ ssl_config_service_, net_log_)));
DCHECK(tcp_https_ret.second);
std::pair<HTTPProxySocketPoolMap::iterator, bool> ret =
@@ -509,8 +500,7 @@ HttpProxyClientSocketPool* ClientSocketPoolManager::GetSocketPoolForHTTPProxy(
host_resolver_,
tcp_http_ret.first->second,
ssl_https_ret.first->second,
- net_log_,
- NULL)));
+ net_log_)));
return ret.first->second;
}
@@ -535,8 +525,7 @@ SSLClientSocketPool* ClientSocketPoolManager::GetSocketPoolForSSLWithProxy(
GetSocketPoolForSOCKSProxy(proxy_server),
GetSocketPoolForHTTPProxy(proxy_server),
ssl_config_service_,
- net_log_,
- NULL);
+ net_log_);
std::pair<SSLSocketPoolMap::iterator, bool> ret =
ssl_socket_pools_for_proxies_.insert(std::make_pair(proxy_server,
diff --git a/net/socket/client_socket_pool_manager.h b/net/socket/client_socket_pool_manager.h
index 28074c7..54b13f7 100644
--- a/net/socket/client_socket_pool_manager.h
+++ b/net/socket/client_socket_pool_manager.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
//
@@ -45,7 +44,6 @@ class SSLClientSocketPool;
class SSLConfigService;
class SSLHostInfoFactory;
class TransportClientSocketPool;
-class HttpNetworkSession;
struct HttpRequestInfo;
struct SSLConfig;
@@ -79,8 +77,7 @@ class ClientSocketPoolManager : public base::NonThreadSafe,
DnsCertProvenanceChecker* dns_cert_checker,
SSLHostInfoFactory* ssl_host_info_factory,
ProxyService* proxy_service,
- SSLConfigService* ssl_config_service,
- HttpNetworkSession *network_session);
+ SSLConfigService* ssl_config_service);
~ClientSocketPoolManager();
void FlushSocketPools();
@@ -177,7 +174,6 @@ class ClientSocketPoolManager : public base::NonThreadSafe,
SSLHostInfoFactory* const ssl_host_info_factory_;
const scoped_refptr<ProxyService> proxy_service_;
const scoped_refptr<SSLConfigService> ssl_config_service_;
- HttpNetworkSession *http_network_session_;
// Note: this ordering is important.
diff --git a/net/socket/socks_client_socket_pool.cc b/net/socket/socks_client_socket_pool.cc
index dd7dbf7..be563c8 100644
--- a/net/socket/socks_client_socket_pool.cc
+++ b/net/socket/socks_client_socket_pool.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -223,8 +222,7 @@ SOCKSClientSocketPool::SOCKSClientSocketPool(
ClientSocketPoolHistograms* histograms,
HostResolver* host_resolver,
TransportClientSocketPool* transport_pool,
- NetLog* net_log,
- HttpNetworkSession *network_session)
+ NetLog* net_log)
: transport_pool_(transport_pool),
base_(max_sockets, max_sockets_per_group, histograms,
base::TimeDelta::FromSeconds(
@@ -232,8 +230,7 @@ SOCKSClientSocketPool::SOCKSClientSocketPool(
base::TimeDelta::FromSeconds(kUsedIdleSocketTimeout),
new SOCKSConnectJobFactory(transport_pool,
host_resolver,
- net_log),
- network_session) {
+ net_log)) {
}
SOCKSClientSocketPool::~SOCKSClientSocketPool() {}
diff --git a/net/socket/socks_client_socket_pool.h b/net/socket/socks_client_socket_pool.h
index d554815..894ee2b 100644
--- a/net/socket/socks_client_socket_pool.h
+++ b/net/socket/socks_client_socket_pool.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -118,8 +117,7 @@ class SOCKSClientSocketPool : public ClientSocketPool {
ClientSocketPoolHistograms* histograms,
HostResolver* host_resolver,
TransportClientSocketPool* transport_pool,
- NetLog* net_log,
- HttpNetworkSession *network_session);
+ NetLog* net_log);
virtual ~SOCKSClientSocketPool();
diff --git a/net/socket/ssl_client_socket_pool.cc b/net/socket/ssl_client_socket_pool.cc
index 66146a9..52554f8 100644
--- a/net/socket/ssl_client_socket_pool.cc
+++ b/net/socket/ssl_client_socket_pool.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -506,8 +505,7 @@ SSLClientSocketPool::SSLClientSocketPool(
SOCKSClientSocketPool* socks_pool,
HttpProxyClientSocketPool* http_proxy_pool,
SSLConfigService* ssl_config_service,
- NetLog* net_log,
- HttpNetworkSession *network_session)
+ NetLog* net_log)
: transport_pool_(transport_pool),
socks_pool_(socks_pool),
http_proxy_pool_(http_proxy_pool),
@@ -524,8 +522,7 @@ SSLClientSocketPool::SSLClientSocketPool(
dnsrr_resolver,
dns_cert_checker,
ssl_host_info_factory,
- net_log),
- network_session),
+ net_log)),
ssl_config_service_(ssl_config_service) {
if (ssl_config_service_)
ssl_config_service_->AddObserver(this);
diff --git a/net/socket/ssl_client_socket_pool.h b/net/socket/ssl_client_socket_pool.h
index 558b373..3f2efc3 100644
--- a/net/socket/ssl_client_socket_pool.h
+++ b/net/socket/ssl_client_socket_pool.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -195,8 +194,7 @@ class SSLClientSocketPool : public ClientSocketPool,
SOCKSClientSocketPool* socks_pool,
HttpProxyClientSocketPool* http_proxy_pool,
SSLConfigService* ssl_config_service,
- NetLog* net_log,
- HttpNetworkSession *network_session);
+ NetLog* net_log);
virtual ~SSLClientSocketPool();
diff --git a/net/socket/tcp_client_socket_libevent.cc b/net/socket/tcp_client_socket_libevent.cc
index da3e1a0..f820955 100644
--- a/net/socket/tcp_client_socket_libevent.cc
+++ b/net/socket/tcp_client_socket_libevent.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012, Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -27,7 +26,6 @@
#include "net/base/net_log.h"
#include "net/base/net_util.h"
#include "net/base/network_change_notifier.h"
-#include "net/http/http_getzip_factory.h"
#if defined(USE_SYSTEM_LIBEVENT)
#include <event.h>
#else
@@ -127,7 +125,6 @@ TCPClientSocketLibevent::TCPClientSocketLibevent(
, calling_uid_(0)
#endif
{
- HttpGetZipFactory::GetGETZipManager()->OpenGetZipConnection( ((ClientSocket*)this) );
scoped_refptr<NetLog::EventParameters> params;
if (source.is_valid())
params = new NetLogSourceParameter("source_dependency", source);
@@ -138,7 +135,6 @@ TCPClientSocketLibevent::TCPClientSocketLibevent(
}
TCPClientSocketLibevent::~TCPClientSocketLibevent() {
- HttpGetZipFactory::GetGETZipManager()->StopGetZipConnection( ((ClientSocket*)this) );
Disconnect();
net_log_.EndEvent(NetLog::TYPE_SOCKET_ALIVE, NULL);
}
diff --git a/net/socket/tcp_client_socket_pool.cc b/net/socket/tcp_client_socket_pool.cc
index a4c43e4..735f498 100644
--- a/net/socket/tcp_client_socket_pool.cc
+++ b/net/socket/tcp_client_socket_pool.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -248,15 +247,13 @@ TCPClientSocketPool::TCPClientSocketPool(
ClientSocketPoolHistograms* histograms,
HostResolver* host_resolver,
ClientSocketFactory* client_socket_factory,
- NetLog* net_log,
- HttpNetworkSession *network_session)
+ NetLog* net_log)
: base_(max_sockets, max_sockets_per_group, histograms,
base::TimeDelta::FromSeconds(
ClientSocketPool::unused_idle_socket_timeout()),
base::TimeDelta::FromSeconds(kUsedIdleSocketTimeout),
new TCPConnectJobFactory(client_socket_factory,
- host_resolver, net_log),
- network_session) {
+ host_resolver, net_log)) {
base_.EnableConnectBackupJobs();
}
diff --git a/net/socket/tcp_client_socket_pool.h b/net/socket/tcp_client_socket_pool.h
index 1537cf4..cb671db 100644
--- a/net/socket/tcp_client_socket_pool.h
+++ b/net/socket/tcp_client_socket_pool.h
@@ -1,5 +1,4 @@
// Copyright (c) 2010 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -127,8 +126,7 @@ class TCPClientSocketPool : public ClientSocketPool {
ClientSocketPoolHistograms* histograms,
HostResolver* host_resolver,
ClientSocketFactory* client_socket_factory,
- NetLog* net_log,
- HttpNetworkSession *network_session);
+ NetLog* net_log);
virtual ~TCPClientSocketPool();
diff --git a/net/socket/tcp_fin_aggregation.h b/net/socket/tcp_fin_aggregation.h
deleted file mode 100644
index 26ab3f8..0000000
--- a/net/socket/tcp_fin_aggregation.h
+++ /dev/null
@@ -1,52 +0,0 @@
-// Copyright (c) 2011,2012 Code Aurora Forum. All rights reserved.
-
-// Redistribution and use in source and binary forms, with or without
-// modification, are permitted provided that the following conditions are
-// met:
-// * Redistributions of source code must retain the above copyright
-// notice, this list of conditions and the following disclaimer.
-// * Redistributions in binary form must reproduce the above
-// copyright notice, this list of conditions and the following
-// disclaimer in the documentation and/or other materials provided
-// with the distribution.
-// * Neither the name of Code Aurora Forum, Inc. nor the names of its
-// contributors may be used to endorse or promote products derived
-// from this software without specific prior written permission.
-
-// THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-// BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-// BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-// OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-// IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
-#ifndef TCP_FIN_AGGREGATION_H_
-#define TCP_FIN_AGGREGATION_H_
-
-#include "base/basictypes.h"
-#include "client_socket_pool_base.h"
-
-namespace net {
-
-class ITCPFinAggregation {
-
-public:
- ITCPFinAggregation() {};
- virtual ~ITCPFinAggregation() {};
-
- virtual bool IsEnabled() = 0;
- virtual void ReaperCleanup(bool close_unused_socket) = 0;
- virtual int GetCleanupInterval(int current_interval) = 0;
-
-private:
- DISALLOW_COPY_AND_ASSIGN(ITCPFinAggregation);
-};
-
-} // namespace net
-
-#endif /* TCP_FIN_AGGREGATION_H_ */
diff --git a/net/socket/tcp_fin_aggregation_bridge.h b/net/socket/tcp_fin_aggregation_bridge.h
deleted file mode 100644
index 071832a..0000000
--- a/net/socket/tcp_fin_aggregation_bridge.h
+++ /dev/null
@@ -1,46 +0,0 @@
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
-// Redistribution and use in source and binary forms, with or without
-// modification, are permitted provided that the following conditions are
-// met:
-// * Redistributions of source code must retain the above copyright
-// notice, this list of conditions and the following disclaimer.
-// * Redistributions in binary form must reproduce the above
-// copyright notice, this list of conditions and the following
-// disclaimer in the documentation and/or other materials provided
-// with the distribution.
-// * Neither the name of Code Aurora Forum, Inc. nor the names of its
-// contributors may be used to endorse or promote products derived
-// from this software without specific prior written permission.
-
-// THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-// BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-// BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-// OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-// IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
-#ifndef TCP_FIN_AGGREGATION_BRIDGE_H_
-#define TCP_FIN_AGGREGATION_BRIDGE_H_
-
-#include "client_socket_pool_base.h"
-#include "time.h"
-
-namespace net {
-namespace internal {
- class ClientSocketPoolBaseHelper;
- class IdleSocket;
-}
-};
-
-extern void DecrementIdleCount(net::internal::ClientSocketPoolBaseHelper* pool_base_helper) __attribute__((visibility("default"), used));
-extern void RemoveGroup(net::internal::ClientSocketPoolBaseHelper* pool_base_helper, const std::string& group_name) __attribute__((visibility("default"), used));
-extern bool ShouldCleanup(net::internal::IdleSocket* idle_socket, base::Time now, base::TimeDelta timeout) __attribute__((visibility("default"), used));
-extern base::Time GetCurrentTime() __attribute__((visibility("default"), used));
-
-#endif /* TCP_FIN_AGGREGATION_BRIDGE_H_ */
diff --git a/net/socket/tcp_fin_aggregation_factory.cc b/net/socket/tcp_fin_aggregation_factory.cc
deleted file mode 100644
index 0b13243..0000000
--- a/net/socket/tcp_fin_aggregation_factory.cc
+++ /dev/null
@@ -1,88 +0,0 @@
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
-// Redistribution and use in source and binary forms, with or without
-// modification, are permitted provided that the following conditions are
-// met:
-// * Redistributions of source code must retain the above copyright
-// notice, this list of conditions and the following disclaimer.
-// * Redistributions in binary form must reproduce the above
-// copyright notice, this list of conditions and the following
-// disclaimer in the documentation and/or other materials provided
-// with the distribution.
-// * Neither the name of Code Aurora Forum, Inc. nor the names of its
-// contributors may be used to endorse or promote products derived
-// from this software without specific prior written permission.
-
-// THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-// BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-// BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-// OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-// IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
-#include "tcp_fin_aggregation_factory.h"
-#include "tcp_fin_aggregation_bridge.h"
-#include <dlfcn.h>
-#include <cutils/log.h>
-
-namespace net {
-
-base::Lock TCPFinAggregationFactory::m_mutex;
-
-TCPFinAggregationFactory* TCPFinAggregationFactory::s_pFactory = NULL;
-
-TCPFinAggregationFactory* TCPFinAggregationFactory::GetTCPFinFactoryInstance(internal::ClientSocketPoolBaseHelper* pool_base_helper) {
- base::AutoLock myLock(TCPFinAggregationFactory::m_mutex);
- if(s_pFactory == NULL) {
- s_pFactory = new TCPFinAggregationFactory(pool_base_helper);
- }
- return s_pFactory;
-}
-
-TCPFinAggregationFactory::TCPFinAggregationFactory(internal::ClientSocketPoolBaseHelper* pool_base_helper):m_pTCPFin(NULL) {
- InitTCPFinAggregation(pool_base_helper);
-}
-
-void TCPFinAggregationFactory::InitTCPFinAggregation(internal::ClientSocketPoolBaseHelper* pool_base_helper) {
- void* libHandle = dlopen("libtcpfinaggr.so", RTLD_LAZY);
- if (!libHandle)
- {
- SLOGD("dl error message %s", dlerror());
- }
-
- if(libHandle) {
- SLOGD("%s: libtcpfinaggr.so successfully loaded", __FILE__);
- *(void **)(&tcpfin_create_) = dlsym(libHandle, "createTCPFinAggregation");
-
- if(tcpfin_create_) {
- SLOGD("%s,: TCP Fin Aggregation initializing method was found in libtcpfinaggr.so", __FILE__);
- m_pTCPFin = tcpfin_create_(pool_base_helper);
- return;
- }
- ::dlclose(libHandle);
- SLOGD("Failed to load createTCPFinAggregation symbol in libtcpfinaggr.so");
- }
-}
-}; // namespace net
-
-void DecrementIdleCount(net::internal::ClientSocketPoolBaseHelper* pool_base_helper)
-{
- pool_base_helper->DecrementIdleCount();
-}
-void RemoveGroup(net::internal::ClientSocketPoolBaseHelper* pool_base_helper, const std::string& group_name)
-{
- pool_base_helper->RemoveGroup(group_name);
-}
-bool ShouldCleanup(net::internal::IdleSocket* idle_socket, base::Time now, base::TimeDelta timeout)
-{
- return idle_socket->ShouldCleanup(now, timeout);
-}
-base::Time GetCurrentTime()
-{
- return base::Time::Now();
-}
diff --git a/net/socket/tcp_fin_aggregation_factory.h b/net/socket/tcp_fin_aggregation_factory.h
deleted file mode 100644
index 17e61c1..0000000
--- a/net/socket/tcp_fin_aggregation_factory.h
+++ /dev/null
@@ -1,71 +0,0 @@
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved.
-
-// Redistribution and use in source and binary forms, with or without
-// modification, are permitted provided that the following conditions are
-// met:
-// * Redistributions of source code must retain the above copyright
-// notice, this list of conditions and the following disclaimer.
-// * Redistributions in binary form must reproduce the above
-// copyright notice, this list of conditions and the following
-// disclaimer in the documentation and/or other materials provided
-// with the distribution.
-// * Neither the name of Code Aurora Forum, Inc. nor the names of its
-// contributors may be used to endorse or promote products derived
-// from this software without specific prior written permission.
-
-// THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED
-// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
-// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT
-// ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS
-// BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
-// CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
-// SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
-// BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
-// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
-// OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
-// IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
-#ifndef TCP_FIN_AGGREGATION_FACTORY_H_
-#define TCP_FIN_AGGREGATION_FACTORY_H_
-
-#include "tcp_fin_aggregation.h"
-#include "client_socket_pool_base.h"
-#include "base/synchronization/lock.h"
-#include "tcp_fin_aggregation_bridge.h"
-
-namespace net {
-class ITCPFinAggregation;
-namespace internal {
- class ClientSocketPoolBaseHelper;
-}
-
-static ITCPFinAggregation* (*tcpfin_create_)(internal::ClientSocketPoolBaseHelper* pool_base_helper) = NULL;
-
-class TCPFinAggregationFactory {
-
-public:
-
-
- static TCPFinAggregationFactory* GetTCPFinFactoryInstance(internal::ClientSocketPoolBaseHelper* pool_base_helper);
-
- ITCPFinAggregation* GetTCPFinAggregation(){ return m_pTCPFin;}
-
-private:
-
- ITCPFinAggregation* m_pTCPFin;
-
- static TCPFinAggregationFactory* s_pFactory;
-
- static base::Lock m_mutex;
-
- TCPFinAggregationFactory(internal::ClientSocketPoolBaseHelper* pool_base_helper);
-
- ~TCPFinAggregationFactory();
-
- void InitTCPFinAggregation(internal::ClientSocketPoolBaseHelper* pool_base_helper);
-
- DISALLOW_COPY_AND_ASSIGN(TCPFinAggregationFactory);
-};
-
-} // namespace net
-#endif
diff --git a/net/socket/transport_client_socket_pool.cc b/net/socket/transport_client_socket_pool.cc
index d1ac198..ef02061 100644
--- a/net/socket/transport_client_socket_pool.cc
+++ b/net/socket/transport_client_socket_pool.cc
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -426,15 +425,13 @@ TransportClientSocketPool::TransportClientSocketPool(
ClientSocketPoolHistograms* histograms,
HostResolver* host_resolver,
ClientSocketFactory* client_socket_factory,
- NetLog* net_log,
- HttpNetworkSession *network_session)
+ NetLog* net_log)
: base_(max_sockets, max_sockets_per_group, histograms,
base::TimeDelta::FromSeconds(
ClientSocketPool::unused_idle_socket_timeout()),
base::TimeDelta::FromSeconds(kUsedIdleSocketTimeout),
new TransportConnectJobFactory(client_socket_factory,
- host_resolver, net_log),
- network_session) {
+ host_resolver, net_log)) {
base_.EnableConnectBackupJobs();
}
diff --git a/net/socket/transport_client_socket_pool.h b/net/socket/transport_client_socket_pool.h
index c6fdce5..c1633bb 100644
--- a/net/socket/transport_client_socket_pool.h
+++ b/net/socket/transport_client_socket_pool.h
@@ -1,5 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2012 Code Aurora Forum. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -148,8 +147,7 @@ class TransportClientSocketPool : public ClientSocketPool {
ClientSocketPoolHistograms* histograms,
HostResolver* host_resolver,
ClientSocketFactory* client_socket_factory,
- NetLog* net_log,
- HttpNetworkSession *network_session);
+ NetLog* net_log);
virtual ~TransportClientSocketPool();
diff --git a/net/url_request/url_request_http_job.cc b/net/url_request/url_request_http_job.cc
index 2818d19..95f536f 100644
--- a/net/url_request/url_request_http_job.cc
+++ b/net/url_request/url_request_http_job.cc
@@ -1,6 +1,4 @@
// Copyright (c) 2011 The Chromium Authors. All rights reserved.
-// Copyright (c) 2011, Code Aurora Forum. All rights reserved
-
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
@@ -42,7 +40,6 @@
#include "net/url_request/url_request_redirect_job.h"
#include "net/url_request/url_request_throttler_header_adapter.h"
#include "net/url_request/url_request_throttler_manager.h"
-#include "net/disk_cache/stat_hub_api.h"
static const char kAvailDictionaryHeader[] = "Avail-Dictionary";
@@ -288,9 +285,6 @@ void URLRequestHttpJob::NotifyHeadersComplete() {
void URLRequestHttpJob::NotifyDone(const URLRequestStatus& status) {
RecordCompressionHistograms();
- GURL& url = request_info_.url;
- unsigned short url_len = url.spec().length();
- StatHubCmd(INPUT_CMD_CH_URL_REQUEST_DONE, (void*)url.spec().c_str(), url_len+1, NULL, 0);
URLRequestJob::NotifyDone(status);
}
@@ -302,11 +296,6 @@ void URLRequestHttpJob::DestroyTransaction() {
context_ = NULL;
}
-static void updateUrlRequest(const GURL& url, const std::string& headers) {
- unsigned short url_len = url.spec().length();
- StatHubCmd(INPUT_CMD_CH_URL_REQUEST, (void*)url.spec().c_str(), url_len+1, (void*)headers.c_str(), headers.length()+1);
-}
-
void URLRequestHttpJob::StartTransaction() {
// NOTE: This method assumes that request_info_ is already setup properly.
@@ -328,7 +317,6 @@ void URLRequestHttpJob::StartTransaction() {
if (rv == OK) {
if (!URLRequestThrottlerManager::GetInstance()->enforce_throttling() ||
!throttling_entry_->IsDuringExponentialBackoff()) {
- updateUrlRequest(request_info_.url, request_info_.extra_headers.ToString().c_str());
rv = transaction_->Start(
&request_info_, &start_callback_, request_->net_log());
} else {