Web Socket support: Chromium IPC

chrome/common/render_messages_internal.h

 // Copyright (c) 2009 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 // This header is meant to be included in multiple passes, hence no traditional
 // header guard.
 // See ipc_message_macros.h for explanation of the macros and passes.
 
 #include <map>
 #include <string>
@@ skipping 769 matching lines @@
 
   // Tell the utility process to parse the given JSON data and verify its
   // validity.
   IPC_MESSAGE_CONTROL1(UtilityMsg_UnpackWebResource,
                        std::string /* JSON data */)
 
   // Tell the utility process to parse the given xml document.
   IPC_MESSAGE_CONTROL1(UtilityMsg_ParseUpdateManifest,
                        std::string /* xml document contents */)
 
+  // Socket Stream messages:
+  // These are messages from the browser to the SocketStreamHandle on
+  // a renderer.
+
+  // A |socket_id| is assigned by ViewHostMsg_SocketStream_Connect.
+  // The Socket Stream is connected. The SocketStreamHandle should keep track
+  // of how much it has pending (how much it has requested to be sent) and
+  // shouldn't go over |max_pending_send_allowed| bytes.
+  IPC_MESSAGE_CONTROL2(ViewMsg_SocketStream_Connected,
+                       int /* socket_id */,
+                       int /* max_pending_send_allowed */)
+
+  // |data| is received on the Socket Stream.
+  IPC_MESSAGE_CONTROL2(ViewMsg_SocketStream_ReceivedData,
+                       int /* socket_id */,
+                       std::vector<char> /* data */)
+
+  // |amount_sent| bytes of data requested by
+  // ViewHostMsg_SocketStream_SendData has been sent on the Socket Stream.
+  IPC_MESSAGE_CONTROL2(ViewMsg_SocketStream_SentData,
+                       int /* socket_id */,
+                       int /* amount_sent */)
+
+  // The Socket Stream is closed.
+  IPC_MESSAGE_CONTROL1(ViewMsg_SocketStream_Closed,
+                       int /* socket_id */)
+
 IPC_END_MESSAGES(View)
 
 
 //-----------------------------------------------------------------------------
 // TabContents messages
 // These are messages sent from the renderer to the browser process.
 
 IPC_BEGIN_MESSAGES(ViewHost)
   // Sent by the renderer when it is creating a new window.  The browser creates
   // a tab for it and responds with a ViewMsg_CreatingNew_ACK.  If route_id is
@@ skipping 1033 matching lines @@
   // Asks the browser process to return the attributes of a DB file
   IPC_MESSAGE_CONTROL2(ViewHostMsg_DatabaseGetFileAttributes,
                        FilePath /* the name of the file */,
                        int32 /* a unique message ID */)
 
   // Asks the browser process to return the size of a DB file
   IPC_MESSAGE_CONTROL2(ViewHostMsg_DatabaseGetFileSize,
                        FilePath /* the name of the file */,
                        int32 /* a unique message ID */)
 
+  //---------------------------------------------------------------------------
+  // Socket Stream messages:
+  // These are messages from the SocketStreamHandle to the browser.
+
+  // Open new Socket Stream for the |socket_url| identified by |socket_id|
+  // in the renderer process.
+  // The browser starts connecting asynchronously.
+  // Once Socket Stream connection is established, the browser will send
+  // ViewMsg_SocketStream_Connected back.
+  IPC_MESSAGE_CONTROL2(ViewHostMsg_SocketStream_Connect,
+                       GURL /* socket_url */,
+                       int /* socket_id */)
+
+  // Request to send data on the Socket Stream.
+  // SocketStreamHandle can send data at most |max_pending_send_allowed| bytes,
+  // which is given by ViewMsg_SocketStream_Connected at any time.
+  // The number of pending bytes can be tracked by size of |data| sent
+  // and |amount_sent| parameter of ViewMsg_SocketStream_DataSent.
+  // That is, the following constraints is applied:
+  //  (accumulated total of |data|) - (accumulated total of |amount_sent|)
+  // <= |max_pending_send_allowed|
+  // If the SocketStreamHandle ever tries to exceed the
+  // |max_pending_send_allowed|, the connection will be closed.
+  IPC_MESSAGE_CONTROL2(ViewHostMsg_SocketStream_SendData,
+                       int /* socket_id */,
+                       std::vector<char> /* data */)
+
+  // Request to close the Socket Stream.
+  // The browser will send ViewMsg_SocketStream_Closed back when the Socket
+  // Stream is completely closed.
+  IPC_MESSAGE_CONTROL1(ViewHostMsg_SocketStream_Close,
+                       int /* socket_id */)
+
 IPC_END_MESSAGES(ViewHost)