Searched refs:WebSocketJob (Results 1 – 6 of 6) sorted by relevance
36 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::WebSocketJob75 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 …]
86 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()
191 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 …]
19 class WebSocketJob; variable37 void PutInQueue(WebSocketJob* job);41 void RemoveFromQueue(WebSocketJob* job);50 typedef std::deque<WebSocketJob*> ConnectingQueue;
32 class WebSocketJob : public SocketStreamJob, public SocketStream::Delegate {43 explicit WebSocketJob(SocketStream::Delegate* delegate);74 virtual ~WebSocketJob();115 DISALLOW_COPY_AND_ASSIGN(WebSocketJob);
62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) { in PutInQueue()89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) { in RemoveFromQueue()137 WebSocketJob* job = *iter; in WakeupSocketIfNecessary()