- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 324 for if (0.17 sec)
-
cmd/peer-rest-client.go
if gridHost == "" { bugLogIf(context.Background(), fmt.Errorf("gridHost is empty for peer %s", peer.String()), peer.String()+":gridHost") return nil } gc := gridConn.Load() if gc != nil { return gc } gm := globalGrid.Load() if gm == nil { return nil } gc = gm.Connection(gridHost) if gc == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
if err != nil { t.Fatal(err) } if err = signRequestV4(req, globalActiveCred.AccessKey, globalActiveCred.SecretKey); err != nil { t.Fatal(err) } _, owner, s3Err := checkKeyValid(req, globalActiveCred.AccessKey) if s3Err != ErrNone { t.Fatalf("Unexpected failure with %v", errorCodes.ToAPIErr(s3Err)) } if !owner {
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/bucket-replication-stats.go
if err == nil { r.srStats.update(sr, dID) } } // Update updates in-memory replication statistics with new values. func (r *ReplicationStats) Update(bucket string, ri replicatedTargetInfo, status, prevStatus replication.StatusType) { if r == nil { return } var rs replStat switch status { case replication.Pending: if ri.OpType.IsDataReplication() && prevStatus != status {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
log.Debug("pod netns was not found, trying to find it using procfs") // this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/erasure-decode_test.go
closeBitrotReaders(bitrotReaders) if err != nil && !test.shouldFail { t.Errorf("Test %d: should pass but failed with: %v", i, err) } if err == nil && test.shouldFail { t.Errorf("Test %d: should fail but it passed", i) } if err == nil { if content := writer.Bytes(); !bytes.Equal(content, data[test.offset:test.offset+test.length]) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 21.1K bytes - Viewed (1) -
cmd/sftp-server.go
if globalIAMSys.LDAPConfig.Enabled() { sa, _, err := globalIAMSys.getServiceAccount(context.Background(), c.User()) if err != nil && !errors.Is(err, errNoSuchServiceAccount) { return nil, err } if errors.Is(err, errNoSuchServiceAccount) { targetUser, targetGroups, err := globalIAMSys.LDAPConfig.Bind(c.User(), string(pass)) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 10.4K bytes - Viewed (0) -
internal/config/api/api.go
maxVerStr := env.Get(EnvAPIObjectMaxVersions, "") if maxVerStr == "" { maxVerStr = env.Get(EnvAPIObjectMaxVersionsLegacy, kvs.Get(apiObjectMaxVersions)) } if maxVerStr != "" { maxVersions, err := strconv.ParseInt(maxVerStr, 10, 64) if err != nil { return cfg, err } if maxVersions <= 0 { return cfg, fmt.Errorf("invalid object max versions value: %v", maxVersions) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
chainable_api.go
tx = db.getInstance() if strings.Contains(name, " ") || strings.Contains(name, "`") || len(args) > 0 { tx.Statement.TableExpr = &clause.Expr{SQL: name, Vars: args} if results := tableRegexp.FindStringSubmatch(name); len(results) == 3 { if results[1] != "" { tx.Statement.Table = results[1] } else { tx.Statement.Table = results[2] } } } else if tables := strings.Split(name, "."); len(tables) == 2 {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Apr 17 03:38:55 GMT 2024 - 14.3K bytes - Viewed (1) -
src/archive/zip/struct.go
m = s_IFIFO case fs.ModeSocket: m = s_IFSOCK case fs.ModeDevice: m = s_IFBLK case fs.ModeDevice | fs.ModeCharDevice: m = s_IFCHR } if mode&fs.ModeSetuid != 0 { m |= s_ISUID } if mode&fs.ModeSetgid != 0 { m |= s_ISGID } if mode&fs.ModeSticky != 0 { m |= s_ISVTX } return m | uint32(mode&0777) } func unixModeToFileMode(m uint32) fs.FileMode {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 12.1K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
cmd.SetOut(&out) cmd.SetErr(&out) cmd.SilenceUsage = true if c.namespace != "" { namespace = c.namespace } fErr := cmd.Execute() output := out.String() if c.expectedException { if fErr == nil { t.Fatalf("Wanted an exception, "+ "didn't get one, output was %q", output) } } else { if fErr != nil { t.Fatalf("Unwanted exception: %v", fErr) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0)