- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 282 for drain1 (0.12 sec)
-
internal/grid/stream.go
func (s *Stream) Results(next func(b []byte) error) (err error) { done := false defer func() { if s.cancel != nil { s.cancel(err) } if !done { // Drain channel. for range s.responses { } } }() doneCh := s.ctx.Done() for { select { case <-doneCh: if err := context.Cause(s.ctx); !errors.Is(err, errStreamEOF) { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
src/sync/pool_test.go
} func testPool(t *testing.T, drain bool) { var p Pool const N = 100 loop: for try := 0; try < 3; try++ { if try == 1 && testing.Short() { break } var fin, fin1 uint32 for i := 0; i < N; i++ { v := new(string) runtime.SetFinalizer(v, func(vv *string) { atomic.AddUint32(&fin, 1) }) p.Put(v) } if drain { for i := 0; i < N; i++ { p.Get()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8K bytes - Viewed (0) -
manifests/charts/ztunnel/values.yaml
defaultConfig: proxyMetadata: {} # This value defines: # 1. how many seconds kube waits for ztunnel pod to gracefully exit before forcibly terminating it (this value) # 2. how many seconds ztunnel waits to drain its own connections (this value - 1 sec) # Default K8S value is 30 seconds terminationGracePeriodSeconds: 30 # Revision is set as 'version' label and part of the resource names when installing multiple control planes.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:30 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/s3select/json/reader.go
return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. err := r.readCloser.Close() for range r.valueCh { // Drain values so we don't leak a goroutine. // Since we have closed the input, it should fail rather quickly. } return err } // NewReader - creates new JSON reader using readCloser.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 24 03:58:53 UTC 2022 - 3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/TestConnection.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
tensorflow/cc/saved_model/image_format/BUILD
) load("//tensorflow/core/platform:rules_cc.bzl", "cc_library") package( # copybara:uncomment default_applicable_licenses = ["//tensorflow:license"], default_visibility = [ "//smartass/brain/configure:__subpackages__", "//tensorflow/cc/experimental/tfa:__subpackages__", "//tensorflow/cc/saved_model:__subpackages__", "//tensorflow/tools/tfg_graph_transforms:__subpackages__",
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Dec 20 03:07:44 UTC 2023 - 1.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/util/internal/DisconnectableInputStream.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 6.5K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/native-sidecar.yaml.injected
lifecycle: preStop: exec: command: - pilot-agent - request - --debug-port=15020 - POST - drain name: istio-proxy ports: - containerPort: 15090 name: http-envoy-prom protocol: TCP readinessProbe: failureThreshold: 4 httpGet: path: /healthz/ready
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/RedrawableLabel.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.logging.console; /** * This label have the concept of been drawn on screen. */ public interface RedrawableLabel extends Label, StyledLabel { void redraw(AnsiContext ansi);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 826 bytes - Viewed (0) -
src/time/sleep.go
// if the program has not received from t.C already and the timer is // running, Stop is guaranteed to return true. // Before Go 1.23, the only safe way to use Stop was insert an extra // <-t.C if Stop returned false to drain a potential stale value. // See the [NewTimer] documentation for more details. func (t *Timer) Stop() bool { if !t.initTimer { panic("time: Stop called on uninitialized Timer") } return stopTimer(t) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0)