- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 875 for channel2 (0.14 sec)
-
cluster/gce/gci/README.md
81, 85. Each milestone will experience three release channels -- dev, beta and stable to reach stability. The promotion between those channels are about six weeks. Starting milestone 69, for every 4 milestones, the last milestone will be promoted into LTS image after it becomes stable. For details, please see COS's [Release Channels](https://cloud.google.com/container-optimized-os/docs/concepts/release-channels) and [Support
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 14:55:40 UTC 2023 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/doc.go
// a single websocket. // // "channel.k8s.io" // // The Websocket RemoteCommand subprotocol "channel.k8s.io" prepends each binary message with a // byte indicating the channel number (zero indexed) the message was sent on. Messages in both // directions should prefix their messages with this channel byte. Used for remote execution,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 18:37:18 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/test/kotlin/org/gradle/kotlin/dsl/resolver/KotlinBuildScriptModelRepositoryTest.kt
*/ package org.gradle.kotlin.dsl.resolver import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.Deferred import kotlinx.coroutines.async import kotlinx.coroutines.channels.Channel import kotlinx.coroutines.channels.trySendBlocking import kotlinx.coroutines.runBlocking import kotlinx.coroutines.withTimeout import kotlinx.coroutines.withTimeoutOrNull import org.gradle.kotlin.dsl.tooling.models.EditorReport
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 6.3K 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/doubleselect.go
import ( "flag" "runtime" ) var iterations *int = flag.Int("n", 100000, "number of iterations") // sender sends a counter to one of four different channels. If two // cases both end up running in the same iteration, the same value will be sent // to two different channels. func sender(n int, c1, c2, c3, c4 chan<- int) { defer close(c1) defer close(c2) defer close(c3) defer close(c4) for i := 0; i < n; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 24 01:34:14 UTC 2017 - 2K bytes - Viewed (0) -
samples/ambient-argo/README.md
supports any number of phases based on the needs of your platform. In a channel model, multiple versions of Istio are available for use by application developers at any point in time, based on their requirements for risk profile and new features or bugfixes. For example, at the time of this writing, the stable tag or channel is using Istio 1.18.5, while the rapid channel is using Istio 1.19.3. Under the channel model, these versions would be updated in-place as new patch releases are produced...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Nov 04 01:54:50 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/channels/unbounded.go
default: } } b.mu.Unlock() } // Get returns a read channel on which values added to the buffer, via Put(), // are sent on. // // Upon reading a value from this channel, users are expected to call Load() to // send the next buffered value onto the channel if there is any. func (b *Unbounded[T]) Get() <-chan T { return b.c
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 31 19:53:39 UTC 2022 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/FileOperator.kt
import java.io.IOException import java.nio.channels.FileChannel import okio.Buffer /** * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)` * this class offers: * * * **Read/write:** read and write using the same operator. * * **Random access:** access any position within the file. * * **Shared channels:** read and write a file channel that's shared between
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
// to a closed channel following a broadcaster shutdown. incomingBlock sync.Mutex incoming chan Event stopped chan struct{} // How large to make watcher's channel. watchQueueLength int // If one of the watch channels is full, don't wait for it to become empty. // Instead just deliver it to the watchers that do have space in their // channels and move on to the next event.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0) -
test/chan/sieve2.go
func Sieve() chan int { // The output values. out := make(chan int, 10) out <- 2 out <- 3 // The channel of all composites to be eliminated in increasing order. composites := make(chan int, 50) // The feedback loop. primes := make(chan int, 10) primes <- 3 // Merge channels of multiples of 'primes' into 'composites'. go func() { var h PeekChHeap min := 15 for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Feb 19 06:44:02 UTC 2012 - 3.9K bytes - Viewed (0)