Search Options

Results per page
Sort
Preferred Languages
Advance

Results 741 - 750 of 979 for buffer (0.14 sec)

  1. src/test/java/jcifs/internal/smb2/ioctl/Smb2IoctlResponseTest.java

            resp.decode(packet, 0);
            assertEquals(output.length, resp.getOutputLength());
            assertArrayEquals(output, outBuf, "Output should be copied into provided buffer");
            // No Decodable output when buffer is provided
            assertNull(resp.getOutputData());
            assertThrows(SmbException.class, () -> resp.getOutputData(SrvCopyChunkCopyResponse.class));
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  2. src/test/java/jcifs/netbios/NodeStatusRequestTest.java

            nodeStatusRequest = new NodeStatusRequest(mockConfig, realName);
            nodeStatusRequest.nameTrnId = 0x1234;
    
            byte[] buffer = new byte[512];
    
            // Act - Write
            int writeLength = nodeStatusRequest.writeWireFormat(buffer, 0);
    
            // Assert write
            assertTrue(writeLength > 0);
    
            // Create new request to read
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  3. schema/serializer.go

    	return
    }
    
    // Value implements serializer interface
    func (GobSerializer) Value(ctx context.Context, field *Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	buf := new(bytes.Buffer)
    	err := gob.NewEncoder(buf).Encode(fieldValue)
    	return buf.Bytes(), err
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. cmd/erasure-heal_test.go

    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    		_, err = erasure.Encode(t.Context(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. src/bytes/compare_test.go

    	{nil, []byte("a"), -1},
    }
    
    func TestCompare(t *testing.T) {
    	for _, tt := range compareTests {
    		numShifts := 16
    		buffer := make([]byte, len(tt.b)+numShifts)
    		// vary the input alignment of tt.b
    		for offset := 0; offset <= numShifts; offset++ {
    			shiftedB := buffer[offset : len(tt.b)+offset]
    			copy(shiftedB, tt.b)
    			cmp := Compare(tt.a, shiftedB)
    			if cmp != tt.i {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Jul 13 23:11:42 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

          content: String,
          chunkSize: Int,
        ) {
          setBody(response, Buffer().writeUtf8(content), chunkSize)
        }
      }
    
      /** Returns a gzipped copy of `bytes`.  */
      fun gzip(data: String): Buffer {
        val result = Buffer()
        val sink = GzipSink(result).buffer()
        sink.writeUtf8(data)
        sink.close()
        return result
      }
    
      companion object {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/SmbComNTCreateAndX.java

            return n;
        }
    
        @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() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

          route: Route,
          socket: JavaNetSocket,
          idleAtNs: Long,
        ): RealConnection {
          val bufferedSocket =
            object : BufferedSocket {
              override val sink = Buffer()
              override val source = Buffer()
    
              override fun cancel() {
              }
            }
    
          val result =
            RealConnection(
              taskRunner = taskRunner,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/tree/Smb2TreeDisconnectRequest.java

        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int)
         */
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  10. cmd/xl-storage_test.go

    			0, 5, nil, errFileNameTooLong,
    		},
    		// Buffer size greater than object size. - 6
    		{
    			volume, "myobject", 0, 16,
    			[]byte("hello, world"),
    			io.ErrUnexpectedEOF,
    		},
    		// Reading from an offset success. - 7
    		{
    			volume, "myobject", 7, 5,
    			[]byte("world"), nil,
    		},
    		// Reading from an object but buffer size greater. - 8
    		{
    			volume, "myobject",
    			7, 8,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
Back to top