- Sort Score
- Result 10 results
- Languages All
Results 351 - 360 of 410 for callbacks (0.12 sec)
-
src/main/java/jcifs/smb/SmbTreeConnection.java
try (SmbSessionImpl treesess = t.getSession()) { if (treesess.getCredentials().isAnonymous() || treesess.getCredentials().isGuest()) { // refresh anonymous session or fallback to anonymous from guest login try (SmbSessionInternal s = trans.getSmbSession(this.ctx.withAnonymousCredentials(), treesess.getTargetHost(), treesess.getTargetDomain())
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 30.4K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
/** * Atomically reschedules this task and assigns the new future to {@link * #cancellationDelegate}. */ @CanIgnoreReturnValue Cancellable reschedule() { // invoke the callback outside the lock, prevents some shenanigans. Schedule schedule; try { schedule = CustomScheduler.this.getNextSchedule(); } catch (Throwable t) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
docs/smb3-features/04-directory-leasing-design.md
if (entry.getInconsistencyCount() > 5) { entry.invalidate(); } } } } ``` ### 9.2 Fallback Mechanisms ```java public class DirectoryOperationFallback { public SmbFile[] safeListFiles(SmbFile directory) throws IOException { try { // Try cached listing first
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 36.2K bytes - Viewed (0) -
okhttp/api/jvm/okhttp.api
} public abstract interface class okhttp3/Call : java/lang/Cloneable { public abstract fun cancel ()V public abstract fun clone ()Lokhttp3/Call; public abstract fun enqueue (Lokhttp3/Callback;)V public abstract fun execute ()Lokhttp3/Response; public abstract fun isCanceled ()Z public abstract fun isExecuted ()Z public abstract fun request ()Lokhttp3/Request; public abstract fun timeout ()Lokio/Timeout;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 16 09:39:51 UTC 2025 - 69.4K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/SuggestJobTest.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 31.4K bytes - Viewed (0) -
cmd/erasure-multipart.go
if split := strings.Split(string(b64), "x"); len(split) == 2 { t, err := strconv.ParseInt(split[1], 10, 64) if err == nil { modTime = time.Unix(0, t) } } } // Fallback for older uploads without time in the ID. if modTime.IsZero() { wait := deleteMultipartCleanupSleeper.Timer(ctx) fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{})
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
} finally { SMailCallbackContext.clearPreparedMessageHookOnThread(); } } } /** * Retrieves a value from a map with a default fallback. * * @param dataMap the map to retrieve the value from * @param key the key to look up * @param defaultValue the default value to return if key is not found or value is blank
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 31K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt
frame.writeByte(99) // type 99 frame.writeByte(FLAG_NONE) frame.writeInt(expectedStreamId) frame.writeInt(111111111) // custom data reader.nextFrame(requireSettings = false, BaseTestHandler()) // Should not callback. } @Test fun onlyOneLiteralHeadersFrame() { val sentHeaders = headerEntries("name", "value") val headerBytes = literalHeaders(sentHeaders) writeMedium(frame, headerBytes.size.toInt())
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 28.1K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/SystemHelperTest.java
getMockRequest().setLocale(Locale.JAPANESE); helpUrl = systemHelper.getHelpUrl("https://example.com/{lang}/{version}/test.html"); // Check if Japanese is actually supported or just use the fallback assertTrue(helpUrl.contains("98.76")); getMockRequest().setLocale(Locale.ITALIAN); helpUrl = systemHelper.getHelpUrl("https://example.com/{lang}/{version}/test.html");
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 19 23:49:30 UTC 2025 - 28.9K bytes - Viewed (0) -
src/bytes/bytes.go
return i - last next: fails++ i++ if (haveFastIndex && fails > bytealg.Cutover(i)) && i < len(s) || (!haveFastIndex && fails >= 4+i>>4 && i < len(s)) { goto fallback } } return -1 fallback: // Switch to bytealg.Index, if available, or a brute force search when // IndexByte returns too many false positives. if haveFastIndex {
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Wed Sep 03 14:04:47 UTC 2025 - 35.5K bytes - Viewed (0)