/external/chromium_org/ipc/mojo/ |
H A D | ipc_message_pipe_reader.cc | 19 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 D | ipc_message_pipe_reader.h | 51 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 D | ipc_channel_nacl.cc | 86 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 D | ipc_channel_win.cc | 87 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 D | ipc_channel_posix.cc | 189 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 D | ipc_channel_nacl.h | 73 int pipe_; member in class:IPC::ChannelNacl
|
H A D | ipc_channel_win.h | 77 base::win::ScopedHandle pipe_; member in class:IPC::ChannelWin
|
H A D | ipc_channel_posix.h | 158 int pipe_; member in class:IPC::ChannelPosix 161 // pipe_ that is passed to the client.
|
/external/chromium_org/remoting/host/linux/ |
H A D | audio_pipe_reader.cc | 74 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 D | audio_pipe_reader.h | 81 base::File pipe_; member in class:remoting::AudioPipeReader
|
/external/chromium_org/native_client_sdk/src/libraries/nacl_io/pipe/ |
H A D | pipe_node.h | 31 ScopedPipeEventEmitter pipe_; member in class:nacl_io::PipeNode
|
H A D | pipe_node.cc | 23 : StreamNode(fs), pipe_(new PipeEventEmitter(kDefaultPipeSize)) { 27 return pipe_.get();
|
/external/chromium_org/mojo/spy/ |
H A D | spy_server_impl.cc | 36 BindToPipe(this, pipe_.handle0.Pass()); 89 return ScopedMessagePipeHandle(pipe_.handle1.Pass()).Pass();
|
H A D | spy_server_impl.h | 52 MessagePipe pipe_; member in class:mojo::SpyServerImpl
|
/external/chromium_org/native_client_sdk/src/libraries/nacl_io/devfs/ |
H A D | jspipe_node.h | 67 ScopedJSPipeEventEmitter pipe_; member in class:nacl_io::JSPipeNode
|
H A D | jspipe_node.cc | 27 pipe_(new JSPipeEventEmitter(filesystem_->ppapi(), 32 return pipe_.get();
|
/external/chromium_org/sandbox/mac/ |
H A D | xpc_message_server_unittest.cc | 43 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 D | wts_session_process_delegate.cc | 130 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 D | run_loop_unittest.cc | 306 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 D | url_loader_impl.cc | 65 : 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 D | udp_proxy.cc | 33 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 D | udp_proxy.h | 43 scoped_ptr<PacketPipe> pipe_; member in class:media::cast::test::PacketPipe
|
H A D | udp_proxy_main.cc | 74 pipe_->Send(packet.Pass());
|
/external/chromium_org/third_party/mesa/src/src/gallium/targets/pipe-loader/ |
H A D | Makefile | 8 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 D | Makefile | 8 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)
|