Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 725 for bufLen (0.06 sec)

  1. internal/crypto/key.go

    		return etag
    	}
    	var buffer bytes.Buffer
    	mac := hmac.New(sha256.New, key[:])
    	mac.Write([]byte("SSE-etag"))
    	if _, err := sio.Encrypt(&buffer, bytes.NewReader(etag), sio.Config{Key: mac.Sum(nil), CipherSuites: fips.DARECiphers()}); err != nil {
    		logger.CriticalIf(context.Background(), errors.New("Unable to encrypt ETag using object key"))
    	}
    	return buffer.Bytes()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:28:10 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. cmd/server_test.go

    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	var buffer bytes.Buffer
    	// data to be written into buffer.
    	data := "1234567890"
    	// seed the random number generator once.
    	rand.Seed(3)
    	// generate a random number between 13 and 200.
    	randInt := getRandomRange(13, 200, -1)
    	// write into buffer till length of the buffer is greater than the generated random number.
    	for i := 0; i <= randInt; i += 10 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/cache/FaultHidingSink.kt

    import java.io.IOException
    import okio.Buffer
    import okio.ForwardingSink
    import okio.Sink
    
    /** A sink that never throws IOExceptions, even if the underlying sink does. */
    internal open class FaultHidingSink(
      delegate: Sink,
      val onException: (IOException) -> Unit,
    ) : ForwardingSink(delegate) {
      private var hasErrors = false
    
      override fun write(
        source: Buffer,
        byteCount: Long,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http/BridgeInterceptor.kt

    import okhttp3.Cookie
    import okhttp3.CookieJar
    import okhttp3.Interceptor
    import okhttp3.Response
    import okhttp3.internal.USER_AGENT
    import okhttp3.internal.toHostHeader
    import okio.GzipSource
    import okio.buffer
    
    /**
     * Bridges from application code to network code. First it builds a network request from a user
     * request. Then it proceeds to call the network. Finally it builds a user response from the network
     * response.
     */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbComClose.java

            return 6;
        }
        int writeBytesWireFormat( byte[] dst, int dstIndex ) {
            return 0;
        }
        int readParameterWordsWireFormat( byte[] buffer, int bufferIndex ) {
            return 0;
        }
        int readBytesWireFormat( byte[] buffer, int bufferIndex ) {
            return 0;
        }
        public String toString() {
            return new String( "SmbComClose[" +
                super.toString() +
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 1.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/io/Smb2FlushResponse.java

         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) throws SMBProtocolDecodingException {
            int start = bufferIndex;
            int structureSize = SMBUtil.readInt2(buffer, bufferIndex);
            if ( structureSize != 4 ) {
                throw new SMBProtocolDecodingException("Expected structureSize = 4");
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/session/Smb2LogoffResponse.java

         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) throws SMBProtocolDecodingException {
            int structureSize = SMBUtil.readInt2(buffer, bufferIndex);
            if ( structureSize != 4 ) {
                throw new SMBProtocolDecodingException("Structure size is not 4");
            }
            return 4;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.9K bytes
    - Viewed (0)
  8. src/main/java/jcifs/dcerpc/msrpc/samr.java

                _dst.enc_ndr_long(this.idx);
                _dst.enc_ndr_short(this.name.length);
                _dst.enc_ndr_short(this.name.maximum_length);
                _dst.enc_ndr_referent(this.name.buffer, 1);
    
                if ( this.name.buffer != null ) {
                    _dst = _dst.deferred;
                    int _name_bufferl = this.name.length / 2;
                    int _name_buffers = this.name.maximum_length / 2;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:40:13 UTC 2019
    - 15.1K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/Utf8.java

       * {@link #isWellFormed(byte[])}. Note that this can be false even when {@code
       * isWellFormed(bytes)} is true.
       *
       * @param bytes the input buffer
       * @param off the offset in the buffer of the first byte to read
       * @param len the number of bytes to read from the buffer
       */
      public static boolean isWellFormed(byte[] bytes, int off, int len) {
        int end = off + len;
        checkPositionIndexes(off, end, bytes.length);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7K bytes
    - Viewed (0)
  10. cmd/api-headers.go

    func encodeResponseList(response interface{}) []byte {
    	var buf bytes.Buffer
    	buf.WriteString(xxml.Header)
    	if err := xxml.NewEncoder(&buf).Encode(response); err != nil {
    		bugLogIf(GlobalContext, err)
    		return nil
    	}
    	return buf.Bytes()
    }
    
    // Encodes the response headers into JSON format.
    func encodeResponseJSON(response interface{}) []byte {
    	var bytesBuffer bytes.Buffer
    	e := json.NewEncoder(&bytesBuffer)
    	e.Encode(response)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
Back to top