pipe 2477 base/file_util_unittest.cc ASSERT_EQ(0, pipe(fds)); pipe 2501 base/file_util_unittest.cc ASSERT_EQ(0, pipe(fds)); pipe 225 base/files/file_path_watcher_linux.cc if (inotify_fd_ >= 0 && pipe(shutdown_pipe_) == 0 && thread_.Start()) { pipe 63 base/mac/authorization_util.h FILE** pipe, pipe 76 base/mac/authorization_util.h FILE** pipe, pipe 783 base/message_loop/message_loop_unittest.cc int err = pipe(pipefds); pipe 808 base/message_loop/message_loop_unittest.cc int err = pipe(pipefds); pipe 144 base/message_loop/message_pump_glib.cc int ret = pipe(fds); pipe 27 base/message_loop/message_pump_io_ios_unittest.cc int ret = pipe(pipefds_); pipe 29 base/message_loop/message_pump_io_ios_unittest.cc ret = pipe(alternate_pipefds_); pipe 315 base/message_loop/message_pump_libevent.cc if (pipe(fds)) { pipe 28 base/message_loop/message_pump_libevent_unittest.cc int ret = pipe(pipefds_); pipe 512 base/process/launch_posix.cc if (pipe(pipe_fd) < 0) pipe 503 base/process/process_util_unittest.cc if (pipe(fds) < 0) pipe 577 base/process/process_util_unittest.cc PCHECK(pipe(fds) == 0); pipe 353 base/test/launcher/test_launcher.cc CHECK_EQ(0, pipe(g_shutdown_pipe)); pipe 310 chrome/browser/chrome_browser_main_posix.cc int ret = pipe(pipefd); pipe 223 chrome/browser/extensions/api/messaging/native_message_process_host_unittest.cc ASSERT_EQ(0, pipe(pipe_handles)); pipe 58 chrome/browser/extensions/api/messaging/native_process_launcher_posix.cc if (HANDLE_EINTR(pipe(read_pipe_fds)) != 0) { pipe 67 chrome/browser/extensions/api/messaging/native_process_launcher_posix.cc if (HANDLE_EINTR(pipe(write_pipe_fds)) != 0) { pipe 125 chrome/browser/mac/relauncher.cc if (HANDLE_EINTR(pipe(pipe_fds)) != 0) { pipe 103 chrome/browser/process_info_snapshot_mac_unittest.cc PCHECK(pipe(fds) == 0); pipe 177 chrome/common/service_process_util_posix.cc if (pipe(state_->sockets_) < 0) { pipe 87 chrome/test/security_tests/ipc_security_tests.cc HANDLE pipe = ::CreateNamedPipeW(pipe_name, PIPE_ACCESS_DUPLEX, pipe 90 chrome/test/security_tests/ipc_security_tests.cc if (INVALID_HANDLE_VALUE == pipe) { pipe 93 chrome/test/security_tests/ipc_security_tests.cc return pipe; pipe 104 chrome/test/security_tests/ipc_security_tests.cc HANDLE pipe; pipe 105 chrome/test/security_tests/ipc_security_tests.cc explicit Context(HANDLE arg_pipe) : pipe(arg_pipe) { pipe 114 chrome/test/security_tests/ipc_security_tests.cc ::DisconnectNamedPipe(context->pipe); pipe 124 chrome/test/security_tests/ipc_security_tests.cc HANDLE server_pipe = context->pipe; pipe 35 chromeos/dbus/pipe_reader.cc const int status = HANDLE_EINTR(pipe(pipe_fds)); pipe 105 chromeos/process_proxy/process_output_watcher_unittest.cc ASSERT_FALSE(HANDLE_EINTR(pipe(pt_pipe))); pipe 106 chromeos/process_proxy/process_output_watcher_unittest.cc ASSERT_FALSE(HANDLE_EINTR(pipe(stop_pipe))); pipe 74 chromeos/process_proxy/process_proxy.cc if (pipe(shutdown_pipe_)) pipe 240 chromeos/process_proxy/process_proxy.cc void ProcessProxy::CloseFdPair(int* pipe) { pipe 241 chromeos/process_proxy/process_proxy.cc CloseFd(&(pipe[PIPE_END_READ])); pipe 242 chromeos/process_proxy/process_proxy.cc CloseFd(&(pipe[PIPE_END_WRITE])); pipe 258 chromeos/process_proxy/process_proxy.cc void ProcessProxy::ClearFdPair(int* pipe) { pipe 259 chromeos/process_proxy/process_proxy.cc pipe[PIPE_END_READ] = kInvalidFd; pipe 260 chromeos/process_proxy/process_proxy.cc pipe[PIPE_END_WRITE] = kInvalidFd; pipe 75 chromeos/process_proxy/process_proxy.h void CloseFdPair(int* pipe); pipe 80 chromeos/process_proxy/process_proxy.h void ClearFdPair(int* pipe); pipe 112 cloud_print/service/win/setup_listener.cc base::win::ScopedHandle pipe( pipe 119 cloud_print/service/win/setup_listener.cc if (pipe.IsValid()) { pipe 120 cloud_print/service/win/setup_listener.cc channel_.reset(new IPC::Channel(IPC::ChannelHandle(pipe), pipe 743 content/browser/renderer_host/render_sandbox_host_linux.cc CHECK(0 == pipe(pipefds)); pipe 107 content/browser/webui/web_ui_mojo_browsertest.cc mojo::InterfacePipe<mojo::BrowserTarget, mojo::RendererTarget> pipe; pipe 109 content/browser/webui/web_ui_mojo_browsertest.cc new BrowserTargetImpl(pipe.handle_to_peer.Pass(), run_loop_)); pipe 111 content/browser/webui/web_ui_mojo_browsertest.cc mojo::ScopedMessagePipeHandle(pipe.handle_to_self.release())); pipe 70 content/renderer/media/android/audio_decoder_android.cc if (pipe(pipefd)) pipe 321 content/zygote/zygote_linux.cc if (pipe(pipe_fds) != 0) { pipe 45 ipc/ipc_channel_handle.h explicit ChannelHandle(HANDLE h) : pipe(h) {} pipe 61 ipc/ipc_channel_handle.h PipeHandle pipe; pipe 34 ipc/ipc_channel_nacl.cc bool ReadDataOnReaderThread(int pipe, MessageContents* contents) { pipe 35 ipc/ipc_channel_nacl.cc DCHECK(pipe >= 0); pipe 36 ipc/ipc_channel_nacl.cc if (pipe < 0) pipe 47 ipc/ipc_channel_nacl.cc int bytes_read = imc_recvmsg(pipe, &msg, 0); pipe 76 ipc/ipc_channel_nacl.cc int pipe, pipe 95 ipc/ipc_channel_nacl.cc int pipe, pipe 99 ipc/ipc_channel_nacl.cc : pipe_(pipe), pipe 155 ipc/ipc_channel_unittest.cc HANDLE pipe = CreateNamedPipeA(name.c_str(), pipe 164 ipc/ipc_channel_unittest.cc CreateChannelFromChannelHandle(IPC::ChannelHandle(pipe), &listener); pipe 165 ipc/ipc_channel_unittest.cc CloseHandle(pipe); // The channel duplicates the handle. pipe 209 ipc/ipc_channel_win.cc if (channel_handle.pipe.handle) { pipe 216 ipc/ipc_channel_win.cc GetNamedPipeInfo(channel_handle.pipe.handle, &flags, NULL, NULL, NULL); pipe 224 ipc/ipc_channel_win.cc channel_handle.pipe.handle, pipe 234 ipc/ipc_channel_win.cc DCHECK(!channel_handle.pipe.handle); pipe 248 ipc/ipc_channel_win.cc DCHECK(!channel_handle.pipe.handle); pipe 660 ipc/ipc_message_utils.cc DCHECK(p.pipe.handle == NULL); pipe 30 media/cast/test/utility/udp_proxy.cc void PacketPipe::AppendToPipe(scoped_ptr<PacketPipe> pipe) { pipe 32 media/cast/test/utility/udp_proxy.cc pipe_->AppendToPipe(pipe.Pass()); pipe 34 media/cast/test/utility/udp_proxy.cc pipe_ = pipe.Pass(); pipe 341 media/cast/test/utility/udp_proxy.cc virtual void AppendToPipe(scoped_ptr<PacketPipe> pipe) OVERRIDE { pipe 359 media/cast/test/utility/udp_proxy.cc void BuildPipe(scoped_ptr<PacketPipe>* pipe, PacketPipe* next) { pipe 360 media/cast/test/utility/udp_proxy.cc if (*pipe) { pipe 361 media/cast/test/utility/udp_proxy.cc (*pipe)->AppendToPipe(scoped_ptr<PacketPipe>(next).Pass()); pipe 363 media/cast/test/utility/udp_proxy.cc pipe->reset(next); pipe 370 media/cast/test/utility/udp_proxy.cc scoped_ptr<PacketPipe> pipe; pipe 371 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new Buffer(256 << 10, 5000000)); pipe 372 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomDrop(0.005)); pipe 374 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new ConstantDelay(1E-3)); pipe 375 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomSortedDelay(1E-3, 20E-3, 3)); pipe 376 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new Buffer(256 << 10, 5000000)); pipe 377 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new ConstantDelay(1E-3)); pipe 378 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomSortedDelay(1E-3, 20E-3, 3)); pipe 379 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomDrop(0.005)); pipe 381 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new Buffer(256 << 10, 5000000)); pipe 382 media/cast/test/utility/udp_proxy.cc return pipe.Pass(); pipe 387 media/cast/test/utility/udp_proxy.cc scoped_ptr<PacketPipe> pipe; pipe 388 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new Buffer(4 << 10, 2000000)); pipe 390 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomDrop(0.1)); // 10% packet drop pipe 391 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomSortedDelay(20E-3, 60E-3, 1)); pipe 392 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new Buffer(4 << 10, 1000000)); // 4 kb buf, 1mbit/s pipe 393 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomDrop(0.1)); // 10% packet drop pipe 394 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new ConstantDelay(1E-3)); pipe 395 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new NetworkGlitchPipe(2.0, 0.3)); pipe 396 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new RandomUnsortedDelay(20E-3)); pipe 398 media/cast/test/utility/udp_proxy.cc BuildPipe(&pipe, new Buffer(4 << 10, 2000000)); // 4 kb buf, 2mbit/s pipe 399 media/cast/test/utility/udp_proxy.cc return pipe.Pass(); pipe 31 media/cast/test/utility/udp_proxy.h virtual void AppendToPipe(scoped_ptr<PacketPipe> pipe); pipe 189 media/midi/midi_manager_alsa.cc if (pipe(pipe_fd_) < 0) { pipe 25 mojo/apps/js/main.cc void Start(MojoHandle pipe, const std::string& module) { pipe 31 mojo/apps/js/main.cc delegate.Start(&runner, pipe, module); pipe 39 mojo/apps/js/main.cc extern "C" MOJO_APPS_JS_EXPORT MojoResult CDECL MojoMain(MojoHandle pipe) { pipe 41 mojo/apps/js/main.cc mojo::apps::Start(pipe, "mojo/apps/js/main"); pipe 37 mojo/apps/js/mojo_runner_delegate.cc MojoHandle pipe, pipe 44 mojo/apps/js/mojo_runner_delegate.cc gin::ConvertToV8(isolate, mojo::Handle(pipe)) }; pipe 65 mojo/apps/js/mojo_runner_delegate.cc MojoHandle pipe, pipe 71 mojo/apps/js/mojo_runner_delegate.cc base::Bind(StartCallback, runner->GetWeakPtr(), pipe)); pipe 20 mojo/apps/js/mojo_runner_delegate.h void Start(gin::Runner* runner, MojoHandle pipe, const std::string& module); pipe 120 mojo/examples/aura_demo/aura_demo.cc InterfacePipe<NativeViewport, AnyInterface> pipe; pipe 124 mojo/examples/aura_demo/aura_demo.cc pipe.handle_to_peer.Pass()); pipe 126 mojo/examples/aura_demo/aura_demo.cc pipe.handle_to_self.Pass(), pipe 202 mojo/examples/launcher/launcher.cc InterfacePipe<NativeViewport, AnyInterface> pipe; pipe 206 mojo/examples/launcher/launcher.cc pipe.handle_to_peer.Pass()); pipe 209 mojo/examples/launcher/launcher.cc pipe.handle_to_self.Pass(), gfx::Rect(50, 50, 450, 60), pipe 28 mojo/examples/pepper_container_app/graphics_3d_resource.cc ScopedMessagePipeHandle pipe = MojoPpapiGlobals::Get()->CreateGLES2Context(); pipe 29 mojo/examples/pepper_container_app/graphics_3d_resource.cc context_ = MojoGLES2CreateContext(pipe.release().value(), pipe 24 mojo/examples/sample_app/gles2_client_impl.cc GLES2ClientImpl::GLES2ClientImpl(ScopedMessagePipeHandle pipe) pipe 27 mojo/examples/sample_app/gles2_client_impl.cc pipe.release().value(), pipe 20 mojo/examples/sample_app/gles2_client_impl.h explicit GLES2ClientImpl(ScopedMessagePipeHandle pipe); pipe 71 mojo/examples/view_manager/view_manager.cc InterfacePipe<View> pipe; pipe 72 mojo/examples/view_manager/view_manager.cc views_.push_back(new ViewImpl(pipe.handle_to_peer.Pass())); pipe 73 mojo/examples/view_manager/view_manager.cc callback.Run(pipe.handle_to_self.Pass()); pipe 105 mojo/examples/view_manager/view_manager.cc InterfacePipe<NativeViewport, AnyInterface> pipe; pipe 109 mojo/examples/view_manager/view_manager.cc pipe.handle_to_peer.Pass()); pipe 111 mojo/examples/view_manager/view_manager.cc native_viewport_.reset(pipe.handle_to_self.Pass(), this); pipe 120 mojo/examples/view_manager/view_manager.cc InterfacePipe<Launcher, AnyInterface> pipe; pipe 123 mojo/examples/view_manager/view_manager.cc shell()->Connect("mojo:mojo_launcher", pipe.handle_to_peer.Pass()); pipe 125 mojo/examples/view_manager/view_manager.cc launcher_.reset(pipe.handle_to_self.Pass(), this); pipe 27 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc ScopedMessagePipeHandle pipe) MOJO_OVERRIDE { pipe 29 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc if (pipe.is_valid()) pipe 30 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc EXPECT_TRUE(ReadTextMessage(pipe.get(), &text1)); pipe 33 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc if (request.pipe().is_valid()) { pipe 34 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc EXPECT_TRUE(ReadTextMessage(request.pipe().get(), &text2)); pipe 37 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc EXPECT_TRUE(request.pipe().is_valid()); pipe 53 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc virtual void DoStuff2(ScopedDataPipeConsumerHandle pipe) MOJO_OVERRIDE { pipe 56 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc ASSERT_TRUE(pipe.is_valid()); pipe 59 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc ReadDataRaw(pipe.get(), NULL, &data_size, pipe 65 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc ReadDataRaw(pipe.get(), data, &data_size, pipe 146 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc if (response.pipe().is_valid()) { pipe 148 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc EXPECT_TRUE(ReadTextMessage(response.pipe().get(), &text2)); pipe 151 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc EXPECT_TRUE(response.pipe().is_valid()); pipe 156 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc ScopedMessagePipeHandle p = response.pipe().Pass(); pipe 158 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc EXPECT_FALSE(response.pipe().is_valid()); pipe 189 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc InterfacePipe<sample::Factory> pipe; pipe 191 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc SampleFactoryImpl factory(pipe.handle_to_peer.Pass()); pipe 192 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc SampleFactoryClientImpl factory_client(pipe.handle_to_self.Pass()); pipe 204 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc InterfacePipe<sample::Factory> pipe; pipe 206 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc SampleFactoryImpl factory(pipe.handle_to_peer.Pass()); pipe 207 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc SampleFactoryClientImpl factory_client(pipe.handle_to_self.Pass()); pipe 220 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc InterfacePipe<sample::Factory> pipe; pipe 222 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc SampleFactoryImpl factory(pipe.handle_to_peer.Pass()); pipe 223 mojo/public/cpp/bindings/tests/handle_passing_unittest.cc SampleFactoryClientImpl factory_client(pipe.handle_to_self.Pass()); pipe 224 mojo/public/cpp/bindings/tests/remote_ptr_unittest.cc InterfacePipe<sample::Port, NoInterface> pipe; pipe 225 mojo/public/cpp/bindings/tests/remote_ptr_unittest.cc RemotePtr<sample::Port> port(pipe.handle_to_self.Pass(), NULL); pipe 87 mojo/public/cpp/bindings/tests/request_response_unittest.cc InterfacePipe<sample::Provider> pipe; pipe 88 mojo/public/cpp/bindings/tests/request_response_unittest.cc ProviderImpl provider_impl(pipe.handle_to_peer.Pass()); pipe 89 mojo/public/cpp/bindings/tests/request_response_unittest.cc RemotePtr<sample::Provider> provider(pipe.handle_to_self.Pass(), NULL); pipe 103 mojo/public/cpp/bindings/tests/request_response_unittest.cc InterfacePipe<sample::Provider> pipe; pipe 104 mojo/public/cpp/bindings/tests/request_response_unittest.cc ProviderImpl provider_impl(pipe.handle_to_peer.Pass()); pipe 105 mojo/public/cpp/bindings/tests/request_response_unittest.cc RemotePtr<sample::Provider> provider(pipe.handle_to_self.Pass(), NULL); pipe 119 mojo/public/cpp/bindings/tests/request_response_unittest.cc InterfacePipe<sample::Provider> pipe; pipe 120 mojo/public/cpp/bindings/tests/request_response_unittest.cc ProviderImpl provider_impl(pipe.handle_to_peer.Pass()); pipe 121 mojo/public/cpp/bindings/tests/request_response_unittest.cc RemotePtr<sample::Provider> provider(pipe.handle_to_self.Pass(), NULL); pipe 310 mojo/public/cpp/bindings/tests/sample_service_unittest.cc mojo::InterfacePipe<Port, mojo::AnyInterface> pipe; pipe 311 mojo/public/cpp/bindings/tests/sample_service_unittest.cc service->Frobinate(foo, Service::BAZ_EXTRA, pipe.handle_to_self.Pass()); pipe 29 mojo/service_manager/service_manager.cc InterfacePipe<Shell> pipe; pipe 30 mojo/service_manager/service_manager.cc shell_client_.reset(pipe.handle_to_peer.Pass(), this, this); pipe 33 mojo/service_manager/service_manager.cc pipe.handle_to_self.Pass()); pipe 87 mojo/service_manager/service_manager_unittest.cc InterfacePipe<TestService, AnyInterface> pipe; pipe 88 mojo/service_manager/service_manager_unittest.cc test_client_.reset(new TestClientImpl(pipe.handle_to_self.Pass())); pipe 89 mojo/service_manager/service_manager_unittest.cc service_manager_->Connect(test_url, pipe.handle_to_peer.Pass()); pipe 202 native_client_sdk/src/libraries/nacl_io/kernel_intercept.cc return s_state.kp->pipe(pipefds); pipe 209 native_client_sdk/src/libraries/nacl_io/kernel_proxy.cc PipeNode* pipe = new PipeNode(stream_mount_.get()); pipe 210 native_client_sdk/src/libraries/nacl_io/kernel_proxy.cc ScopedNode node(pipe); pipe 212 native_client_sdk/src/libraries/nacl_io/kernel_proxy.cc if (pipe->Init(O_RDWR) == 0) { pipe 62 native_client_sdk/src/libraries/nacl_io/kernel_proxy.h virtual int pipe(int pipefds[2]); pipe 165 native_client_sdk/src/tests/nacl_io_test/event_test.cc PipeEventEmitter pipe(32); pipe 169 native_client_sdk/src/tests/nacl_io_test/event_test.cc EventListenerLock locker(&pipe); pipe 175 native_client_sdk/src/tests/nacl_io_test/event_test.cc EventListenerLock locker(&pipe); pipe 177 native_client_sdk/src/tests/nacl_io_test/event_test.cc EXPECT_EQ(sizeof(hello), pipe.Write_Locked(hello, sizeof(hello))); pipe 182 native_client_sdk/src/tests/nacl_io_test/event_test.cc EventListenerLock locker(&pipe); pipe 184 native_client_sdk/src/tests/nacl_io_test/event_test.cc EXPECT_EQ(sizeof(hello), pipe.Read_Locked(tmp, sizeof(tmp))); pipe 200 native_client_sdk/src/tests/nacl_io_test/event_test.cc ScopedRef<PipeNode> pipe(pipe_node); pipe 268 native_client_sdk/src/tests/nacl_io_test/event_test.cc ASSERT_EQ(0, kp->pipe(fds)); pipe 301 native_client_sdk/src/tests/nacl_io_test/event_test.cc ASSERT_EQ(0, kp->pipe(fds)); pipe 398 native_client_sdk/src/tests/nacl_io_test/kernel_wrap_test.cc TEST_F(KernelWrapTest, pipe) { pipe 400 native_client_sdk/src/tests/nacl_io_test/kernel_wrap_test.cc EXPECT_CALL(mock, pipe(fds)).WillOnce(Return(kDummyInt)); pipe 401 native_client_sdk/src/tests/nacl_io_test/kernel_wrap_test.cc EXPECT_EQ(kDummyInt, pipe(fds)); pipe 52 native_client_sdk/src/tests/nacl_io_test/mock_kernel_proxy.h MOCK_METHOD1(pipe, int(int[2])); pipe 118 net/test/spawned_test_server/local_test_server_posix.cc if (pipe(pipefd) != 0) { pipe 109 net/third_party/nss/ssl/sslmutex.c err = pipe(pMutex->u.pipeStr.mPipes); pipe 895 net/tools/dump_cache/upgrade_win.cc int UpgradeCache(const base::FilePath& output_path, HANDLE pipe) { pipe 898 net/tools/dump_cache/upgrade_win.cc MasterSM master(output_path, pipe); pipe 913 net/tools/dump_cache/upgrade_win.cc base::win::ScopedHandle pipe(OpenServer(pipe_number)); pipe 914 net/tools/dump_cache/upgrade_win.cc if (!pipe.IsValid()) { pipe 919 net/tools/dump_cache/upgrade_win.cc SlaveSM slave(input_path, pipe); pipe 16 net/tools/dump_cache/upgrade_win.h int UpgradeCache(const base::FilePath& output_path, HANDLE pipe); pipe 97 net/tools/epoll_server/epoll_server.cc if (pipe(pipe_fds) < 0) { pipe 243 remoting/host/desktop_session_proxy.cc base::win::ScopedHandle pipe(temp_handle); pipe 245 remoting/host/desktop_session_proxy.cc IPC::ChannelHandle desktop_channel_handle(pipe); pipe 48 remoting/host/ipc_util_win.cc ScopedHandle pipe; pipe 49 remoting/host/ipc_util_win.cc if (!CreateIpcChannel(channel_name, security_descriptor, &pipe)) { pipe 55 remoting/host/ipc_util_win.cc IPC::ChannelHandle(pipe), pipe 113 remoting/host/ipc_util_win.cc base::win::ScopedHandle pipe; pipe 114 remoting/host/ipc_util_win.cc pipe.Set(CreateNamedPipe( pipe 123 remoting/host/ipc_util_win.cc if (!pipe.IsValid()) { pipe 129 remoting/host/ipc_util_win.cc *pipe_out = pipe.Pass(); pipe 89 remoting/host/posix/signal_handler.cc int result = pipe(pipe_fd); pipe 370 remoting/host/remoting_me2me_host.cc base::win::ScopedHandle pipe(reinterpret_cast<HANDLE>(pipe_handle)); pipe 371 remoting/host/remoting_me2me_host.cc IPC::ChannelHandle channel_handle(pipe); pipe 373 remoting/host/remoting_me2me_host.cc base::FileDescriptor pipe(pipe_handle, true); pipe 374 remoting/host/remoting_me2me_host.cc IPC::ChannelHandle channel_handle(channel_name, pipe); pipe 21 remoting/host/setup/test_util.cc if (pipe(fds) == 0) { pipe 89 remoting/host/win/launch_process_with_token.cc base::win::ScopedHandle pipe; pipe 91 remoting/host/win/launch_process_with_token.cc pipe.Set(CreateFile(pipe_name.c_str(), pipe 98 remoting/host/win/launch_process_with_token.cc if (pipe.IsValid()) { pipe 114 remoting/host/win/launch_process_with_token.cc if (!pipe.IsValid()) { pipe 119 remoting/host/win/launch_process_with_token.cc *pipe_out = pipe.Pass(); pipe 256 remoting/host/win/launch_process_with_token.cc HANDLE pipe, pipe 267 remoting/host/win/launch_process_with_token.cc if (!ReadFile(pipe, &response, sizeof(response), &bytes, NULL)) { pipe 290 remoting/host/win/launch_process_with_token.cc HANDLE pipe, pipe 361 remoting/host/win/launch_process_with_token.cc if (!WriteFile(pipe, buffer.get(), size, &bytes, NULL)) { pipe 382 remoting/host/win/launch_process_with_token.cc base::win::ScopedHandle pipe; pipe 383 remoting/host/win/launch_process_with_token.cc if (!ConnectToExecutionServer(session_id, &pipe)) pipe 386 remoting/host/win/launch_process_with_token.cc if (!SendCreateProcessRequest(pipe, application_name, command_line, pipe 392 remoting/host/win/launch_process_with_token.cc if (!ReceiveCreateProcessResponse(pipe, &process_information)) pipe 360 remoting/host/win/worker_process_launcher_unittest.cc ScopedHandle pipe; pipe 361 remoting/host/win/worker_process_launcher_unittest.cc ASSERT_TRUE(CreateIpcChannel(channel_name_, kIpcSecurityDescriptor, &pipe)); pipe 365 remoting/host/win/worker_process_launcher_unittest.cc IPC::ChannelHandle(pipe), pipe 375 remoting/host/win/wts_session_process_delegate.cc ScopedHandle pipe; pipe 376 remoting/host/win/wts_session_process_delegate.cc if (!CreateIpcChannel(channel_name, channel_security_, &pipe)) { pipe 383 remoting/host/win/wts_session_process_delegate.cc IPC::ChannelHandle(pipe), pipe 425 remoting/host/win/wts_session_process_delegate.cc pipe_ = pipe.Pass(); pipe 242 sandbox/linux/seccomp-bpf/sandbox_bpf_unittest.cc BPF_ASSERT(pipe(fds) == 0); pipe 243 sandbox/linux/seccomp-bpf/sandbox_bpf_unittest.cc BPF_ASSERT(pipe(fds + 2) == 0); pipe 608 sandbox/linux/seccomp-bpf/sandbox_bpf_unittest.cc BPF_ASSERT(pipe(fds) == 0); pipe 38 sandbox/linux/services/scoped_process.cc PCHECK(0 == pipe(pipe_fds_)); pipe 76 sandbox/linux/services/scoped_process_unittest.cc ASSERT_EQ(0, pipe(pipe_fds)); pipe 111 sandbox/linux/services/scoped_process_unittest.cc ASSERT_EQ(0, pipe(pipe_fds)); pipe 124 sandbox/linux/tests/unit_tests.cc ASSERT_EQ(0, pipe(fds)); pipe 139 sandbox/win/sandbox_poc/sandbox.cc HANDLE pipe = ::CreateFile(log_file.c_str(), pipe 147 sandbox/win/sandbox_poc/sandbox.cc if (INVALID_HANDLE_VALUE == pipe) { pipe 167 sandbox/win/sandbox_poc/sandbox.cc CloseHandle(pipe); pipe 172 sandbox/win/sandbox_poc/sandbox.cc init_function(pipe); pipe 174 sandbox/win/sandbox_poc/sandbox.cc CloseHandle(pipe); pipe 81 sandbox/win/src/named_pipe_dispatcher.cc HANDLE pipe; pipe 87 sandbox/win/src/named_pipe_dispatcher.cc default_timeout, &pipe); pipe 90 sandbox/win/src/named_pipe_dispatcher.cc ipc->return_info.handle = pipe; pipe 23 sandbox/win/src/named_pipe_interception.cc HANDLE pipe = orig_CreateNamedPipeW(pipe_name, open_mode, pipe_mode, pipe 27 sandbox/win/src/named_pipe_interception.cc if (INVALID_HANDLE_VALUE != pipe) pipe 28 sandbox/win/src/named_pipe_interception.cc return pipe; pipe 23 sandbox/win/src/named_pipe_policy.cc HANDLE pipe = ::CreateNamedPipeW(pipe_name, open_mode, pipe_mode, pipe 27 sandbox/win/src/named_pipe_policy.cc if (INVALID_HANDLE_VALUE == pipe) pipe 28 sandbox/win/src/named_pipe_policy.cc return pipe; pipe 31 sandbox/win/src/named_pipe_policy.cc if (!::DuplicateHandle(::GetCurrentProcess(), pipe, pipe 51 sandbox/win/src/named_pipe_policy.cc PolicyRule pipe(ASK_BROKER); pipe 52 sandbox/win/src/named_pipe_policy.cc if (!pipe.AddStringMatch(IF, NameBased::NAME, name, CASE_INSENSITIVE)) { pipe 55 sandbox/win/src/named_pipe_policy.cc if (!policy->AddRule(IPC_CREATENAMEDPIPEW_TAG, &pipe)) { pipe 69 sandbox/win/src/named_pipe_policy.cc HANDLE* pipe) { pipe 75 sandbox/win/src/named_pipe_policy.cc *pipe = CreateNamedPipeHelper(client_info.process, name.c_str(), pipe 80 sandbox/win/src/named_pipe_policy.cc if (INVALID_HANDLE_VALUE == *pipe) pipe 40 sandbox/win/src/named_pipe_policy.h DWORD default_timeout, HANDLE* pipe); pipe 24 sandbox/win/src/named_pipe_policy_test.cc HANDLE pipe = ::CreateNamedPipeW(argv[0], pipe 28 sandbox/win/src/named_pipe_policy_test.cc if (INVALID_HANDLE_VALUE == pipe) pipe 35 sandbox/win/src/named_pipe_policy_test.cc if (GetHandleName(pipe, &handle_name)) { pipe 45 sandbox/win/src/named_pipe_policy_test.cc BOOL result = ::ConnectNamedPipe(pipe, &overlapped); pipe 55 sandbox/win/src/named_pipe_policy_test.cc if (!::CloseHandle(pipe)) pipe 170 third_party/libevent/test/bench.c if (pipe(cp) == -1) { pipe 967 third_party/libusb/src/libusb/os/darwin_usb.c pipe (priv->fds); pipe 43 third_party/libusb/src/libusb/os/openbsd_usb.c int pipe[2]; /* for event notification */ pipe 259 third_party/libusb/src/libusb/os/openbsd_usb.c if (pipe(hpriv->pipe) < 0) pipe 262 third_party/libusb/src/libusb/os/openbsd_usb.c return usbi_add_pollfd(HANDLE_CTX(handle), hpriv->pipe[0], POLLIN); pipe 278 third_party/libusb/src/libusb/os/openbsd_usb.c usbi_remove_pollfd(HANDLE_CTX(handle), hpriv->pipe[0]); pipe 280 third_party/libusb/src/libusb/os/openbsd_usb.c close(hpriv->pipe[0]); pipe 281 third_party/libusb/src/libusb/os/openbsd_usb.c close(hpriv->pipe[1]); pipe 509 third_party/libusb/src/libusb/os/openbsd_usb.c if (write(hpriv->pipe[1], &itransfer, sizeof(itransfer)) < 0) pipe 556 third_party/libusb/src/libusb/os/openbsd_usb.c if (hpriv->pipe[0] == pollfd->fd) pipe 569 third_party/libusb/src/libusb/os/openbsd_usb.c usbi_remove_pollfd(HANDLE_CTX(handle), hpriv->pipe[0]); pipe 574 third_party/libusb/src/libusb/os/openbsd_usb.c if (read(hpriv->pipe[0], &itransfer, sizeof(itransfer)) < 0) { pipe 30 third_party/libusb/src/libusb/os/poll_posix.c int ret = pipe(pipefd); pipe 298 third_party/protobuf/src/google/protobuf/compiler/subprocess.cc GOOGLE_CHECK(pipe(stdin_pipe) != -1); pipe 299 third_party/protobuf/src/google/protobuf/compiler/subprocess.cc GOOGLE_CHECK(pipe(stdout_pipe) != -1); pipe 818 third_party/protobuf/src/google/protobuf/io/zero_copy_stream_unittest.cc ASSERT_EQ(pipe(files), 0); pipe 45 third_party/talloc/libreplace/socketpair.c return pipe(sv); pipe 2214 third_party/tcmalloc/chromium/src/base/linux_syscall_support.h LSS_INLINE int LSS_NAME(pipe)(int *p) { pipe 2233 third_party/tcmalloc/chromium/src/base/linux_syscall_support.h LSS_INLINE _syscall1(int, pipe, int *, p) pipe 2118 third_party/tcmalloc/vendor/src/base/linux_syscall_support.h LSS_INLINE int LSS_NAME(pipe)(int *p) { pipe 2137 third_party/tcmalloc/vendor/src/base/linux_syscall_support.h LSS_INLINE _syscall1(int, pipe, int *, p) pipe 112 tools/android/file_poller/file_poller.cc pipe(pipes); pipe 20 tools/android/forwarder2/pipe_notifier.cc int ret = pipe(pipe_fd); pipe 159 tools/gn/function_exec_script.cc if (pipe(pipe_fd) < 0) pipe 183 tools/win/link_limiter/limiter.cc HANDLE pipe = INVALID_HANDLE_VALUE; pipe 185 tools/win/link_limiter/limiter.cc pipe = CreateNamedPipe( pipe 194 tools/win/link_limiter/limiter.cc if (pipe != INVALID_HANDLE_VALUE) pipe 213 tools/win/link_limiter/limiter.cc return pipe; pipe 233 tools/win/link_limiter/limiter.cc HANDLE pipe = pipe 245 tools/win/link_limiter/limiter.cc if (pipe != INVALID_HANDLE_VALUE) pipe 246 tools/win/link_limiter/limiter.cc CloseHandle(pipe); pipe 57 ui/events/ozone/evdev/key_event_converter_evdev_unittest.cc if (pipe(evdev_io)) pipe 84 ui/events/ozone/evdev/touch_event_converter_evdev_unittest.cc if (pipe(fds)) pipe 117 ui/events/ozone/evdev/touch_event_converter_evdev_unittest.cc if (pipe(evdev_io))