- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 316 for dcancel (0.03 sec)
-
cmd/server-main.go
} ip := "127.0.0.1" host, _ := mustSplitHostPort(globalLocalNodeName) if host != "" { if net.ParseIP(host) != nil { ip = host } else { ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second) defer cancel() haddrs, err := globalDNSCache.LookupHost(ctx, host) if err == nil { ip = haddrs[0] } } } ifs, _ := net.Interfaces()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
docs/sts/tls.md
*Applications that use direct S3 API will work fine, however interactive users uploading content using (when POSTing to the presigned URL an app generates) a popup becomes visible on browser to provide client certs, you would have to manually cancel and continue. This may be annoying to use but there is no workaround for now.* ## Explore Further - [MinIO Admin Complete Guide](https://docs.min.io/community/minio-object-store/reference/minio-mc-admin.html)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 6K bytes - Viewed (1) -
internal/cachevalue/cache.go
t.Once.Do(func() { t.ttl = ttl t.updateFn = update t.opts = opts }) } // GetWithCtx will return a cached value or fetch a new one. // passes a caller context, if caller context cancels nothing // is cached. // If the Update function returns an error the value is forwarded as is and not cached. func (t *Cache[T]) GetWithCtx(ctx context.Context) (T, error) { v := t.val.Load() ttl := t.ttl
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/ServerMessageBlock.java
} this.response = (ServerMessageBlock) response; } /** * {@inheritDoc} * * @see jcifs.util.transport.Request#isCancel() */ @Override public boolean isCancel() { return false; } /** * @return the mid */ @Override public final long getMid() { return this.mid; }Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 38.9K bytes - Viewed (0) -
cmd/data-usage-cache.go
// Abandon if more than time.Minute, so we don't hold up scanner. // drive timeout by default is 2 minutes, we do not need to wait longer. ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel() r, err := store.GetObjectNInfo(ctx, minioMetaBucket, pathJoin(bucketMetaPrefix, name), nil, http.Header{}, ObjectOptions{NoLock: true}) if err != nil { switch err.(type) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 34.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
logger.error("SuggestCreator terminated unexpectedly.", t); exitCode = Constants.EXIT_FAIL; } finally { if (systemMonitorTask != null) { systemMonitorTask.cancel(); } destroyContainer(); } logger.info("Finished SuggestCreator."); System.exit(exitCode); } private static void destroyContainer() {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 11.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
resultBuf.append(e.getMessage()).append("\n"); } finally { if (timeoutTask != null && !timeoutTask.isCanceled()) { timeoutTask.cancel(); } } return resultBuf.toString(); } /** * Executes the suggest creator process.
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 10.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java
if (logger.isDebugEnabled()) { logger.debug("Canceled urlQueue: {}", urlQueue); } // cancel crawling crawlerContext.decrementAndGetAccessCount(); final List<UrlQueue<?>> newUrlQueueList = new ArrayList<>(); newUrlQueueList.add(urlQueue);
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 12.5K bytes - Viewed (0) -
cmd/admin-heal-ops.go
currentStatus healSequenceStatus // channel signaled by background routine when traversal has // completed traverseAndHealDoneCh chan error // canceler to cancel heal sequence. cancelCtx context.CancelFunc // the last result index sent to client lastSentResultIndex int64 // Number of total items scanned against item type
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
resultBuf.append(e.getMessage()).append("\n"); } finally { if (timeoutTask != null && !timeoutTask.isCanceled()) { timeoutTask.cancel(); } } return resultBuf.toString(); } /** * Executes the Python script with the configured parameters.
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 8.2K bytes - Viewed (0)