- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for arkite (0.18 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val dataLength = 16384 // Write the mocking script. peer.sendFrame().settings(Settings()) peer.acceptFrame() // ACK peer.acceptFrame() // SYN_STREAM peer.sendFrame().headers(false, 3, headerEntries("b", "banana")) peer.sendFrame().data(false, 3, Buffer().write(ByteArray(dataLength)), dataLength) peer.sendFrame().data(false, 3, Buffer().write(ByteArray(dataLength)), dataLength)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
configure.py
if e.errno == errno.EEXIST: os.remove(link_name) os.symlink(target, link_name) else: raise e def write_to_bazelrc(line): with open(_TF_BAZELRC, 'a') as f: f.write(line + '\n') def write_action_env_to_bazelrc(var_name, var): write_to_bazelrc('build --action_env {}="{}"'.format(var_name, str(var))) def run_shell(cmd, allow_non_zero=False, stderr=None):
Python - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 18:25:36 GMT 2024 - 53.8K bytes - Viewed (1) -
cmd/bucket-replication-utils_gen.go
func (z *BucketReplicationResyncStatus) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 4 // write "v" err = en.Append(0x84, 0xa1, 0x76) if err != nil { return } err = en.WriteInt(z.Version) if err != nil { err = msgp.WrapError(err, "Version") return } // write "brs" err = en.Append(0xa3, 0x62, 0x72, 0x73) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 61.1K bytes - Viewed (0) -
cmd/xl-storage-format-v2_gen.go
return } if (zb0001Mask & 0x1) == 0 { // if not omitted // write "V2Obj" err = en.Append(0xa5, 0x56, 0x32, 0x4f, 0x62, 0x6a) if err != nil { return } if z.ObjectV2 == nil { err = en.WriteNil() if err != nil { return } } else { // map header, size 1 // write "DDir" err = en.Append(0x81, 0xa4, 0x44, 0x44, 0x69, 0x72) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 53.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
readTimeout = checkDuration("duration", duration) } /** * Sets the default write timeout for new connections. A value of 0 means no timeout, otherwise * values must be between 1 and [Integer.MAX_VALUE] when converted to milliseconds. * * The write timeout is applied for individual write IO operations. The default value is 10 * seconds. * * @see Sink.timeout */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
* * - All (unsynchronized) read operations must first read the "count" field, and should not * look at table entries if it is 0. * * - All (synchronized) write operations should write to the "count" field after structurally * changing any bin. The operations must not take any action that could even momentarily
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 91.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
// Get current region. region := globalSite.Region if region != globalMinioDefaultRegion { encodedSuccessResponse = encodeResponse(LocationResponse{ Location: region, }) } // Write success response. writeSuccessResponseXML(w, encodedSuccessResponse) } // ListMultipartUploadsHandler - GET Bucket (List Multipart uploads) // -------------------------
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
// // 2. In done() where we may propagate cancellation to the input. In this case it is _not_ fine. // There is currently nothing that enforces that the write to inputFuture in the constructor is // visible to done(). This is because there is no happens before edge between the write and a // (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0)