OLD | NEW |
| (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 | |
OLD | NEW |