- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 413 for readPing (0.09 sec)
-
cmd/erasure-object.go
if !opts.NoAuditLog { auditObjectErasureSet(ctx, "GetObjectInfo", object, &er) } if !opts.NoLock { // Lock the object before reading. lk := er.NewNSLock(bucket, object) lkctx, err := lk.GetRLock(ctx, globalOperationTimeout) if err != nil { return ObjectInfo{}, err } ctx = lkctx.Context() defer lk.RUnlock(lkctx) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0) -
gradlew
# Attempt to set APP_HOME # Resolve links: $0 may be a link app_path=$0 # Need this for daisy-chained symlinks. while APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path [ -h "$app_path" ] do ls=$( ls -ld "$app_path" ) link=${ls#*' -> '} case $link in #( /*) app_path=$link ;; #( *) app_path=$APP_HOME$link ;; esac done
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Aug 01 08:06:31 UTC 2025 - 8.5K bytes - Viewed (0) -
cmd/storage-rest-common_gen.go
} switch msgp.UnsafeString(field) { case "id": z.DiskID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DiskID") return } case "m": z.ScanMode, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "ScanMode") return } case "c": if dc.IsNil() { err = dc.ReadNil() if err != nil { err = msgp.WrapError(err, "Cache") return
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 7.9K bytes - Viewed (0) -
cmd/metacache-walk_gen.go
return } case "ForwardTo": z.ForwardTo, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ForwardTo") return } case "Limit": z.Limit, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Limit") return } case "DiskID": z.DiskID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "DiskID") return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt
} /** * Read 100 MiB of 'a' chars. This was really slow due to a performance bug in [MultipartReader], * and will be really slow if we regress the fix for that. */ @Test fun `reading a large part with small byteCount`() { val multipartBody = MultipartBody .Builder("foo") .addPart( headersOf("header-name", "header-value"), object : RequestBody() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 15.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java
/* * We overload this because we want readAndXWireFormat to * read the parameter words and bytes. This is so when * commands are batched together we can recursivly call * readAndXWireFormat without reading the non-existent header. */ @Override public int decode(final byte[] buffer, int bufferIndex) throws SMBProtocolDecodingException { final int start = this.headerStart = bufferIndex;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.8K bytes - Viewed (0) -
src/test/java/jcifs/http/NetworkExplorerTest.java
throw new ServletException(e); } } }; assertDoesNotThrow(() -> networkExplorer.init(servletConfig)); // Verify parameter reading verify(servletConfig).getInitParameter("jcifs.smb.client.domain"); verify(servletConfig).getInitParameter("jcifs.http.enableBasic"); } /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 04:51:33 UTC 2025 - 21.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* must be between 1 and [Integer.MAX_VALUE] when converted to milliseconds. * * The call timeout spans the entire call: resolving DNS, connecting, writing the request body, * server processing, and reading the response body. If the call requires redirects or retries * all must complete within one timeout period. * * The default value is 0 which imposes no timeout. */ fun callTimeout(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
*/ protected static class ProcessDestroyer extends TimerTask { /** The process to monitor and destroy. */ private final Process p; /** The input stream thread reading process output. */ private final InputStreamThread ist; /** Flag indicating if the destroyer has been executed. */ private final AtomicBoolean executed = new AtomicBoolean(false);
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Fri Jul 18 14:34:06 UTC 2025 - 14.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java
TransPeekNamedPipeResponse testResponse = new TransPeekNamedPipeResponse(testConfig); // Assert assertNotNull(testResponse); } @Test @DisplayName("Test state changes after reading parameters") void testStateAfterReadingParameters() { // Arrange byte[] buffer = new byte[10]; SMBUtil.writeInt2(1500, buffer, 0); SMBUtil.writeInt2(0xFFFF, buffer, 2);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.8K bytes - Viewed (0)