- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,346 for READ (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)