HomeSort by relevance Sort by last modified time
    Searched refs:WebSocketJob (Results 1 - 14 of 14) sorted by null

  /external/chromium/net/websockets/
websocket_throttle.h 19 class WebSocketJob;
37 void PutInQueue(WebSocketJob* job);
41 void RemoveFromQueue(WebSocketJob* job);
50 typedef std::deque<WebSocketJob*> ConnectingQueue;
websocket_job.cc 36 net::WebSocketJob* job = new net::WebSocketJob(delegate);
58 void WebSocketJob::EnsureInit() {
62 WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate)
75 WebSocketJob::~WebSocketJob() {
81 void WebSocketJob::Connect() {
88 bool WebSocketJob::SendData(const char* data, int len) {
128 void WebSocketJob::Close()
    [all...]
websocket_throttle_unittest.cc 86 scoped_refptr<WebSocketJob> w1(new WebSocketJob(&delegate));
106 scoped_refptr<WebSocketJob> w2(new WebSocketJob(&delegate));
125 scoped_refptr<WebSocketJob> w3(new WebSocketJob(&delegate));
144 scoped_refptr<WebSocketJob> w4(new WebSocketJob(&delegate));
162 scoped_refptr<WebSocketJob> w5(new WebSocketJob(&delegate))
    [all...]
websocket_job.h 32 class WebSocketJob : public SocketStreamJob, public SocketStream::Delegate {
43 explicit WebSocketJob(SocketStream::Delegate* delegate);
74 virtual ~WebSocketJob();
115 DISALLOW_COPY_AND_ASSIGN(WebSocketJob);
websocket_job_unittest.cc 191 websocket_ = new WebSocketJob(delegate);
195 websocket_->state_ = WebSocketJob::CONNECTING;
208 WebSocketJob::State GetWebSocketJobState() {
216 websocket_->state_ = WebSocketJob::CLOSED;
227 scoped_refptr<WebSocketJob> websocket_;
253 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState());
272 EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState());
300 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState());
324 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState());
329 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState())
    [all...]
websocket_throttle.cc 62 void WebSocketThrottle::PutInQueue(WebSocketJob* job) {
89 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) {
137 WebSocketJob* job = *iter;
  /external/chromium_org/net/websockets/
websocket_throttle.h 21 class WebSocketJob;
42 bool PutInQueue(WebSocketJob* job);
47 void RemoveFromQueue(WebSocketJob* job);
50 typedef std::deque<WebSocketJob*> ConnectingQueue;
62 const std::set<WebSocketJob*>& wakeup_candidates);
websocket_job.cc 40 net::WebSocketJob* job = new net::WebSocketJob(delegate);
61 bool WebSocketJob::websocket_over_spdy_enabled_ = false;
64 void WebSocketJob::EnsureInit() {
69 void WebSocketJob::set_websocket_over_spdy_enabled(bool enabled) {
73 WebSocketJob::WebSocketJob(SocketStream::Delegate* delegate)
89 WebSocketJob::~WebSocketJob() {
95 void WebSocketJob::Connect()
    [all...]
websocket_throttle_test.cc 67 WebSocketJob::set_websocket_over_spdy_enabled(true);
74 scoped_refptr<WebSocketJob> w1(new WebSocketJob(&delegate));
95 scoped_refptr<WebSocketJob> w2(new WebSocketJob(&delegate));
116 scoped_refptr<WebSocketJob> w3(new WebSocketJob(&delegate));
137 scoped_refptr<WebSocketJob> w4(new WebSocketJob(&delegate));
157 scoped_refptr<WebSocketJob> w5(new WebSocketJob(&delegate))
    [all...]
websocket_job.h 34 class NET_EXPORT WebSocketJob
48 explicit WebSocketJob(SocketStream::Delegate* delegate);
92 virtual ~WebSocketJob();
155 base::WeakPtrFactory<WebSocketJob> weak_ptr_factory_;
156 base::WeakPtrFactory<WebSocketJob> weak_ptr_factory_for_send_pending_;
158 DISALLOW_COPY_AND_ASSIGN(WebSocketJob);
websocket_job_test.cc 357 websocket_ = new WebSocketJob(delegate);
386 // a WebSocketJob purely to block another one in a throttling test, we don't
394 websocket_->state_ = WebSocketJob::CONNECTING;
397 WebSocketJob::State GetWebSocketJobState() {
405 websocket_->state_ = WebSocketJob::CLOSED;
441 scoped_refptr<WebSocketJob> websocket_;
549 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState());
559 EXPECT_EQ(WebSocketJob::OPEN, GetWebSocketJobState());
574 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState());
587 EXPECT_EQ(WebSocketJob::CONNECTING, GetWebSocketJobState())
    [all...]
websocket_throttle.cc 42 bool WebSocketThrottle::PutInQueue(WebSocketJob* job) {
73 void WebSocketThrottle::RemoveFromQueue(WebSocketJob* job) {
80 std::set<WebSocketJob*> wakeup_candidates;
117 const std::set<WebSocketJob*>& wakeup_candidates) {
118 for (std::set<WebSocketJob*>::const_iterator iter = wakeup_candidates.begin();
121 WebSocketJob* job = *iter;
  /external/chromium_org/content/browser/renderer_host/
socket_stream_dispatcher_host.cc 40 net::WebSocketJob::EnsureInit();
  /external/chromium_org/chrome/browser/
io_thread.cc 748 net::WebSocketJob::set_websocket_over_spdy_enabled(true);
    [all...]

Completed in 184 milliseconds