There - Code Search

src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHookTest.java

        // during the process, though we can't directly test the lock state

        // When
        try {
            curtainBeforeHook.processDBFluteSystem();

            // Then - if we get here without exception, the unlock/lock worked
            DfFinalTimeZoneProvider provider = getDBFluteSystemTimeZoneProvider();
            // Provider might be null due to reflection limitations, which is ok

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Tue Aug 19 14:09:36 UTC 2025

- 8.1K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

  public void testTimeoutOnGetWorksCorrectly() throws InterruptedException, ExecutionException {

    // The task thread waits for the latch, so we expect a timeout here.
    try {
      future.get(20, MILLISECONDS);
      fail("Should have timed out trying to get the value.");
    } catch (TimeoutException expected) {
    } finally {
      latch.countDown();
    }
  }

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Fri Jul 11 18:52:30 UTC 2025

- 6.1K bytes

- Viewed (0)

github.com/apache/maven

compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/DefaultArtifactRepository.java

        return sb.toString();
    }

    @Override
    public Artifact find(Artifact artifact) {
        File artifactFile = new File(getBasedir(), pathOf(artifact));

        // We need to set the file here or the resolver will fail with an NPE, not fully equipped to deal
        // with multiple local repository implementations yet.
        artifact.setFile(artifactFile);

        if (artifactFile.exists()) {

Registered: Sun Sep 07 03:35:12 UTC 2025

- Last Modified: Fri Jun 06 14:28:57 UTC 2025

- 7.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/warm-backend-s3.go

		if err := gopts.SetRange(opts.startOffset, opts.startOffset+opts.length-1); err != nil {
			return nil, s3.ToObjectError(err, object)
		}
	}
	c := &minio.Core{Client: s3.client}
	// Important to use core primitives here to pass range get options as is.
	r, _, _, err := c.GetObject(ctx, s3.Bucket, s3.getDest(object), gopts)
	if err != nil {
		return nil, s3.ToObjectError(err, object)
	}
	return r, nil
}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Sun Jun 08 16:13:30 UTC 2025

- 5.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

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

    public int hashCode() {
        int result = name.hashCode();
        result += 65599 * hexCode;
        result += 65599 * srcHashCode; /* hashCode is different depending
                                        * on where it came from
                                        */
        if (scope != null && scope.length() != 0) {
            result += scope.hashCode();
        }
        return result;
    }

    @Override

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 7.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/netbios/Name.java

        result += 65599 * this.hexCode;
        result += 65599 * this.srcHashCode; /*
                                             * hashCode is different depending
                                             * on where it came from
                                             */
        if (this.scope != null && this.scope.length() != 0) {
            result += this.scope.hashCode();
        }
        return result;
    }

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 8K bytes

- Viewed (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);
        assertTrue(result.isEmpty());

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jul 12 05:35:01 UTC 2025

- 22.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/hash/Murmur3Hash32Test.java

  }

  private boolean allBmp(String string) {
    // Ordinarily we'd use something like i += Character.charCount(string.codePointAt(i)) here. But
    // we can get away with i++ because the whole point of this method is to return false if we find
    // a code point that doesn't fit in a char.
    for (int i = 0; i < string.length(); i++) {

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Thu Dec 19 18:03:30 UTC 2024

- 8.4K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/hash/Fingerprint2011.java

 * to unsigned arithmetic in all cases except:
 *
 * <ul>
 *   <li>comparisons (signed values can be negative)
 *   <li>division (avoided here)
 *   <li>shifting (right shift must be unsigned)
 * </ul>
 *
 * @author ******@****.*** (Kyle Maddison)
 * @author ******@****.*** (Geoff Pike)
 */

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Mon Aug 11 19:31:30 UTC 2025

- 6.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-coding.go

	lastBlockSize := totalLength % e.blockSize
	lastShardSize := ceilFrac(lastBlockSize, int64(e.dataBlocks))
	return numShards*e.ShardSize() + lastShardSize
}

// ShardFileOffset - returns the effective offset where erasure reading begins.
func (e *Erasure) ShardFileOffset(startOffset, length, totalLength int64) int64 {
	shardSize := e.ShardSize()
	shardFileSize := e.ShardFileSize(totalLength)

Registered: Sun Sep 07 19:28:11 UTC 2025

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

- 8.5K bytes

- Viewed (0)

Search Options