- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 238 for sweeping (0.34 sec)
-
src/cmd/compile/internal/typebits/typebits.go
// a. If it is a compile-time-allocated type, it points into // the read-only data section. // b. If it is a reflect-allocated type, it points into the Go heap. // Reflect is responsible for keeping a reference to // the underlying type so it won't be GCd. // If we ever have a moving GC, we need to change this for 2b (as // well as scan itabs to update their itab._type fields).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 22 01:53:41 UTC 2023 - 3.2K bytes - Viewed (0) -
src/slices/iter.go
func SortedFunc[E any](seq iter.Seq[E], cmp func(E, E) int) []E { s := Collect(seq) SortFunc(s, cmp) return s } // SortedStableFunc collects values from seq into a new slice. // It then sorts the slice while keeping the original order of equal elements, // using the comparison function to compare elements. // It returns the new slice. func SortedStableFunc[E any](seq iter.Seq[E], cmp func(E, E) int) []E { s := Collect(seq)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:40:32 UTC 2024 - 2.9K bytes - Viewed (0) -
src/math/rand/v2/example_test.go
words[i], words[j] = words[j], words[i] }) fmt.Println(words) } func ExampleShuffle_slicesInUnison() { numbers := []byte("12345") letters := []byte("ABCDE") // Shuffle numbers, swapping corresponding entries in letters at the same time. rand.Shuffle(len(numbers), func(i, j int) { numbers[i], numbers[j] = numbers[j], numbers[i] letters[i], letters[j] = letters[j], letters[i] })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 30 17:09:26 UTC 2023 - 4.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_network_linux.go
// creates a security hole (https://issue.k8s.io/90259) which this // iptables rule mitigates. This rule should have been added to // kube-proxy, but it mistakenly ended up in kubelet instead, and we are // keeping it in kubelet for now in case other third-party components // depend on it. if _, err := iptClient.EnsureRule(utiliptables.Append, utiliptables.TableFilter, KubeFirewallChain,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 20:51:47 UTC 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} if (queue.futureTasks.isNotEmpty()) { readyQueues.add(queue) } } /** * Returns an immediately-executable task for the calling thread to execute, sleeping as necessary * until one is ready. If there are no ready queues, or if other threads have everything under * control this will return null. If there is more than a single task ready to execute immediately
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
.github/actions/notify-translations/app/main.py
github_event = PartialGitHubEvent.parse_raw(contents) # Avoid race conditions with multiple labels sleep_time = random.random() * 10 # random number between 0 and 10 seconds logging.info( f"Sleeping for {sleep_time} seconds to avoid " "race conditions and multiple comments" ) time.sleep(sleep_time) # Get PR logging.debug(f"Processing PR: #{github_event.pull_request.number}")
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Sep 27 23:01:46 UTC 2023 - 12.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 12.7K bytes - Viewed (0) -
src/net/net_windows_test.go
} return nil } if envaddr := os.Getenv("GOTEST_DIAL_ADDR"); envaddr != "" { // In child process. c, err := Dial("tcp", envaddr) if err != nil { t.Fatal(err) } fmt.Printf("sleeping\n") time.Sleep(time.Minute) // process will be killed here c.Close() } ln, err := Listen("tcp", "127.0.0.1:0") if err != nil { t.Fatal(err) } defer ln.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
build/common.sh
if [[ "${tag}" != "${2}"* ]] ; then V=3 kube::log::status "Keeping image ${1}:${tag}" continue fi if [[ -z "${3:-}" || "${tag}" != "${3}" ]] ; then V=2 kube::log::status "Deleting image ${1}:${tag}" "${DOCKER[@]}" rmi "${1}:${tag}" >/dev/null else V=3 kube::log::status "Keeping image ${1}:${tag}" fi done }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 26.5K bytes - Viewed (0) -
src/runtime/select.go
typedmemmove(c.elemtype, chanbuf(c, c.sendx), cas.elem) c.sendx++ if c.sendx == c.dataqsiz { c.sendx = 0 } c.qcount++ selunlock(scases, lockorder) goto retc recv: // can receive from sleeping sender (sg) recv(c, sg, cas.elem, func() { selunlock(scases, lockorder) }, 2) if debugSelect { print("syncrecv: cas0=", cas0, " c=", c, "\n") } recvOK = true goto retc rclose:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0)