- Sort Score
- Result 10 results
- Languages All
Results 381 - 390 of 725 for bufLen (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)