activo - Code Search

.github/workflows/labeler.yml

jobs:
  labeler:
    permissions:
      contents: read
      pull-requests: write
    runs-on: ubuntu-latest
    steps:
    - uses: actions/labeler@v6
      if: ${{ github.event.action != 'labeled' && github.event.action != 'unlabeled' }}
    - run: echo "Done adding labels"
  # Run this after labeler applied labels
  check-labels:
    needs:
      - labeler
    permissions:
      pull-requests: read

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Tue Sep 09 09:11:44 GMT 2025

- 828 bytes

- Click Count (1)

github.com/codelibs/fess-crawler

fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.bulk.BulkResponse;
import org.opensearch.action.delete.DeleteResponse;
import org.opensearch.action.get.GetResponse;
import org.opensearch.action.index.IndexResponse;
import org.opensearch.action.search.SearchRequestBuilder;
import org.opensearch.action.search.SearchResponse;
import org.opensearch.action.support.WriteRequest.RefreshPolicy;

Created: Sat Dec 20 11:21:39 GMT 2025

- Last Modified: Thu Nov 20 08:40:57 GMT 2025

- 34.3K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/Streams.java

                min(splitrA.estimateSize(), splitrB.estimateSize()), characteristics) {
              @Override
              public boolean tryAdvance(Consumer<? super R> action) {
                if (itrA.hasNext() && itrB.hasNext()) {
                  action.accept(function.apply(itrA.next(), itrB.next()));
                  return true;
                }
                return false;
              }
            },

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Sat Aug 09 01:14:59 GMT 2025

- 36.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/Smb2EchoResponse.java

import jcifs.Configuration;
import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Echo response message.
 *
 * This response confirms that the server is still active
 * and the connection is working properly.
 *
 * @author mbechler
 */
public class Smb2EchoResponse extends ServerMessageBlock2Response {

    /**
     * Constructs an SMB2 echo response

Created: Sat Dec 20 13:44:44 GMT 2025

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

- 2.1K bytes

- Click Count (0)

github.com/minio/minio

cmd/metrics-v3-ilm.go

)

var (
	ilmExpiryPendingTasksMD             = NewGaugeMD(expiryPendingTasks, "Number of pending ILM expiry tasks in the queue")
	ilmTransitionActiveTasksMD          = NewGaugeMD(transitionActiveTasks, "Number of active ILM transition tasks")
	ilmTransitionPendingTasksMD         = NewGaugeMD(transitionPendingTasks, "Number of pending ILM transition tasks in the queue")

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Thu Jun 06 09:36:25 GMT 2024

- 2.3K bytes

- Click Count (0)

github.com/minio/minio

docs/throttle/README.md

MinIO server allows to throttle incoming requests:

- limit the number of active requests allowed across the cluster
- limit the wait duration for each request in the queue

These values are enabled using server's configuration or environment variables.

## Examples

### Configuring connection limit

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 16 08:43:49 GMT 2024

- 1.5K bytes

- Click Count (1)

github.com/tiangolo/fastapi

docs_src/request_files/tutorial002_py39.py

    return {"filenames": [file.filename for file in files]}


@app.get("/")
async def main():
    content = """
<body>
<form action="/files/" enctype="multipart/form-data" method="post">
<input name="files" type="file" multiple>
<input type="submit">
</form>
<form action="/uploadfiles/" enctype="multipart/form-data" method="post">
<input name="files" type="file" multiple>
<input type="submit">
</form>
</body>

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Fri May 13 23:38:22 GMT 2022

- 786 bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbTreeHandleInternal.java

     * @throws CIFSException if an error occurs retrieving the buffer size
     */
    int getMaximumBufferSize() throws CIFSException;

    /**
     * Checks if SMB message signing is active for this session
     * @return whether the session uses SMB signing
     * @throws CIFSException if a general CIFS error occurs
     * @throws SmbException if an SMB-specific error occurs
     */

Created: Sat Dec 20 13:44:44 GMT 2025

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

- 3K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/model/PropertyMetaData.java

            return overriddenMethod.getOwnerClass().findDeclaredProperty(name);
        }

        return null;
    }

    @Override
    public void visitTypes(Action<TypeMetaData> action) {
        action.execute(type);
    }

Created: Wed Dec 31 11:36:14 GMT 2025

- Last Modified: Wed Dec 09 08:14:05 GMT 2020

- 3K bytes

- Click Count (0)

github.com/codelibs/fess-crawler

fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

import org.mockito.Mockito;
import org.opensearch.action.admin.cluster.health.ClusterHealthResponse;
import org.opensearch.action.bulk.BulkRequestBuilder;
import org.opensearch.action.bulk.BulkResponse;
import org.opensearch.action.delete.DeleteRequestBuilder;
import org.opensearch.action.search.ClearScrollRequestBuilder;
import org.opensearch.action.search.ClearScrollResponse;
import org.opensearch.action.search.SearchRequestBuilder;

Created: Sat Dec 20 11:21:39 GMT 2025

- Last Modified: Thu Nov 20 08:44:44 GMT 2025

- 17K bytes

- Click Count (0)

Search Options