Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 1,640 for writer (0.09 sec)

  1. cmd/admin-handlers.go

    			bugLogIf(ctx, err)
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    
    		// Write a version for making *incompatible* changes.
    		// The AdminClient will reject any version it does not know.
    		if publicKey == nil {
    			w.Write([]byte{1})
    			w.Write(key[:])
    		}
    
    		stream, err := sio.AES_256_GCM.Stream(key[:])
    		if err != nil {
    			bugLogIf(ctx, err)
    			return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

            bits: Int,
          ) {
            var value = value
            // Write the raw value for a single byte value.
            if (value < prefixMask) {
              out.writeByte(bits or value)
              return
            }
    
            // Write the mask to start a multibyte value.
            out.writeByte(bits or prefixMask)
            value -= prefixMask
    
            // Write 7 bits at a time 'til we're done.
            while (value >= 0x80) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    			inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    	n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum)
    	closeErrs := closeBitrotWriters(writers)
    	if erasureErr != nil {
    		return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  4. cmd/metacache-walk_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *WalkDirOptions) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 8
    	// write "Bucket"
    	err = en.Append(0x88, 0xa6, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.Bucket)
    	if err != nil {
    		err = msgp.WrapError(err, "Bucket")
    		return
    	}
    	// write "BaseDir"
    	err = en.Append(0xa7, 0x42, 0x61, 0x73, 0x65, 0x44, 0x69, 0x72)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7K bytes
    - Viewed (0)
  5. src/bytes/reader_test.go

    }
    
    // verify that copying from an empty reader always has the same results,
    // regardless of the presence of a WriteTo method.
    func TestReaderCopyNothing(t *testing.T) {
    	type nErr struct {
    		n   int64
    		err error
    	}
    	type justReader struct {
    		io.Reader
    	}
    	type justWriter struct {
    		io.Writer
    	}
    	discard := justWriter{io.Discard} // hide ReadFrom
    
    	var with, withOut nErr
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Dec 13 18:45:54 UTC 2021
    - 8K bytes
    - Viewed (0)
  6. api/go1.18.txt

    pkg bufio, method (*Writer) AvailableBuffer() []uint8
    pkg bufio, method (ReadWriter) AvailableBuffer() []uint8
    pkg bytes, func Cut([]uint8, []uint8) ([]uint8, []uint8, bool)
    pkg bytes, func Title //deprecated
    pkg crypto/tls, method (*Conn) NetConn() net.Conn
    pkg crypto/tls, type Config struct, PreferServerCipherSuites //deprecated
    pkg crypto/x509, method (*CertPool) Subjects //deprecated
    pkg debug/buildinfo, func Read(io.ReaderAt) (*debug.BuildInfo, error)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 13K bytes
    - Viewed (0)
  7. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintStream;
    import java.io.PrintWriter;
    import java.io.Reader;
    import java.io.StringReader;
    import java.io.StringWriter;
    import java.io.Writer;
    import java.lang.reflect.AnnotatedElement;
    import java.lang.reflect.GenericDeclaration;
    import java.lang.reflect.Type;
    import java.math.BigDecimal;
    import java.math.BigInteger;
    import java.nio.Buffer;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  8. src/cmd/asm/internal/asm/parse.go

    		return nil, false
    	}
    	p.patch()
    	return p.firstProg, true
    }
    
    // ParseSymABIs parses p's assembly code to find text symbol
    // definitions and references and writes a symabis file to w.
    func (p *Parser) ParseSymABIs(w io.Writer) bool {
    	operands := make([][]lex.Token, 0, 3)
    	for {
    		word, _, operands1, ok := p.line(operands)
    		if !ok {
    			break
    		}
    		operands = operands1
    
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 14 15:13:11 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

            .isTrue();
        if (!failures.isEmpty()) {
          StringWriter message = new StringWriter();
          PrintWriter writer = new PrintWriter(message);
          writer.println("Expected no failures, but found:");
          for (AssertionError failure : failures) {
            failure.printStackTrace(writer);
          }
          failures.clear();
          assertWithMessage(message.toString()).fail();
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
  10. api/go1.7.txt

    pkg net/http, var ErrUseLastResponse error
    pkg net/http, var LocalAddrContextKey *contextKey
    pkg net/http, var ServerContextKey *contextKey
    pkg net/http/cgi, type Handler struct, Stderr io.Writer
    pkg net/http/httptest, func NewRequest(string, string, io.Reader) *http.Request
    pkg net/http/httptest, method (*ResponseRecorder) Result() *http.Response
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
Back to top