Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 391 for ctx_ (0.06 sec)

  1. tensorflow/c/eager/c_api_test_util.h

    TFE_TensorHandle* TestScalarTensorHandle(TFE_Context* ctx, const T value) {
      T data[] = {value};
      return TestTensorHandleWithDims<T, datatype>(ctx, data, nullptr, 0);
    }
    
    // Return a tensor handle containing a 100x100 matrix of floats
    TFE_TensorHandle* TestMatrixTensorHandle100x100(TFE_Context* ctx);
    
    // Return a tensor handle containing a 3x2 matrix of doubles
    TFE_TensorHandle* DoubleTestMatrixTensorHandle3X2(TFE_Context* ctx);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Jul 17 23:43:59 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if msg.DeadlineMS > 0 {
    		ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond)
    	} else {
    		ctx, cancel = context.WithCancel(ctx)
    	}
    	m := muxServer{
    		ID:        msg.MuxID,
    		RecvSeq:   msg.Seq + 1,
    		SendSeq:   msg.Seq,
    		ctx:       ctx,
    		cancel:    cancel,
    		parent:    c,
    		LastPing:  time.Now().Unix(),
    		BaseFlags: c.baseFlags,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  3. cmd/object-api-input-checks.go

    )
    
    // Checks on CopyObject arguments, bucket and object.
    func checkCopyObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    // Checks on GetObject arguments, bucket and object.
    func checkGetObjArgs(ctx context.Context, bucket, object string) error {
    	return checkBucketAndObjectNames(ctx, bucket, object)
    }
    
    // Checks on DeleteObject arguments, bucket and object.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  4. cmd/logging.go

    	logger.LogOnceIf(ctx, "iam", err, id, errKind...)
    }
    
    func iamLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	if !errors.Is(err, grid.ErrDisconnected) {
    		logger.LogIf(ctx, "iam", err, errKind...)
    	}
    }
    
    func iamLogEvent(ctx context.Context, msg string, args ...interface{}) {
    	logger.Event(ctx, "iam", msg, args...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    			retErr = err
    		}
    
    		if retErr != nil {
    			healingLogIf(ctx, fmt.Errorf("listing failed with: %v on bucket: %v", retErr, bucket))
    			continue
    		}
    
    		select {
    		// If context is canceled don't mark as done...
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			tracker.bucketDone(bucket)
    			healingLogIf(ctx, tracker.update(ctx))
    		}
    	}
    	if retErr != nil {
    		return retErr
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. cmd/callhome.go

    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    	// Perform callhome once and then keep running it at regular intervals.
    	performCallhome(ctx)
    
    	callhomeTimer := time.NewTimer(globalCallhomeConfig.FrequencyDur())
    	defer callhomeTimer.Stop()
    
    	for {
    		if !globalCallhomeConfig.Enabled() {
    			// Stop the processing as callhome got disabled
    			return false
    		}
    
    		select {
    		case <-ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users.go

    	if globalIAMSys.LDAPConfig.Enabled() {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errIAMActionNotAllowed), r.URL)
    		return
    	}
    
    	updatedAt, err := globalIAMSys.CreateUser(ctx, accessKey, ureq)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	replLogIf(ctx, globalSiteReplicationSys.IAMChangeHook(ctx, madmin.SRIAMItem{
    		Type: madmin.SRIAMItemIAMUser,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  8. cmd/lock-rest-client.go

    func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRLock, &args)
    }
    
    // Lock calls lock REST API.
    func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCLock, &args)
    }
    
    // RUnlock calls read unlock REST API.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  9. cmd/admin-handlers-site-replication.go

    		return
    	}
    
    	var state madmin.SRStateEditReq
    	if err := parseJSONBody(ctx, r.Body, &state, ""); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    	if err := globalSiteReplicationSys.PeerStateEditReq(ctx, state); err != nil {
    		adminLogIf(ctx, err)
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  10. cmd/tier-handlers.go

    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	if err := globalTierConfigMgr.Remove(ctx, tier, force); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	if err := globalTierConfigMgr.Save(ctx, objAPI); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top