- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for atomics (0.69 sec)
-
cmd/bucket-replication.go
return } switch v := oi.(type) { case ReplicateObjectInfo: globalReplicationStats.incQ(v.Bucket, v.Size, v.DeleteMarker, v.OpType) atomic.AddInt32(&p.activeMRFWorkers, 1) replicateObject(p.ctx, v, p.objLayer) atomic.AddInt32(&p.activeMRFWorkers, -1) globalReplicationStats.decQ(v.Bucket, v.Size, v.DeleteMarker, v.OpType) default:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
src/net/http/server.go
bufw *bufio.Writer // lastMethod is the method of the most recent request // on this connection, if any. lastMethod string curReq atomic.Pointer[response] // (which has a Request in it) curState atomic.Uint64 // packed (unixtime<<8|uint8(ConnState)) // mu guards hijackedv mu sync.Mutex // hijackedv is whether this connection has been hijacked
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/net/http/serve_test.go
} // countCloseListener is a Listener wrapper that counts the number of Close calls. type countCloseListener struct { net.Listener closes int32 // atomic } func (p *countCloseListener) Close() error { var err error if n := atomic.AddInt32(&p.closes, 1); n == 1 && p.Listener != nil { err = p.Listener.Close() } return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
cmd/metrics-v2.go
}, Value: float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshSuccesses)), }, { Description: MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: iamSubsystem, Name: "sync_failures", Help: "Number of failed IAM data syncs since server uptime", Type: counterMetric, }, Value: float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshFailures)),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
src/cmd/go/alldocs.go
// -cover // enable code coverage instrumentation. // -covermode set,count,atomic // set the mode for coverage analysis. // The default is "set" unless -race is enabled, // in which case it is "atomic". // The values: // set: bool: does this statement run? // count: int: how many times does this statement run? // atomic: int: count, but correct in multithreaded tests; // significantly more expensive.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:54:28 UTC 2024 - 142.4K bytes - Viewed (0) -
go.sum
go.uber.org/atomic v1.3.2/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE= go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE= go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 15:32:28 UTC 2024 - 101.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
limitations under the License. */ package registry import ( "context" "encoding/json" "fmt" "path" "reflect" "strconv" "strings" "sync" "sync/atomic" "testing" "time" fuzz "github.com/google/gofuzz" "k8s.io/apimachinery/pkg/api/apitesting" apiequality "k8s.io/apimachinery/pkg/api/equality" "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 - 101.8K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
"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) -
pkg/kubelet/kubelet.go
*/ package kubelet import ( "context" "crypto/tls" "errors" "fmt" "math" "net" "net/http" "os" "path/filepath" sysruntime "runtime" "sort" "sync" "sync/atomic" "time" cadvisorapi "github.com/google/cadvisor/info/v1" "github.com/google/go-cmp/cmp" "github.com/opencontainers/selinux/go-selinux" "go.opentelemetry.io/otel/attribute"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
cmd/object-handlers.go
"bytes" "context" "encoding/hex" "encoding/xml" "errors" "fmt" "io" "net/http" "net/http/httptest" "net/textproto" "net/url" "os" "sort" "strconv" "strings" "sync/atomic" "time" "unicode" "github.com/google/uuid" "github.com/klauspost/compress/gzhttp" miniogo "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/credentials"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0)