matched - Code Search

android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                && queue.removeLastOccurrence(submittedTask);
        // If the delegate is directExecutor(), the submitted runnable could have thrown a REE. But
        // that's handled by the log check that catches RuntimeExceptions in the queue worker.
        if (!(t instanceof RejectedExecutionException) || removed) {
          throw t;
        }
      }
      return;
    }

    /*

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 10.6K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

import assertk.assertThat
import assertk.assertions.isEqualTo
import assertk.assertions.isLessThan
import assertk.assertions.isLessThanOrEqualTo
import assertk.assertions.isSameInstanceAs
import assertk.assertions.matches
import java.net.UnknownHostException
import mockwebserver3.MockResponse
import mockwebserver3.MockWebServer
import mockwebserver3.junit5.StartStop
import okhttp3.HttpUrl
import okhttp3.Interceptor

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Fri Nov 07 02:57:33 GMT 2025

- 39.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/erasure-metadata-utils.go

			continue
		}
		if !meta.IsValid() {
			inconsistent++
			continue
		}
		if meta.XLV1 != fi.XLV1 {
			inconsistent++
			continue
		}
		// check if erasure distribution order matches the index
		// position if this is not correct we discard the disk
		// and move to collect others
		if distribution[i] != meta.Erasure.Index {
			inconsistent++ // keep track of inconsistent entries
			continue
		}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 11.7K bytes

- Click Count (0)

github.com/elastic/elasticsearch

build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/TestingConventionsTasks.java

        if (naming.stream().map(TestingConventionRule::getSuffix).anyMatch(suffix -> className.endsWith(suffix))) {
            getLogger().debug("{} is a test because it matches the naming convention", className);
            return true;
        }
        return false;
    }

    private boolean matchesTestMethodNamingConvention(Method method) {

Created: Wed Apr 08 16:19:15 GMT 2026

- Last Modified: Tue Jun 01 09:19:30 GMT 2021

- 17.6K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/job/CrawlJobTest.java

        String result = crawlJob.execute();

        assertNotNull(crawlJob.sessionId);
        // Check format: yyyyMMddHHmmss
        assertEquals(14, crawlJob.sessionId.length());
        assertTrue(crawlJob.sessionId.matches("\\d{14}"));
        assertTrue(result.contains("Session Id: " + crawlJob.sessionId));
    }

    // Test with negative max crawler processes
    @Test
    public void test_execute_negativeMaxProcesses() {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 25K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/helper/PluginHelperTest.java

        PluginHelper testHelper = new PluginHelper() {
            @Override
            protected String getRepositoryContent(String url) {
                return "<html><body>No plugin matches here</body></html>";
            }
        };

        List<Artifact> result = testHelper.processRepository(ArtifactType.DATA_STORE, "test-repo/");
        assertNotNull(result);

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 22.6K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

        .build()
    val call2 = client2.newCall(request)
    val response = call2.execute()
    assert200Http2Response(response, "san.com")
  }

  /** If the existing connection matches a SAN but not a match for DNS then skip.  */
  @Test
  fun skipsWhenDnsDontMatch() {
    server.enqueue(MockResponse())
    assert200Http2Response(execute(url), server.hostName)

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Thu Jun 19 11:44:16 GMT 2025

- 19.1K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/fscc/FileBothDirectoryInfoTest.java

        // Decode and check return value
        int bytesConsumed = fileBothDirectoryInfo.decode(buffer, 0, buffer.length);

        // Verify bytes consumed matches the actual data size
        assertTrue(bytesConsumed < 0); // Return value is negative (start - bufferIndex)
        assertEquals(-94 - filename.length() * 2, bytesConsumed); // Base structure + filename length
    }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 20.9K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                 * be cached and cause other types to fail even though they may
                 * not be the authority for the name. For example, if a WINS lookup
                 * for FOO fails and caches unknownAddress for FOO, a subsequent
                 * lookup for FOO using BCAST should not fail because of that
                 * name cached from WINS.
                 *

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 07:14:38 GMT 2025

- 17.6K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/base/Throwables.java

   */
  public static Throwable getRootCause(Throwable throwable) {
    // Keep a second pointer that slowly walks the causal chain. If the fast pointer ever catches
    // the slower pointer, then there's a loop.
    Throwable slowPointer = throwable;
    boolean advanceSlowPointer = false;

    Throwable cause;
    while ((cause = throwable.getCause()) != null) {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 20.6K bytes

- Click Count (0)

Search Options