- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 46 for syncs (0.13 sec)
-
src/database/sql/sql.go
package sql import ( "context" "database/sql/driver" "errors" "fmt" "io" "math/rand/v2" "reflect" "runtime" "slices" "strconv" "sync" "sync/atomic" "time" _ "unsafe" ) var driversMu sync.RWMutex // drivers should be an internal detail, // but widely used packages access it using linkname. // (It is extra wrong that they linkname drivers but not driversMu.)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K 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) -
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_pods.go
if t { return "true" } return "" } runningPods := make(map[types.UID]sets.Empty) possiblyRunningPods := make(map[types.UID]sets.Empty) for uid, sync := range workingPods { switch sync.State { case SyncPod: runningPods[uid] = struct{}{} possiblyRunningPods[uid] = struct{}{} case TerminatingPod: possiblyRunningPods[uid] = struct{}{} default: }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
cmd/site-replication.go
infos, err := globalSiteReplicationSys.GetClusterInfo(ctx) if err != nil { return results, err } var wg sync.WaitGroup var resultsMu sync.RWMutex for _, info := range infos.Sites { info := info // will call siteNetperf, means call others's adminAPISiteReplicationDevNull if globalDeploymentID() == info.DeploymentID { wg.Add(1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
cluster/gce/util.sh
function construct-linux-kubelet-flags { local node_type="$1" local flags flags="$(construct-common-kubelet-flags)" # Keep in sync with CONTAINERIZED_MOUNTER_HOME in configure-helper.sh flags+=" --experimental-mounter-path=/home/kubernetes/containerized_mounter/mounter" # Keep in sync with the mkdir command in configure-helper.sh (until the TODO is resolved) flags+=" --cert-dir=/var/lib/kubelet/pki/"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.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) -
src/net/http/serve_test.go
"net/http/httptrace" "net/http/httputil" "net/http/internal" "net/http/internal/testcert" "net/url" "os" "path/filepath" "reflect" "regexp" "runtime" "strconv" "strings" "sync" "sync/atomic" "syscall" "testing" "time" ) type dummyAddr string type oneConnListener struct { conn net.Conn } func (l *oneConnListener) Accept() (c net.Conn, err error) { c = l.conn
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K 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 (1)