- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 77 for fully (0.15 sec)
-
src/cmd/cgo/internal/test/callback_windows.go
fname := f.Name() switch fname { case "goCallback": // TODO(qmuntal): investigate why this function doesn't appear // when using the external linker. continue } // In module mode, this package has a fully-qualified import path. // Remove it if present. fname = strings.TrimPrefix(fname, "cmd/cgo/internal/") if !strings.HasPrefix(fname, "test.") { continue } got = append(got, fname) }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Wed Nov 29 16:01:37 GMT 2023 - 2.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
} return nil } // repairPod actually dynamically repairs a pod. This is done by entering the pods network namespace and setting up rules. // This differs from the general CNI plugin flow, which triggers before the pod fully starts. // Additionally, we need to jump through hoops to find the network namespace. func (c *Controller) repairPod(pod *corev1.Pod) error { m := podsRepaired.With(typeLabel.Value(repairType))
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/metrics-v3-types.go
func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() { mg.bucketsLock.Lock() mg.buckets = buckets return func() { mg.bucketsLock.Unlock() } } // MetricFQN - returns the fully qualified name for the given metric name. func (mg *MetricsGroup) MetricFQN(name MetricName) string { v, ok := mg.descriptorMap[name] if !ok { // This should never happen. return "" }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 14.6K bytes - Viewed (0) -
src/archive/tar/writer.go
} type fileWriter interface { io.Writer fileState ReadFrom(io.Reader) (int64, error) } // Flush finishes writing the current file's block padding. // The current file must be fully written before Flush can be called. // // This is unnecessary as the next call to [Writer.WriteHeader] or [Writer.Close] // will implicitly flush out the file's padding. func (tw *Writer) Flush() error { if tw.err != nil {
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
internal/grid/handlers.go
// StreamHandler handles fully bidirectional streams, // There is flow control in both directions. StreamHandler struct { // Handle an incoming request. Initial payload is sent. // Additional input packets (if any) are streamed to request. // Upstream will block when request channel is full. // Response packets can be sent at any time.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0) -
cmd/erasure-multipart.go
} case size >= fi.Erasure.BlockSize: buffer = globalBytePoolCap.Load().Get() defer globalBytePoolCap.Load().Put(buffer) case size < fi.Erasure.BlockSize: // No need to allocate fully fi.Erasure.BlockSize buffer if the incoming data is smaller. buffer = make([]byte, size, 2*size+int64(fi.Erasure.ParityBlocks+fi.Erasure.DataBlocks-1)) } if len(buffer) > int(fi.Erasure.BlockSize) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/erasure-healing.go
if shouldHealObjectOnDisk(errs[i], dataErrs[i], partsMetadata[i], latestMeta) { outDatedDisks[i] = storageDisks[i] disksToHealCount++ continue } } if isAllNotFound(errs) { // File is fully gone, fileInfo is empty. err := errFileNotFound if versionID != "" { err = errFileVersionNotFound } return er.defaultHealResult(FileInfo{}, storageDisks, storageEndpoints, errs,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
internal/config/config.go
// returns error if it find extra or superfluous keys. func CheckValidKeys(subSys string, kv KVS, validKVS KVS, deprecatedKeys ...string) error { nkv := KVS{} for _, kv := range kv { // Comment is a valid key, its also fully optional // ignore it since it is a valid key for all // sub-systems. if kv.Key == Comment { continue } var skip bool for _, deprecatedKey := range deprecatedKeys {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/bucket-replication.go
} } return } // replicateAll replicates metadata for specified version of the object to destination bucket // if the destination version is missing it automatically does fully copy as well. // The source object is then updated to reflect the replication status. func (ri ReplicateObjectInfo) replicateAll(ctx context.Context, objectAPI ObjectLayer, tgt *TargetClient) (rinfo replicatedTargetInfo) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
internal/rest/client.go
// the client offline in such situations. // generally all implementations should simply return // 403, but in situations where there is a dependency // with the caller to take the client offline purpose // fully it should make sure to respond with '412' // instead, see cmd/storage-rest-server.go for ideas. if c.HealthCheckFn != nil && resp.StatusCode == http.StatusPreconditionFailed {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0)