Index: sync/internal_api/syncapi_server_connection_manager.cc |
diff --git a/sync/internal_api/syncapi_server_connection_manager.cc b/sync/internal_api/syncapi_server_connection_manager.cc |
deleted file mode 100644 |
index a54fcbc8ff6e03791c020e9f9c8e8abe293506b1..0000000000000000000000000000000000000000 |
--- a/sync/internal_api/syncapi_server_connection_manager.cc |
+++ /dev/null |
@@ -1,106 +0,0 @@ |
-// Copyright (c) 2012 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "sync/internal_api/syncapi_server_connection_manager.h" |
- |
-#include <stdint.h> |
- |
-#include "net/base/net_errors.h" |
-#include "net/http/http_status_code.h" |
-#include "sync/internal_api/public/http_post_provider_factory.h" |
-#include "sync/internal_api/public/http_post_provider_interface.h" |
- |
-namespace syncer { |
- |
-SyncAPIBridgedConnection::SyncAPIBridgedConnection( |
- ServerConnectionManager* scm, |
- HttpPostProviderFactory* factory) |
- : Connection(scm), factory_(factory) { |
- post_provider_ = factory_->Create(); |
-} |
- |
-SyncAPIBridgedConnection::~SyncAPIBridgedConnection() { |
- DCHECK(post_provider_); |
- factory_->Destroy(post_provider_); |
- post_provider_ = NULL; |
-} |
- |
-bool SyncAPIBridgedConnection::Init(const char* path, |
- const std::string& auth_token, |
- const std::string& payload, |
- HttpResponse* response) { |
- std::string sync_server; |
- int sync_server_port = 0; |
- bool use_ssl = false; |
- GetServerParams(&sync_server, &sync_server_port, &use_ssl); |
- std::string connection_url = MakeConnectionURL(sync_server, path, use_ssl); |
- |
- HttpPostProviderInterface* http = post_provider_; |
- http->SetURL(connection_url.c_str(), sync_server_port); |
- |
- if (!auth_token.empty()) { |
- std::string headers; |
- headers = "Authorization: Bearer " + auth_token; |
- http->SetExtraRequestHeaders(headers.c_str()); |
- } |
- |
- // Must be octet-stream, or the payload may be parsed for a cookie. |
- http->SetPostPayload("application/octet-stream", payload.length(), |
- payload.data()); |
- |
- // Issue the POST, blocking until it finishes. |
- int error_code = 0; |
- int response_code = 0; |
- if (!http->MakeSynchronousPost(&error_code, &response_code)) { |
- DCHECK_NE(error_code, net::OK); |
- DVLOG(1) << "Http POST failed, error returns: " << error_code; |
- response->server_status = HttpResponse::CONNECTION_UNAVAILABLE; |
- return false; |
- } |
- |
- // We got a server response, copy over response codes and content. |
- response->response_code = response_code; |
- response->content_length = |
- static_cast<int64_t>(http->GetResponseContentLength()); |
- response->payload_length = |
- static_cast<int64_t>(http->GetResponseContentLength()); |
- if (response->response_code < 400) |
- response->server_status = HttpResponse::SERVER_CONNECTION_OK; |
- else if (response->response_code == net::HTTP_UNAUTHORIZED) |
- response->server_status = HttpResponse::SYNC_AUTH_ERROR; |
- else |
- response->server_status = HttpResponse::SYNC_SERVER_ERROR; |
- |
- // Write the content into our buffer. |
- buffer_.assign(http->GetResponseContent(), http->GetResponseContentLength()); |
- return true; |
-} |
- |
-void SyncAPIBridgedConnection::Abort() { |
- DCHECK(post_provider_); |
- post_provider_->Abort(); |
-} |
- |
-SyncAPIServerConnectionManager::SyncAPIServerConnectionManager( |
- const std::string& server, |
- int port, |
- bool use_ssl, |
- HttpPostProviderFactory* factory, |
- CancelationSignal* cancelation_signal) |
- : ServerConnectionManager(server, |
- port, |
- use_ssl, |
- cancelation_signal), |
- post_provider_factory_(factory) { |
- DCHECK(post_provider_factory_.get()); |
-} |
- |
-SyncAPIServerConnectionManager::~SyncAPIServerConnectionManager() {} |
- |
-ServerConnectionManager::Connection* |
-SyncAPIServerConnectionManager::MakeConnection() { |
- return new SyncAPIBridgedConnection(this, post_provider_factory_.get()); |
-} |
- |
-} // namespace syncer |