- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 723 for Writes (0.05 sec)
-
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
set("b", "b", "b") // Create an entry that fails to write to the journal during commit. val editor = cache.edit("c")!! editor.setString(0, "c") editor.setString(1, "c") filesystem.setFaultyWrite(journalFile, true) editor.commit() // Once the journal has a failure, subsequent writes aren't permitted. filesystem.setFaultyWrite(journalFile, false)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0) -
src/bytes/buffer.go
m, e := w.Write(b.buf[b.off:]) if m > nBytes { panic("bytes.Buffer.WriteTo: invalid Write count") } b.off += m n = int64(m) if e != nil { return n, e } // all bytes should have been written, by definition of // Write method in io.Writer if m != nBytes { return n, io.ErrShortWrite } } // Buffer is now empty; reset. b.Reset() return n, nil }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Oct 29 16:47:05 UTC 2024 - 15.7K bytes - Viewed (0) -
docs/en/docs/tutorial/request-files.md
`UploadFile` has the following `async` methods. They all call the corresponding file methods underneath (using the internal `SpooledTemporaryFile`). * `write(data)`: Writes `data` (`str` or `bytes`) to the file. * `read(size)`: Reads `size` (`int`) bytes/characters of the file. * `seek(offset)`: Goes to the byte position `offset` (`int`) in the file.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 10.2K bytes - Viewed (0) -
internal/grid/connection.go
c.blockMessages.Store(&block) c.connMu.Unlock() } } // wsWriter writes websocket messages. type wsWriter struct { tmp [ws.MaxHeaderSize]byte } // writeMessage writes a message to w without allocations. func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error { const fin = true var frame ws.Frame if s.ClientSide() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// drop the contract on the method that enforces this queue like behavior since depending on it // is likely to be a bug anyway. // N.B. All writes to the list and the next pointers must have happened before the above // synchronized block, so we can iterate the list without the lock held here. RunnableExecutorPair reversedList = null; while (list != null) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
docs/docker/README.md
The command creates a new local directory `~/minio/data` in your user home directory. It then starts the MinIO container with the `-v` argument to map the local path (`~/minio/data`) to the specified virtual container directory (`/data`). When MinIO writes data to `/data`, that data is actually written to the local path `~/minio/data` where it can persist between container restarts. ### Windows ```sh docker run \ -p 9000:9000 \ -p 9001:9001 \ --name minio1 \
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 8.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
this.connectionType = mode.second if (connectionType == H2) { platform.assumeHttp2Support() } // Sockets on some platforms can have large buffers that mean writes do not block when // required. These socket factories explicitly set the buffer sizes on sockets created. server = MockWebServer() server.serverSocketFactory =
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableMapTest.java
@GwtIncompatible // SerializableTester @SuppressWarnings("unchecked") public void ignore_testSerializationNoDuplication_regularImmutableMap() throws Exception { // Tests that serializing a map, its keySet, and values only writes the underlying data once. Entry<Integer, Integer>[] entries = (Entry<Integer, Integer>[]) new Entry<?, ?>[1000]; for (int i = 0; i < 1000; i++) { entries[i] = ImmutableMap.entryOf(i, i); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 41.1K bytes - Viewed (0) -
internal/http/headers.go
MinIOSourceMTime = "x-minio-source-mtime" // Header indicates if the etag should be preserved by client MinIOSourceETag = "x-minio-source-etag" // Writes expected write quorum MinIOWriteQuorum = "x-minio-write-quorum" // Reads expected read quorum MinIOReadQuorum = "x-minio-read-quorum" // Indicates if we are using default storage class and there was problem loading config
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:31:56 UTC 2024 - 10.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE private var closed: Boolean = false val hpackWriter: Hpack.Writer = Hpack.Writer(out = hpackBuffer) @Throws(IOException::class) fun connectionPreface() { this.withLock { if (closed) throw IOException("closed") if (!client) return // Nothing to write; servers don't send connection headers! if (logger.isLoggable(FINE)) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K bytes - Viewed (0)