Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 400 for acancel (0.56 seconds)

  1. cmd/admin-router.go

    			adminRouter.Methods(http.MethodPost).Path(adminVersion+"/pools/cancel").HandlerFunc(adminMiddleware(adminAPI.CancelDecommission, traceAllFlag)).Queries("pool", "{pool:.*}")
    
    			// Rebalance operations
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  2. 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.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  3. 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()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  4. 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.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  5. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        Object unused =
            new Object() {
              @SuppressWarnings({"removal", "Finalize"}) // b/487687332
              @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());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                resultBuf.append(e.getMessage()).append("\n");
            } finally {
                if (timeoutTask != null && !timeoutTask.isCanceled()) {
                    timeoutTask.cancel();
                }
            }
    
            return resultBuf.toString();
    
        }
    
        /**
         * Executes the thumbnail generator process.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        }
      }
    
      private static final class RuntimeExceptionThrowingFuture<V> implements Future<V> {
        final CountDownLatch allowGetToComplete = new CountDownLatch(1);
    
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          throw new AssertionFailedError();
        }
    
        @Override
        public V get() throws InterruptedException {
          /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/helper/LogNotificationHelperTest.java

        public void test_init_and_destroy() {
            LogNotificationHelper helper = new LogNotificationHelper();
            // init() registers a TimeoutTarget with TimeoutManager
            helper.init();
            // destroy() cancels the task and flushes; should not throw
            helper.destroy();
        }
    
        @Test
        public void test_destroy_beforeInit() {
            LogNotificationHelper helper = new LogNotificationHelper();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  9. docs/fr/docs/deployment/versions.md

    # À propos des versions de FastAPI { #about-fastapi-versions }
    
    **FastAPI** est déjà utilisé en production dans de nombreuses applications et de nombreux systèmes. Et la couverture de tests est maintenue à 100 %. Mais son développement avance toujours rapidement.
    
    De nouvelles fonctionnalités sont ajoutées fréquemment, des bogues sont corrigés régulièrement et le code s'améliore continuellement.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 4.2K bytes
    - Click Count (0)
  10. cmd/object-api-utils_test.go

    	// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    	// Call the ServeHTTP to execute the handler.
    	apiRouter.ServeHTTP(rec, req)
    
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    	// Now check if we actually wrote to backend (regardless of the response
    	// returned by the server).
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 24.1K bytes
    - Click Count (0)
Back to Top