| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #ifndef CHROME_COMMON_IPC_CHANNEL_H_ | |
| 6 #define CHROME_COMMON_IPC_CHANNEL_H_ | |
| 7 | |
| 8 #include "chrome/common/ipc_message.h" | |
| 9 | |
| 10 namespace IPC { | |
| 11 | |
| 12 //------------------------------------------------------------------------------ | |
| 13 | |
| 14 class Channel : public Message::Sender { | |
| 15 // Security tests need access to the pipe handle. | |
| 16 friend class ChannelTest; | |
| 17 | |
| 18 public: | |
| 19 // Implemented by consumers of a Channel to receive messages. | |
| 20 class Listener { | |
| 21 public: | |
| 22 virtual ~Listener() {} | |
| 23 | |
| 24 // Called when a message is received. | |
| 25 virtual void OnMessageReceived(const Message& message) = 0; | |
| 26 | |
| 27 // Called when the channel is connected and we have received the internal | |
| 28 // Hello message from the peer. | |
| 29 virtual void OnChannelConnected(int32 peer_pid) {} | |
| 30 | |
| 31 // Called when an error is detected that causes the channel to close. | |
| 32 // This method is not called when a channel is closed normally. | |
| 33 virtual void OnChannelError() {} | |
| 34 }; | |
| 35 | |
| 36 enum Mode { | |
| 37 MODE_SERVER, | |
| 38 MODE_CLIENT | |
| 39 }; | |
| 40 | |
| 41 enum { | |
| 42 // The maximum message size in bytes. Attempting to receive a | |
| 43 // message of this size or bigger results in a channel error. | |
| 44 kMaximumMessageSize = 256 * 1024 * 1024, | |
| 45 | |
| 46 // Ammount of data to read at once from the pipe. | |
| 47 kReadBufferSize = 4 * 1024 | |
| 48 }; | |
| 49 | |
| 50 // Initialize a Channel. | |
| 51 // | |
| 52 // |channel_id| identifies the communication Channel. | |
| 53 // |mode| specifies whether this Channel is to operate in server mode or | |
| 54 // client mode. In server mode, the Channel is responsible for setting up the | |
| 55 // IPC object, whereas in client mode, the Channel merely connects to the | |
| 56 // already established IPC object. | |
| 57 // |listener| receives a callback on the current thread for each newly | |
| 58 // received message. | |
| 59 // | |
| 60 Channel(const std::string& channel_id, Mode mode, Listener* listener); | |
| 61 | |
| 62 ~Channel(); | |
| 63 | |
| 64 // Connect the pipe. On the server side, this will initiate | |
| 65 // waiting for connections. On the client, it attempts to | |
| 66 // connect to a pre-existing pipe. Note, calling Connect() | |
| 67 // will not block the calling thread and may complete | |
| 68 // asynchronously. | |
| 69 bool Connect(); | |
| 70 | |
| 71 // Close this Channel explicitly. May be called multiple times. | |
| 72 void Close(); | |
| 73 | |
| 74 // Modify the Channel's listener. | |
| 75 void set_listener(Listener* listener); | |
| 76 | |
| 77 // Send a message over the Channel to the listener on the other end. | |
| 78 // | |
| 79 // |message| must be allocated using operator new. This object will be | |
| 80 // deleted once the contents of the Message have been sent. | |
| 81 // | |
| 82 // FIXME bug 551500: the channel does not notice failures, so if the | |
| 83 // renderer crashes, it will silently succeed, leaking the parameter. | |
| 84 // At least the leak will be fixed by... | |
| 85 // | |
| 86 virtual bool Send(Message* message); | |
| 87 | |
| 88 #if defined(OS_POSIX) | |
| 89 // On POSIX an IPC::Channel wraps a socketpair(), this method returns the | |
| 90 // FD # for the client end of the socket. | |
| 91 // This method may only be called on the server side of a channel. | |
| 92 // | |
| 93 // If the kTestingChannelID flag is specified on the command line then | |
| 94 // a named FIFO is used as the channel transport mechanism rather than a | |
| 95 // socketpair() in which case this method returns -1. | |
| 96 int GetClientFileDescriptor() const; | |
| 97 #endif // defined(OS_POSIX) | |
| 98 | |
| 99 private: | |
| 100 // PIMPL to which all channel calls are delegated. | |
| 101 class ChannelImpl; | |
| 102 ChannelImpl *channel_impl_; | |
| 103 | |
| 104 // The Hello message is internal to the Channel class. It is sent | |
| 105 // by the peer when the channel is connected. The message contains | |
| 106 // just the process id (pid). The message has a special routing_id | |
| 107 // (MSG_ROUTING_NONE) and type (HELLO_MESSAGE_TYPE). | |
| 108 enum { | |
| 109 HELLO_MESSAGE_TYPE = kuint16max // Maximum value of message type (uint16), | |
| 110 // to avoid conflicting with normal | |
| 111 // message types, which are enumeration | |
| 112 // constants starting from 0. | |
| 113 }; | |
| 114 }; | |
| 115 | |
| 116 } // namespace IPC | |
| 117 | |
| 118 #endif // CHROME_COMMON_IPC_CHANNEL_H_ | |
| OLD | NEW |