Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 435 for cancel (0.05 sec)

  1. cmd/ftp-server-driver.go

    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    	clnt, err := driver.getMinIOClient(ctx)
    	if err != nil {
    		return err
    	}
    
    	cctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	bucket, prefix := path2BucketObject(objPath)
    	if bucket == "" {
    		buckets, err := clnt.ListBuckets(cctx)
    		if err != nil {
    			return err
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  2. cmd/auth-handler_test.go

    	}
    	return req
    }
    
    // Tests is requested authenticated function, tests replies for s3 errors.
    func TestIsReqAuthenticated(t *testing.T) {
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    	objLayer, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. .github/workflows/upgrade-ci-cd.yaml

    name: Upgrade old version tests
    
    on:
      pull_request:
        branches:
          - master
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      build:
        name: Go ${{ matrix.go-version }} on ${{ matrix.os }}
        runs-on: ${{ matrix.os }}
        strategy:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 729 bytes
    - Viewed (0)
  4. internal/lsync/lrwmutex.go

    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	retryCtx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	for {
    		select {
    		case <-retryCtx.Done():
    			// Caller context canceled or we timedout,
    			// return false anyways for both situations.
    			return false
    		default:
    			if lm.lock(id, source, isWriteLock) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       next task will wait for any running callable (or pending {@code Future} returned by an
     *       {@code AsyncCallable}) to complete, without interrupting it (and without calling {@code
     *       cancel} on the {@code Future}). So beware: <i>Even if you cancel every preceding {@code
     *       Future} returned by this class, the next task may still have to wait.</i>.
     *   <li>Once an {@code AsyncCallable} returns a {@code Future}, this class considers that task to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users-race_test.go

    			func(t *testing.T) {
    				runAllIAMConcurrencyTests(testCase, &check{t, testCase.serverType})
    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestDeleteUserRace(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 90*time.Second)
    	defer cancel()
    
    	bucket := getRandomBucketName()
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket creat error: %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  7. cmd/lock-rest-server-common_test.go

    		t.Fatal(err)
    	}
    	return fsDir, locker, token
    }
    
    // Test function to remove lock entries from map based on name & uid combination
    func TestLockRpcServerRemoveEntry(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	testPath, locker, _ := createLockTestServer(ctx, t)
    	defer os.RemoveAll(testPath)
    
    	lockRequesterInfo1 := lockRequesterInfo{
    		Owner:           "owner",
    		Writer:          true,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

              connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue
            }
    
            if (connectResult.isSuccess) {
              // We have a connected TCP connection. Cancel and defer the racing connects that all lost.
              cancelInFlightConnects()
    
              // Finish connecting. We won't have to if the winner is from the connection pool.
              if (!connectResult.plan.isReady) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    		setObjectLayer(newObjectLayerFn())
    		cancel()
    		removeRoots(fsDirs)
    	}
    }
    
    // ExecObjectLayerTestWithDirs - executes object layer tests.
    // Creates single node and Erasure ObjectLayer instance and runs test for both the layers.
    func ExecObjectLayerTestWithDirs(t TestErrHandler, objTest objTestTypeWithDirs) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	if localMetacacheMgr != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  10. cmd/server-main_test.go

    				}
    			}
    		})
    	}
    }
    
    // Tests initializing new object layer.
    func TestNewObjectLayer(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	// Tests for ErasureSD object layer.
    	nDisks := 1
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal("Failed to create drives for the backend")
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 07 09:33:56 UTC 2023
    - 3.1K bytes
    - Viewed (0)
Back to top