Searched refs:pipe_ (Results 1 - 25 of 28) sorted by relevance

12

/external/chromium_org/ipc/mojo/
H A Dipc_message_pipe_reader.cc19 pipe_(handle.Pass()) {
29 pipe_.reset();
44 DCHECK(pipe_.is_valid());
52 pipe_.get().value(),
83 while (pipe_.is_valid()) {
103 if (pipe_.is_valid())
112 MojoResult result = MojoReadMessage(pipe_.get().value(),
123 result = MojoReadMessage(pipe_.get().value(),
H A Dipc_message_pipe_reader.h51 MojoHandle handle() const { return pipe_.get().value(); }
69 bool IsValid() { return pipe_.is_valid(); }
90 mojo::ScopedMessagePipeHandle pipe_; member in class:IPC::internal::MessagePipeReader
/external/chromium_org/ipc/
H A Dipc_channel_nacl.cc86 int pipe_; member in class:IPC::ChannelNacl::ReaderThreadRunner
99 : pipe_(pipe),
108 bool success = ReadDataOnReaderThread(pipe_, msg_contents.get());
127 pipe_(-1),
153 if (pipe_ == -1) {
165 pipe_,
194 close(pipe_);
195 pipe_ = -1;
222 if (pipe_ == -1)
246 DCHECK(pipe_
[all...]
H A Dipc_channel_win.cc87 CancelIo(pipe_.Get());
91 if (pipe_.IsValid())
92 pipe_.Close();
158 if (!pipe_.IsValid())
163 BOOL ok = ReadFile(pipe_.Get(), buffer, buffer_len,
245 DCHECK(!pipe_.IsValid());
277 pipe_.Set(local_handle);
284 pipe_.Set(CreateNamedPipeW(pipe_name.c_str(),
295 pipe_.Set(CreateFileW(pipe_name.c_str(),
307 if (!pipe_
[all...]
H A Dipc_channel_posix.cc189 pipe_(-1),
236 DCHECK(server_listen_pipe_ == -1 && pipe_ == -1);
336 pipe_ = local_pipe;
341 if (server_listen_pipe_ == -1 && pipe_ == -1) {
389 if (pipe_ == -1)
462 fd_written = pipe_;
468 bytes_written = HANDLE_EINTR(write(pipe_, out_bytes, amt_to_write));
472 bytes_written = HANDLE_EINTR(sendmsg(pipe_, &msgh, MSG_DONTWAIT));
510 pipe_,
521 << " with type " << msg->type() << " on fd " << pipe_;
[all...]
H A Dipc_channel_nacl.h73 int pipe_; member in class:IPC::ChannelNacl
H A Dipc_channel_win.h77 base::win::ScopedHandle pipe_; member in class:IPC::ChannelWin
H A Dipc_channel_posix.h158 int pipe_; member in class:IPC::ChannelPosix
161 // pipe_ that is passed to the client.
/external/chromium_org/remoting/host/linux/
H A Daudio_pipe_reader.cc74 DCHECK_EQ(fd, pipe_.GetPlatformFile());
115 // If both |pipe_| and |new_pipe| are valid then compare inodes for the two
117 if (new_pipe.IsValid() && pipe_.IsValid()) {
120 if (fstat(pipe_.GetPlatformFile(), &old_stat) == 0 &&
130 pipe_ = new_pipe.Pass();
132 if (pipe_.IsValid()) {
134 if (HANDLE_EINTR(fcntl(pipe_.GetPlatformFile(), F_SETFL, O_NONBLOCK)) < 0) {
136 pipe_.Close();
142 pipe_.GetPlatformFile(), F_SETPIPE_SZ, kPipeBufferSizeBytes)) < 0) {
160 DCHECK(pipe_
[all...]
H A Daudio_pipe_reader.h81 base::File pipe_; member in class:remoting::AudioPipeReader
/external/chromium_org/native_client_sdk/src/libraries/nacl_io/pipe/
H A Dpipe_node.h31 ScopedPipeEventEmitter pipe_; member in class:nacl_io::PipeNode
H A Dpipe_node.cc23 : StreamNode(fs), pipe_(new PipeEventEmitter(kDefaultPipeSize)) {
27 return pipe_.get();
/external/chromium_org/mojo/spy/
H A Dspy_server_impl.cc36 BindToPipe(this, pipe_.handle0.Pass());
89 return ScopedMessagePipeHandle(pipe_.handle1.Pass()).Pass();
H A Dspy_server_impl.h52 MessagePipe pipe_; member in class:mojo::SpyServerImpl
/external/chromium_org/native_client_sdk/src/libraries/nacl_io/devfs/
H A Djspipe_node.h67 ScopedJSPipeEventEmitter pipe_; member in class:nacl_io::JSPipeNode
H A Djspipe_node.cc27 pipe_(new JSPipeEventEmitter(filesystem_->ppapi(),
32 return pipe_.get();
/external/chromium_org/sandbox/mac/
H A Dxpc_message_server_unittest.cc43 pipe_(NULL) {
47 if (pipe_)
48 xpc_release(pipe_);
66 pipe_ = xpc_pipe_create_from_port(server_.GetServerPort(), 0);
75 xpc_pipe_t pipe() { return pipe_; }
86 xpc_pipe_t pipe_; member in class:sandbox::BlockDemuxer
/external/chromium_org/remoting/host/win/
H A Dwts_session_process_delegate.cc130 base::win::ScopedHandle pipe_; member in class:remoting::WtsSessionProcessDelegate::Core
251 pipe_.Close();
260 pipe_.Close();
276 DCHECK(!pipe_.IsValid());
309 if (!get_named_pipe_client_pid_(pipe_.Get(), &pid)) {
348 DCHECK(!pipe_.IsValid());
424 pipe_ = pipe.Pass();
496 pipe_.Close();
/external/chromium_org/mojo/public/cpp/utility/tests/
H A Drun_loop_unittest.cc306 pipe_(NULL),
313 void set_pipe(MessagePipe* pipe) { pipe_ = pipe; }
319 EXPECT_EQ(handle.value(), pipe_->handle0.get().value());
345 pipe_->handle1.get(),
355 pipe_->handle0.get(),
364 MessagePipe* pipe_; member in class:mojo::__anon8799::NestingRunLoopHandler
/external/chromium_org/mojo/services/network/
H A Durl_loader_impl.cc65 : pipe_(pipe.Pass()), num_bytes_(0) {}
71 ReadDataRaw(pipe_.get(), NULL, &num_bytes_, MOJO_READ_DATA_FLAG_QUERY);
90 ReadDataRaw(pipe_.get(), buf->data(), &bytes_read,
99 ScopedDataPipeConsumerHandle pipe_; member in class:mojo::__anon8816::UploadDataPipeElementReader
/external/chromium_org/media/cast/test/utility/
H A Dudp_proxy.cc33 if (pipe_) {
34 pipe_->InitOnIOThread(task_runner, clock);
38 if (pipe_) {
39 pipe_->AppendToPipe(pipe.Pass());
41 pipe_ = pipe.Pass();
95 pipe_->Send(packet.Pass());
121 pipe_->Send(packet.Pass());
152 pipe_->Send(packet.Pass());
197 pipe_->Send(scoped_ptr<Packet>(new Packet(*packet.get())));
269 pipe_
[all...]
H A Dudp_proxy.h43 scoped_ptr<PacketPipe> pipe_; member in class:media::cast::test::PacketPipe
H A Dudp_proxy_main.cc74 pipe_->Send(packet.Pass());
/external/chromium_org/third_party/mesa/src/src/gallium/targets/pipe-loader/
H A DMakefile8 PIPE_PREFIX ?= pipe_
147 $(PIPE_TARGETS_CC): $(PIPE_PREFIX)%.so: pipe_%.o $(PIPE_LIBS) $$(%_LIBS)
154 $(PIPE_TARGETS_CXX): $(PIPE_PREFIX)%.so: pipe_%.o $(PIPE_LIBS) $$(%_LIBS)
/external/mesa3d/src/gallium/targets/pipe-loader/
H A DMakefile8 PIPE_PREFIX ?= pipe_
147 $(PIPE_TARGETS_CC): $(PIPE_PREFIX)%.so: pipe_%.o $(PIPE_LIBS) $$(%_LIBS)
154 $(PIPE_TARGETS_CXX): $(PIPE_PREFIX)%.so: pipe_%.o $(PIPE_LIBS) $$(%_LIBS)

Completed in 1042 milliseconds

12