- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 103 for pushHead (0.14 sec)
-
pkg/kubelet/cm/devicemanager/plugin/v1beta1/client.go
return } for { response, err := stream.Recv() if err != nil { klog.ErrorS(err, "ListAndWatch ended unexpectedly for device plugin", "resource", c.resource) return } klog.V(2).InfoS("State pushed for device plugin", "resource", c.resource, "resourceCapacity", len(response.Devices)) c.handler.PluginListAndWatchReceiver(c.resource, response) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:35:13 UTC 2023 - 3.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/optimize_op_order.cc
num_elements *= tensor.getDimSize(i); } } return num_elements; }; // If the op is the pass-through op with (3x) smaller output, the dequantize // op can be pushed down to the single result of this op. if (!llvm::dyn_cast<mlir::SameScalesOpInterface>(passthrough_op) || passthrough_op->getNumResults() != 1) { return failure(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 5.1K bytes - Viewed (0) -
src/runtime/signal_ppc64x.go
c.set_pc(uint64(abi.FuncPCABIInternal(sigpanic))) } func (c *sigctxt) pushCall(targetPC, resumePC uintptr) { // Push the LR to stack, as we'll clobber it in order to // push the call. The function being pushed is responsible // for restoring the LR and setting the SP back. // This extra space is known to gentraceback. sp := c.sp() - sys.MinFrameSize c.set_sp(sp) *(*uint64)(unsafe.Pointer(uintptr(sp))) = c.link()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 15:08:04 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/queue/instance.go
// the processing go routine should stop. func (q *queueImpl) get() (task *queueTask, shutdown bool) { q.cond.L.Lock() defer q.cond.L.Unlock() // wait for closing to be set, or a task to be pushed for !q.closing && len(q.tasks) == 0 { q.cond.Wait() } if q.closing && len(q.tasks) == 0 { // We must be shutting down. return nil, true } task = q.tasks[0]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 4.1K bytes - Viewed (0) -
src/runtime/signal_arm64.go
c.set_pc(uint64(abi.FuncPCABIInternal(sigpanic))) } func (c *sigctxt) pushCall(targetPC, resumePC uintptr) { // Push the LR to stack, as we'll clobber it in order to // push the call. The function being pushed is responsible // for restoring the LR and setting the SP back. // This extra space is known to gentraceback. sp := c.sp() - 16 // SP needs 16-byte alignment c.set_sp(sp) *(*uint64)(unsafe.Pointer(uintptr(sp))) = c.lr()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 05 18:16:00 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
// from API Server containing information that requires updating service rules. It // indicates that the proxier for the given IP family has received changes but has not // yet pushed them to its backend. If the proxier does not call Updated within the // healthTimeout time then it will be considered unhealthy. func (hs *ProxierHealthServer) QueuedUpdate(ipFamily v1.IPFamily) { hs.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0) -
architecture/networking/pilot.md
determine which *types* may be impacted. For example, we know a `WasmPlugin` does not impact the `Cluster` type, so we can skip generating `Cluster` in this case. Warning: Envoy currently has a bug that *requires* `Endpoints` to be pushed any time the corresponding `Cluster` is pushed, so this optimization is intentionally turned off in this specific case. Finally, we determine which subset of the type we need to generate. XDS has two modes - "State of the World (SotW)" and "Delta". In SotW, we...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 17:53:24 UTC 2024 - 19.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/configuration/DaemonParameters.java
this.requestedJvmCriteria = new DaemonJvmCriteria(javaVersion, DefaultJvmVendorSpec.any(), JvmImplementation.VENDOR_SPECIFIC); } catch (Exception e) { // TODO: This should be pushed somewhere else so we consistently report this message in the right context.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:16:16 UTC 2024 - 10.5K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/CacheTaskArchiveErrorIntegrationTest.groovy
!localCache.hasCacheEntry(cacheKey) localCache.listCacheTempFiles().empty } @ToBeFixedForConfigurationCache(skip = INVESTIGATE) def "archive is not pushed to remote when packing fails"() { executer.withStacktraceEnabled() when: file("input.txt") << "data" settingsFile << remoteCache.remoteCacheConfiguration()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
} w.MeshConfig.Store(meshConfig) handlers = append(handlers, w.handlers...) } // TODO hack: the first handler added is the ConfigPush, other handlers affect what will be pushed, so reversing iteration for i := len(handlers) - 1; i >= 0; i-- { handlers[i].handler() } } // Add to the FileWatcher the provided file and execute the provided function
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0)