Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 320 for acancel (0.07 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java

            } finally {
                if (accessTimeout != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
            return data;
        }
    
        public void setUrl(final String url) {
            this.url = url;
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. cmd/metacache-walk.go

    	_, err := opts.UnmarshalMsg(payload)
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    
    	if !s.checkID(opts.DiskID) {
    		return grid.NewRemoteErr(errDiskNotFound)
    	}
    
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    	return grid.NewRemoteErr(s.getStorage().WalkDir(ctx, opts, grid.WriterToChannel(ctx, out)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

            } finally {
                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (!accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        protected ResponseData getResponseData(final String uri, final boolean includeContent) {
            final ResponseData responseData = new ResponseData();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        Object unused =
            new Object() {
              @SuppressWarnings({"removal", "Finalize"}) // b/260137033
              @Override
              protected void finalize() {
                future.cancel(false);
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  5. src/main/webapp/js/admin/plugins/daterangepicker/daterangepicker.js

            this.locale = {
                direction: 'ltr',
                format: moment.localeData().longDateFormat('L'),
                separator: ' - ',
                applyLabel: 'Apply',
                cancelLabel: 'Cancel',
                weekLabel: 'W',
                customRangeLabel: 'Custom Range',
                daysOfWeek: moment.weekdaysMin(),
                monthNames: moment.monthsShort(),
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 64.8K bytes
    - Viewed (0)
  6. istioctl/pkg/precheck/precheck.go

    		resource.Namespace(ctx.Namespace()),
    		resource.Namespace(ctx.IstioNamespace()),
    		nil,
    	)
    	if err != nil {
    		return nil, err
    	}
    	sa.AddRunningKubeSource(cli)
    	cancel := make(chan struct{})
    	result, err := sa.Analyze(cancel)
    	if err != nil {
    		return nil, err
    	}
    	if result.Messages != nil {
    		msgs = append(msgs, result.Messages...)
    	}
    
    	return msgs, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 02:31:32 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  7. docs/fr/docs/advanced/path-operation-advanced-configuration.md

    # Configuration avancée des paramètres de chemin
    
    ## ID d'opération OpenAPI
    
    /// warning | "Attention"
    
    Si vous n'êtes pas un "expert" en OpenAPI, vous n'en avez probablement pas besoin.
    
    ///
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  9. cmd/utils.go

    		CurvePreferences: fips.TLSCurveIDs(),
    		TCPOptions:       globalTCPOptions,
    		EnableHTTP2:      false,
    	}
    
    	if clientCert != "" && clientKey != "" {
    		ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    		defer cancel()
    		transport, err := s.NewHTTPTransportWithClientCerts(ctx, clientCert, clientKey)
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	var results []dataUsageCache
    	var firstErr error
    
    	allBuckets, err := z.ListBuckets(ctx, BucketOptions{})
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top