handik - Code Search

src/main/java/org/codelibs/fess/score/ScoreBooster.java

                .execute()
                .actionGet(requestTimeout);
        return Arrays.stream(response.getHits().getHits()).map(SearchHit::getId).toArray(n -> new String[n]);
    };

    /**
     * A function to handle requests.
     */
    protected Function<Map<String, Object>, Long> requestHandler = params -> {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final String[] ids = idFinder.apply(params);

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

- Last Modified: Thu Aug 07 03:06:29 UTC 2025

- 6.6K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java

          // or we could avoid inputstreamreader and use the decoder api directly
          // TODO(lukes): in a real implementation we would need to handle overflow conditions
          int maxChars = (int) (size.get().intValue() * cs.newDecoder().maxCharsPerByte());
          char[] buffer = new char[maxChars];
          int bufIndex = 0;
          int remaining = buffer.length;

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

- Last Modified: Tue May 13 18:46:00 UTC 2025

- 5.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/tests/persistent/PersistentHandleManagerTest.java

        MockitoAnnotations.openMocks(this);

        // Create temporary directory for test state
        tempDir = Files.createTempDirectory("jcifs-test-handles");

        // Set system property for handle state directory
        System.setProperty("jcifs.smb.client.handleStateDirectory", tempDir.toString());

        when(mockContext.getConfig()).thenReturn(mockConfig);

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

- Last Modified: Thu Aug 21 04:51:33 UTC 2025

- 6.6K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

 *   <li>Handle timeouts during SMB operations.</li>
 * </ul>
 *
 * <p>
 * The client uses a {@link SmbAuthenticationHolder} to manage SMB authentication credentials.
 * It also integrates with other Fess Crawler components, such as {@link ContentLengthHelper} and
 * {@link MimeTypeHelper}, to handle content length checks and MIME type detection.
 * </p>
 *
 * <p>

Registered: Sun Sep 21 03:50:09 UTC 2025

- Last Modified: Thu Sep 18 09:30:45 UTC 2025

- 23K bytes

- Viewed (0)

github.com/google/guava

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

   * declaredType}. Example usage:
   *
   * <pre>
   * try {
   *   someMethodThatCouldThrowAnything();
   * } catch (IKnowWhatToDoWithThisException e) {
   *   handle(e);
   * } catch (Throwable t) {
   *   Throwables.propagateIfInstanceOf(t, IOException.class);
   *   Throwables.propagateIfInstanceOf(t, SQLException.class);
   *   throw Throwables.propagate(t);
   * }
   * </pre>

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

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

- 20.6K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

ci/official/utilities/generate_index_html.sh

# See the License for the specific language governing permissions and
# limitations under the License.
# ==============================================================================

# Generates a handy index.html with a bunch of Kokoro links for GitHub
# presubmits.
# Usage: generate_index_html.sh /path/to/output/index.html

cat > "$1" <<EOF
<html>
<head>
<title>$(basename "$KOKORO_JOB_NAME")</title>
</head>

Registered: Tue Sep 09 12:39:10 UTC 2025

- Last Modified: Fri Sep 29 20:26:13 UTC 2023

- 2.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/ntlmssp/NtlmFlags.java

    /**
    * Sent by the server to indicate that the server and client are
    * on the same machine.  This implies that the server will include
    * a local security context handle in the Type 2 message, for
    * use in local authentication.
    */
    int NTLMSSP_NEGOTIATE_LOCAL_CALL = 0x00004000;

    /**
    * Indicates that authenticated communication between the client

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

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

- 5.1K bytes

- Viewed (0)

github.com/codelibs/fess

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

                return 1;
            }

            @Override
            public <T> T unwrap(Class<T> type) {
                return null;
            }
        };

        // Should handle exception gracefully and still return result
        assertEquals("1TestUser", sambaHelper.getAccountId(exceptionSID));
    }

    // Helper methods

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

- Last Modified: Sat Jul 19 23:49:30 UTC 2025

- 14.7K bytes

- Viewed (0)

github.com/square/okhttp

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

   * until one is ready. If there are no ready queues, or if other threads have everything under
   * control this will return null. If there is more than a single task ready to execute immediately
   * this will start another thread to handle that work.
   */
  fun awaitTaskToRun(): Task? {
    assertLockHeld()

    while (true) {
      if (readyQueues.isEmpty()) {
        return null // Nothing to do.
      }

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Sat Aug 30 11:30:11 UTC 2025

- 10.4K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/escape/ArrayBasedUnicodeEscaper.java

 * <p>A good example of usage of this class is for HTML escaping where the replacement array
 * contains information about the named HTML entities such as {@code &amp;} and {@code &quot;} while
 * {@link #escapeUnsafe} is overridden to handle general escaping of the form {@code &#NNNNN;}.
 *
 * <p>The size of the data structure used by {@link ArrayBasedUnicodeEscaper} is proportional to the

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

- Last Modified: Thu Feb 13 15:45:16 UTC 2025

- 8.5K bytes

- Viewed (0)

Search Options