- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 4,005 for Receive (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/goaway_test.go
} // encounter watch bytes received, does not expect to be broken if url == urlWatch || url == urlWatchWithGoaway { ch := make(chan watchResponse) go func() { defer resp.Body.Close() body := make([]byte, 0) buffer := make([]byte, 1) for { n, err := resp.Body.Read(buffer) if err != nil { // urlWatch will receive io.EOF,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 17 12:58:54 UTC 2021 - 13.9K bytes - Viewed (0) -
pilot/pkg/features/tuning.go
"ISTIO_GPRC_MAXSTREAMS", 100000, "Sets the maximum number of concurrent grpc streams.", ).Get() // MaxRecvMsgSize The max receive buffer size of gRPC received channel of Pilot in bytes. MaxRecvMsgSize = env.Register( "ISTIO_GPRC_MAXRECVMSGSIZE", 4*1024*1024, "Sets the max receive buffer size of gRPC stream in bytes.", ).Get() PushThrottle = func() int { v := env.Register( "PILOT_PUSH_THROTTLE", 0,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 04:22:19 UTC 2024 - 4.8K bytes - Viewed (1) -
.github/ISSUE_TEMPLATE/20_contributor_feature_request.yml
description: Suggest an idea for this project labels: [ "a:feature", "to-triage" ] assignees: [ ] body: - type: markdown attributes: value: | Please follow the instructions below. We receive dozens of issues every week, so to stay productive, we will close issues that don't provide enough information. Please open Android-related issues on [the Android Issue Tracker](https://source.android.com/source/report-bugs)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 06 11:10:39 UTC 2023 - 1.5K bytes - Viewed (0) -
test/sieve.go
} } // Copy the values from channel 'in' to channel 'out', // removing those divisible by 'prime'. func Filter(in <-chan int, out chan<- int, prime int) { for { i := <-in // Receive value of new variable 'i' from 'in'. if i%prime != 0 { out <- i // Send 'i' to channel 'out'. } } } // The prime sieve: Daisy-chain Filter processes together. func Sieve() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 24 00:48:19 UTC 2012 - 1K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/WorkerProcessContext.java
*/ Object getWorkerId(); /** * Returns a display name for this worker process. */ String getDisplayName(); /** * Returns the connection which can be used to send/receive messages to/from the server process. Call {@link ObjectConnection#connect()} to complete the connection. */ ObjectConnection getServerConnection(); ClassLoader getApplicationClassLoader();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:58:56 UTC 2024 - 1.3K bytes - Viewed (0) -
src/os/signal/signal_linux_test.go
"testing" "time" ) const prSetKeepCaps = 8 // This test validates that syscall.AllThreadsSyscall() can reliably // reach all 'm' (threads) of the nocgo runtime even when one thread // is blocked waiting to receive signals from the kernel. This monitors // for a regression vs. the fix for #43149. func TestAllThreadsSyscallSignals(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 1.1K bytes - Viewed (0) -
docs/en/docs/reference/websockets.md
- query_params - path_params - cookies - client - state - url_for - client_state - application_state - receive - send - accept - receive_text - receive_bytes - receive_json - iter_text - iter_bytes - iter_json
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 1.6K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/FileWatcherProbeRegistry.java
* * The {@link #unprovenHierarchies()} stream returns any hierarchies that were armed, but never received * a file system event. * These locations cannot be trusted to receive file system events in a timely manner. * * Note: a probe needs to be armed only once, if it receives an event, we will trust that location until * the registry is closed. */ public interface FileWatcherProbeRegistry {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:38:01 UTC 2023 - 2.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransCallNamedPipeResponse.java
if( pipe.pipeIn != null ) { TransactNamedPipeInputStream in = (TransactNamedPipeInputStream)pipe.pipeIn; synchronized( in.lock ) { in.receive( buffer, bufferIndex, len ); in.lock.notify(); } } return len; } public String toString() {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2K bytes - Viewed (0) -
pkg/kubelet/qos/doc.go
limitations under the License. */ // Package qos contains helper functions for quality of service. // For each resource (memory, CPU) Kubelet supports three classes of containers. // Memory guaranteed containers will receive the highest priority and will get all the resources // they need. // Burstable containers will be guaranteed their request and can "burst" and use more resources // when available.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 19 05:07:26 UTC 2020 - 1.1K bytes - Viewed (0)