- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Buffer (0.22 sec)
-
cmd/server_test.go
c.Assert(err, nil) c.Assert(response.StatusCode, http.StatusOK) var buffer bytes.Buffer // data to be written into buffer. data := "1234567890" // seed the random number generator once. rand.Seed(3) // generate a random number between 13 and 200. randInt := getRandomRange(13, 200, -1) // write into buffer till length of the buffer is greater than the generated random number. for i := 0; i <= randInt; i += 10 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
tensorflow/c/c_api.cc
} *result = TF_TensorFromTensor(**status_or, &status->status); return status->status.ok(); } TF_ApiDefMap* TF_NewApiDefMap(TF_Buffer* op_list_buffer, TF_Status* status) { tensorflow::OpList op_list; if (!op_list.ParseFromArray(op_list_buffer->data, op_list_buffer->length)) { status->status = InvalidArgument("Unparseable OpList"); return nullptr; } status->status = absl::OkStatus();
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 102.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
@Test fun contentDisagreesWithChunkedHeaderBodyTooLong() { val builder = MockResponse.Builder() .chunkedBody("abc", 3) val buffer = Buffer() builder.body!!.writeTo(buffer) buffer.writeUtf8("\r\nYOU SHOULD NOT SEE THIS") builder.body(buffer) builder.clearHeaders() builder.addHeader("Transfer-encoding: chunked") server.enqueue(builder.build())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/test/java/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 {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
.hostnameVerifier(RecordingHostnameVerifier()) .build() server.useHttps(handshakeCertificates.sslSocketFactory()) } private fun gzip(data: String): Buffer { val result = Buffer() val sink = GzipSink(result).buffer() sink.writeUtf8(data) sink.close() return result } private fun cancelLater( call: Call, delay: Long, ): Thread {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
cmd/object-handlers_test.go
}{ {byteData: generateBytesData(6 * humanize.KiByte)}, } h := md5.New() h.Write(bytesData[0].byteData) bytesData[0].md5sum = hex.EncodeToString(h.Sum(nil)) buffers := []*bytes.Buffer{ new(bytes.Buffer), new(bytes.Buffer), } // set of inputs for uploading the objects before tests for downloading is done. putObjectInputs := []struct { bucketName string objectName string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
cmd/admin-handlers.go
if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } // Convert local entries to JSON go func() { var buf bytes.Buffer enc := json.NewEncoder(&buf) for { select { case <-ctx.Done(): return case li := <-logCh: if !li.SendLog(node, logKind) { continue } buf.Reset()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
doc/go1.17_spec.html
name string "any string is permitted as a tag" _ [4]byte "ceci n'est pas un champ de structure" } // A struct corresponding to a TimeStamp protocol buffer. // The tag strings define the protocol buffer field numbers; // they follow the convention outlined by the reflect package. struct { microsec uint64 `protobuf:"1"` serverIP6 uint64 `protobuf:"2"` } </pre>
HTML - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 211.6K bytes - Viewed (0) -
maven-api-impl/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar
Object, boolean) throws Exception; private static ClassMap getClassMap(Class); static void <clinit>(); } org/codehaus/plexus/util/IOUtil.class package org.codehaus.plexus.util; public final synchronized class IOUtil { private static final int DEFAULT_BUFFER_SIZE = 4096; private void IOUtil(); public static void copy(java.io.InputStream, java.io.OutputStream) throws java.io.IOException; public static void copy(java.io.InputStream, java.io.OutputStream, int) throws java.io.IOException; public static void...
Archive - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 164.6K bytes - Viewed (0) -
cmd/object-handlers.go
} const ( compressionAlgorithmV1 = "golang/snappy/LZ77" compressionAlgorithmV2 = "klauspost/compress/s2" // When an upload exceeds encryptBufferThreshold ... encryptBufferThreshold = 1 << 20 // add an input buffer of this size. encryptBufferSize = 1 << 20 // minCompressibleSize is the minimum size at which we enable compression. minCompressibleSize = 4096 )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0)