Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 411 - 420 of 722 for WRITE (0.02 seconds)

  1. cmd/erasure-server-pool.go

    			healthy := erasureSetUpCount[poolIdx][setIdx].online >= poolWriteQuorums[poolIdx]
    			if !healthy && !opts.NoLogging {
    				storageLogIf(logger.SetReqInfo(ctx, reqInfo),
    					fmt.Errorf("Write quorum could not be established on pool: %d, set: %d, expected write quorum: %d, drives-online: %d",
    						poolIdx, setIdx, poolWriteQuorums[poolIdx], erasureSetUpCount[poolIdx][setIdx].online), logger.FatalKind)
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. docs/en/docs/benchmarks.md

    * **Uvicorn**:
        * Will have the best performance, as it doesn't have much extra code apart from the server itself.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:15:41 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  3. guava/src/com/google/common/hash/PrimitiveSink.java

       * {@code bytes[off + len - 1]} is the last.
       *
       * @param bytes a byte array
       * @param off the start offset in the array
       * @param len the number of bytes to write
       * @return this instance
       * @throws IndexOutOfBoundsException if {@code off < 0} or {@code off + len > bytes.length} or
       *     {@code len < 0}
       */
      @CanIgnoreReturnValue
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt

                length = header.length,
                bytes = bytes,
              )
            }
          }
    
          override fun toDer(
            writer: DerWriter,
            value: AnyValue,
          ) {
            writer.write("ANY", value.tagClass, value.tag) {
              writer.writeOctetString(value.bytes)
              writer.constructed = value.constructed
            }
          }
        }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 15K bytes
    - Click Count (0)
  5. internal/grid/connection.go

    	var buf bytes.Buffer
    	var wsw wsWriter
    	var lastSetDeadline time.Time
    
    	// Helper to write everything in buf.
    	// Return false if an error occurred and the connection is unusable.
    	// Buffer will be reset empty when returning successfully.
    	writeBuffer := func() (ok bool) {
    		now := time.Now()
    		// Only set write deadline once every second
    		if now.Sub(lastSetDeadline) > time.Second {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  6. cmd/format-erasure.go

    	}
    
    	// Marshal and write to disk.
    	formatData, err := json.Marshal(format)
    	if err != nil {
    		return err
    	}
    
    	tmpFormat := mustGetUUID()
    
    	// Purge any existing temporary file, okay to ignore errors here.
    	defer disk.Delete(context.TODO(), minioMetaBucket, tmpFormat, DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    
    	// write to unique file.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/internal/compat/interactivity/LegacyPlexusInteractivity.java

            for (String line = readLine(); line != null && !line.isEmpty(); line = readLine()) {
                lines.add(line);
            }
            return lines;
        }
    
        @Override
        public void write(String line) throws IOException {
            try {
                prompter.showMessage(line);
            } catch (org.apache.maven.api.services.PrompterException e) {
                throw new IOException("Unable to prompt", e);
            }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Apr 03 13:48:41 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  8. docs/en/docs/alternatives.md

    That's why, as said in the official website:
    
    > Requests is one of the most downloaded Python packages of all time
    
    The way you use it is very simple. For example, to do a `GET` request, you would write:
    
    ```Python
    response = requests.get("http://example.com/some/url")
    ```
    
    The FastAPI counterpart API *path operation* could look like:
    
    ```Python hl_lines="1"
    @app.get("/some/url")
    def read_url():
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  9. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

        while (!body.exhausted()) {
          val chunkSize = minOf(body.size, maxChunkSize.toLong())
          bytesOut.writeHexadecimalUnsignedLong(chunkSize)
          bytesOut.writeUtf8("\r\n")
          bytesOut.write(body, chunkSize)
          bytesOut.writeUtf8("\r\n")
        }
        bytesOut.writeUtf8("0\r\n") // Last chunk. Trailers follow!
        this.body = bytesOut
      }
    
      fun setChunkedBody(
        body: String,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat May 10 11:15:14 GMT 2025
    - 7.1K bytes
    - Click Count (1)
  10. guava-tests/test/com/google/common/base/EnumsTest.java

        Class<TestEnum> shadowTestEnum =
            (Class<TestEnum>) Class.forName(TestEnum.class.getName(), false, shadowLoader);
        assertThat(shadowTestEnum).isNotEqualTo(TestEnum.class);
        // We can't write Set<TestEnum> because that is a Set of the TestEnum from the original
        // ClassLoader.
        Set<Object> shadowConstants = new HashSet<>();
        for (TestEnum constant : TestEnum.values()) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 8.3K bytes
    - Click Count (0)
Back to Top