Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 251 - 260 of 975 for Buffer (0.05 seconds)

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

  1. okhttp/src/jvmTest/kotlin/okhttp3/FormBodyTest.kt

        val buffer = Buffer()
        body.writeTo(buffer)
        assertThat(buffer.readUtf8()).isEqualTo(expected)
      }
    
      @Test
      fun buildEmptyForm() {
        val body = FormBody.Builder().build()
        val expected = ""
        assertThat(body.contentLength()).isEqualTo(expected.length.toLong())
        val buffer = Buffer()
        body.writeTo(buffer)
        assertThat(buffer.readUtf8()).isEqualTo(expected)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb1/trans2/Trans2FindFirst2.java

        @Override
        protected int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            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;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb1/trans/TransWaitNamedPipeTest.java

        void testReadSetupWireFormat() {
            // Arrange
            transWaitNamedPipe = new TransWaitNamedPipe(mockConfig, testPipeName);
            byte[] buffer = new byte[10];
    
            // Act
            int result = transWaitNamedPipe.readSetupWireFormat(buffer, 0, 10);
    
            // Assert
            assertEquals(0, result);
        }
    
        @Test
        @DisplayName("writeParametersWireFormat should return 0")
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  4. src/bytes/buffer_test.go

    	// Confirm that when Reader panics, the empty buffer remains empty
    	var buf2 Buffer
    	defer func() {
    		recover()
    		check(t, "TestReadFromPanicReader (2)", &buf2, "")
    	}()
    	buf2.ReadFrom(panicReader{panic: true})
    }
    
    func TestReadFromNegativeReader(t *testing.T) {
    	var b Buffer
    	defer func() {
    		switch err := recover().(type) {
    		case nil:
    			t.Fatal("bytes.Buffer.ReadFrom didn't panic")
    		case error:
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Nov 14 19:01:17 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt

                  repeat(100) {
                    sink.writeUtf8(a1024x1024)
                  }
                }
              },
            ).build()
        val buffer = Buffer()
        multipartBody.writeTo(buffer)
    
        val multipartReader = MultipartReader(buffer, "foo")
        val onlyPart = multipartReader.nextPart()!!
        assertThat(onlyPart.headers).isEqualTo(
          headersOf(
            "header-name",
            "header-value",
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 02:11:14 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb1/smb1/TransTransactNamedPipeResponse.java

            return 0;
        }
    
        @Override
        int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            if (pipe.pipeIn != null) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb1/trans/nt/NtTransQuerySecurityDescTest.java

        void testReadSetupWireFormat() {
            querySecurityDesc = new NtTransQuerySecurityDesc(mockConfig, 0x1234, OWNER_SECURITY_INFORMATION);
            byte[] buffer = new byte[100];
    
            int result = querySecurityDesc.readSetupWireFormat(buffer, 10, 50);
    
            assertEquals(0, result);
        }
    
        @Test
        @DisplayName("Test readParametersWireFormat returns zero")
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 13.9K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/nego/PreauthIntegrityNegotiateContext.java

         * @see jcifs.Decodable#decode(byte[], int, int)
         */
        @Override
        public int decode(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException {
            final int start = bufferIndex;
            final int nalgos = SMBUtil.readInt2(buffer, bufferIndex);
            final int nsalt = SMBUtil.readInt2(buffer, bufferIndex + 2);
            bufferIndex += 4;
    
            this.hashAlgos = new int[nalgos];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb1/smb1/SmbComSessionSetupAndXResponse.java

            return 0;
        }
    
        @Override
        int readParameterWordsWireFormat(final byte[] buffer, int bufferIndex) {
            final int start = bufferIndex;
            isLoggedInAsGuest = ((buffer[bufferIndex] & 0x01) == 0x01) == true;
            bufferIndex += 2;
            if (extendedSecurity) {
                final int blobLength = readInt2(buffer, bufferIndex);
                bufferIndex += 2;
                blob = new byte[blobLength];
            }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java

                logNotificationTarget.flush();
            }
        }
    
        /**
         * Offers an event to the buffer. If the buffer exceeds the maximum size, the oldest event is dropped.
         *
         * @param event the log notification event to add
         */
        public void offer(final LogNotificationEvent event) {
            int maxBufferSize;
            try {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 5.3K bytes
    - Click Count (0)
Back to Top