Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 829 for Writes (0.04 seconds)

  1. cmd/erasure-utils.go

    		offset = 0
    
    		// We have written all the blocks, write the last remaining block.
    		if write < int64(len(block)) {
    			n, err := dst.Write(block[:write])
    			if err != nil {
    				return 0, err
    			}
    			totalWritten += int64(n)
    			break
    		}
    
    		// Copy the block.
    		n, err := dst.Write(block)
    		if err != nil {
    			return 0, err
    		}
    
    		// Decrement output size.
    		write -= int64(n)
    
    		// Increment written.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       *
       * 1. visibility of the writes to these fields to Fire.run:
       *
       * The initial write to delegateRef is made definitely visible via the semantics of
       * addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed,
       * however that is fine since the correctness is based on the atomic state in our base class. The
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
  3. cmd/api-response.go

    	mimeXML mimeType = "application/xml"
    )
    
    // writeSuccessResponseJSON writes success headers and response if any,
    // with content-type set to `application/json`.
    func writeSuccessResponseJSON(w http.ResponseWriter, response []byte) {
    	writeResponse(w, http.StatusOK, response, mimeJSON)
    }
    
    // writeSuccessResponseXML writes success headers and response if any,
    // with content-type set to `application/xml`.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 35K bytes
    - Click Count (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

      fun fromDer(byteString: ByteString): T {
        val buffer = Buffer().write(byteString)
        val reader = DerReader(buffer)
        return fromDer(reader)
      }
    
      /**
       * Writes [value] to this adapter, unless it is the default value and can be safely omitted.
       *
       * If this does write a value, it will write a tag and a length and a full value.
       */
      fun toDer(
        writer: DerWriter,
        value: T,
      )
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  5. src/cmd/addr2line/main.go

    	"strings"
    
    	"cmd/internal/objfile"
    	"cmd/internal/telemetry/counter"
    )
    
    func printUsage(w *os.File) {
    	fmt.Fprintf(w, "usage: addr2line binary\n")
    	fmt.Fprintf(w, "reads addresses from standard input and writes two lines for each:\n")
    	fmt.Fprintf(w, "\tfunction name\n")
    	fmt.Fprintf(w, "\tfile:line\n")
    }
    
    func usage() {
    	printUsage(os.Stderr)
    	os.Exit(2)
    }
    
    func main() {
    	log.SetFlags(0)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Jun 21 19:58:04 GMT 2024
    - 2.4K bytes
    - Click Count (0)
  6. cmd/copy-part-range.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"net/http"
    	"net/url"
    )
    
    // Writes S3 compatible copy part range error.
    func writeCopyPartErr(ctx context.Context, w http.ResponseWriter, err error, url *url.URL) {
    	switch err {
    	case errInvalidRange:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jun 18 03:27:04 GMT 2021
    - 2.5K bytes
    - Click Count (0)
  7. lib/time/mkzip.go

    // Copyright 2022 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    //go:build ignore
    
    // Mkzip writes a zoneinfo.zip with the content of the current directory
    // and its subdirectories, with no compression, suitable for package time.
    //
    // Usage:
    //
    //	go run ../../mkzip.go ../../zoneinfo.zip
    //
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Mar 04 17:32:07 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/FormBody.kt

      override fun contentLength(): Long = writeOrCountBytes(null, true)
    
      @Throws(IOException::class)
      override fun writeTo(sink: BufferedSink) {
        writeOrCountBytes(sink, false)
      }
    
      /**
       * Either writes this request to [sink] or measures its content length. We have one method
       * do double-duty to make sure the counting and content are consistent, particularly when it comes
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  9. guava/src/com/google/common/util/concurrent/CollectionFuture.java

       * on the fields of TimeoutFuture. This field is slightly different from the fields discussed
       * there: cancel() never reads this field, only writes to it. That makes the race here completely
       * harmless, rather than just 99.99% harmless.
       */
      @LazyInit private @Nullable List<@Nullable Present<V>> values;
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  10. cmd/globals.go

    	// diskAssumeUnknownSize is the size to assume when an unknown size upload is requested.
    	diskAssumeUnknownSize = 1 << 30
    
    	// diskMinInodes is the minimum number of inodes we want free on a disk to perform writes.
    	diskMinInodes = 1000
    
    	// tlsClientSessionCacheSize is the cache size for client sessions.
    	tlsClientSessionCacheSize = 100
    )
    
    func init() {
    	// Injected to prevent circular dependency.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Sep 03 18:23:41 GMT 2024
    - 16.2K bytes
    - Click Count (1)
Back to Top