- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,665 for writeFn (0.08 sec)
-
doc/go_mem.html
<p> Note that if there are no read-write or write-write data races on memory location <i>x</i>, then any read <i>r</i> on <i>x</i> has only one possible <i>W</i>(<i>r</i>): the single <i>w</i> that immediately precedes it in the happens before order. </p> <p> More generally, it can be shown that any Go program that is data-race-free, meaning it has no program executions with read-write or write-write data races,
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
src/archive/zip/writer_test.go
dw, err := w.Create("dir/") if err != nil { t.Fatal(err) } if _, err := dw.Write(nil); err != nil { t.Errorf("Write(nil) to directory: got %v, want nil", err) } if _, err := dw.Write([]byte("hello")); err == nil { t.Error(`Write("hello") to directory: got nil error, want non-nil`) } } func TestWriterDirAttributes(t *testing.T) { var buf 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) -
cmd/batch-expire_gen.go
} // EncodeMsg implements msgp.Encodable func (z BatchJobExpirePurge) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 1 // write "RetainVersions" err = en.Append(0x81, 0xae, 0x52, 0x65, 0x74, 0x61, 0x69, 0x6e, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73) if err != nil { return } err = en.WriteInt(z.RetainVersions) if err != nil { err = msgp.WrapError(err, "RetainVersions") return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 19.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_gen.go
} // EncodeMsg implements msgp.Encodable func (z *PoolStatus) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 4 // write "id" err = en.Append(0x84, 0xa2, 0x69, 0x64) if err != nil { return } err = en.WriteInt(z.ID) if err != nil { err = msgp.WrapError(err, "ID") return } // write "cl" err = en.Append(0xa2, 0x63, 0x6c) if err != nil { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 04 21:02:54 UTC 2022 - 26.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java
file.close(); tmp = null; } /** * Writes the specified byte to this file output stream. * * @throws IOException if a network error occurs */ public void write( int b ) throws IOException { tmp[0] = (byte)b; write( tmp, 0, 1 ); } /** * Writes b.length bytes from the specified byte array to this * file output stream. *
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 9.2K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/SourceSinkFactories.java
public CharSink createSink() throws IOException { File file = createFile(); if (initialString != null) { Writer writer = new OutputStreamWriter(new FileOutputStream(file), UTF_8); try { writer.write(initialString); } finally { writer.close(); } return Files.asCharSink(file, UTF_8, FileWriteMode.APPEND); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 17.7K bytes - Viewed (0) -
cmd/erasure-object.go
inlineBuffers[i] = bytes.NewBuffer(buf[:0]) defer grid.PutByteBuffer(buf) writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize()) } } n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum) closeBitrotWriters(writers) if erasureErr != nil { return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} if (associatedStreamId == 0) { writer.headers(outFinished, streamId, requestHeaders) } else { require(!client) { "client streams shouldn't have associated stream IDs" } // HTTP/2 has a PUSH_PROMISE frame. writer.pushPromise(associatedStreamId, streamId, requestHeaders) } } if (flushHeaders) { writer.flush() } return stream }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HpackTest.kt
// Use a new Writer because we don't support change the dynamic table // size after Writer constructed. val writer = Hpack.Writer(110, false, bytesOut) writer.writeHeaders(headerBlock) assertThat(bytesOut).isEqualTo(bytesIn) assertThat(writer.headerCount).isEqualTo(2) val tableLength = writer.dynamicTable.size var entry = writer.dynamicTable[tableLength - 1]!!
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 38.2K bytes - Viewed (0)