- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 142 for syncs (0.05 sec)
-
src/cmd/go/internal/modload/buildlist.go
// license that can be found in the LICENSE file. package modload import ( "context" "errors" "fmt" "maps" "os" "runtime" "runtime/debug" "slices" "strings" "sync" "sync/atomic" "cmd/go/internal/base" "cmd/go/internal/cfg" "cmd/go/internal/gover" "cmd/go/internal/mvs" "cmd/go/internal/par" "golang.org/x/mod/module" )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 16:04:44 UTC 2024 - 53.8K bytes - Viewed (0) -
cmd/xl-storage.go
formatLastCheck time.Time diskInfoCache *cachevalue.Cache[DiskInfo] sync.RWMutex formatData []byte nrRequests uint64 major, minor uint32 fsType string immediatePurge chan string // mutex to prevent concurrent read operations overloading walks. rotational bool walkMu *sync.Mutex walkReadMu *sync.Mutex }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (2) -
src/cmd/go/internal/test/test.go
// package Q which appears later in the list (if this // happens we'll wind up building the Q compile action // before updating its deps to include sync/atomic). if cfg.BuildCoverMode == "atomic" && p.ImportPath != "sync/atomic" { load.EnsureImport(p, "sync/atomic") } // Tag the package for static meta-data generation if no // test files (this works only with the new coverage
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 71.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
limitations under the License. */ package cacher import ( "context" "crypto/rand" "errors" "fmt" "reflect" goruntime "runtime" "strconv" "sync" "testing" "time" "github.com/stretchr/testify/require" "google.golang.org/grpc/metadata" apiequality "k8s.io/apimachinery/pkg/api/equality" apierrors "k8s.io/apimachinery/pkg/api/errors"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K 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-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:11 UTC 2024 - 93.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
endpointZoneInfo: map[string]topologycache.EndpointZoneInfo{ "ns/svc1": {zoneA: 1, zoneB: 2, zoneC: 3}, }, expectedQueueLen: 1, }, { name: "even zones, uneven endpoint distribution but within threshold, no sync required", nodes: []nodeInfo{ {zoneLabel: &zoneB, ready: &readyTrue, cpu: &cpu2000}, {zoneLabel: &zoneB, ready: &readyTrue, cpu: &cpu2000}, {zoneLabel: &zoneC, ready: &readyTrue, cpu: &cpu2000},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
cmd/batch-handlers.go
//msgp:ignore BatchJobPool // BatchJobPool batch job pool type BatchJobPool struct { ctx context.Context objLayer ObjectLayer once sync.Once mu sync.Mutex jobCh chan *BatchJobRequest jmu sync.Mutex // protects jobCancelers jobCancelers map[string]context.CancelFunc workerKillCh chan struct{} workerSize int }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
src/net/http/client_test.go
"errors" "fmt" "internal/testenv" "io" "log" "net" . "net/http" "net/http/cookiejar" "net/http/httptest" "net/url" "reflect" "runtime" "strconv" "strings" "sync" "sync/atomic" "testing" "time" ) var robotsTxtHandler = HandlerFunc(func(w ResponseWriter, r *Request) { w.Header().Set("Last-Modified", "sometime") fmt.Fprintf(w, "User-agent: go\nDisallow: /something/") })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
src/crypto/tls/conn.go
package tls import ( "bytes" "context" "crypto/cipher" "crypto/subtle" "crypto/x509" "errors" "fmt" "hash" "internal/godebug" "io" "net" "sync" "sync/atomic" "time" ) // A Conn represents a secured connection. // It implements the net.Conn interface. type Conn struct { // constant conn net.Conn isClient bool
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
src/cmd/go/internal/modload/init.go
import ( "bytes" "context" "encoding/json" "errors" "fmt" "internal/godebugs" "internal/lazyregexp" "io" "os" "path" "path/filepath" "slices" "strconv" "strings" "sync" "cmd/go/internal/base" "cmd/go/internal/cfg" "cmd/go/internal/fsys" "cmd/go/internal/gover" "cmd/go/internal/lockedfile" "cmd/go/internal/modfetch" "cmd/go/internal/search"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:36:30 UTC 2024 - 69.8K bytes - Viewed (0)