Home
last modified time | relevance | path

Searched refs:Pipe (Results 1 - 25 of 62) sorted by relevance

123

/third_party/node/test/parallel/
H A Dtest-net-connect-options-fd.js11 const { Pipe, constants: PipeConstants } = internalBinding('pipe_wrap');
35 // Test Pipe fd is wrapped correctly
49 console.error(`[Pipe]Received data from fd ${clientFd}`);
54 console.error(`[Pipe]Received end from fd ${clientFd}, total ${counter}`);
57 console.error(`[Pipe]Server closed by fd ${clientFd}`);
66 console.error(`[Pipe]Clean up handle with fd ${pair[1].fd}`);
73 assert.fail(`[Pipe server]${err}`);
77 const handle = new Pipe(PipeConstants.SOCKET);
82 console.error(`[Pipe]Bound handle with Pipe
[all...]
H A Dtest-net-server-listen-handle.js11 const { Pipe, constants: PipeConstants } = internalBinding('pipe_wrap');
47 handle = new Pipe(PipeConstants.SOCKET);
/third_party/rust/crates/env_logger/src/fmt/writer/
H A Dmod.rs23 Pipe(Box<dyn io::Write + Send + 'static>),
40 Self::Pipe(_) => "pipe", in fmt()
55 Pipe(Box<Mutex<dyn io::Write + Send + 'static>>),
63 Target::Pipe(pipe) => Self::Pipe(Box::new(Mutex::new(pipe))), in from()
82 Self::Pipe(_) => "pipe", in fmt()
183 WritableTarget::Pipe(_) => false,
196 WritableTarget::Pipe(pipe) => BufferWriter::pipe(color_choice, pipe),
/third_party/skia/third_party/externals/tint/src/utils/io/
H A Dcommand_posix.cc72 /// Pipe is a simple wrapper around a POSIX pipe() function
73 class Pipe { class
76 Pipe() { in Pipe() function in tint::utils::__anon26162::Pipe
150 Pipe stdin_pipe; in Exec()
151 Pipe stdout_pipe; in Exec()
152 Pipe stderr_pipe; in Exec()
H A Dcommand_windows.cc68 /// Pipe is a simple wrapper around a Win32 CreatePipe() function
69 class Pipe { class
72 explicit Pipe(bool for_read) { in Pipe() function in tint::utils::__anon26164::Pipe
151 Pipe stdout_pipe(true); in Exec()
152 Pipe stderr_pipe(true); in Exec()
153 Pipe stdin_pipe(false); in Exec()
/third_party/skia/third_party/externals/spirv-tools/source/opt/
H A Dtypes.h56 class Pipe;
198 DeclareCastMethod(Pipe)
554 class Pipe : public Type { class
556 Pipe(SpvAccessQualifier qualifier) in Pipe() function in spvtools::opt::analysis::Pipe
558 Pipe(const Pipe&) = default;
562 Pipe* AsPipe() override { return this; }
563 const Pipe* AsPipe() const override { return this; }
H A Dtypes.cpp125 DeclareKindCase(Pipe); in Clone()
171 DeclareKindCase(Pipe); in operator ==()
222 DeclareKindCase(Pipe); in GetHashWords()
619 bool Pipe::IsSameImpl(const Type* that, IsSameCache*) const { in IsSameImpl()
620 const Pipe* pt = that->AsPipe(); in IsSameImpl()
625 std::string Pipe::str() const { in str()
631 void Pipe::GetExtraHashWords(std::vector<uint32_t>* words, in GetExtraHashWords()
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/source/opt/
H A Dtypes.h56 class Pipe;
198 DeclareCastMethod(Pipe)
554 class Pipe : public Type { class
556 Pipe(SpvAccessQualifier qualifier) in Pipe() function in spvtools::opt::analysis::Pipe
558 Pipe(const Pipe&) = default;
562 Pipe* AsPipe() override { return this; }
563 const Pipe* AsPipe() const override { return this; }
H A Dtypes.cpp125 DeclareKindCase(Pipe); in Clone()
171 DeclareKindCase(Pipe); in operator ==()
222 DeclareKindCase(Pipe); in GetHashWords()
619 bool Pipe::IsSameImpl(const Type* that, IsSameCache*) const { in IsSameImpl()
620 const Pipe* pt = that->AsPipe(); in IsSameImpl()
625 std::string Pipe::str() const { in str()
631 void Pipe::GetExtraHashWords(std::vector<uint32_t>* words, in GetExtraHashWords()
/third_party/spirv-tools/source/opt/
H A Dtypes.h57 class Pipe;
200 DeclareCastMethod(Pipe)
551 class Pipe : public Type { class
553 Pipe(spv::AccessQualifier qualifier) in Pipe() function in spvtools::opt::analysis::Pipe
555 Pipe(const Pipe&) = default;
559 Pipe* AsPipe() override { return this; }
560 const Pipe* AsPipe() const override { return this; }
H A Dtypes.cpp125 DeclareKindCase(Pipe); in Clone()
173 DeclareKindCase(Pipe); in operator ==()
229 DeclareKindCase(Pipe); in ComputeHashValue()
635 bool Pipe::IsSameImpl(const Type* that, IsSameCache*) const { in IsSameImpl()
636 const Pipe* pt = that->AsPipe(); in IsSameImpl()
641 std::string Pipe::str() const { in str()
647 size_t Pipe::ComputeExtraStateHash(size_t hash, SeenTypes*) const { in ComputeExtraStateHash()
/third_party/json/tests/thirdparty/Fuzzer/
H A DFuzzerUtil.cpp209 FILE *Pipe = OpenProcessPipe(Command.c_str(), "r"); in ExecuteCommandAndReadOutput() local
210 if (!Pipe) return false; in ExecuteCommandAndReadOutput()
213 while ((N = fread(Buff, 1, sizeof(Buff), Pipe)) > 0) in ExecuteCommandAndReadOutput()
/third_party/python/Lib/multiprocessing/
H A Dcontext.py60 def Pipe(self, duplex=True): member in BaseContext
62 from .connection import Pipe namespace
63 return Pipe(duplex)
/third_party/rust/crates/env_logger/src/fmt/writer/termcolor/
H A Dextern_impl.rs112 uncolored_target: Some(WritableTarget::Pipe(pipe)),
133 WritableTarget::Pipe(pipe) => write!(pipe.lock().unwrap(), "{}", log)?,
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/MCA/HardwareUnits/
H A DResourceManager.cpp309 ResourceRef Pipe = selectPipe(R.first); in issueInstruction() local
310 use(Pipe); in issueInstruction()
311 BusyResources[Pipe] += CS.size(); in issueInstruction()
313 Pipe, ResourceCycles(CS.size()))); in issueInstruction()
/third_party/python/Lib/test/
H A D_test_multiprocessing.py328 rconn, wconn = self.Pipe(duplex=False)
349 rconn, wconn = self.Pipe(duplex=False)
544 rconn, wconn = self.Pipe(duplex=False)
839 self.child_conn, self.parent_conn = multiprocessing.Pipe()
2051 conn, child_conn = self.Pipe(False)
3113 conn, child_conn = self.Pipe()
3192 reader, writer = self.Pipe(duplex=False)
3210 conn, child_conn = self.Pipe()
3230 a, b = self.Pipe()
3284 conn, child_conn = self.Pipe(duple
5851 Pipe = staticmethod(multiprocessing.Pipe) global() variable in ProcessesMixin
5935 Pipe = staticmethod(multiprocessing.dummy.Pipe) global() variable in ThreadsMixin
[all...]
/third_party/node/lib/internal/
H A Dchild_process.js53 const { Pipe, constants: PipeConstants } = internalBinding('pipe_wrap');
334 if (stream instanceof Pipe) return 'pipe';
794 } else if (handle instanceof TCP || handle instanceof Pipe) {
1022 a.handle = new Pipe(PipeConstants.SOCKET);
1035 ipc = new Pipe(PipeConstants.IPC);
/third_party/skia/third_party/externals/spirv-tools/test/opt/
H A Dtypes_test.cpp108 TestMultipleInstancesOfTheSameType(Pipe, SpvAccessQualifierReadWrite)
238 // Pipe, Forward Pointer, PipeStorage, NamedBarrier in GenerateAllTypes()
239 types.emplace_back(new Pipe(SpvAccessQualifierReadWrite)); in GenerateAllTypes()
240 types.emplace_back(new Pipe(SpvAccessQualifierReadOnly)); in GenerateAllTypes()
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/test/opt/
H A Dtypes_test.cpp108 TestMultipleInstancesOfTheSameType(Pipe, SpvAccessQualifierReadWrite)
238 // Pipe, Forward Pointer, PipeStorage, NamedBarrier in GenerateAllTypes()
239 types.emplace_back(new Pipe(SpvAccessQualifierReadWrite)); in GenerateAllTypes()
240 types.emplace_back(new Pipe(SpvAccessQualifierReadOnly)); in GenerateAllTypes()
/third_party/python/Parser/
H A Dasdl.py214 (ConstructorId, TypeId, Equals, Comma, Question, Pipe, Asterisk,
218 '=': Equals, ',': Comma, '?': Question, '|': Pipe, '(': LParen,
301 while self.cur_token.kind == TokenKind.Pipe:
/third_party/python/Lib/multiprocessing/dummy/
H A Dconnection.py10 __all__ = [ 'Client', 'Listener', 'Pipe' ]
46 def Pipe(duplex=True): function
/third_party/node/test/sequential/
H A Dtest-async-wrap-getasyncid.js187 const handle = new binding.Pipe(binding.constants.IPC);
188 testInitialized(handle, 'Pipe');
198 const handle = new binding.Pipe(binding.constants.SOCKET);
199 testInitialized(handle, 'Pipe');
/third_party/rust/crates/rustix/src/backend/linux_raw/process/
H A Dtypes.rs115 Pipe = linux_raw_sys::general::SIGPIPE,
179 linux_raw_sys::general::SIGPIPE => Some(Self::Pipe), in from_raw()
/third_party/python/Modules/clinic/
H A Doverlapped.c.h775 HANDLE Pipe);
781 HANDLE Pipe; in _overlapped_Overlapped_ConnectNamedPipe() local
783 if (!PyArg_Parse(arg, ""F_HANDLE":ConnectNamedPipe", &Pipe)) { in _overlapped_Overlapped_ConnectNamedPipe()
786 return_value = _overlapped_Overlapped_ConnectNamedPipe_impl(self, Pipe); in _overlapped_Overlapped_ConnectNamedPipe()
/third_party/spirv-tools/test/opt/
H A Dtypes_test.cpp108 TestMultipleInstancesOfTheSameType(Pipe, spv::AccessQualifier::ReadWrite)
242 // Pipe, Forward Pointer, PipeStorage, NamedBarrier in GenerateAllTypes()
243 types.emplace_back(new Pipe(spv::AccessQualifier::ReadWrite)); in GenerateAllTypes()
244 types.emplace_back(new Pipe(spv::AccessQualifier::ReadOnly)); in GenerateAllTypes()

Completed in 39 milliseconds

123