- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 316 for channel2 (0.17 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
when: def dispatcher1 = hub.getOutgoing("channel1", String) def dispatcher2 = hub.getOutgoing("channel1", Integer) then: dispatcher1 != null dispatcher2 != null dispatcher1 != dispatcher2 } def "creates a separate dispatcher for each outgoing channel"() { when: def dispatcher1 = hub.getOutgoing("channel1", String)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
conn.channels[channel].Close() // After first Close, other closes are noop. } continue } channel := data[0] if conn.codec == base64Codec { channel = channel - '0' } data = data[1:] if int(channel) >= len(conn.channels) { klog.V(6).Infof("Frame is targeted for a reader %d that is not valid, possible protocol error", channel) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn_test.go
WebSocketProtocolHeader: "v4.channel.k8s.io, v5.channel.k8s.io, v3.channel.k8s.io", }, expected: true, }, "Websocket connection upgrade headers key is case-insensitive": { headers: map[string]string{ "Connection": "upgrade", "Upgrade": "websocket", "sec-websocket-protocol": "v4.channel.k8s.io, v5.channel.k8s.io, v3.channel.k8s.io", }, expected: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 11.4K bytes - Viewed (0) -
src/runtime/chan.go
} // recv processes a receive operation on a full channel c. // There are 2 parts: // 1. The value sent by the sender sg is put into the channel // and the sender is woken up to go on its merry way. // 2. The value received by the receiver (the current G) is // written to ep. // // For synchronous channels, both values are the same. // For asynchronous channels, the receiver gets its data from
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 11:28:54 UTC 2023 - 12.1K bytes - Viewed (0) -
src/runtime/select.go
if sg.c != lastc && lastc != nil { // As soon as we unlock the channel, fields in // any sudog with that channel may change, // including c and waitlink. Since multiple // sudogs may have the same channel, we unlock // only after we've passed the last instance // of a channel. unlock(&lastc.lock) } lastc = sg.c } if lastc != nil { unlock(&lastc.lock) } return true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
test/chan/powser1.go
// newest hold queued data that has already been sent to // out[0]. When data has finally been sent to out[1], // a signal on the release-wait channel tells the next newer // generation to begin servicing out[1]. func dosplit(in *dch, out *dch2, wait chan int) { both := false // do not service both channels select { case <-out[0].req: case <-wait: both = true select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 25 22:22:20 UTC 2020 - 12.7K bytes - Viewed (0) -
test/chan/powser2.go
// newest hold queued data that has already been sent to // out[0]. When data has finally been sent to out[1], // a signal on the release-wait channel tells the next newer // generation to begin servicing out[1]. func dosplit(in *dch, out *dch2, wait chan int) { both := false // do not service both channels select { case <-out[0].req: case <-wait: both = true select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 25 22:22:20 UTC 2020 - 13.3K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
* <ol> * <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output * channel have their own file descriptors. Generally this only happens when both channels * are files or sockets. This performs zero copies - the bytes never enter userspace. * <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jan 17 18:59:58 UTC 2024 - 29.7K bytes - Viewed (0) -
src/os/signal/doc.go
On Windows a ^C (Control-C) or ^BREAK (Control-Break) normally cause the program to exit. If Notify is called for [os.Interrupt], ^C or ^BREAK will cause [os.Interrupt] to be sent on the channel, and the program will not exit. If Reset is called, or Stop is called on all channels passed to Notify, then the default behavior will be restored. Additionally, if Notify is called, and Windows sends CTRL_CLOSE_EVENT,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0)