- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 875 for channel2 (0.13 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// an error event and close the result channel. Stop() // ResultChan returns a channel which will receive events from the event // producer. If an error occurs or Stop() is called, the producer must // close this channel and release any resources used by the watch. // Closing the result channel tells the consumer that no more events will be // sent. ResultChan() <-chan Event }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
return endpoint; } @Override public Socket accept() throws IOException { try { UnixSocketChannel channel = serverSocketChannel.accept(); return new TunnelingUnixSocket(path, channel, endpoint); } catch (ClosedChannelException e) { SocketException exception = new SocketException(); exception.initCause(e); throw exception; }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Feb 12 16:33:52 UTC 2019 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/timer.go
// You should not call Next() after Stop() is invoked. Next() // Stop releases the timer. It is safe to invoke if no other methods have been // called. Stop() } type noopTimer struct { closedCh <-chan time.Time } // newNoopTimer creates a timer with a unique channel to avoid contention // for the channel's lock across multiple unrelated timers.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 2.9K 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) -
platforms/native/platform-native/src/test/groovy/org/gradle/nativeplatform/toolchain/internal/msvcpp/version/CommandLineToolVersionLocatorTest.groovy
"channelId": "VisualStudio.15.Release", "channelPath": "C:\\\\Users\\\\IEUser\\\\AppData\\\\Local\\\\Microsoft\\\\VisualStudio\\\\Packages\\\\_Channels\\\\4CB340F5\\\\catalog.json", "channelUri": "https://aka.ms/vs/15/release/channel", "releaseNotes": "https://go.microsoft.com/fwlink/?LinkId=660469#15.3.26730.16",
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 9.6K bytes - Viewed (2) -
releasenotes/notes/release-channels-remote-cluster.yaml
Whitney Griffith <******@****.***> 1716925617 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 19:46:57 UTC 2024 - 297 bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
w.channels = make(map[types.UID]*WorkChannelItem) } channel, ok := w.channels[uid] if !ok { channel = &WorkChannelItem{ out: make(chan struct{}, 1), } w.channels[uid] = channel } return channel } func (w *WorkChannel) Intercept(uid types.UID, ch chan struct{}) (outCh <-chan struct{}) { channel := w.Channel(uid) w.lock.Lock() defer w.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/filter.go
// Filter passes all events through f before allowing them to pass on. // Putting a filter on a watch, as an unavoidable side-effect due to the way // go channels work, effectively causes the watch's event channel to have its // queue length increased by one. // // WARNING: filter has a fatal flaw, in that it can't properly update the // Type field (Add/Modified/Deleted) to reflect items beginning to pass the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typeparams/coretype.go
return U } ch, ok := U.(*types.Chan) if !ok { return nil // no core type as identical < len(terms) and U is not a channel. } // https://go.dev/ref/spec#Core_types // "the type chan E if T contains only bidirectional channels, or the type chan<- E or // <-chan E depending on the direction of the directional channels present." for chans := identical; chans < len(terms); chans++ { curr, ok := terms[chans].Type().Underlying().(*types.Chan)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 5.3K bytes - Viewed (0)