_manager - Code Search

src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

     * Performs the actual crawling operation for the provided data configurations.
     * This method manages the creation and execution of crawler threads,
     * monitors their progress, and handles cleanup operations.
     *
     * <p>The method:</p>
     * <ul>
     *   <li>Creates crawler threads for each data configuration</li>
     *   <li>Manages concurrent execution based on thread count limits</li>

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

- Last Modified: Fri Nov 28 16:29:12 GMT 2025

- 19K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

    private final ChannelManager manager;
    private final ExecutorService executor;
    private final ConcurrentMap<String, FailoverState> failoverStates;

    /**
     * Create channel failover handler
     *
     * @param manager channel manager
     */
    public ChannelFailover(ChannelManager manager) {
        this.manager = manager;
        this.executor = Executors.newCachedThreadPool(r -> {

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

- Last Modified: Thu Aug 21 11:13:46 GMT 2025

- 11.6K bytes

- Click Count (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.23.md

v1.23.17](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager) | [amd64](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager-amd64), [arm](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager-arm), [arm64](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager-arm64), [ppc64le](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-co...

Created: Fri Apr 03 09:05:14 GMT 2026

- Last Modified: Tue Feb 28 21:06:52 GMT 2023

- 424.5K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-compat/src/test/resources/org/apache/maven/artifact/manager/DefaultWagonManagerTest.xml

      <role>org.apache.maven.wagon.Wagon</role>
      <role-hint>a</role-hint>
      <implementation>org.apache.maven.artifact.manager.WagonA</implementation>
    </component>
    <component>
      <role>org.apache.maven.wagon.Wagon</role>
      <role-hint>b1</role-hint>
      <implementation>org.apache.maven.artifact.manager.WagonB</implementation>
    </component>
    <component>
      <role>org.apache.maven.wagon.Wagon</role>

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Fri Oct 25 12:31:46 GMT 2024

- 1.7K bytes

- Click Count (0)

github.com/codelibs/fess

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

            public String getQueryBrowserLangParameterName() {
                return "lang";
            }
        };
        ComponentUtil.setFessConfig(mockConfig);

        // Setup mock request manager
        RequestManager mockRequestManager = createMockRequestManager("en_US");

        // Execute
        OptionalThing<Locale> result = provider.findBusinessLocale(null, mockRequestManager);

        // Verify

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

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

- 11.1K bytes

- Click Count (0)

github.com/go-gorm/gorm

tests/update_test.go

	result.Company = user2.Company
	result.Manager = user2.Manager
	result.Team = user2.Team
	result.Languages = user2.Languages
	result.Friends = user2.Friends

	DB.Select("Name", "Account", "Toys", "Manager", "ManagerID", "Languages").Save(&result)

	var result2 User

Created: Sun Apr 05 09:35:12 GMT 2026

- Last Modified: Mon Jul 21 02:46:58 GMT 2025

- 30.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/Kerb5Context.java

        GSSManager manager = GSSManager.getInstance();
        GSSCredential clientCreds = null;
        Oid mechOid = JGSS_KRB5_MECH_OID;
        if (realm != null) {
            this.serviceName = manager.createName(service + "/" + host + "@" + realm, JGSS_KRB5_NAME_OID, mechOid);
        } else {
            this.serviceName = manager.createName(service + "@" + host, GSSName.NT_HOSTBASED_SERVICE, mechOid);

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

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

- 13.5K bytes

- Click Count (1)

github.com/go-gorm/gorm

prepare_stmt.go

//
// Returns:
// - A pointer to a PreparedStmtDB instance, which manages prepared statements using the provided connection pool and configuration.
func NewPreparedStmtDB(connPool ConnPool, maxSize int, ttl time.Duration) *PreparedStmtDB {
	return &PreparedStmtDB{
		ConnPool: connPool,                     // Assigns the provided connection pool to manage database connections.

Created: Sun Apr 05 09:35:12 GMT 2026

- Last Modified: Fri Apr 25 08:22:26 GMT 2025

- 5.7K bytes

- Click Count (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.27.md

27.11](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager) | [amd64](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager-amd64), [arm64](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager-arm64), [ppc64le](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube-controller-manager-ppc64le), [s390x](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/kube...

Created: Fri Apr 03 09:05:14 GMT 2026

- Last Modified: Wed Jul 17 07:48:22 GMT 2024

- 466.3K bytes

- Click Count (2)

github.com/codelibs/jcifs

docs/smb3-features/03-multi-channel-design.md

    }
    
    public ChannelLoadBalancer(ChannelManager manager) {
        this.manager = manager;
        this.strategy = LoadBalancingStrategy.ADAPTIVE;
    }
    
    public ChannelInfo selectChannel(SMBMessage message) {
        Collection<ChannelInfo> availableChannels = manager.getHealthyChannels();
        
        if (availableChannels.isEmpty()) {

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

- Last Modified: Sat Aug 16 02:53:50 GMT 2025

- 39.6K bytes

- Click Count (0)

Search Options