Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 183 for dopts (0.03 sec)

  1. tensorflow/c/eager/dlpack_test.cc

    }
    
    TEST(DLPack, HandleFromDLPackStrides) {
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_Context* ctx = TFE_NewContext(opts, status);
      ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TestHandleFromDLPack(status, ctx, {}, {});
      TestHandleFromDLPack(status, ctx, {4}, {});
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Fri Jun 30 03:04:46 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex.go

    				dm.startContinuousLockRefresh(lockLossCallback, id, source, quorum)
    
    				return locked
    			}
    
    			switch {
    			case opts.RetryInterval < 0:
    				return false
    			case opts.RetryInterval > 0:
    				time.Sleep(opts.RetryInterval)
    			default:
    				attempt++
    				time.Sleep(lockRetryBackOff(dm.rng, attempt))
    			}
    		}
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  3. cmd/etcd.go

    	return etcdErrToErr(err, client.Endpoints())
    }
    
    func saveKeyEtcd(ctx context.Context, client *etcd.Client, key string, data []byte, opts ...options) error {
    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    	if len(opts) > 0 {
    		return saveKeyEtcdWithTTL(ctx, client, key, data, opts[0].ttl)
    	}
    	_, err := client.Put(timeoutCtx, key, string(data))
    	etcdLogIf(ctx, err)
    	return etcdErrToErr(err, client.Endpoints())
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. internal/s3select/simdj/reader_amd64_test.go

    					t.Error(err)
    				}
    				var gotB, wantB bytes.Buffer
    				opts := sql.WriteCSVOpts{
    					FieldDelimiter: ',',
    					Quote:          '"',
    					QuoteEscape:    '"',
    					AlwaysQuote:    false,
    				}
    				err = rec.WriteCSV(&gotB, opts)
    				if err != nil {
    					t.Error(err)
    				}
    				err = want.WriteCSV(&wantB, opts)
    				if err != nil {
    					t.Error(err)
    				}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  5. tests/connpool_test.go

    //
    //	func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) {
    //		 return c.db.BeginTx(ctx, opts)
    //	}
    //
    // You should use BeginTx returned gorm.Tx which could wrap *sql.Tx then you can record all queries.
    func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (gorm.ConnPool, error) {
    	tx, err := c.db.BeginTx(ctx, opts)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. interfaces.go

    	RollbackTo(tx *DB, name string) error
    }
    
    // TxBeginner tx beginner
    type TxBeginner interface {
    	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
    }
    
    // ConnPoolBeginner conn pool beginner
    type ConnPoolBeginner interface {
    	BeginTx(ctx context.Context, opts *sql.TxOptions) (ConnPool, error)
    }
    
    // TxCommitter tx committer
    type TxCommitter interface {
    	Commit() error
    	Rollback() error
    }
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Aug 19 13:33:31 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  7. cmd/os_windows.go

    			// filtering requested to return by caller.
    			return nil
    		}
    	}
    
    	return nil
    }
    
    // Return N entries at the directory dirPath.
    func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {
    	// Ensure we don't pick up files as directories.
    	globAll := filepath.Clean(dirPath) + `\*`
    	globAllP, err := syscall.UTF16PtrFromString(globAll)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  8. internal/kms/config.go

    			return nil, err
    		}
    
    		key, err := kms.ParseAPIKey(env.Get(EnvKMSAPIKey, ""))
    		if err != nil {
    			return nil, err
    		}
    
    		var rootCAs *x509.CertPool
    		if opts != nil && opts.CADir != "" {
    			rootCAs, err = certs.GetRootCAs(opts.CADir)
    			if err != nil {
    				return nil, err
    			}
    		}
    
    		client, err := kms.NewClient(&kms.Config{
    			Endpoints: endpoints,
    			APIKey:    key,
    			TLS: &tls.Config{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  9. cmd/warm-backend-azure.go

    }
    
    func (az *warmBackendAzure) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) {
    	if opts.startOffset < 0 {
    		return nil, InvalidRange{}
    	}
    	resp, err := az.clnt.DownloadStream(ctx, az.Bucket, az.getDest(object), &azblob.DownloadStreamOptions{
    		Range: blob.HTTPRange{Offset: opts.startOffset, Count: opts.length},
    	})
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. cmd/api-headers.go

    			w.Header().Set(k, v)
    		}
    	}
    
    	var start, rangeLen int64
    	totalObjectSize, err := objInfo.GetActualSize()
    	if err != nil {
    		return err
    	}
    
    	if rs == nil && opts.PartNumber > 0 {
    		rs = partNumberToRangeSpec(objInfo, opts.PartNumber)
    	}
    
    	// For providing ranged content
    	start, rangeLen, err = rs.GetOffsetLength(totalObjectSize)
    	if err != nil {
    		return err
    	}
    
    	// Set content length.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
Back to top