Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 941 for Writes (1.14 sec)

  1. internal/s3select/select.go

    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = bpool.Pool[*bufio.Writer]{
    	New: func() *bufio.Writer {
    		// io.Discard is just used to create the writer. Actual destination
    		// writer is set later by Reset() before using it.
    		return bufio.NewWriter(xioutil.Discard)
    	},
    }
    
    // UnmarshalXML - decodes XML data.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  2. docs/multi-tenancy/README.md

    minio server --address :9003 /data/tenant3
    ```
    
    ![Example-1](https://github.com/minio/minio/blob/master/docs/screenshots/Example-1.jpg?raw=true)
    
    ### 1.2 Host Multiple Tenants on Multiple Drives (Erasure Code)
    
    Use the following commands to host 3 tenants on multiple drives:
    
    ```sh
    minio server --address :9001 /disk{1...4}/data/tenant1
    minio server --address :9002 /disk{1...4}/data/tenant2
    minio server --address :9003 /disk{1...4}/data/tenant3
    ```
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  3. internal/config/storageclass/storage-class.go

    // Supported Storage Class format is "Scheme:Number of parity drives".
    // Currently only supported scheme is "EC".
    func parseStorageClass(storageClassEnv string) (sc StorageClass, err error) {
    	s := strings.Split(storageClassEnv, ":")
    
    	// only two elements allowed in the string - "scheme" and "number of parity drives"
    	if len(s) > 2 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  4. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/InteractiveGoalSupport.java

            if (!context.interactive) {
                context.terminal.writer().println("This tool works only in interactive mode!");
                context.terminal
                        .writer()
                        .println("Tool purpose is to configure password management on developer workstations.");
                context.terminal
                        .writer()
                        .println(
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Dec 11 09:13:06 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CharSourceTester.java

        Reader reader = source.openStream();
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertExpectedString(writer.toString());
      }
    
      public void testOpenBufferedStream() throws IOException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  6. cmd/metacache-stream.go

    		}
    		return nil
    	}
    	return &w
    }
    
    // write one or more objects to the stream in order.
    // It is favorable to send as many objects as possible in a single write,
    // but no more than math.MaxUint32
    func (w *metacacheWriter) write(objs ...metaCacheEntry) error {
    	if w == nil {
    		return errors.New("metacacheWriter: nil writer")
    	}
    	if len(objs) == 0 {
    		return nil
    	}
    	if w.creator != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  7. cmd/metrics-v3-cluster-health.go

    		"Count of offline drives in the cluster")
    	healthDrivesOnlineCountMD = NewGaugeMD(healthDrivesOnlineCount,
    		"Count of online drives in the cluster")
    	healthDrivesCountMD = NewGaugeMD(healthDrivesCount,
    		"Count of all drives in the cluster")
    )
    
    // loadClusterHealthDriveMetrics - `MetricsLoaderFn` for cluster storage drive metrics
    // such as online, offline and total drives.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. internal/config/subnet/subnet.go

    	}
    
    	var body bytes.Buffer
    	writer := multipart.NewWriter(&body)
    	part, e := writer.CreateFormFile("file", filename)
    	if e != nil {
    		return "", e
    	}
    
    	if _, e = part.Write(payload); e != nil {
    		return "", e
    	}
    	writer.Close()
    
    	r, e := http.NewRequest(http.MethodPost, reqURL, &body)
    	if e != nil {
    		return "", e
    	}
    	r.Header.Add("Content-Type", writer.FormDataContentType())
    
    	return c.submitPost(r)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  9. samples/tlssurvey/src/main/kotlin/okhttp3/survey/Iana.kt

      val id = (matcher.groupValues[1] + matcher.groupValues[2]).decodeHex()
      return SuiteId(id, matcher.groupValues[3])
    }
    
    class IanaSuites(
      val name: String,
      val suites: List<SuiteId>,
    ) {
      fun fromJavaName(javaName: String): SuiteId =
        suites.firstOrNull {
          it.name == javaName || it.name == "TLS_${javaName.drop(4)}"
        } ?: throw IllegalArgumentException("No such suite: $javaName")
    }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2K bytes
    - Viewed (0)
  10. docs_src/python_types/tutorial008_py39.py

    def process_items(prices: dict[str, float]):
        for item_name, item_price in prices.items():
            print(item_name)
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Jan 16 14:44:08 UTC 2022
    - 145 bytes
    - Viewed (0)
Back to top