- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for isync (0.14 sec)
-
pkg/controller/garbagecollector/garbagecollector_test.go
// for cache sync ~2 times in every wait.PollImmediateUntil() loop. // // The 1s sleep in the test allows GetDeletableResources and // gc.resyncMonitors to run ~5 times to ensure the changes to the // fakeDiscoveryClient are picked up. go gc.Sync(tCtx, fakeDiscoveryClient, 200*time.Millisecond) // Wait until the sync discovers the initial resources time.Sleep(1 * time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
fastapi/routing.py
actual_response_class: Type[Response] = response_class.value else: actual_response_class = response_class async def app(request: Request) -> Response: response: Union[Response, None] = None async with AsyncExitStack() as file_stack: try: body: Any = None if body_field: if is_body_form:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 170.1K bytes - Viewed (0) -
go.sum
golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 15:32:28 UTC 2024 - 101.6K bytes - Viewed (0) -
fastapi/applications.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 18 00:48:03 UTC 2024 - 172.2K bytes - Viewed (0) -
src/database/sql/sql_test.go
"fmt" "internal/race" "internal/testenv" "math/rand" "reflect" "runtime" "slices" "strings" "sync" "sync/atomic" "testing" "time" ) func init() { type dbConn struct { db *DB c *driverConn } freedFrom := make(map[dbConn]string) var mu sync.Mutex getFreedFrom := func(c dbConn) string { mu.Lock() defer mu.Unlock() return freedFrom[c] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
// Run once to populate the status map. kl.HandlePodAdditions(pods) if _, found := kl.statusManager.GetPodStatus(podToTest.UID); !found { t.Fatalf("expected to have status cached for pod2") } // Sync with empty pods so that the entry in status map will be removed. kl.podManager.SetPods([]*v1.Pod{}) kl.HandlePodCleanups(ctx) if _, found := kl.statusManager.GetPodStatus(podToTest.UID); found {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
// for client state to sync. In fact, because the client is not updated during tests, informer updates will break tests // by unexpectedly deleting objects. // // TODO: It might be better to rewrite all these tests manipulate the client an explicitly sync to ensure consistent // state, or to create a fake client that does not use a local cache.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
"fmt" "internal/abi" "log" "math/rand" "os" "sort" "strconv" "strings" "sync" "sync/atomic" ) // isRuntimeDepPkg reports whether pkg is the runtime package or its dependency. func isRuntimeDepPkg(pkg string) bool { switch pkg { case "runtime", "sync/atomic", // runtime may call to sync/atomic, due to go:linkname "internal/abi", // used by reflectcall (and maybe more)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (0) -
cmd/admin-handlers.go
z, ok := objectAPI.(*erasureServerPools) if !ok { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL) return } vars := mux.Vars(r) var args dsync.LockArgs var lockers []dsync.NetLocker for _, path := range strings.Split(vars["paths"], ",") { if path == "" { continue } args.Resources = append(args.Resources, path) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
"fmt" "go/token" "internal/lazyregexp" "io" "io/fs" "log" "math/rand" "os" "os/exec" "path/filepath" "regexp" "runtime" "slices" "sort" "strconv" "strings" "sync" "time" "cmd/go/internal/base" "cmd/go/internal/cache" "cmd/go/internal/cfg" "cmd/go/internal/fsys" "cmd/go/internal/gover" "cmd/go/internal/load" "cmd/go/internal/modload" "cmd/go/internal/str"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0)