Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 551 - 560 of 925 for buffers (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/jcifs/smb1/smb1/SmbComQueryInformation.java

            dstIndex += writeString(path, dst, dstIndex);
            return dstIndex - start;
        }
    
        @Override
        int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
        @Override
        int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
        @Override
        public String toString() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  2. internal/s3select/message.go

    }
    
    func genMessage(header, payload []byte) []byte {
    	headerLength := len(header)
    	payloadLength := len(payload)
    	totalLength := totalByteLength(headerLength, payloadLength)
    
    	buf := new(bytes.Buffer)
    	binary.Write(buf, binary.BigEndian, uint32(totalLength))
    	binary.Write(buf, binary.BigEndian, uint32(headerLength))
    	prelude := buf.Bytes()
    	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/persistent/DurableHandleV2Response.java

            return CONTEXT_NAME_BYTES;
        }
    
        @Override
        public int decode(byte[] buffer, int bufferIndex, int len) throws SMBProtocolDecodingException {
            if (len != 8) {
                throw new SMBProtocolDecodingException("Invalid durable handle V2 response length: " + len);
            }
    
            this.timeout100Ns = SMBUtil.readInt4(buffer, bufferIndex) & 0xFFFFFFFFL; // Timeout (4 bytes, 100-ns intervals, unsigned)
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 3K bytes
    - Click Count (0)
  4. src/main/java/jcifs/internal/smb1/com/SmbComSeekResponse.java

        protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) {
            this.offset = SMBUtil.readInt4(buffer, bufferIndex);
            return 4;
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb1.ServerMessageBlock#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) throws SMBProtocolDecodingException {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb1/trans/TransWaitNamedPipe.java

            return 0;
        }
    
        @Override
        protected int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        protected int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        public String toString() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  6. cmd/background-newdisks-heal-ops_gen_test.go

    	v := healingTracker{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodehealingTracker(b *testing.B) {
    	v := healingTracker{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb1/com/SmbComBlankResponse.java

            return 0;
        }
    
        @Override
        protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
        @Override
        public String toString() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  8. samples/static-server/src/main/java/okhttp3/sample/SampleServer.java

        return new MockResponse()
            .setStatus("HTTP/1.1 200")
            .setBody(fileToBytes(file))
            .addHeader("content-type: " + contentType(path));
      }
    
      private Buffer fileToBytes(File file) throws IOException {
        Buffer result = new Buffer();
        result.writeAll(Okio.source(file));
        return result;
      }
    
      private String contentType(String path) {
        if (path.endsWith(".png")) return "image/png";
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 11 02:37:00 GMT 2026
    - 5.3K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

    import okhttp3.internal.http.HttpMethod
    import okhttp3.internal.http.RealResponseBody
    import okhttp3.internal.http.promisesBody
    import okhttp3.internal.stripBody
    import okio.Buffer
    import okio.Source
    import okio.Timeout
    import okio.buffer
    
    /** Serves requests from the cache and writes responses to the cache. */
    class CacheInterceptor : Interceptor {
      @Throws(IOException::class)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 10.3K bytes
    - Click Count (0)
  10. cmd/erasure-encode_test.go

    		disks := setup.disks
    		erasure, err := NewErasure(t.Context(), test.dataBlocks, test.onDisks-test.dataBlocks, test.blocksize)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    
    		data := make([]byte, test.data)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to generate random test data: %v", i, err)
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
Back to Top