Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 723 for Writes (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top