- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 436 for channel2 (0.15 sec)
-
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/apiserver/pkg/util/proxy/websocket.go
} } // createChannels returns the standard channel types for a shell connection (STDIN 0, STDOUT 1, STDERR 2) // along with the approximate duplex value. It also creates the error (3) and resize (4) channels. func createChannels(opts Options) []wsstream.ChannelType { // open the requested channels, and always open the error channel channels := make([]wsstream.ChannelType, 5) channels[constants.StreamStdIn] = readChannel(opts.Stdin)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 6.2K 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) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/AbstractWritableResultsStore.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.8K bytes - Viewed (0) -
src/cmd/compile/internal/types2/under.go
// If x and y are identical, match returns x. // If x and y are identical channels but for their direction // and one of them is unrestricted, match returns the channel // with the restricted direction. // In all other cases, match returns nil. func match(x, y Type) Type { // Common case: we don't have channels. if Identical(x, y) { return x } // We may have channels that differ in direction only. if x, _ := x.(*Chan); x != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 22:34:27 UTC 2024 - 2.7K bytes - Viewed (0) -
releasenotes/notes/release-channels.yaml
Keith Mattix II <******@****.***> 1713823240 -0500
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 22 22:00:40 UTC 2024 - 261 bytes - Viewed (0) -
src/go/types/under.go
// If x and y are identical, match returns x. // If x and y are identical channels but for their direction // and one of them is unrestricted, match returns the channel // with the restricted direction. // In all other cases, match returns nil. func match(x, y Type) Type { // Common case: we don't have channels. if Identical(x, y) { return x } // We may have channels that differ in direction only. if x, _ := x.(*Chan); x != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 21 22:34:27 UTC 2024 - 2.8K bytes - Viewed (0) -
doc/next/6-stdlib/1-time.md
<!-- go.dev/issue/37196 --> Second, the timer channel associated with a `Timer` or `Ticker` is now unbuffered, with capacity 0. The main effect of this change is that Go now guarantees that for any call to a `Reset` or `Stop` method, no stale values prepared before that call will be sent or received after the call. Earlier versions of Go used channels with a one-element buffer,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 20:49:22 UTC 2024 - 1.5K bytes - Viewed (0) -
src/main/java/org/codelibs/core/nio/ChannelUtil.java
import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.Channel; import java.nio.channels.FileChannel; import java.nio.channels.FileChannel.MapMode; import org.codelibs.core.exception.IORuntimeException; /** * {@link Channel}用のユーティリティです。 * * @author koichik */ public abstract class ChannelUtil { /**
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 6K bytes - Viewed (0) -
src/time/sleep.go
// a problem fixed by asynctimerchan=1: it enables the new // GC-able timer channels (#61542) but not the sync channels (#37196). // // If we decide to roll back the sync channels, we will still have // a fully tested async runtime implementation (asynctimerchan=2) // and can make this function always return c. // // If we decide to keep the sync channels, we can delete all the // handling of asynctimerchan in the runtime and keep just this
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0)