- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 91 for Roll (0.1 sec)
-
src/syscall/fs_wasip1.go
// stdio. Since WebAssembly modules are single-threaded, blocking // system calls temporarily halt execution of the module. If the // runtime supports non-blocking stdio, the Go runtime is able to // use the WASI net poller to poll for read/write readiness and is // able to schedule goroutines while waiting. SetNonblock(0, true) SetNonblock(1, true) SetNonblock(2, true) } type uintptr32 = uint32 type size = uint32
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 24.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
} } @GuardedBy("this") void drainKeyReferenceQueue(ReferenceQueue<K> keyReferenceQueue) { Reference<? extends K> ref; int i = 0; while ((ref = keyReferenceQueue.poll()) != null) { @SuppressWarnings("unchecked") E entry = (E) ref; map.reclaimKey(entry); if (++i == DRAIN_MAX) { break; } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
src/runtime/runtime2.go
} type schedt struct { goidgen atomic.Uint64 lastpoll atomic.Int64 // time of last network poll, 0 if currently polling pollUntil atomic.Int64 // time to which current poll is sleeping lock mutex // When increasing nmidle, nmidlelocked, nmsys, or nmfreed, be // sure to call checkdead().
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
} else { // Remote side closed connection or error processing the request. return <-con.ErrorCh() } case <-con.StopCh(): return nil default: } // If there wasn't already a request, poll for requests and pushes. Note: if we have a huge // amount of incoming requests, we may still send some pushes, as we do not `continue` above;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K 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/controller/podgc/gc_controller_test.go
}, Spec: v1.PodSpec{NodeName: nodeName}, Status: v1.PodStatus{Phase: phase}, } } func waitForAdded(q workqueue.TypedDelayingInterface[string], depth int) error { return wait.Poll(1*time.Millisecond, 10*time.Second, func() (done bool, err error) { if q.Len() == depth { return true, nil } return false, nil }) } func TestGCOrphaned(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
src/os/exec/exec_test.go
// circular dependency on non-cgo darwin. package exec_test import ( "bufio" "bytes" "context" "errors" "flag" "fmt" "internal/poll" "internal/testenv" "io" "log" "net" "net/http" "net/http/httptest" "os" "os/exec" "os/exec/internal/fdtest" "os/signal" "path/filepath" "runtime" "runtime/debug" "strconv"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/opGen.go
reg: regInfo{ inputs: []inputInfo{ {0, 239}, // AX CX DX BX BP SI DI }, outputs: []outputInfo{ {0, 239}, // AX CX DX BX BP SI DI }, }, }, { name: "ROLL", argLen: 2, resultInArg0: true, clobberFlags: true, asm: x86.AROLL, reg: regInfo{ inputs: []inputInfo{ {1, 2}, // CX {0, 239}, // AX CX DX BX BP SI DI
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 15:49:20 UTC 2024 - 1M bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/adapter/ProtocolToModelAdapter.java
Set<Class<?>> seenInterfaces = new HashSet<>(); Queue<Class<?>> queue = new ArrayDeque<>(); queue.add(clazz); Class<?> type; while ((type = queue.poll()) != null) { Class<?> superclass = type.getSuperclass(); if (superclass != null) { queue.add(superclass); } for (Class<?> iface : type.getInterfaces()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 21 04:42:54 UTC 2024 - 45.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/transform/ArtifactTransformCachingIntegrationTest.groovy
import static org.gradle.internal.service.scopes.DefaultGradleUserHomeScopeServiceRegistry.REUSE_USER_HOME_SERVICES import static org.gradle.test.fixtures.ConcurrentTestUtil.poll import static org.hamcrest.Matchers.containsString
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 11:52:44 UTC 2024 - 97.8K bytes - Viewed (0)