Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for ctx_ (0.03 sec)

  1. tensorflow/c/eager/gradient_checker_test.cc

          ASSERT_EQ(errors::OK, s.code()) << s.message();
          ctx_.reset(ctx_raw);
        }
    
        // Computing numerical gradients with TensorFloat-32 is numerically
        // unstable. Some forward pass tests also fail with TensorFloat-32 due to
        // low tolerances
        enable_tensor_float_32_execution(false);
      }
    
      AbstractContextPtr ctx_;
    
     public:
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. tensorflow/c/eager/gradients.cc

    AbstractTensorHandle* TapeTensor::ZerosLike() const { return nullptr; }
    
    class TapeVSpace
        : public eager::VSpace<AbstractTensorHandle, GradientFunction, TapeTensor> {
     public:
      explicit TapeVSpace(AbstractContext* ctx) : ctx_(ctx) {}
      ~TapeVSpace() override {}
    
      // Returns the number of elements in the gradient tensor.
      int64_t NumElements(AbstractTensorHandle* tensor) const override;
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  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/xl-storage-disk-id-check.go

    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricStatVol, volume)
    	if err != nil {
    		return vol, err
    	}
    	defer done(0, &err)
    
    	return xioutil.WithDeadline[VolInfo](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result VolInfo, err error) {
    		return p.storage.StatVol(ctx, volume)
    	})
    }
    
    func (p *xlStorageDiskIDCheck) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top