Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,346 for READ (0.03 sec)

  1. internal/ringbuffer/ring_buffer_benchmark_test.go

    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		rb.Write(data)
    		rb.Read(buf)
    	}
    }
    
    func BenchmarkRingBuffer_AsyncRead(b *testing.B) {
    	// Pretty useless benchmark, but it's here for completeness.
    	rb := New(1024)
    	data := []byte(strings.Repeat("a", 512))
    	buf := make([]byte, 512)
    
    	go func() {
    		for {
    			rb.Read(buf)
    		}
    	}()
    
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		rb.Write(data)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. internal/deadlineconn/deadlineconn_test.go

    		defer deadlineconn.Close()
    
    		// Read a line
    		b := make([]byte, 12)
    		_, terr = deadlineconn.Read(b)
    		if terr != nil {
    			t.Errorf("failed to read from client. %v", terr)
    			return
    		}
    		received := string(b)
    		if received != "message one\n" {
    			t.Errorf(`server: expected: "message one\n", got: %v`, received)
    			return
    		}
    
    		// Wait for more than read timeout to simulate processing.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Nov 05 18:09:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  3. internal/deadlineconn/deadlineconn.go

    // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout.
    type DeadlineConn struct {
    	net.Conn
    	readDeadline  time.Duration // sets the read deadline on a connection.
    	readSetAt     time.Time
    	writeDeadline time.Duration // sets the write deadline on a connection.
    	writeSetAt    time.Time
    }
    
    // Sets read deadline
    func (c *DeadlineConn) setReadDeadline() {
    	if c.readDeadline > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  4. internal/grid/grid.go

    			b = append(b, 0)[:len(b)]
    		}
    		n, err := r.Read(b[len(b):cap(b)])
    		b = b[:len(b)+n]
    		if err != nil {
    			if errors.Is(err, io.EOF) {
    				if want >= 0 && read+int64(n) != want {
    					return nil, io.ErrUnexpectedEOF
    				}
    				err = nil
    			}
    			return b, err
    		}
    		read += int64(n)
    		if want >= 0 && read == want {
    			// No need to read more...
    			return b, nil
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. buildscripts/minio-upgrade.sh

    		up -d --build
    
    	add_alias
    
    	mc mb minio/minio-test/
    	mc cp ./minio minio/minio-test/to-read/
    	mc cp /etc/hosts minio/minio-test/to-read/hosts
    	mc anonymous set download minio/minio-test
    
    	verify_checksum_mc ./minio minio/minio-test/to-read/minio
    
    	curl -s http://127.0.0.1:9000/minio-test/to-read/hosts | sha256sum
    
    	MINIO_VERSION=dev /tmp/gopath/bin/docker-compose -f "buildscripts/upgrade-tests/compose.yml" stop
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 05:08:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. compat/maven-toolchain-builder/src/test/java/org/apache/maven/toolchain/merge/MavenToolchainMergerTest.java

                    InputStream isRecessive = MavenToolchainMergerTest.class.getResourceAsStream("toolchains-jdks.xml")) {
                PersistedToolchains dominant = read(isDominant);
                PersistedToolchains recessive = read(isRecessive);
                assertEquals(2, dominant.getToolchains().size());
    
                merger.merge(dominant, recessive, TrackableBase.USER_LEVEL);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/io/CountingInputStreamTest.java

        assertEquals(-1, counter.read());
        assertEquals(20, counter.getCount());
      }
    
      public void testReadArrayEOF() throws IOException {
        assertEquals(20, counter.read(new byte[30]));
        assertEquals(20, counter.getCount());
        assertEquals(-1, counter.read(new byte[30]));
        assertEquals(20, counter.getCount());
      }
    
      @SuppressWarnings("CheckReturnValue") // calling read() to skip a byte
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  8. src/archive/zip/writer_test.go

    		Method: Deflate,
    		Mode:   0755 | fs.ModeDevice | fs.ModeCharDevice,
    	},
    }
    
    func TestWriter(t *testing.T) {
    	largeData := make([]byte, 1<<17)
    	if _, err := rand.Read(largeData); err != nil {
    		t.Fatal("rand.Read failed:", err)
    	}
    	writeTests[1].Data = largeData
    	defer func() {
    		writeTests[1].Data = nil
    	}()
    
    	// write a zip file
    	buf := new(bytes.Buffer)
    	w := NewWriter(buf)
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  9. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        assertThat(inputStream!!.read()).isEqualTo('A'.code)
        assertThat(inputStream.read()).isEqualTo('B'.code)
        assertThat(inputStream.read()).isEqualTo('C'.code)
        assertThat(inputStream.read()).isEqualTo('D'.code)
        assertThat(inputStream.read()).isEqualTo('E'.code)
        assertThat(inputStream.read()).isEqualTo('F'.code)
        assertThat(inputStream.read()).isEqualTo(-1)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  10. docs/en/docs/environment-variables.md

    // Use it with other programs, like
    $ echo "Hello $Env:MY_NAME"
    
    Hello Wade Wilson
    ```
    
    </div>
    
    ////
    
    ## Read env vars in Python
    
    You could also create environment variables **outside** of Python, in the terminal (or with any other method), and then **read them in Python**.
    
    For example you could have a file `main.py` with:
    
    ```Python hl_lines="3"
    import os
    
    name = os.getenv("MY_NAME", "World")
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Sep 08 20:36:53 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top