- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 112 for failure (0.16 sec)
-
internal/dsync/locker.go
// Do read lock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of lock request operation. RLock(ctx context.Context, args LockArgs) (bool, error) // Do write lock for given LockArgs. It should return // * a boolean to indicate success/failure of the operation // * an error on failure of lock request operation. Lock(ctx context.Context, args LockArgs) (bool, error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
initial := timeout.Timeout() for i := 0; i < dynamicTimeoutLogSize; i++ { timeout.LogFailure() } adjusted := timeout.Timeout() if initial >= adjusted { t.Errorf("Failure to increase timeout, expected %v to be more than %v", adjusted, initial) } } func TestDynamicTimeoutDualIncrease(t *testing.T) { timeout := newDynamicTimeout(time.Minute, time.Second) initial := timeout.Timeout()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
cmd/server-main_test.go
sctx := &serverCtxt{} err := mergeServerCtxtFromConfigFile(testcase.config, sctx) if testcase.expectedErr && err == nil { t.Error("expected failure, got success") } if !testcase.expectedErr && err != nil { t.Error("expected success, got failure", err) } if err == nil { if len(sctx.Layout.pools) != 2 { t.Error("expected parsed pools to be 2, not", len(sctx.Layout.pools)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Dec 07 09:33:56 GMT 2023 - 3.1K bytes - Viewed (0) -
cni/pkg/install/kubeconfig_test.go
} result, err := createKubeConfig(cfg) if err != nil { if !c.expectedFailure { t.Fatalf("did not expect failure: %v", err) } // Successful test case expecting failure return } else if c.expectedFailure { t.Fatalf("expected failure") } goldenFilepath := "testdata/kubeconfig-tls" if c.skipTLSVerify { goldenFilepath = "testdata/kubeconfig-skip-tls" }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 03:52:24 GMT 2024 - 5.1K bytes - Viewed (0) -
cmd/format-erasure_test.go
false, }, } // Valid all test cases. for i, testCase := range testCases { if err := checkFormatErasureValue(testCase.format, nil); err != nil && testCase.success { t.Errorf("Test %d: Expected failure %s", i+1, err) } } } // Tests getFormatErasureInQuorum() func TestGetFormatErasureInQuorumCheck(t *testing.T) { setCount := 2 setDriveCount := 16
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.9K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
package mountinfo import ( "fmt" "os" "path/filepath" "strings" "testing" ) // Tests cross device mount verification function, for both failure // and success cases. func TestCrossDeviceMountPaths(t *testing.T) { successCase := `/dev/0 /path/to/0/1 type0 flags 0 0 /dev/1 /path/to/1 type1 flags 1 1 /dev/2 /path/to/1/2 type2 flags,1,2=3 2 2
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
internal/config/identity/openid/jwt_test.go
claims["exp"] = testCase.exp err := updateClaimsExpiry(testCase.dsecs, claims) if err != nil && !testCase.expectedFailure { t.Errorf("Expected success, got failure %s", err) } if err == nil && testCase.expectedFailure { t.Error("Expected failure, got success") } }) } } func initJWKSServer() *httptest.Server { server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.3K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
NoAuditLog: true, }) var failure bool if err != nil { if isErrObjectNotFound(err) || isErrVersionNotFound(err) { err = nil } } stopFn(err) if err != nil { decomLogIf(ctx, err) failure = true } z.poolMetaMutex.Lock() z.poolMeta.CountItem(idx, 0, failure) z.poolMetaMutex.Unlock() if !failure {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/tier.go
} type tierMetrics struct { sync.RWMutex // protects requestsCount only requestsCount map[string]struct { success int64 failure int64 } histogram *prometheus.HistogramVec } var globalTierMetrics = tierMetrics{ requestsCount: make(map[string]struct { success int64 failure int64 }), histogram: prometheus.NewHistogramVec(prometheus.HistogramOpts{ Name: "tier_ttlb_seconds",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
SkipRebalancing: true, // make sure we skip the decommissioned pool NoAuditLog: true, }) var failure bool if err != nil && !isErrObjectNotFound(err) && !isErrVersionNotFound(err) { rebalanceLogIf(ctx, err) failure = true } if !failure { z.updatePoolStats(poolIdx, bucket, version) rebalanced++ }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0)