- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 178 for exits (0.14 sec)
-
internal/logger/logrotate.go
func (w *Writer) Write(p []byte) (n int, err error) { return w.pw.Write(p) } // Close closes the writer. // Any accepted writes will be flushed. Any new writes will be rejected. // Once Close() exits, files are synchronized to disk. func (w *Writer) Close() error { w.pw.CloseWithError(nil) if w.f != nil { if err := w.closeCurrentFile(); err != nil { return err } } return nil }
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) -
cni/pkg/nodeagent/cni-watcher.go
} go func() { err := s.cniListenServer.Serve(unixListener) select { case <-s.ctx.Done(): // ctx done, we should silently go away return default: // If the cniListener exits, at least we should record an error log log.Errorf("CNI listener server exiting unexpectedly: %v", err) } }() context.AfterFunc(s.ctx, func() { if err := s.cniListenServer.Close(); err != nil {
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) -
cmd/admin-heal-ops.go
// argument returns if a heal sequence actually exists. func (ahs *allHealState) getHealSequence(path string) (h *healSequence, exists bool) { ahs.RLock() defer ahs.RUnlock() h, exists = ahs.healSeqMap[path] return h, exists } func (ahs *allHealState) stopHealSequence(path string) ([]byte, APIError) { var hsp madmin.HealStopSuccess he, exists := ahs.getHealSequence(path) if !exists { hsp = madmin.HealStopSuccess{
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/event/target/elasticsearch.go
res, err := c.Exists( index, key, c.Exists.WithContext(ctx), ) if err != nil { return false, err } xhttp.DrainBody(res.Body) return !res.IsError(), nil } func (c *esClientV7) removeEntry(ctx context.Context, index string, key string) error { exists, err := c.entryExists(ctx, index, key) if err == nil && exists { res, err := c.Delete( index,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/typed-errors.go
// error returned when temporary account is not found var errNoSuchTempAccount = errors.New("Specified temporary account does not exist") // error returned in IAM subsystem when an account doesn't exist. var errNoSuchAccount = errors.New("Specified account does not exist") // error returned in IAM subsystem when groups doesn't exist.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
cmd/metacache-entries.go
dst := make(metaCacheEntries, len(m)) copy(dst, m) return dst } type metadataResolutionParams struct { dirQuorum int // Number if disks needed for a directory to 'exist'. objQuorum int // Number of disks needed for an object to 'exist'. // An optimization request only an 'n' amount of versions from xl.meta // to avoid resolving all versions to figure out the latest 'version' // for ListObjects, ListObjectsV2
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
t.Fatalf("Unexpected failure with %v", errorCodes.ToAPIErr(s3Err)) } if !owner { t.Fatalf("Expected owner to be 'true', found %t", owner) } _, _, s3Err = checkKeyValid(req, "does-not-exist") if s3Err != ErrInvalidAccessKeyID { t.Fatalf("Expected error 'ErrInvalidAccessKeyID', found %v", s3Err) } ucreds, err := auth.CreateCredentials("myuser1", "mypassword1") if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
cmd/os-reliable.go
return errFileAccessDenied } return osErrToFileErr(err) } return nil } // Reliably retries os.MkdirAll if for some reason os.MkdirAll returns // syscall.ENOENT (parent does not exist). func reliableMkdirAll(dirPath string, mode os.FileMode, baseDir string) (err error) { i := 0 for { // Creates all the parent directories, with mode 0777 mkdir honors system umask.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
src/cmd/addr2line/addr2line_test.go
// GO_ADDR2LINETEST_IS_ADDR2LINE is set, and runs the tests otherwise. func TestMain(m *testing.M) { if os.Getenv("GO_ADDR2LINETEST_IS_ADDR2LINE") != "" { main() os.Exit(0) } os.Setenv("GO_ADDR2LINETEST_IS_ADDR2LINE", "1") // Set for subprocesses to inherit. os.Exit(m.Run()) } // addr2linePath returns the path to the "addr2line" binary to run. func addr2linePath(t testing.TB) string { t.Helper() testenv.MustHaveExec(t)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 22:16:54 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/batch-expire.go
if isErrBucketNotFound(err) { return batchExpireJobError{ Code: "NoSuchSourceBucket", Description: "The specified source bucket does not exist", HTTPStatusCode: http.StatusNotFound, } } return err } if len(r.Rules) > maxBatchRules { return batchExpireJobError{ Code: "InvalidArgument",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1)