Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 968 for Buffer (0.1 sec)

  1. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelProblem.java

            StringBuilder buffer = new StringBuilder(128);
    
            buffer.append('[').append(getSeverity()).append("] ");
            buffer.append(getMessage());
            String location = ModelProblemUtils.formatLocation(this, null);
            if (!location.isEmpty()) {
                buffer.append(" @ ");
                buffer.append(location);
            }
    
            return buffer.toString();
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. cmd/storage-rest-common_gen_test.go

    	v := nsScannerOptions{}
    	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 BenchmarkDecodensScannerOptions(b *testing.B) {
    	v := nsScannerOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbComTreeConnectAndXResponse.java

            return 0;
        }
        int readParameterWordsWireFormat( byte[] buffer, int bufferIndex ) {
            supportSearchBits = ( buffer[bufferIndex] & SMB_SUPPORT_SEARCH_BITS ) == SMB_SUPPORT_SEARCH_BITS;
            shareIsInDfs = ( buffer[bufferIndex] & SMB_SHARE_IS_IN_DFS ) == SMB_SHARE_IS_IN_DFS;
            return 2;
        }
        int readBytesWireFormat( byte[] buffer, int bufferIndex ) {
            int start = bufferIndex;
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.9K bytes
    - Viewed (0)
  4. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt

      fun encodeQuery(
        host: String,
        type: Int,
      ): ByteString =
        Buffer().apply {
          writeShort(0) // query id
          writeShort(256) // flags with recursion
          writeShort(1) // question count
          writeShort(0) // answerCount
          writeShort(0) // authorityResourceCount
          writeShort(0) // additional
    
          val nameBuf = Buffer()
          val labels = host.split('.').dropLastWhile { it.isEmpty() }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

              .build(),
          )
        val response = call.execute()
        interruptLater(500)
        val responseBody = response.body.byteStream()
        val buffer = ByteArray(1024)
        assertFailsWith<IOException> {
          while (responseBody.read(buffer) != -1) {
          }
        }
        responseBody.close()
      }
    
      private fun sleep(delayMillis: Int) {
        try {
          Thread.sleep(delayMillis.toLong())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/SmbComTransactionResponse.java

            bufferIndex += 2;
            parameterOffset = readInt2( buffer, bufferIndex );
            bufferIndex += 2;
            parameterDisplacement = readInt2( buffer, bufferIndex );
            bufferIndex += 2;
            dataCount = readInt2( buffer, bufferIndex );
            bufferIndex += 2;
            dataOffset = readInt2( buffer, bufferIndex );
            bufferIndex += 2;
            dataDisplacement = readInt2( buffer, bufferIndex );
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/Trans2SetFileInformationResponse.java

        int writeDataWireFormat( byte[] dst, int dstIndex ) {
            return 0;
        }
        int readSetupWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        int readParametersWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        int readDataWireFormat( byte[] buffer, int bufferIndex, int len ) {
            return 0;
        }
        public String toString() {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 1.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/SmbComOpenAndXResponse.java

        }
        int readParameterWordsWireFormat( byte[] buffer, int bufferIndex ) {
            int start = bufferIndex;
    
            fid = readInt2( buffer, bufferIndex );
            bufferIndex += 2;
            fileAttributes = readInt2( buffer, bufferIndex );
            bufferIndex += 2;
            lastWriteTime = readUTime( buffer, bufferIndex );
            bufferIndex += 4;
            dataSize = readInt4( buffer, bufferIndex );
            bufferIndex += 4;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.8K bytes
    - Viewed (0)
  9. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

            } else {
              var buffer = Buffer()
              requestBody.writeTo(buffer)
    
              var gzippedLength: Long? = null
              if ("gzip".equals(headers["Content-Encoding"], ignoreCase = true)) {
                gzippedLength = buffer.size
                GzipSource(buffer).use { gzippedResponseBody ->
                  buffer = Buffer()
                  buffer.writeAll(gzippedResponseBody)
                }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 09:14:38 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  10. internal/bpool/bpool.go

    	select {
    	case b = <-bp.c:
    		// reuse existing buffer
    	default:
    		// create new aligned buffer
    		b = reedsolomon.AllocAligned(1, bp.wcap)[0][:bp.w]
    	}
    	return
    }
    
    // Put returns the given Buffer to the BytePool.
    func (bp *BytePoolCap) Put(b []byte) {
    	if bp == nil {
    		return
    	}
    
    	if cap(b) != bp.wcap {
    		// someone tried to put back buffer which is not part of this buffer pool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top