- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 99 for pipe (0.19 sec)
-
internal/ioutil/wait_pipe.go
err = r.PipeReader.CloseWithError(err) r.wait() return err } // WaitPipe implements wait-group backend io.Pipe to provide // synchronization between read() end with write() end. func WaitPipe() (*PipeReader, *PipeWriter) { r, w := io.Pipe() var wg sync.WaitGroup wg.Add(1) return &PipeReader{ PipeReader: r, wait: wg.Wait, }, &PipeWriter{ PipeWriter: w,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener_test.go
}}, }, expect: true, }, { desc: "listener-pipe", inFilter: &ListenerFilter{ Address: "", Port: 0, Type: "", }, inListener: &listener.Listener{ Address: &core.Address{ Address: &core.Address_Pipe{ Pipe: &core.Pipe{Path: "unix:///dev/shm/uds.socket"}, }, }, }, expect: true, }, }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 4.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() { val pipe = Pipe(1024) val sink = pipe.sink.buffer() val relay = edit(file, pipe.source, metadata, 5) val future1 = executor.submit(sourceReader(relay.newSource())) val future2 = executor.submit(sourceReader(relay.newSource())) Thread.sleep(500)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
cmd/bitrot-streaming.go
// Race condition is because of io.PipeWriter implementation. i.e consider the following // sequent of operations: // 1) pipe.Write() // 2) pipe.Close() // Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk // Hence an immediate Read() on the file can return incorrect data. if b.canClose != nil { b.canClose.Wait() } return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
// zero effect on the behavior of the WebSocket API which is why tests are only written once // from the perspective of a single peer. private val random = Random(0) private val client2Server = Pipe(8192L) private val server2client = Pipe(8192L) private val taskFaker = TaskFaker() private val client = TestStreams(true, taskFaker, server2client, client2Server) private val server = TestStreams(false, taskFaker, client2Server, server2client)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/clusters/clusters.go
return nil } func retrieveEndpointAddress(host *admin.HostStatus) string { addr := host.Address.GetSocketAddress() if addr != nil { return addr.Address } if pipe := host.Address.GetPipe(); pipe != nil { return "unix://" + pipe.Path } if internal := host.Address.GetEnvoyInternalAddress(); internal != nil { switch an := internal.GetAddressNameSpecifier().(type) { case *core.EnvoyInternalAddress_ServerListenerName:
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 5.8K bytes - Viewed (0) -
docs/bucket/versioning/versioning-tests.sh
./mc mb sitea/delissue --insecure ./mc version enable sitea/delissue --insecure echo hello | ./mc pipe sitea/delissue/hello --insecure ./mc version suspend sitea/delissue --insecure ./mc rm sitea/delissue/hello --insecure ./mc version enable sitea/delissue --insecure echo hello | ./mc pipe sitea/delissue/hello --insecure ./mc version suspend sitea/delissue --insecure
Shell Script - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 11 09:50:52 GMT 2024 - 2.4K bytes - Viewed (0) -
.cm/includes_todos.cm
:warning: 'There are new TODOs present in this change. Should any be removed?' # To simplify the automations section, some calculations are placed under unique YAML keys defined here. # Read the "|" not as "or", but as a "pipe", taking the output of the previous command and passing it to the next command. # This section could also appear ahead of the automations section. colors:
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Fri Apr 12 13:42:16 GMT 2024 - 1.9K bytes - Viewed (0) -
ci/official/utilities/setup.sh
# exec". # Important: "tfrun foo | bar" is "( tfrun foo ) | bar", not "tfrun (foo | bar)". # Therefore, "tfrun" commands cannot include pipes -- which is # probably for the better. If a pipe is necessary for something, it is probably # complex. Write a well-documented script under utilities/ to encapsulate the # functionality instead. tfrun() { "$@"; }
Shell Script - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Jan 26 00:33:34 GMT 2024 - 5.2K bytes - Viewed (1) -
.cm/complex_changes.cm
- action: set-required-approvals@v1 args: approvals: 2 # To simplify the automations section, some calculations are placed under unique YAML keys defined here. # Read the "|" not as "or", but as a "pipe", taking the output of the previous command and passing it to the next command. # This section could also appear ahead of the automations section.
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Fri Apr 12 13:42:16 GMT 2024 - 1.7K bytes - Viewed (0)