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

Side by Side Diff: net/socket_stream/socket_stream_job.cc

Issue 723343002: Update from https://crrev.com/304121 (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 6 years, 1 month 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 unified diff | Download patch
« no previous file with comments | « net/socket_stream/socket_stream_job.h ('k') | net/socket_stream/socket_stream_job_manager.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "net/socket_stream/socket_stream_job.h"
6
7 #include "base/memory/singleton.h"
8 #include "net/http/transport_security_state.h"
9 #include "net/socket_stream/socket_stream_job_manager.h"
10 #include "net/ssl/ssl_config_service.h"
11 #include "net/url_request/url_request_context.h"
12
13 namespace net {
14
15 // static
16 SocketStreamJob::ProtocolFactory* SocketStreamJob::RegisterProtocolFactory(
17 const std::string& scheme, ProtocolFactory* factory) {
18 return SocketStreamJobManager::GetInstance()->RegisterProtocolFactory(
19 scheme, factory);
20 }
21
22 // static
23 SocketStreamJob* SocketStreamJob::CreateSocketStreamJob(
24 const GURL& url,
25 SocketStream::Delegate* delegate,
26 TransportSecurityState* sts,
27 SSLConfigService* ssl,
28 URLRequestContext* context,
29 CookieStore* cookie_store) {
30 GURL socket_url(url);
31 if (url.scheme() == "ws" && sts &&
32 sts->ShouldUpgradeToSSL(url.host())) {
33 url::Replacements<char> replacements;
34 static const char kNewScheme[] = "wss";
35 replacements.SetScheme(kNewScheme, url::Component(0, strlen(kNewScheme)));
36 socket_url = url.ReplaceComponents(replacements);
37 }
38 return SocketStreamJobManager::GetInstance()->CreateJob(
39 socket_url, delegate, context, cookie_store);
40 }
41
42 SocketStreamJob::SocketStreamJob() {}
43
44 SocketStream::UserData* SocketStreamJob::GetUserData(const void* key) const {
45 return socket_->GetUserData(key);
46 }
47
48 void SocketStreamJob::SetUserData(const void* key,
49 SocketStream::UserData* data) {
50 socket_->SetUserData(key, data);
51 }
52
53 void SocketStreamJob::Connect() {
54 socket_->Connect();
55 }
56
57 bool SocketStreamJob::SendData(const char* data, int len) {
58 return socket_->SendData(data, len);
59 }
60
61 void SocketStreamJob::Close() {
62 socket_->Close();
63 }
64
65 void SocketStreamJob::RestartWithAuth(const AuthCredentials& credentials) {
66 socket_->RestartWithAuth(credentials);
67 }
68
69 void SocketStreamJob::CancelWithError(int error) {
70 socket_->CancelWithError(error);
71 }
72
73 void SocketStreamJob::CancelWithSSLError(const net::SSLInfo& ssl_info) {
74 socket_->CancelWithSSLError(ssl_info);
75 }
76
77 void SocketStreamJob::ContinueDespiteError() {
78 socket_->ContinueDespiteError();
79 }
80
81 void SocketStreamJob::DetachDelegate() {
82 socket_->DetachDelegate();
83 }
84
85 void SocketStreamJob::DetachContext() {
86 if (socket_.get())
87 socket_->DetachContext();
88 }
89
90 SocketStreamJob::~SocketStreamJob() {}
91
92 } // namespace net
OLDNEW
« no previous file with comments | « net/socket_stream/socket_stream_job.h ('k') | net/socket_stream/socket_stream_job_manager.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698