summaryrefslogtreecommitdiffstats
path: root/chrome/common/ipc_channel_posix.h
diff options
context:
space:
mode:
Diffstat (limited to 'chrome/common/ipc_channel_posix.h')
-rw-r--r--chrome/common/ipc_channel_posix.h112
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_