Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 777 for buffer (0.04 sec)

  1. cmd/storage-datatypes_gen_test.go

    	v := BaseOptions{}
    	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 BenchmarkDecodeBaseOptions(b *testing.B) {
    	v := BaseOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 73.9K bytes
    - Viewed (0)
  2. compat/maven-artifact/src/main/java/org/apache/maven/artifact/repository/ArtifactRepositoryPolicy.java

        @Override
        public String toString() {
            StringBuilder buffer = new StringBuilder(64);
            buffer.append("{enabled=");
            buffer.append(enabled);
            buffer.append(", checksums=");
            buffer.append(checksumPolicy);
            buffer.append(", updates=");
            buffer.append(updatePolicy);
            buffer.append('}');
            return buffer.toString();
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. mockwebserver/src/main/kotlin/mockwebserver3/internal/BufferMockResponseBody.kt

    import mockwebserver3.MockResponseBody
    import okio.Buffer
    import okio.BufferedSink
    
    internal fun Buffer.toMockResponseBody(): MockResponseBody {
      val defensiveCopy = clone()
      return BufferMockResponseBody(defensiveCopy)
    }
    
    internal class BufferMockResponseBody(
      val buffer: Buffer,
    ) : MockResponseBody {
      override val contentLength = buffer.size
    
      override fun writeTo(sink: BufferedSink) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 07 16:05:34 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/FormBody.kt

      ): Long {
        var byteCount = 0L
        val buffer: Buffer = if (countBytes) Buffer() else sink!!.buffer
    
        for (i in 0 until encodedNames.size) {
          if (i > 0) buffer.writeByte('&'.code)
          buffer.writeUtf8(encodedNames[i])
          buffer.writeByte('='.code)
          buffer.writeUtf8(encodedValues[i])
        }
    
        if (countBytes) {
          byteCount = buffer.size
          buffer.clear()
        }
    
        return byteCount
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 09 12:33:05 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  5. compat/maven-artifact/src/main/java/org/apache/maven/artifact/versioning/ComparableVersion.java

            @Override
            public String toString() {
                StringBuilder buffer = new StringBuilder();
                for (Item item : this) {
                    if (buffer.length() > 0) {
                        buffer.append((item instanceof ListItem) ? '-' : '.');
                    }
                    buffer.append(item);
                }
                return buffer.toString();
            }
    
            /**
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 26K bytes
    - Viewed (0)
  6. internal/config/crypto.go

    		return nil, errors.New("config: encryption metadata is too large")
    	}
    	header[0] = Version
    	binary.LittleEndian.PutUint32(header[1:], uint32(len(metadata)))
    	buffer.Write(header[:])
    	buffer.Write(metadata)
    
    	return io.MultiReader(
    		&buffer,
    		stream.EncryptReader(plaintext, nonce, nil),
    	), nil
    }
    
    // Decrypt decrypts the ciphertext using a key managed by the KMS.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/math/PairedStats.java

       * versions.
       */
      public byte[] toByteArray() {
        ByteBuffer buffer = ByteBuffer.allocate(BYTES).order(ByteOrder.LITTLE_ENDIAN);
        xStats.writeTo(buffer);
        yStats.writeTo(buffer);
        buffer.putDouble(sumOfProductsOfDeltas);
        return buffer.array();
      }
    
      /**
       * Creates a {@link PairedStats} instance from the given byte representation which was obtained by
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 17:02:53 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/security/MessageDigestUtil.java

            final StringBuilder buffer = new StringBuilder(200);
            for (final byte element : digest) {
                final String tmp = Integer.toHexString(element & 0xff);
                if (tmp.length() == 1) {
                    buffer.append('0').append(tmp);
                } else {
                    buffer.append(tmp);
                }
            }
            return buffer.toString();
        }
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  9. compat/maven-embedder/src/main/java/org/apache/maven/cli/CleanArgument.java

                    continue;
                }
    
                // if we haven't added this arg to the buffer, and we ARE building an argument
                // buffer, then append it with a preceding space...again, not sure what else to
                // do other than collapse whitespace.
                // NOTE: The case of a trailing quote is handled by nullifying the arg buffer.
                if (!addedToBuffer) {
                    if (currentArg != null) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilCommon.kt

     */
    package okhttp3
    
    import okio.Buffer
    import okio.Path
    import okio.Path.Companion.toPath
    
    val okHttpRoot: Path
      get() = getEnv("OKHTTP_ROOT")!!.toPath()
    
    fun String(vararg codePoints: Int): String {
      val buffer = Buffer()
      for (codePoint in codePoints) {
        buffer.writeUtf8CodePoint(codePoint)
      }
      return buffer.readUtf8()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 931 bytes
    - Viewed (0)
Back to top