Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(6453)

Unified Diff: chrome/browser/sync/internal_api/syncapi_server_connection_manager_unittest.cc

Issue 10147003: [Sync] Move 'syncapi_core' and 'sync_unit_tests' targets to sync/ (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix Win update errors Created 8 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: chrome/browser/sync/internal_api/syncapi_server_connection_manager_unittest.cc
diff --git a/chrome/browser/sync/internal_api/syncapi_server_connection_manager_unittest.cc b/chrome/browser/sync/internal_api/syncapi_server_connection_manager_unittest.cc
deleted file mode 100644
index 720b57472a55eb2217f4af0e014005ff82a6f14a..0000000000000000000000000000000000000000
--- a/chrome/browser/sync/internal_api/syncapi_server_connection_manager_unittest.cc
+++ /dev/null
@@ -1,115 +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 "chrome/browser/sync/internal_api/syncapi_server_connection_manager.h"
-
-#include "base/bind.h"
-#include "base/bind_helpers.h"
-#include "base/compiler_specific.h"
-#include "base/synchronization/waitable_event.h"
-#include "base/test/test_timeouts.h"
-#include "base/threading/thread.h"
-#include "base/time.h"
-#include "chrome/browser/sync/internal_api/http_post_provider_factory.h"
-#include "chrome/browser/sync/internal_api/http_post_provider_interface.h"
-#include "net/base/net_errors.h"
-#include "testing/gtest/include/gtest/gtest.h"
-
-using base::TimeDelta;
-using browser_sync::HttpResponse;
-using browser_sync::ServerConnectionManager;
-using browser_sync::ScopedServerStatusWatcher;
-
-namespace sync_api {
-namespace {
-
-class BlockingHttpPost : public HttpPostProviderInterface {
- public:
- BlockingHttpPost() : wait_for_abort_(false, false) {}
- virtual ~BlockingHttpPost() {}
-
- virtual void SetUserAgent(const char* user_agent) OVERRIDE {}
- virtual void SetExtraRequestHeaders(const char* headers) OVERRIDE {}
- virtual void SetURL(const char* url, int port) OVERRIDE {}
- virtual void SetPostPayload(const char* content_type,
- int content_length,
- const char* content) OVERRIDE {}
- virtual bool MakeSynchronousPost(int* error_code, int* response_code)
- OVERRIDE {
- wait_for_abort_.TimedWait(TimeDelta::FromMilliseconds(
- TestTimeouts::action_max_timeout_ms()));
- *error_code = net::ERR_ABORTED;
- return false;
- }
- virtual int GetResponseContentLength() const OVERRIDE {
- return 0;
- }
- virtual const char* GetResponseContent() const OVERRIDE {
- return "";
- }
- virtual const std::string GetResponseHeaderValue(
- const std::string& name) const OVERRIDE {
- return "";
- }
- virtual void Abort() OVERRIDE {
- wait_for_abort_.Signal();
- }
- private:
- base::WaitableEvent wait_for_abort_;
-};
-
-class BlockingHttpPostFactory : public HttpPostProviderFactory {
- public:
- virtual ~BlockingHttpPostFactory() {}
- virtual HttpPostProviderInterface* Create() OVERRIDE {
- return new BlockingHttpPost();
- }
- virtual void Destroy(HttpPostProviderInterface* http) OVERRIDE {
- delete http;
- }
-};
-
-} // namespace
-
-TEST(SyncAPIServerConnectionManagerTest, EarlyAbortPost) {
- SyncAPIServerConnectionManager server(
- "server", 0, true, "1", new BlockingHttpPostFactory());
-
- ServerConnectionManager::PostBufferParams params;
- ScopedServerStatusWatcher watcher(&server, &params.response);
-
- server.TerminateAllIO();
- bool result = server.PostBufferToPath(
- &params, "/testpath", "testauth", &watcher);
-
- EXPECT_FALSE(result);
- EXPECT_EQ(HttpResponse::CONNECTION_UNAVAILABLE,
- params.response.server_status);
-}
-
-TEST(SyncAPIServerConnectionManagerTest, AbortPost) {
- SyncAPIServerConnectionManager server(
- "server", 0, true, "1", new BlockingHttpPostFactory());
-
- ServerConnectionManager::PostBufferParams params;
- ScopedServerStatusWatcher watcher(&server, &params.response);
-
- base::Thread abort_thread("Test_AbortThread");
- ASSERT_TRUE(abort_thread.Start());
- abort_thread.message_loop()->PostDelayedTask(
- FROM_HERE,
- base::Bind(&ServerConnectionManager::TerminateAllIO,
- base::Unretained(&server)),
- TestTimeouts::tiny_timeout());
-
- bool result = server.PostBufferToPath(
- &params, "/testpath", "testauth", &watcher);
-
- EXPECT_FALSE(result);
- EXPECT_EQ(HttpResponse::CONNECTION_UNAVAILABLE,
- params.response.server_status);
- abort_thread.Stop();
-}
-
-} // namespace sync_api

Powered by Google App Engine
This is Rietveld 408576698