- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 170 for safe (0.12 sec)
-
internal/logger/logrotate.go
// may fall on the same timestamp. // Eg. // 2020-03-28_15-00-945-<random-hash>.log // When FileNameFunc is not specified, DefaultFilenameFunc will be used. FileNameFunc func() string // Compress specify if you want the logs to be compressed after rotation. Compress bool } // Writer is a concurrency-safe writer with file rotation. type Writer struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/dsync/dsync_test.go
// Make it run twice. timer := time.NewTimer(testDrwMutexRefreshInterval * 2) select { case <-ctx.Done(): t.Fatal("Lock context canceled which is not expected") case <-timer.C: } // Should be safe operation in all cases dm.Unlock(context.Background()) } // Test canceling context while quorum servers report lock not found func TestFailedRefreshLock(t *testing.T) { if testing.Short() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// traverseAndHeal - traverses on-disk data and performs healing // according to settings. At each "safe" point it also checks if an // external quit signal has been received and quits if so. Since the // healing traversal may be mutating on-disk data when an external // quit signal is received, this routine cannot quit immediately and // has to wait until a safe point is reached, such as between scanning // two objects.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
internal/grid/handlers.go
} // RoundTripper provides an interface for type roundtrip serialization. type RoundTripper interface { msgp.Unmarshaler msgp.Marshaler msgp.Sizer comparable } // SingleHandler is a type safe handler for single roundtrip requests. type SingleHandler[Req, Resp RoundTripper] struct { id HandlerID sharedResp bool callReuseReq bool ignoreNilConn bool newReq func() Req
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
// The CNI node plugin should have already checked the pod against the k8s API before forwarding us the event, // but we have to invoke the K8S client anyway, so to be safe we check it again here to make sure we get the same result. maxStaleRetries := 10 msInterval := 10 retries := 0 var ambientPod *corev1.Pod var err error
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
src/bufio/scan.go
s.end -= s.start s.start = 0 } // Finally we can read some input. Make sure we don't get stuck with // a misbehaving Reader. Officially we don't need to do this, but let's // be extra careful: Scanner is for safe, simple jobs. for loop := 0; ; { n, err := s.r.Read(s.buf[s.end:len(s.buf)]) if n < 0 || len(s.buf)-s.end < n { s.setErr(ErrBadReadCount) break } s.end += n if err != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 14.2K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
" To get started, check out https://istio.io/latest/docs/setup/getting-started/\n") } else { fmt.Fprintln(cmd.OutOrStdout(), output) } for _, m := range msgs { if m.Type.Level().IsWorseThanOrEqualTo(diag.Warning) { e := fmt.Sprintf(`Issues found when checking the cluster. Istio may not be safe to install or upgrade.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/signature-v4-utils.go
// Expect header is always of form: // // Expect = "Expect" ":" 1#expectation // expectation = "100-continue" | expectation-extension // // So it safe to assume that '100-continue' is what would // be sent, for the time being keep this work around. // Adding a *TODO* to remove this later when Golang server // doesn't filter out the 'Expect' header.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
cmd/peer-s3-client.go
} buckets := make([]BucketInfo, 0, len(bi.Value())) for _, b := range bi.Value() { if b != nil { buckets = append(buckets, *b) } } bi.Recycle() // BucketInfo has no internal pointers, so it's safe to recycle. return buckets, nil } func (client *remotePeerS3Client) HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error) { conn := client.gridConn() if conn == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
src/archive/zip/reader.go
end, baseOffset, err := readDirectoryEnd(rdr, size) if err != nil { return err } r.r = rdr r.baseOffset = baseOffset // Since the number of directory records is not validated, it is not // safe to preallocate r.File without first checking that the specified // number of files is reasonable, since a malformed archive may // indicate it contains up to 1 << 128 - 1 files. Since each file has a
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0)