- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 4,372 for dwrite (0.1 sec)
-
src/vendor/golang.org/x/net/nettest/conntest.go
checkForTimeoutError(t, err) if _, err := c1.Write(make([]byte, 1024)); err != nil { t.Errorf("unexpected Write error: %v", err) } } // testWriteTimeout tests that Write timeouts do not affect Read. func testWriteTimeout(t *testing.T, c1, c2 net.Conn) { go chunkedCopy(c2, rand.New(rand.NewSource(0))) c1.SetWriteDeadline(aLongTimeAgo) _, err := c1.Write(make([]byte, 1024)) checkForTimeoutError(t, err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
t.Fatalf("write failed: %v", err) } wroteBytes += n wrote.Write(buf[:n]) debugln("WRITE 4\t", n, wroteBytes) // TryWriteByte err = rb.TryWriteByte(buf[0]) if err != nil && err != ErrAcquireLock && err != ErrTooMuchDataToWrite && err != ErrIsFull { t.Fatalf("write failed: %v", err) } if err == nil { wroteBytes++ wrote.Write(buf[:1]) debugln("WRITE 5\t", 1, wroteBytes)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/external/javadoc/internal/JavadocOptionFileWriterContext.java
import java.io.IOException; import java.io.Writer; import java.util.Collection; import java.util.Iterator; public class JavadocOptionFileWriterContext { private final Writer writer; public JavadocOptionFileWriterContext(Writer writer) { this.writer = writer; } public JavadocOptionFileWriterContext write(String string) throws IOException { writer.write(string); return this; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 4.2K bytes - Viewed (0) -
src/runtime/profbuf_test.go
}) t.Run("ReadMany", func(t *testing.T) { b := NewProfBuf(2, 50, 50) write(t, b, unsafe.Pointer(&myTags[0]), 1, []uint64{2, 3}, []uintptr{4, 5, 6, 7, 8, 9}) write(t, b, unsafe.Pointer(&myTags[2]), 99, []uint64{101, 102}, []uintptr{201, 202, 203, 204}) write(t, b, unsafe.Pointer(&myTags[1]), 500, []uint64{502, 504}, []uintptr{506})
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 15 20:04:56 UTC 2023 - 8.5K bytes - Viewed (0) -
src/os/pipe_test.go
// 232 is Windows error code ERROR_NO_DATA, "The pipe is being closed". expect = syscall.Errno(232) } // Every time we write to the pipe we should get an EPIPE. for i := 0; i < 20; i++ { _, err = w.Write([]byte("hi")) if err == nil { t.Fatal("unexpected success of Write to broken pipe") } if pe, ok := err.(*fs.PathError); ok { err = pe.Err } if se, ok := err.(*os.SyscallError); ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
platforms/core-runtime/files/src/main/java/org/gradle/internal/file/RandomAccessFileOutputStream.java
this.file = file; } @Override public void write(int i) throws IOException { file.write(i); } @Override public void write(byte[] bytes) throws IOException { file.write(bytes); } @Override public void write(byte[] bytes, int offset, int length) throws IOException { file.write(bytes, offset, length); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 1.5K bytes - Viewed (0) -
internal/crypto/key.go
mac := hmac.New(sha256.New, extKey) mac.Write(sealedKey.IV[:]) mac.Write([]byte(domain)) mac.Write([]byte(SealAlgorithm)) mac.Write([]byte(path.Join(bucket, object))) // use path.Join for canonical 'bucket/object' unsealConfig = sio.Config{MinVersion: sio.Version20, Key: mac.Sum(nil), CipherSuites: fips.DARECiphers()} case InsecureSealAlgorithm: sha := sha256.New() sha.Write(extKey) sha.Write(sealedKey.IV[:])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 19 20:28:10 UTC 2024 - 6.4K bytes - Viewed (0) -
platforms/extensibility/test-kit/src/main/java/org/gradle/testkit/runner/internal/io/NoCloseOutputStream.java
} @Override public synchronized void write(int b) throws IOException { delegate.write(b); } @Override public synchronized void flush() throws IOException { delegate.flush(); } @Override public synchronized void write(byte[] b, int off, int len) throws IOException { delegate.write(b, off, len); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 22:36:52 UTC 2023 - 1.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/TestCharSink.java
return byteSink.wasStreamClosed(); } @Override public Writer openStream() throws IOException { // using TestByteSink's output stream to get option behavior, so flush to it on every write return new FilterWriter(new OutputStreamWriter(byteSink.openStream(), UTF_8)) { @Override public void write(int c) throws IOException { super.write(c); flush(); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Apr 21 02:27:51 UTC 2017 - 2K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/store/DefaultBinaryStoreTest.groovy
def "stores binary data"() { def store = new DefaultBinaryStore(temp.file("foo.bin")) when: store.write({ it.writeInt(10) } as BinaryStore.WriteAction) store.write({ it.writeString("x") } as BinaryStore.WriteAction) def data1 = store.done() store.write({ it.writeString("y") } as BinaryStore.WriteAction) def data2 = store.done() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 3.4K bytes - Viewed (0)