Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 320 for acancel (0.04 sec)

  1. 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.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

                if (accessTimeoutTarget != null) {
                    accessTimeoutTarget.stop();
                    if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) {
                        accessTimeoutTask.cancel();
                    }
                }
            }
        }
    
        /**
         * Gets response data for the given URI.
         *
         * @param uri the URI to get response data for
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  3. 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]
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    )
    
    func (p *poolMeta) Decommission(idx int, pi poolSpaceInfo) error {
    	// Return an error when there is decommission on going - the user needs
    	// to explicitly cancel it first in order to restart decommissioning again.
    	if p.Pools[idx].Decommission != nil &&
    		!p.Pools[idx].Decommission.Complete &&
    		!p.Pools[idx].Decommission.Failed &&
    		!p.Pools[idx].Decommission.Canceled {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 42.2K bytes
    - Viewed (1)
  5. src/main/java/org/codelibs/fess/exec/Crawler.java

                    commandThread.interrupt();
                }
                if (systemMonitorTask != null) {
                    systemMonitorTask.cancel();
                }
                if (hotThreadMonitorTask != null) {
                    hotThreadMonitorTask.cancel();
                }
                destroyContainer();
            }
    
            if (exitCode != Constants.EXIT_OK) {
                System.exit(exitCode);
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  6. cmd/admin-router.go

    			adminRouter.Methods(http.MethodPost).Path(adminVersion+"/pools/cancel").HandlerFunc(adminMiddleware(adminAPI.CancelDecommission, traceAllFlag)).Queries("pool", "{pool:.*}")
    
    			// Rebalance operations
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/collect/QueuesTest.java

          assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L);
    
          // If even the first one wasn't there, clean up so that the next test doesn't see an element.
          producerThread.cancel(true);
          producer.doneProducing.await();
          if (drained == 0) {
            q.poll(); // not necessarily there if producer was interrupted
          }
        }
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  8. docs/es/docs/how-to/custom-request-and-route.md

    Todo lo que necesitamos hacer es manejar el request dentro de un bloque `try`/`except`:
    
    {* ../../docs_src/custom_request_and_route/tutorial002_an_py310.py hl[14,16] *}
    
    Si ocurre una excepción, la `Request instance` aún estará en el alcance, así que podemos leer y hacer uso del request body cuando manejamos el error:
    
    {* ../../docs_src/custom_request_and_route/tutorial002_an_py310.py hl[17:19] *}
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 5K bytes
    - Viewed (0)
  9. docs/es/llm-prompt.md

    * media type: media type (do not translate to "tipo de medio")
    * instantiate: crear un instance (do not translate to "instanciar")
    * OAuth2 Scopes: Scopes de OAuth2 (do not translate to "Alcances de OAuth2")
    * on the fly: sobre la marcha (do not translate to "al vuelo")
    * terminal: terminal (femenine, as in "la terminal")
    * terminals: terminales (plural femenine, as in "las terminales")
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  10. CHANGELOG.md

        intend to ship a public API for these features, but we don't want to hold OkHttp 5.0.0 until
        those APIs are stable.
    
     *  Fix: Change `MockWebServer.close()` to cancel ongoing calls that are blocked on a delay.
    
     *  Upgrade: [Okio 3.13.0][okio_3_13_0].
    
    This release also stabilizes many APIs in the `mockwebserver3` artifact that's new in 5.0.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
Back to top