15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#ifndef CONTENT_CHILD_SOCKET_STREAM_DISPATCHER_H_ 6868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#define CONTENT_CHILD_SOCKET_STREAM_DISPATCHER_H_ 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <vector> 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/basictypes.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/compiler_specific.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "ipc/ipc_listener.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 14f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles)namespace blink { 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class WebSocketStreamHandle; 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 18a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles)namespace content { 19a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class WebSocketStreamHandleBridge; 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class WebSocketStreamHandleDelegate; 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Dispatches socket stream related messages sent to a child process from the 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// main browser process. There is one instance per child process. Messages 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// are dispatched on the main child thread. The RenderThread class 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// creates an instance of SocketStreamDispatcher and delegates calls to it. 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class SocketStreamDispatcher : public IPC::Listener { 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SocketStreamDispatcher(); 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual ~SocketStreamDispatcher() {} 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 32a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) static WebSocketStreamHandleBridge* CreateBridge( 33f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) blink::WebSocketStreamHandle* handle, 34a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) WebSocketStreamHandleDelegate* delegate); 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // IPC::Listener implementation. 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE; 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) private: 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnConnected(int socket_id, int max_amount_send_allowed); 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnSentData(int socket_id, int amount_sent); 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnReceivedData(int socket_id, const std::vector<char>& data); 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnClosed(int socket_id); 44c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) void OnFailed(int socket_id, int error_code); 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(SocketStreamDispatcher); 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace content 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 51868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#endif // CONTENT_CHILD_SOCKET_STREAM_DISPATCHER_H_ 52