WebSocketJob 774 chrome/browser/io_thread.cc net::WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 41 content/browser/renderer_host/socket_stream_dispatcher_host.cc net::WebSocketJob::EnsureInit(); WebSocketJob 41 net/websockets/websocket_job.cc net::WebSocketJob* job = new net::WebSocketJob(delegate); WebSocketJob 62 net/websockets/websocket_job.cc bool WebSocketJob::websocket_over_spdy_enabled_ = false; WebSocketJob 65 net/websockets/websocket_job.cc void WebSocketJob::EnsureInit() { WebSocketJob 70 net/websockets/websocket_job.cc void WebSocketJob::set_websocket_over_spdy_enabled(bool enabled) { WebSocketJob 74 net/websockets/websocket_job.cc WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate) WebSocketJob 90 net/websockets/websocket_job.cc WebSocketJob::~WebSocketJob() { WebSocketJob 96 net/websockets/websocket_job.cc void WebSocketJob::Connect() { WebSocketJob 103 net/websockets/websocket_job.cc bool WebSocketJob::SendData(const char* data, int len) { WebSocketJob 131 net/websockets/websocket_job.cc void WebSocketJob::Close() { WebSocketJob 144 net/websockets/websocket_job.cc void WebSocketJob::RestartWithAuth(const AuthCredentials& credentials) { WebSocketJob 149 net/websockets/websocket_job.cc void WebSocketJob::DetachDelegate() { WebSocketJob 153 net/websockets/websocket_job.cc scoped_refptr<WebSocketJob> protect(this); WebSocketJob 168 net/websockets/websocket_job.cc int WebSocketJob::OnStartOpenConnection( WebSocketJob 192 net/websockets/websocket_job.cc void WebSocketJob::OnConnected( WebSocketJob 201 net/websockets/websocket_job.cc void WebSocketJob::OnSentData(SocketStream* socket, int amount_sent) { WebSocketJob 229 net/websockets/websocket_job.cc base::Bind(&WebSocketJob::SendPending, WebSocketJob 236 net/websockets/websocket_job.cc void WebSocketJob::OnReceivedData( WebSocketJob 250 net/websockets/websocket_job.cc void WebSocketJob::OnClose(SocketStream* socket) { WebSocketJob 254 net/websockets/websocket_job.cc scoped_refptr<WebSocketJob> protect(this); WebSocketJob 269 net/websockets/websocket_job.cc void WebSocketJob::OnAuthRequired( WebSocketJob 275 net/websockets/websocket_job.cc void WebSocketJob::OnSSLCertificateError( WebSocketJob 281 net/websockets/websocket_job.cc void WebSocketJob::OnError(const SocketStream* socket, int error) { WebSocketJob 286 net/websockets/websocket_job.cc void WebSocketJob::OnCreatedSpdyStream(int result) { WebSocketJob 303 net/websockets/websocket_job.cc void WebSocketJob::OnSentSpdyHeaders() { WebSocketJob 313 net/websockets/websocket_job.cc void WebSocketJob::OnSpdyResponseHeadersUpdated( WebSocketJob 326 net/websockets/websocket_job.cc void WebSocketJob::OnSentSpdyData(size_t bytes_sent) { WebSocketJob 336 net/websockets/websocket_job.cc void WebSocketJob::OnReceivedSpdyData(scoped_ptr<SpdyBuffer> buffer) { WebSocketJob 351 net/websockets/websocket_job.cc void WebSocketJob::OnCloseSpdyStream() { WebSocketJob 356 net/websockets/websocket_job.cc bool WebSocketJob::SendHandshakeRequest(const char* data, int len) { WebSocketJob 367 net/websockets/websocket_job.cc void WebSocketJob::AddCookieHeaderAndSend() { WebSocketJob 381 net/websockets/websocket_job.cc base::Bind(&WebSocketJob::LoadCookieCallback, WebSocketJob 389 net/websockets/websocket_job.cc void WebSocketJob::LoadCookieCallback(const std::string& cookie) { WebSocketJob 399 net/websockets/websocket_job.cc void WebSocketJob::DoSendData() { WebSocketJob 419 net/websockets/websocket_job.cc void WebSocketJob::OnSentHandshakeRequest( WebSocketJob 436 net/websockets/websocket_job.cc void WebSocketJob::OnReceivedHandshakeResponse( WebSocketJob 465 net/websockets/websocket_job.cc void WebSocketJob::SaveCookiesAndNotifyHeadersComplete() { WebSocketJob 480 net/websockets/websocket_job.cc void WebSocketJob::NotifyHeadersComplete() { WebSocketJob 504 net/websockets/websocket_job.cc void WebSocketJob::SaveNextCookie() { WebSocketJob 534 net/websockets/websocket_job.cc base::Bind(&WebSocketJob::OnCookieSaved, WebSocketJob 550 net/websockets/websocket_job.cc void WebSocketJob::OnCookieSaved(bool cookie_status) { WebSocketJob 566 net/websockets/websocket_job.cc GURL WebSocketJob::GetURLForCookies() const { WebSocketJob 575 net/websockets/websocket_job.cc const AddressList& WebSocketJob::address_list() const { WebSocketJob 579 net/websockets/websocket_job.cc int WebSocketJob::TrySpdyStream() { WebSocketJob 631 net/websockets/websocket_job.cc void WebSocketJob::SetWaiting() { WebSocketJob 635 net/websockets/websocket_job.cc bool WebSocketJob::IsWaiting() const { WebSocketJob 639 net/websockets/websocket_job.cc void WebSocketJob::Wakeup() { WebSocketJob 646 net/websockets/websocket_job.cc base::Bind(&WebSocketJob::RetryPendingIO, WebSocketJob 650 net/websockets/websocket_job.cc void WebSocketJob::RetryPendingIO() { WebSocketJob 659 net/websockets/websocket_job.cc void WebSocketJob::CompleteIO(int result) { WebSocketJob 669 net/websockets/websocket_job.cc bool WebSocketJob::SendDataInternal(const char* data, int length) { WebSocketJob 677 net/websockets/websocket_job.cc void WebSocketJob::CloseInternal() { WebSocketJob 684 net/websockets/websocket_job.cc void WebSocketJob::SendPending() { WebSocketJob 34 net/websockets/websocket_job.h class NET_EXPORT WebSocketJob WebSocketJob 48 net/websockets/websocket_job.h explicit WebSocketJob(SocketStream::Delegate* delegate); WebSocketJob 92 net/websockets/websocket_job.h virtual ~WebSocketJob(); WebSocketJob 155 net/websockets/websocket_job.h base::WeakPtrFactory<WebSocketJob> weak_ptr_factory_; WebSocketJob 156 net/websockets/websocket_job.h base::WeakPtrFactory<WebSocketJob> weak_ptr_factory_for_send_pending_; WebSocketJob 158 net/websockets/websocket_job.h DISALLOW_COPY_AND_ASSIGN(WebSocketJob); WebSocketJob 327 net/websockets/websocket_job_test.cc WebSocketJob* job() { return job_.get(); } WebSocketJob 329 net/websockets/websocket_job_test.cc void set_job(WebSocketJob* job) { job_ = job; } WebSocketJob 383 net/websockets/websocket_job_test.cc scoped_refptr<WebSocketJob> job_; WebSocketJob 439 net/websockets/websocket_job_test.cc websocket_ = new WebSocketJob(delegate); WebSocketJob 476 net/websockets/websocket_job_test.cc websocket_->state_ = WebSocketJob::CONNECTING; WebSocketJob 479 net/websockets/websocket_job_test.cc WebSocketJob::State GetWebSocketJobState() { WebSocketJob 487 net/websockets/websocket_job_test.cc websocket_->state_ = WebSocketJob::CLOSED; WebSocketJob 523 net/websockets/websocket_job_test.cc scoped_refptr<WebSocketJob> websocket_; WebSocketJob 561 net/websockets/websocket_job_test.cc WebSocketJob* websocket = new WebSocketJob(delegate_.get()); WebSocketJob 571 net/websockets/websocket_job_test.cc WebSocketJob* job() { return delegate_->job(); } WebSocketJob 659 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 669 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState()); WebSocketJob 684 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 697 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 703 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState()); WebSocketJob 715 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 739 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 750 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState()); WebSocketJob 774 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 785 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState()); WebSocketJob 818 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 827 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState()); WebSocketJob 867 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 876 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); WebSocketJob 932 net/websockets/websocket_job_test.cc scoped_refptr<WebSocketJob> block_websocket; WebSocketJob 935 net/websockets/websocket_job_test.cc block_websocket = new WebSocketJob(NULL); WebSocketJob 949 net/websockets/websocket_job_test.cc block_websocket->state_ = WebSocketJob::CLOSED; WebSocketJob 957 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CLOSED, GetWebSocketJobState()); WebSocketJob 1061 net/websockets/websocket_job_test.cc scoped_refptr<WebSocketJob> block_websocket; WebSocketJob 1064 net/websockets/websocket_job_test.cc block_websocket = new WebSocketJob(NULL); WebSocketJob 1078 net/websockets/websocket_job_test.cc block_websocket->state_ = WebSocketJob::CLOSED; WebSocketJob 1086 net/websockets/websocket_job_test.cc EXPECT_EQ(WebSocketJob::CLOSED, GetWebSocketJobState()); WebSocketJob 1090 net/websockets/websocket_job_test.cc std::vector<scoped_refptr<WebSocketJob> > jobs; WebSocketJob 1095 net/websockets/websocket_job_test.cc scoped_refptr<WebSocketJob> job = new WebSocketJob(NULL); WebSocketJob 1106 net/websockets/websocket_job_test.cc for (std::vector<scoped_refptr<WebSocketJob> >::reverse_iterator iter = WebSocketJob 1110 net/websockets/websocket_job_test.cc WebSocketJob* job = (*iter).get(); WebSocketJob 1111 net/websockets/websocket_job_test.cc job->state_ = WebSocketJob::CLOSED; WebSocketJob 1118 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1123 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1128 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1133 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1138 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1143 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1148 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1153 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1158 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1163 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1168 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1173 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1178 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1183 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1188 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1193 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1198 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1207 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 1212 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 1217 net/websockets/websocket_job_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 42 net/websockets/websocket_throttle.cc bool WebSocketThrottle::PutInQueue(WebSocketJob* job) { WebSocketJob 73 net/websockets/websocket_throttle.cc void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { WebSocketJob 80 net/websockets/websocket_throttle.cc std::set<WebSocketJob*> wakeup_candidates; WebSocketJob 117 net/websockets/websocket_throttle.cc const std::set<WebSocketJob*>& wakeup_candidates) { WebSocketJob 118 net/websockets/websocket_throttle.cc for (std::set<WebSocketJob*>::const_iterator iter = wakeup_candidates.begin(); WebSocketJob 121 net/websockets/websocket_throttle.cc WebSocketJob* job = *iter; WebSocketJob 21 net/websockets/websocket_throttle.h class WebSocketJob; WebSocketJob 42 net/websockets/websocket_throttle.h bool PutInQueue(WebSocketJob* job); WebSocketJob 47 net/websockets/websocket_throttle.h void RemoveFromQueue(WebSocketJob* job); WebSocketJob 50 net/websockets/websocket_throttle.h typedef std::deque<WebSocketJob*> ConnectingQueue; WebSocketJob 62 net/websockets/websocket_throttle.h const std::set<WebSocketJob*>& wakeup_candidates); WebSocketJob 67 net/websockets/websocket_throttle_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 74 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w1(new WebSocketJob(&delegate)); WebSocketJob 94 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w2(new WebSocketJob(&delegate)); WebSocketJob 114 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w3(new WebSocketJob(&delegate)); WebSocketJob 134 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w4(new WebSocketJob(&delegate)); WebSocketJob 153 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w5(new WebSocketJob(&delegate)); WebSocketJob 172 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w6(new WebSocketJob(&delegate)); WebSocketJob 210 net/websockets/websocket_throttle_test.cc EXPECT_EQ(WebSocketJob::OPEN, w1->state()); WebSocketJob 278 net/websockets/websocket_throttle_test.cc WebSocketJob::set_websocket_over_spdy_enabled(true); WebSocketJob 284 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w1(new WebSocketJob(&delegate)); WebSocketJob 309 net/websockets/websocket_throttle_test.cc WebSocketJob::set_websocket_over_spdy_enabled(false); WebSocketJob 312 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w1(new WebSocketJob(&delegate)); WebSocketJob 325 net/websockets/websocket_throttle_test.cc scoped_refptr<WebSocketJob> w2(new WebSocketJob(&delegate));