Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 391 for ctx_ (0.02 sec)

  1. 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)
  2. tensorflow/c/eager/gradient_checker.cc

    absl::Status RunAndMaybeSum(AbstractContext* ctx, Model forward,
                                absl::Span<AbstractTensorHandle* const> inputs,
                                absl::Span<AbstractTensorHandle*> outputs,
                                bool use_function) {
      AbstractTensorHandle* model_outputs[1];
    
      // Run the model.
      TF_RETURN_IF_ERROR(
          RunModel(forward, ctx, inputs, model_outputs, use_function));
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  3. schema/serializer.go

    // Scan implements serializer interface
    func (UnixSecondSerializer) Scan(ctx context.Context, field *Field, dst reflect.Value, dbValue interface{}) (err error) {
    	t := sql.NullTime{}
    	if err = t.Scan(dbValue); err == nil && t.Valid {
    		err = field.Set(ctx, dst, t.Time.Unix())
    	}
    
    	return
    }
    
    // Value implements serializer interface
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. cmd/bucket-listobjects-handlers.go

    	listObjectVersionsInfo, err := listObjectVersions(ctx, bucket, prefix, marker, versionIDMarker, delimiter, maxkeys)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	if err = DecryptETags(ctx, GlobalKMS, listObjectVersionsInfo.Objects); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. cmd/notification.go

    			// Errors are logged but not returned.
    			ctx, cancel := context.WithTimeout(ctx, 15*time.Second)
    			defer cancel()
    			data, err := client.DownloadProfileData(ctx)
    			if err != nil {
    				reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", client.host.String())
    				ctx := logger.SetReqInfo(ctx, reqInfo)
    				peersLogOnceIf(ctx, err, client.host.String())
    				return nil
    			}
    
    			for typ, data := range data {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  6. 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);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb1/com/SmbComNegotiateResponse.java

    
        /**
         * 
         * @param ctx
         */
        public SmbComNegotiateResponse ( CIFSContext ctx ) {
            super(ctx.getConfig());
            this.server = new ServerData();
            this.capabilities = ctx.getConfig().getCapabilities();
            this.negotiatedFlags2 = ctx.getConfig().getFlags2();
            this.maxMpxCount = ctx.getConfig().getMaxMpxCount();
            this.snd_buf_size = ctx.getConfig().getSendBufferSize();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:52:42 UTC 2020
    - 15.4K bytes
    - Viewed (0)
  8. cmd/s3-zip-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	zipInfo := zipObjInfo.ArchiveInfo(r.Header)
    	if len(zipInfo) == 0 {
    		opts.EncryptFn, err = zipObjInfo.metadataEncryptFn(r.Header)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  9. 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)
  10. cmd/erasure-server-pool.go

    			return ListObjectsInfo{}, err
    		}
    		if contextCanceled(ctx) {
    			return ListObjectsInfo{}, ctx.Err()
    		}
    	}
    	return listFn(ctx, opts, maxKeys)
    }
    
    func (z *erasureServerPools) ListMultipartUploads(ctx context.Context, bucket, prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int) (ListMultipartsInfo, error) {
    	if err := checkListMultipartArgs(ctx, bucket, prefix, keyMarker, uploadIDMarker, delimiter); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top