diff options
Diffstat (limited to 'chrome/common/ipc_channel_posix.h')
-rw-r--r-- | chrome/common/ipc_channel_posix.h | 112 |
1 files changed, 0 insertions, 112 deletions
diff --git a/chrome/common/ipc_channel_posix.h b/chrome/common/ipc_channel_posix.h deleted file mode 100644 index fbdd59b..0000000 --- a/chrome/common/ipc_channel_posix.h +++ /dev/null @@ -1,112 +0,0 @@ -// Copyright (c) 2008 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. - -#ifndef CHROME_COMMON_IPC_CHANNEL_POSIX_H_ -#define CHROME_COMMON_IPC_CHANNEL_POSIX_H_ - -#include "chrome/common/ipc_channel.h" - -#include <sys/socket.h> // for CMSG macros - -#include <queue> -#include <string> -#include <vector> - -#include "base/message_loop.h" -#include "chrome/common/file_descriptor_set_posix.h" - -namespace IPC { - -class Channel::ChannelImpl : public MessageLoopForIO::Watcher { - public: - // Mirror methods of Channel, see ipc_channel.h for description. - ChannelImpl(const std::wstring& channel_id, Mode mode, Listener* listener); - ~ChannelImpl() { Close(); } - bool Connect(); - void Close(); - void set_listener(Listener* listener) { listener_ = listener; } - bool Send(Message* message); - void GetClientFileDescriptorMapping(int *src_fd, int *dest_fd); - void OnClientConnected(); - - private: - const std::wstring PipeName(const std::wstring& channel_id) const; - bool CreatePipe(const std::wstring& channel_id, Mode mode); - - bool ProcessIncomingMessages(); - bool ProcessOutgoingMessages(); - - void OnFileCanReadWithoutBlocking(int fd); - void OnFileCanWriteWithoutBlocking(int fd); - - Mode mode_; - - // After accepting one client connection on our server socket we want to - // stop listening. - MessageLoopForIO::FileDescriptorWatcher server_listen_connection_watcher_; - MessageLoopForIO::FileDescriptorWatcher read_watcher_; - MessageLoopForIO::FileDescriptorWatcher write_watcher_; - - // Indicates whether we're currently blocked waiting for a write to complete. - bool is_blocked_on_write_; - - // If sending a message blocks then we use this variable - // to keep track of where we are. - size_t message_send_bytes_written_; - - // If the kTestingChannelID flag is specified, we use a FIFO instead of - // a socketpair(). - bool uses_fifo_; - - int server_listen_pipe_; - int pipe_; - int client_pipe_; // The client end of our socketpair(). - std::string pipe_name_; - - Listener* listener_; - - // Messages to be sent are queued here. - std::queue<Message*> output_queue_; - - // We read from the pipe into this buffer - char input_buf_[Channel::kReadBufferSize]; - - enum { - // We assume a worst case: kReadBufferSize bytes of messages, where each - // message has no payload and a full complement of descriptors. - MAX_READ_FDS = (Channel::kReadBufferSize / sizeof(IPC::Message::Header)) * - FileDescriptorSet::MAX_DESCRIPTORS_PER_MESSAGE, - }; - - // This is a control message buffer large enough to hold kMaxReadFDs -#if defined(OS_MACOSX) - // TODO(agl): OSX appears to have non-constant CMSG macros! - char input_cmsg_buf_[1024]; -#else - char input_cmsg_buf_[CMSG_SPACE(sizeof(int) * MAX_READ_FDS)]; -#endif - - // Large messages that span multiple pipe buffers, get built-up using - // this buffer. - std::string input_overflow_buf_; - std::vector<int> input_overflow_fds_; - - // In server-mode, we have to wait for the client to connect before we - // can begin reading. We make use of the input_state_ when performing - // the connect operation in overlapped mode. - bool waiting_connect_; - - // This flag is set when processing incoming messages. It is used to - // avoid recursing through ProcessIncomingMessages, which could cause - // problems. TODO(darin): make this unnecessary - bool processing_incoming_; - - ScopedRunnableMethodFactory<ChannelImpl> factory_; - - DISALLOW_COPY_AND_ASSIGN(ChannelImpl); -}; - -} // namespace IPC - -#endif // CHROME_COMMON_IPC_CHANNEL_POSIX_H_ |