Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 391 for ctx_ (0.03 sec)

  1. tensorflow/c/eager/dlpack_test.cc

      TestHandleFromDLPack(status, ctx, {1}, {1});
      TestHandleFromDLPack(status, ctx, {1}, {0});
      TestHandleFromDLPack(status, ctx, {4, 1, 2}, {2, 1, 1});
      TestHandleFromDLPack(status, ctx, {4, 1, 2}, {2, 0, 1});
      TestHandleFromDLPack(status, ctx, {4, 3, 1}, {3, 1, 1});
      TestHandleFromDLPack(status, ctx, {4, 3, 1}, {3, 1, 0});
      // Test that empty tensors can have any strides.
      TestHandleFromDLPack(status, ctx, {4, 0, 2}, {0, 2, 1});
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Jun 30 03:04:46 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  2. cmd/peer-s3-client.go

    type peerS3Client interface {
    	ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error)
    	HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	GetBucketInfo(ctx context.Context, bucket string, opts BucketOptions) (BucketInfo, error)
    	MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error
    	DeleteBucket(ctx context.Context, bucket string, opts DeleteBucketOptions) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. cmd/erasure.go

    					continue
    				}
    				scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update")
    				updates <- cache.clone()
    
    				lastSave = cache.Info.LastUpdate
    			case v, ok := <-bucketResults:
    				if !ok {
    					// Save final state...
    					cache.Info.NextCycle = wantCycle
    					cache.Info.LastUpdate = time.Now()
    					scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-channel-closed")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  4. cmd/sts-handlers.go

    	// Set the newly generated credentials.
    	updatedAt, err := globalIAMSys.SetTempUser(ctx, cred.AccessKey, cred, "")
    	if err != nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInternalError, err)
    		return
    	}
    
    	// Call hook for site replication.
    	if cred.ParentUser != globalActiveCred.AccessKey {
    		replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{
    			Type: madmin.SRIAMItemSTSAcc,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  5. cmd/iam.go

    					sys.purgeExpiredCredentialsForLDAP(ctx)
    					sys.updateGroupMembershipsForLDAP(ctx)
    				}
    				if sys.OpenIDConfig.ProviderEnabled() {
    					sys.purgeExpiredCredentialsForExternalSSO(ctx)
    				}
    			}
    
    			timer.Reset(waitInterval())
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    func (sys *IAMSys) validateAndAddRolePolicyMappings(ctx context.Context, m map[arn.ARN]string) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  6. cmd/namespace-lock.go

    	}) {
    		timeout.LogFailure()
    		defer cancel()
    		if err := newCtx.Err(); err == context.Canceled {
    			return LockContext{ctx: ctx, cancel: func() {}}, err
    		}
    		return LockContext{ctx: ctx, cancel: func() {}}, OperationTimedOut{}
    	}
    	timeout.LogSuccess(UTCNow().Sub(start))
    	return LockContext{ctx: newCtx, cancel: cancel}, nil
    }
    
    // Unlock - block until write lock is released.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. cmd/erasure-object_test.go

    	defer removeRoots(disks)
    
    	err = objLayer.MakeBucket(ctx, "bucket1", MakeBucketOptions{})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	res, err := objLayer.NewMultipartUpload(ctx, "bucket1", "mpartObj1", opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    	fiveMBBytes := bytes.Repeat([]byte("a"), 5*humanize.MiByte)
    	md5Hex := getMD5Hash(fiveMBBytes)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  8. tensorflow/c/eager/c_api_cluster_test.cc

      CheckRemoteMatMulExecutesOK(ctx, remote_device_name, local_device_name);
    
      TFE_ContextUpdateServerDef(ctx, 0, serialized.data(), serialized.size(),
                                 status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      CheckRemoteMatMulExecutesOK(ctx, remote_device_name, local_device_name);
    
      TFE_DeleteContext(ctx);
      TF_DeleteStatus(status);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  9. cmd/metacache-walk.go

    				return nil
    			}
    			if contextCanceled(ctx) {
    				return ctx.Err()
    			}
    			pop := dirStack[len(dirStack)-1]
    			select {
    			case <-ctx.Done():
    				return ctx.Err()
    			case out <- metaCacheEntry{name: pop}:
    			}
    			if opts.Recursive {
    				// Scan folder we found. Should be in correct sort order where we are.
    				internalLogIf(ctx, scanDir(pop))
    			}
    			dirStack = dirStack[:len(dirStack)-1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  10. cmd/sts-handlers_test.go

    	dillonClient := makeSTSClient("******@****.***", "dillon")
    	// Validate client's permissions
    	c.mustListBuckets(ctx, dillonClient)
    	c.mustListObjects(ctx, dillonClient, "projecta")
    	c.mustListObjects(ctx, dillonClient, "projectb")
    	c.mustListObjects(ctx, dillonClient, "projectaorb")
    	c.mustNotListObjects(ctx, dillonClient, "other")
    
    	// this user's groups attribute is ["projectb"]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
Back to top