Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 254 for Oancea (0.15 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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);
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Thu Aug 07 02:55:08 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  2. 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: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  3. internal/grid/README.md

            return nil
        })
    ```
    
    Context cancellation and timeouts are propagated to the handler.
    The client does not wait for the remote handler to finish before returning.
    Returning any error will also cancel the stream remotely.
    
    CAREFUL: When utilizing two-way communication, it is important to ensure that the remote handler is not blocked on a send.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  4. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 24.1K bytes
    - Click Count (0)
  5. 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
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Nov 23 12:19:14 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  6. 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
          }
        }
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Nov 04 17:24:58 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  7. 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);
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 31.4K bytes
    - Click Count (0)
  8. cmd/admin-router.go

    			adminRouter.Methods(http.MethodPost).Path(adminVersion+"/pools/cancel").HandlerFunc(adminMiddleware(adminAPI.CancelDecommission, traceAllFlag)).Queries("pool", "{pool:.*}")
    
    			// Rebalance operations
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  9. docs/fr/docs/index.md

    </details>
    
    ### Lancez
    
    Lancez le serveur avec :
    
    <div class="termy">
    
    ```console
    $ uvicorn main:app --reload
    
    INFO:     Uvicorn running on http://127.0.0.1:8000 (Press CTRL+C to quit)
    INFO:     Started reloader process [28720]
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 22K bytes
    - Click Count (0)
  10. src/test/java/jcifs/internal/smb2/ServerMessageBlock2RequestTest.java

                testRequest.setOverrideTimeout(5000);
                testRequest.setOverrideTimeout(null);
                assertNull(testRequest.getOverrideTimeout());
            }
        }
    
        @Nested
        @DisplayName("Cancel Request Tests")
        class CancelRequestTests {
    
            @Test
            @DisplayName("createCancel should return Smb2CancelRequest with same mid and asyncId")
            void testCreateCancel() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.7K bytes
    - Click Count (0)
Back to Top