Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 1,066 for readOp (0.22 sec)

  1. tensorflow/c/eager/c_api_experimental_reader_test.cc

      auto* reader = TFE_MonitoringNewCounterReader(counter_name);
      IncrementCounter0(counter);
    
      int64_t actual = TFE_MonitoringReadCounter0(reader);
    
      CHECK_EQ(actual, 1);
    }
    
    TEST(CAPI, MonitoringCellReader1) {
      auto counter_name = "test/counter1";
      auto label_name = "test/label";
      auto* counter = CreateCounter1(counter_name, label_name);
      auto* reader = TFE_MonitoringNewCounterReader(counter_name);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Apr 20 03:14:47 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  2. scripts/docs.py

    @app.command()
    def generate_readme() -> None:
        """
        Generate README.md content from main index.md
        """
        typer.echo("Generating README")
        readme_path = Path("README.md")
        new_content = generate_readme_content()
        readme_path.write_text(new_content, encoding="utf-8")
    
    
    @app.command()
    def verify_readme() -> None:
        """
        Verify README.md content from main index.md
        """
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Oct 08 11:01:17 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. api/go1.23.txt

    pkg net/http, type Cookie struct, Quoted bool #46443
    pkg net/http, type Request struct, Pattern string #66405
    pkg net/http/httptest, func NewRequestWithContext(context.Context, string, string, io.Reader) *http.Request #59473
    pkg os, func CopyFS(string, fs.FS) error #62484
    pkg path/filepath, func Localize(string) (string, error) #57151
    pkg reflect, func SliceAt(Type, unsafe.Pointer, int) Value #61308
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Jun 25 17:08:08 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. src/archive/zip/example_test.go

    	buf := new(bytes.Buffer)
    
    	// Create a new zip archive.
    	w := zip.NewWriter(buf)
    
    	// Add some files to the archive.
    	var files = []struct {
    		Name, Body string
    	}{
    		{"readme.txt", "This archive contains some text files."},
    		{"gopher.txt", "Gopher names:\nGeorge\nGeoffrey\nGonzo"},
    		{"todo.txt", "Get animal handling licence.\nWrite more examples."},
    	}
    	for _, file := range files {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Jan 27 00:22:03 UTC 2016
    - 2K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/apps/v1beta1/generated.proto

      optional DeploymentStrategy strategy = 4;
    
      // minReadySeconds is the minimum number of seconds for which a newly created pod should be ready
      // without any of its container crashing, for it to be considered available.
      // Defaults to 0 (pod will be considered available as soon as it is ready)
      // +optional
      optional int32 minReadySeconds = 5;
    
      // revisionHistoryLimit is the number of old ReplicaSets to retain to allow rollback.
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    	var priv interface{}
    	var err error
    	priv, err = rsa.GenerateKey(crand.Reader, rsaBits)
    	if err != nil {
    		return nil, nil, fmt.Errorf("failed to generate private key: %w", err)
    	}
    
    	notBefore := time.Now()
    	notAfter := notBefore.Add(validFor)
    
    	serialNumberLimit := new(big.Int).Lsh(big.NewInt(1), 128)
    	serialNumber, err := crand.Int(crand.Reader, serialNumberLimit)
    	if err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  7. cmd/admin-bucket-handlers.go

    		return
    	}
    	data, err := io.ReadAll(r.Body)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    	reader := bytes.NewReader(data)
    	zr, err := zip.NewReader(reader, int64(len(data)))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    	rpt := importMetaReport{
    		madmin.BucketMetaImportErrs{
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  8. api/go1.txt

    pkg bufio, func NewWriter(io.Writer) *Writer
    pkg bufio, func NewWriterSize(io.Writer, int) *Writer
    pkg bufio, method (*Reader) Buffered() int
    pkg bufio, method (*Reader) Peek(int) ([]uint8, error)
    pkg bufio, method (*Reader) Read([]uint8) (int, error)
    pkg bufio, method (*Reader) ReadByte() (uint8, error)
    pkg bufio, method (*Reader) ReadBytes(uint8) ([]uint8, error)
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  9. internal/logger/target/kafka/kafka.go

    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan interface{}
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  10. cmd/admin-handlers.go

    	if logKind == 0 {
    		logKind = madmin.LogMaskAll
    	}
    
    	// Avoid reusing tcp connection if read timeout is hit
    	// This is needed to make r.Context().Done() work as
    	// expected in case of read timeout
    	w.Header().Set("Connection", "close")
    
    	setEventStreamHeaders(w)
    
    	logCh := make(chan log.Info, 1000)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
Back to top