- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 587 for blocked (0.23 sec)
-
pkg/istio-agent/xds_proxy.go
// backpressure provided by our channels, we have a risk of deadlock where both Xdsproxy and // Istiod are trying to Send, but both are blocked by gRPC backpressure until Recv() is called. // However, Recv can fail to be called by Send being blocked. This can be triggered by the two // sources in our system (Envoy request and Istiod pushes) producing more events than we can keep // up with.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
tools/istio-iptables/pkg/dependencies/implementation_linux.go
} } // In some setups, iptables can make remote network calls(!!). Since these come from a partially initialized pod network namespace, // these calls can be blocked (or NetworkPolicy, etc could block them anyways). // This is triggered by NSS, which allows various things to use arbitrary code to lookup configuration that typically comes from files.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 20:49:10 UTC 2024 - 12K bytes - Viewed (0) -
platforms/software/maven/src/main/java/org/gradle/api/publish/maven/internal/publication/DefaultMavenPublication.java
updateModuleDescriptorArtifact(); } // TODO: This method should be removed in favor of lazily adding artifacts to the publication state. // This is currently blocked by Signing eagerly realizing the publication artifacts. private void populateFromComponent() { if (populated) { return; } populated = true;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 04 06:46:01 UTC 2024 - 22.8K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_runtime.go
VersionInfo string APIVersionInfo string RuntimeType string Err error InspectErr error StatusErr error // If BlockImagePulls is true, then all PullImage() calls will be blocked until // UnblockImagePulls() is called. This is used to simulate image pull latency // from container runtime. BlockImagePulls bool imagePullTokenBucket chan bool T TB }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 00:23:50 UTC 2024 - 13.9K bytes - Viewed (0) -
src/net/http/roundtrip_js.go
} b := result.Get("body") var body io.ReadCloser // The body is undefined when the browser does not support streaming response bodies (Firefox), // and null in certain error cases, i.e. when the request is blocked because of CORS settings. if !b.IsUndefined() && !b.IsNull() { body = &streamReader{stream: b.Call("getReader")} } else { // Fall back to using ArrayBuffer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go
// One is to limit the time the request waits before its execution starts. // The other reason for it is that Handle() underneath may start additional goroutine // that is blocked on context cancellation. However, from APF point of view, // we don't want to wait until the whole watch request is processed (which is // when it context is actually cancelled) - we want to unblock the goroutine as
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0) -
src/net/http/httptest/server.go
t.CloseIdleConnections() } } s.wg.Wait() } func (s *Server) logCloseHangDebugInfo() { s.mu.Lock() defer s.mu.Unlock() var buf strings.Builder buf.WriteString("httptest.Server blocked in Close after 5 seconds, waiting for connections:\n") for c, st := range s.conns { fmt.Fprintf(&buf, " %T %p %v in state %v\n", c, c, c.RemoteAddr(), st) } log.Print(buf.String()) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
defer c.finishDispatching() // Watchers stopped after startDispatching will be delayed to finishDispatching, // Since add() can block, we explicitly add when cacher is unlocked. // Dispatching event in nonblocking way first, which make faster watchers // not be blocked by slower ones. if event.Type == watch.Bookmark { for _, watcher := range c.watchersBuffer { watcher.nonblockingAdd(event) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
src/cmd/trace/regions.go
<td> <a href="/regionio?{{$p}}">graph</a> <a href="/regionio?{{$p}}&raw=1" download="io.profile">(download)</a></td> </tr> <tr> <td>Sync block profile:</td> <td> <a href="/regionblock?{{$p}}">graph</a> <a href="/regionblock?{{$p}}&raw=1" download="block.profile">(download)</a></td> </tr> <tr> <td>Syscall profile:</td>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 14.3K bytes - Viewed (0) -
pilot/pkg/model/config.go
// Resource versions record the last mutation operation on each object. If a // mutation is applied to a different revision of an object than what the // underlying storage expects as defined by pure equality, the operation is // blocked. The client of this interface should not make assumptions about the // structure or ordering of the revision identifier. // // Object references supplied and returned from this interface should be
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 08:51:03 UTC 2024 - 13.1K bytes - Viewed (0)