- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 140 for Receive (0.23 sec)
-
platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/service/scopes/StatefulListener.java
import java.lang.annotation.Target; /** * Attached to a listener interface to indicate that its events are stateful. * * <p>The listener infrastructure will ensure that a listener of this type will either receive all events, or no events. * Currently, this is done by disallowing the registration of a listener of this type once any events have been fired. * * @see Scope */ @Retention(RetentionPolicy.RUNTIME)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
def assertReceivingSocketEmpty() { try { Executors.newSingleThreadExecutor().submit { DatagramPacket packet = new DatagramPacket(new byte[9], 9) receivingSocket.receive(packet) }.get(1, TimeUnit.SECONDS) } catch (TimeoutException e) { return true } return false }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_node_if_rx_bytes` | Bytes received on the interface in 60s. | | `minio_node_if_rx_bytes_avg` | Bytes received on the interface in 60s (avg) since uptime. | | `minio_node_if_rx_bytes_max` | Bytes received on the interface in 60s (max) since uptime. | | `minio_node_if_rx_errors` | Receive errors in 60s. |
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 43.3K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
* * @param delegate The delegate that should run on single thread. * @param queueSize The event queue size (default {@code 1024}). * @param batchMaxSize The maximum batch size delegate should receive (default {@code 500}). * @param blockOnLastEvent Should this listener block on last transfer end (completed or corrupted) block? (default {@code true}). */ public SimplexTransferListener(
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta3/conversion.go
// Required to pass fuzzer tests. This ClusterConfiguration is empty and is never defaulted. // If we call Convert_v1beta3_ClusterConfiguration_To_kubeadm_ClusterConfiguration() these fields will receive // a default value, thus here we need to reset them back to empty. out.EncryptionAlgorithm = "" out.CertificateValidityPeriod = nil out.CACertificateValidityPeriod = nil // Set default timeouts.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 13 06:41:07 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// errors and needs to stop the watch prematurely, it should instead send // 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.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
cmd/erasure-healing_test.go
Recursive: false, Immediate: false, }) } // Try healing now, expect to receive errFileNotFound. _, err = objLayer.HealObject(ctx, bucket, object, "", madmin.HealOpts{DryRun: false, Remove: true, ScanMode: madmin.HealDeepScan}) if err != nil { if _, ok := err.(ObjectNotFound); !ok { t.Errorf("Expect %v but received %v", ObjectNotFound{Bucket: bucket, Object: object}, err) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
pkg/workloadapi/workload.proto
WorkloadType workload_type = 12; // WorkloadName represents the name for the workload (of type WorkloadType). Used for telemetry. string workload_name = 13; // If set, this indicates a workload expects to directly receive tunnel traffic. // In ztunnel, this means: // * Requests *from* this workload do not need to be tunneled if they already are tunneled by the tunnel_protocol.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/iam-object-store.go
ch := make(chan itemOrErr[string]) go func() { defer xioutil.SafeClose(ch) // Allocate new results channel to receive ObjectInfo. objInfoCh := make(chan itemOrErr[ObjectInfo]) if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil { select { case ch <- itemOrErr[string]{Err: err}:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 19.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
}) if err != nil { t.Fatalf("Failed to create watch: %v", err) } defer w.Stop() received := 0 resChan := w.ResultChan() for event := range resChan { received++ t.Logf("event type: %v, events received so far: %d", event.Type, received) if event.Type != watch.Added { t.Errorf("unexpected event type, expected: %s, got: %s, event: %v", watch.Added, event.Type, event)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0)