Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 453 for ctx_ (0.13 sec)

  1. cmd/perf-tests.go

    			continue
    		}
    		info := info
    		wg.Add(connectionsPerPeer)
    		for i := 0; i < connectionsPerPeer; i++ {
    			go func() {
    				defer wg.Done()
    				ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second)
    				defer cancel()
    				perfNetRequest(
    					ctx,
    					info.DeploymentID,
    					adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationDevNull,
    					r,
    				)
    			}()
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. internal/dsync/locker.go

    	// * 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)
    
    	// Do read unlock for given LockArgs. It should return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  3. cmd/admin-handlers-users-race_test.go

    			},
    		)
    	}
    }
    
    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)
    	}
    
    	// Create a policy policy
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. cmd/erasure-healing.go

    	healingMetricObject
    	healingMetricCheckAbandonedParts
    )
    
    func (er erasureObjects) listAndHeal(ctx context.Context, bucket, prefix string, scanMode madmin.HealScanMode, healEntry func(string, metaCacheEntry, madmin.HealScanMode) error) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	disks, _ := er.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  5. cmd/fmt-gen.go

         {{.Prompt}} {{.HelpName}} http://node{1...32}.example.com/mnt/export{1...32}
    
    `,
    }
    
    func fmtGenMain(ctxt *cli.Context) {
    	deploymentID := ctxt.String("deployment-id")
    	err := buildServerCtxt(ctxt, &globalServerCtxt)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	handleCommonArgs(globalServerCtxt)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. cni/pkg/install/install.go

    // will be redeployed.
    func (in *Installer) Run(ctx context.Context) error {
    	installedBins, err := in.installAll(ctx)
    	if err != nil {
    		return err
    	}
    	installLog.Info("initial installation complete, start watching for re-installation")
    	throttle := newInstallationThrottle(in)
    	for {
    		throttle.Throttle(ctx)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  7. tests/test_tutorial/test_query_param_models/test_tutorial002.py

                            "input": "150",
                            "ctx": {"le": 100},
                        },
                        {
                            "type": "greater_than_equal",
                            "loc": ["query", "offset"],
                            "msg": "Input should be greater than or equal to 0",
                            "input": "-1",
                            "ctx": {"ge": 0},
                        },
                        {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. internal/grid/stream.go

    	Requests chan<- []byte
    
    	muxID uint64
    	ctx   context.Context
    }
    
    // Send a payload to the remote server.
    func (s *Stream) Send(b []byte) error {
    	if s.Requests == nil {
    		return errors.New("stream does not accept requests")
    	}
    	select {
    	case s.Requests <- b:
    		return nil
    	case <-s.ctx.Done():
    		return context.Cause(s.ctx)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  9. schema/utils.go

    func GetRelationsValues(ctx context.Context, reflectValue reflect.Value, rels []*Relationship) (reflectResults reflect.Value) {
    	for _, rel := range rels {
    		reflectResults = reflect.MakeSlice(reflect.SliceOf(reflect.PtrTo(rel.FieldSchema.ModelType)), 0, 1)
    
    		appendToResults := func(value reflect.Value) {
    			if _, isZero := rel.Field.ValueOf(ctx, value); !isZero {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Aug 19 13:35:14 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  10. cmd/warm-backend-s3.go

    	return remoteVersionID(res.VersionID), s3.ToObjectError(err, object)
    }
    
    func (s3 *warmBackendS3) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	return s3.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func (s3 *warmBackendS3) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) {
    	gopts := minio.GetObjectOptions{}
    
    	if rv != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top