- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 55 for GetWork (0.15 sec)
-
cmd/admin-handlers.go
connectTime := time.Now() for { n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte) if err != nil && err != io.EOF && err != io.ErrUnexpectedEOF { // would mean the network is not stable. Logging here will help in debugging network issues. if time.Since(connectTime) < (globalNetPerfMinDuration - time.Second) { adminLogIf(ctx, err) } } totalRx += n
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cluster/gce/gci/configure-helper.sh
use_cloud_config="true" cat <<EOF >>/etc/gce.conf network-project-id = ${NETWORK_PROJECT_ID} EOF fi if [[ -n "${STACK_TYPE:-}" ]]; then use_cloud_config="true" cat <<EOF >>/etc/gce.conf stack-type = ${STACK_TYPE} EOF fi if [[ -n "${NODE_NETWORK:-}" ]]; then use_cloud_config="true" cat <<EOF >>/etc/gce.conf network-name = ${NODE_NETWORK} EOF fi
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 22:07:47 UTC 2024 - 141.1K bytes - Viewed (0) -
okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat
// ticket i/O GmbH : https://ticket.io // Submitted by Christian Franke <******@****.***> tickets.io // Tlon.io : https://tlon.io // Submitted by Mark Staarink <******@****.***> arvo.network azimuth.network tlon.network // Tor Project, Inc. : https://torproject.org // Submitted by Antoine Beaupré <******@****.*** torproject.net pages.torproject.net
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 240.3K bytes - Viewed (0) -
src/net/http/server.go
// If ServeHTTP panics, the server (the caller of ServeHTTP) assumes // that the effect of the panic was isolated to the active request. // It recovers the panic, logs a stack trace to the server error log, // and either closes the network connection or sends an HTTP/2 // RST_STREAM, depending on the HTTP protocol. To abort a handler so // the client sees an interrupted response but the server doesn't log // an error, panic with the value [ErrAbortHandler].
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
"k8s.io/kubernetes/pkg/kubelet/images" "k8s.io/kubernetes/pkg/kubelet/kuberuntime" "k8s.io/kubernetes/pkg/kubelet/lifecycle" "k8s.io/kubernetes/pkg/kubelet/logs" "k8s.io/kubernetes/pkg/kubelet/network/dns" "k8s.io/kubernetes/pkg/kubelet/nodeshutdown" "k8s.io/kubernetes/pkg/kubelet/pleg" "k8s.io/kubernetes/pkg/kubelet/pluginmanager" kubepod "k8s.io/kubernetes/pkg/kubelet/pod"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
src/runtime/proc.go
} } if sched.runqsize != 0 { unlock(&sched.lock) startm(pp, false, false) return } // If this is the last running P and nobody is polling network, // need to wakeup another M to poll network. if sched.npidle.Load() == gomaxprocs-1 && sched.lastpoll.Load() != 0 { unlock(&sched.lock) startm(pp, false, false) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
if useHostNetwork { // if Pod is using host network, read hosts file from the node's filesystem. // `etcHostsPath` references the location of the hosts file on the node. // `/etc/hosts` for *nix systems. hostsFileContent, err = nodeHostsFileContent(etcHostsPath, hostAliases) if err != nil { return err } } else { // if Pod is not using host network, create a managed hosts file with Pod IP and other information.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
.assertRequestUrl(server.url("/")) .assertSentRequestAtMillis(request1SentAt, request1ReceivedAt) .assertReceivedResponseAtMillis(request1SentAt, request1ReceivedAt) // Check the network response. It has the network request, plus caching headers. cacheMiss.networkResponse() .assertCode(200) .assertHeader("Donut", "b")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
pkg/config/validation/validation_test.go
valid: true, }, { name: "missing address", in: &networking.WorkloadEntry{}, valid: false, }, { name: "missing address with network", in: &networking.WorkloadEntry{Network: "network-2"}, valid: true, warning: true, }, { name: "valid unix endpoint", in: &networking.WorkloadEntry{Address: "unix:///lon/google/com"}, valid: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 03:11:45 UTC 2024 - 196K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
"A", "a1", "B", "b2", "B", "b3", "Content-Length", "4", ), ) // The original 'A' header is retained because the network response doesn't have one. // The original 'B' headers are replaced by the network response. // The network's 'C' header is added. val response2 = get(server.url("/")) assertThat(response2.body.string()).isEqualTo("abcd")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 108.6K bytes - Viewed (0)