Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1271 - 1280 of 2,682 for latch (0.03 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

                task = withLock {
                  afterRun(task, delayNanos, true)
                  awaitTaskToRun()
                } ?: return
              }
            } catch (thrown: Throwable) {
              // A task failed. Update execution state and re-throw the exception.
              withLock {
                afterRun(task, -1L, false)
              }
              if (thrown is InterruptedException) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Aug 30 11:30:11 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  2. internal/bucket/replication/replication.go

    			// incoming prefix must be in rule prefix
    			if !recursive && !strings.HasPrefix(prefix, rule.Filter.Prefix) {
    				continue
    			}
    			// If recursive, we can skip this rule if it doesn't match the tested prefix or level below prefix
    			// does not match
    			if recursive && !strings.HasPrefix(rule.Prefix(), prefix) && !strings.HasPrefix(prefix, rule.Prefix()) {
    				continue
    			}
    		}
    		return true
    	}
    	return false
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  3. ci/devinfra/docker/windows/Dockerfile

    # This Dockerfile creates an image that has:
    # - the correct MTU setting for networking from inside the container to work.
    # - Visual Studio 2022 Build Tools
    # - MSVC 14.39
    # - LLVM/Clang 18.1.4
    # - MSYS2 + curl, git, patch, vim, unzip, zip
    # - Python 3.12.3
    # - Bazelisk 1.19.0
    # - JDK 21 (Azul Zulu)
    
    FROM mcr.microsoft.com/windows/servercore:ltsc2019
    
    SHELL ["powershell.exe", "-ExecutionPolicy", "Bypass", "-Command", \
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Fri Jan 17 16:35:57 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  4. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/precommit/LicenseHeadersTask.java

                Files.deleteIfExists(reportFile.toPath());
                BufferedWriter bufferedWriter = new BufferedWriter(new FileWriter(xmlReportFile));
                return toXmlReportFile(config, bufferedWriter);
            } catch (IOException | RatException exception) {
                throw new GradleException("Cannot generate license header report for " + getPath(), exception);
            }
        }
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Sep 09 18:53:35 GMT 2021
    - 10.6K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/suggest/converter/AnalyzerConverterTest.java

            String text = null;
            String field = "content";
    
            try {
                List<String> results = converter.convert(text, field, "en");
                assertNotNull(results);
            } catch (Exception e) {
                // Expected behavior - null text might cause exception
                assertNotNull(e);
            }
        }
    
        @Test
        public void testConvertWithWhitespaceText() throws IOException {
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Mon Sep 01 13:33:03 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/job/AggregateLogJob.java

            final SearchLogHelper searchLogHelper = ComponentUtil.getSearchLogHelper();
    
            final StringBuilder resultBuf = new StringBuilder();
    
            try {
                searchLogHelper.storeSearchLog();
            } catch (final Exception e) {
                logger.error("Failed to store a search log.", e);
                resultBuf.append(e.getMessage()).append("\n");
            }
    
            return resultBuf.toString();
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  7. android/guava-testlib/src/com/google/common/testing/SloppyTearDown.java

      private static final Logger logger = Logger.getLogger(SloppyTearDown.class.getName());
    
      @Override
      public final void tearDown() {
        try {
          sloppyTearDown();
        } catch (Throwable t) {
          logger.log(Level.INFO, "exception thrown during tearDown: " + t.getMessage(), t);
        }
      }
    
      public abstract void sloppyTearDown() throws Exception;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 14:50:24 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/toolchain/ToolchainPrivate.java

         * in the toolchain plugin configuration.
         * @param requirements Map&lt;String, String&gt; key value pair, may not be {@code null}
         * @return {@code true} if the requirements match, otherwise {@code false}
         */
        boolean matchesRequirements(Map<String, String> requirements);
    
        /**
         *
         * @return the original model wrapped by this interface
         */
        ToolchainModel getModel();
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Feb 12 13:13:28 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/ShellCommandRegistryHolder.java

            for (CommandRegistry commandRegistry : commandRegistries) {
                if (commandRegistry instanceof AutoCloseable closeable) {
                    try {
                        closeable.close();
                    } catch (Exception e) {
                        exceptions.add(e);
                    }
                }
            }
            if (!exceptions.isEmpty()) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Dec 17 09:50:45 GMT 2024
    - 2.2K bytes
    - Click Count (0)
  10. build-logic/build-update-utils/src/test/groovy/gradlebuild/buildutils/tasks/PreparePatchReleaseTest.groovy

     * limitations under the License.
     */
    
    package gradlebuild.buildutils.tasks
    
    import spock.lang.Specification
    
    class PreparePatchReleaseTest extends Specification {
    
        def "patch version is correctly bumped"() {
            expect:
            ReleasedVersionsHelperKt.bumpPatchVersion(input) == expected
    
            where:
            input   | expected
            "9.4.0" | "9.4.1"
            "9.4.1" | "9.4.2"
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 23 14:47:12 GMT 2026
    - 1.3K bytes
    - Click Count (0)
Back to Top