Home
last modified time | relevance | path

Searched refs:WebSocketJob (Results 1 – 6 of 6) sorted by relevance

/external/chromium/net/websockets/
Dwebsocket_job.cc36 net::WebSocketJob* job = new net::WebSocketJob(delegate); in WebSocketJobFactory()
58 void WebSocketJob::EnsureInit() { in EnsureInit()
62 WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate) in WebSocketJob() function in net::WebSocketJob
75 WebSocketJob::~WebSocketJob() { in ~WebSocketJob()
81 void WebSocketJob::Connect() { in Connect()
88 bool WebSocketJob::SendData(const char* data, int len) { in SendData()
128 void WebSocketJob::Close() { in Close()
138 void WebSocketJob::RestartWithAuth( in RestartWithAuth()
145 void WebSocketJob::DetachDelegate() { in DetachDelegate()
150 scoped_refptr<WebSocketJob> protect(this); in DetachDelegate()
[all …]
Dwebsocket_throttle_unittest.cc86 scoped_refptr<WebSocketJob> w1(new WebSocketJob(&delegate)); in TEST_F()
106 scoped_refptr<WebSocketJob> w2(new WebSocketJob(&delegate)); in TEST_F()
125 scoped_refptr<WebSocketJob> w3(new WebSocketJob(&delegate)); in TEST_F()
144 scoped_refptr<WebSocketJob> w4(new WebSocketJob(&delegate)); in TEST_F()
162 scoped_refptr<WebSocketJob> w5(new WebSocketJob(&delegate)); in TEST_F()
180 scoped_refptr<WebSocketJob> w6(new WebSocketJob(&delegate)); in TEST_F()
218 EXPECT_EQ(WebSocketJob::OPEN, w1->state()); in TEST_F()
289 scoped_refptr<WebSocketJob> w1(new WebSocketJob(&delegate)); in TEST_F()
Dwebsocket_job_unittest.cc191 websocket_ = new WebSocketJob(delegate); in InitWebSocketJob()
195 websocket_->state_ = WebSocketJob::CONNECTING; in InitWebSocketJob()
208 WebSocketJob::State GetWebSocketJobState() { in GetWebSocketJobState()
216 websocket_->state_ = WebSocketJob::CLOSED; in CloseWebSocketJob()
227 scoped_refptr<WebSocketJob> websocket_;
253 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); in TEST_F()
272 EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState()); in TEST_F()
300 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); in TEST_F()
324 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); in TEST_F()
329 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState()); in TEST_F()
[all …]
Dwebsocket_throttle.h19 class WebSocketJob; variable
37 void PutInQueue(WebSocketJob* job);
41 void RemoveFromQueue(WebSocketJob* job);
50 typedef std::deque<WebSocketJob*> ConnectingQueue;
Dwebsocket_job.h32 class WebSocketJob : public SocketStreamJob, public SocketStream::Delegate {
43 explicit WebSocketJob(SocketStream::Delegate* delegate);
74 virtual ~WebSocketJob();
115 DISALLOW_COPY_AND_ASSIGN(WebSocketJob);
Dwebsocket_throttle.cc62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) { in PutInQueue()
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { in RemoveFromQueue()
137 WebSocketJob* job = *iter; in WakeupSocketIfNecessary()