Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 88 for failure (3.38 sec)

  1. 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)
  2. 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)
  3. internal/hash/reader_test.go

    			size:       4,
    			actualSize: 4,
    		},
    		{
    			desc:       "Failure md5 mismatch.",
    			src:        bytes.NewReader([]byte("abcd")),
    			size:       4,
    			actualSize: 4,
    			md5hex:     "d41d8cd98f00b204e9800998ecf8427f",
    			err: BadDigest{
    				"d41d8cd98f00b204e9800998ecf8427f",
    				"e2fc714c4727ee9395f324cd2e7f331f",
    			},
    		},
    		{
    			desc:       "Failure sha256 mismatch.",
    			src:        bytes.NewReader([]byte("abcd")),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.3K bytes
    - Viewed (0)
  4. 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)
  5. internal/s3select/sql/value.go

    // it returns false only if there is a conversion failure.
    func (v Value) bytesToInt() (int64, bool) {
    	bytes, _ := v.ToBytes()
    	i, err := strconv.ParseInt(strings.TrimSpace(string(bytes)), 10, 64)
    	return i, err == nil
    }
    
    // Converts untyped value into float. The bool return implies success
    // - it returns false only if there is a conversion failure.
    func (v Value) bytesToFloat() (float64, bool) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top