Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 183 for dopts (0.03 sec)

  1. cmd/os_unix.go

    			return nil
    		}
    	}
    
    	return err
    }
    
    // Return count entries at the directory dirPath and all entries
    // if count is set to -1
    func readDirWithOpts(dirPath string, opts readDirOpts) (entries []string, err error) {
    	fd, err := openFileWithFD(dirPath, readMode, 0o666)
    	if err != nil {
    		if !osIsPermission(err) {
    			return nil, osErrToFileErr(err)
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  2. tensorflow/c/c_api_function.cc

                                    const TF_FunctionOptions* opts,
                                    const char* description, TF_Status* status) {
      return TF_GraphToFunctionWithControlOutputs(
          fn_body, fn_name, append_hash_to_fn_name, num_opers, opers, ninputs,
          inputs, noutputs, outputs, output_names, 0, nullptr, nullptr, opts,
          description, status);
    }
    
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    	return r.loadWithOpts(ctx, store, ObjectOptions{})
    }
    
    func (r *rebalanceMeta) loadWithOpts(ctx context.Context, store objectIO, opts ObjectOptions) error {
    	data, _, err := readConfigWithMetadata(ctx, store, rebalMetaName, opts)
    	if err != nil {
    		return err
    	}
    
    	if len(data) == 0 {
    		return nil
    	}
    	if len(data) <= 4 {
    		return fmt.Errorf("rebalanceMeta: no data")
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  4. finisher_api.go

    	return
    }
    
    // Begin begins a transaction with any transaction options opts
    func (db *DB) Begin(opts ...*sql.TxOptions) *DB {
    	var (
    		// clone statement
    		tx  = db.getInstance().Session(&Session{Context: db.Statement.Context, NewDB: db.clone == 1})
    		opt *sql.TxOptions
    		err error
    	)
    
    	if len(opts) > 0 {
    		opt = opts[0]
    	}
    
    	switch beginner := tx.Statement.ConnPool.(type) {
    	case TxBeginner:
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	s.IsValid(w, r)
    }
    
    // DiskInfoHandler - returns disk info.
    func (s *storageRESTServer) DiskInfoHandler(opts *DiskInfoOptions) (*DiskInfo, *grid.RemoteErr) {
    	if !s.checkID(opts.DiskID) {
    		return nil, grid.NewRemoteErr(errDiskNotFound)
    	}
    	info, err := s.getStorage().DiskInfo(context.Background(), *opts)
    	if err != nil {
    		info.Error = err.Error()
    	}
    	return &info, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. cmd/tier.go

    		return nil, nil, err
    	}
    
    	pReader, err := NewPutObjReader(hr).WithEncryption(encHr, &oek)
    	if err != nil {
    		return nil, nil, err
    	}
    	opts := &ObjectOptions{
    		UserDefined: metadata,
    		MTime:       UTCNow(),
    		MaxParity:   true,
    	}
    
    	return pReader, opts, nil
    }
    
    // Reload updates config by reloading remote tier config from config store.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. docs/sts/web-identity.go

    			return
    		}
    
    		opts := &minio.Options{
    			Creds:        sts,
    			BucketLookup: minio.BucketLookupAuto,
    		}
    
    		u, err := url.Parse(stsEndpoint)
    		if err != nil {
    			log.Println(fmt.Errorf("Failed to parse STS Endpoint: %s", err))
    			http.Error(w, err.Error(), http.StatusBadRequest)
    			return
    		}
    
    		clnt, err := minio.New(u.Host, opts)
    		if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  8. tensorflow/c/c_test_util.cc

      return names;
    }
    
    CSession::CSession(TF_Graph* graph, TF_Status* s, bool use_XLA) {
      TF_SessionOptions* opts = TF_NewSessionOptions();
      TF_EnableXLACompilation(opts, use_XLA);
      session_ = TF_NewSession(graph, opts, s);
      TF_DeleteSessionOptions(opts);
    }
    
    CSession::CSession(TF_Session* session) : session_(session) {}
    
    CSession::~CSession() {
      TF_Status* s = TF_NewStatus();
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Fri Oct 15 03:16:52 UTC 2021
    - 17.8K bytes
    - Viewed (0)
  9. internal/s3select/csv/reader_contrib_test.go

    		})
    
    		for {
    			record, err = r.Read(record)
    			if err != nil {
    				break
    			}
    			opts := sql.WriteCSVOpts{
    				FieldDelimiter: []rune(c.fieldDelimiter)[0],
    				Quote:          '"',
    				QuoteEscape:    '"',
    				AlwaysQuote:    false,
    			}
    			record.WriteCSV(&result, opts)
    			result.Truncate(result.Len() - 1)
    			result.WriteString(c.recordDelimiter)
    		}
    		r.Close()
    		if err != io.EOF {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K bytes
    - Viewed (0)
  10. internal/http/check_port_others.go

    // Note: The check method tries to listen on given port and closes it.
    // It is possible to have a disconnected client in this tiny window of time.
    func CheckPortAvailability(host, port string, opts TCPOptions) (err error) {
    	lc := &net.ListenConfig{}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
Back to top