Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 320 for acancel (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top