Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 466 for ctx_ (0.02 seconds)

  1. 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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.7K bytes
    - Click Count (0)
  2. tests/generics_test.go

    	ctx := context.Background()
    
    	// Just test that the API can be called
    	_, err := gorm.G[User](DB).Where("id = ?", 1).Updates(ctx, User{Name: "test"})
    	if err != nil {
    		t.Fatalf("Updates failed: %v", err)
    	}
    }
    
    func TestGenericsDeleteAPI(t *testing.T) {
    	ctx := context.Background()
    
    	// Just test that the API can be called
    	_, err := gorm.G[User](DB).Where("id = ?", 1).Delete(ctx)
    	if err != nil {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Tue Dec 30 08:11:14 GMT 2025
    - 34.9K bytes
    - Click Count (0)
  3. cmd/bucket-notification-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	_, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{})
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	config, err := globalBucketMetadataSys.GetNotificationConfig(bucketName)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  4. tensorflow/c/eager/c_api_test_util.cc

    using tensorflow::tstring;
    
    TFE_TensorHandle* TestScalarTensorHandle(TFE_Context* ctx, float value) {
      float data[] = {value};
      TF_Status* status = TF_NewStatus();
      TF_Tensor* t = TFE_AllocateHostTensor(ctx, TF_FLOAT, nullptr, 0, status);
      memcpy(TF_TensorData(t), &data[0], TF_TensorByteSize(t));
      TFE_TensorHandle* th = TFE_NewTensorHandleFromTensor(ctx, t, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Oct 09 05:56:18 GMT 2025
    - 23.4K bytes
    - Click Count (0)
  5. cmd/bucket-lifecycle-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	bucketLifecycle, err := lifecycle.ParseLifecycleConfigWithID(r.Body)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Validate the received bucket policy document
    	if err = bucketLifecycle.Validate(rcfg); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 7K bytes
    - Click Count (0)
  6. 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
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  7. cmd/peer-rest-client.go

    func (client *peerRESTClient) GetCPUs(ctx context.Context) (info madmin.CPUs, err error) {
    	resp, err := getCPUsHandler.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    // GetNetInfo - fetch network information for a remote node.
    func (client *peerRESTClient) GetNetInfo(ctx context.Context) (info madmin.NetInfo, err error) {
    	resp, err := getNetInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  8. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  9. 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():
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  10. cmd/bucket-versioning-handler.go

    		}, r.URL)
    		return
    	}
    
    	configData, err := xml.Marshal(v)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	//
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5K bytes
    - Click Count (0)
Back to Top