Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 441 for ctx (0.02 sec)

  1. schema/field.go

    			case int8:
    				field.ReflectValueOf(ctx, value).SetInt(int64(data))
    			case int16:
    				field.ReflectValueOf(ctx, value).SetInt(int64(data))
    			case int32:
    				field.ReflectValueOf(ctx, value).SetInt(int64(data))
    			case uint:
    				field.ReflectValueOf(ctx, value).SetInt(int64(data))
    			case uint8:
    				field.ReflectValueOf(ctx, value).SetInt(int64(data))
    			case uint16:
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 15 03:20:20 UTC 2024
    - 32K bytes
    - Viewed (0)
  2. cmd/iam-etcd-store.go

    	return deleteKeyEtcd(ctx, ies.client, path)
    }
    
    func (ies *IAMEtcdStore) loadPolicyDocWithRetry(ctx context.Context, policy string, m map[string]PolicyDoc, _ int) error {
    	return ies.loadPolicyDoc(ctx, policy, m)
    }
    
    func (ies *IAMEtcdStore) loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error {
    	data, err := ies.loadIAMConfigBytes(ctx, getPolicyDocPath(policy))
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    
    	err = verifyBinary(u, sha256Sum, releaseInfo, mode, bytes.NewReader(bin))
    	if err != nil {
    		adminLogIf(ctx, fmt.Errorf("server update failed with %w", err))
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  4. 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)
  5. cmd/iam-object-store.go

    }
    
    func (iamOS *IAMObjectStore) loadPolicyDoc(ctx context.Context, policy string, m map[string]PolicyDoc) error {
    	p, err := iamOS.loadPolicy(ctx, policy)
    	if err != nil {
    		return err
    	}
    	m[policy] = p
    	return nil
    }
    
    func (iamOS *IAMObjectStore) loadPolicyDocs(ctx context.Context, m map[string]PolicyDoc) error {
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    	client.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{},
    		func(ctx context.Context) (info DiskInfo, err error) {
    			ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			defer cancel()
    
    			nopts := DiskInfoOptions{DiskID: *client.diskID.Load(), Metrics: true}
    			infop, err := storageDiskInfoRPC.Call(ctx, client.gridConn, &nopts)
    			if err != nil {
    				return info, toStorageErr(err)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    		default:
    			writeErrorResponseJSON(ctx, w, toAPIError(ctx, errors.New("job ID format unrecognized")), r.URL)
    			return
    		}
    	}
    
    	ri := &batchJobInfo{}
    	if err := ri.load(ctx, objectAPI, req); err != nil {
    		if !errors.Is(err, errNoSuchJob) {
    			batchLogIf(ctx, err)
    		}
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  8. cmd/admin-handlers-config-kv.go

    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    		for _, chEntry := range chEntries {
    			if err = delServerConfigHistory(ctx, objectAPI, chEntry.RestoreID); err != nil {
    				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
    - 15.7K bytes
    - Viewed (0)
  9. 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)
  10. cmd/listen-notification-handlers.go

    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	if bucketName != "" {
    		if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top