Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 183 for unlocked (0.12 sec)

  1. cmd/test-utils_test.go

    	globalObjLayerMutex.Lock()
    	globalObjectAPI = nil
    	globalObjLayerMutex.Unlock()
    }
    
    // reset the value of the Global server config.
    // set it to `nil`.
    func resetGlobalConfig() {
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    	globalServerConfigMu.Unlock()
    }
    
    func resetGlobalEndpoints() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    }
    
    func (es *expiryState) ResizeWorkers(n int) {
    	if n == 0 {
    		n = 100
    	}
    
    	// Lock to avoid multiple resizes to happen at the same time.
    	es.mu.Lock()
    	defer es.mu.Unlock()
    	var workers []chan expiryOp
    	if v := es.workers.Load(); v != nil {
    		// Copy to new array.
    		workers = append(workers, *v...)
    	}
    
    	if n == len(workers) || n < 1 {
    		return
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  3. cmd/api-router.go

    	globalObjLayerMutex.Lock()
    	globalHTTPServer = h
    	globalObjLayerMutex.Unlock()
    }
    
    func newConsoleServerFn() *consoleapi.Server {
    	globalObjLayerMutex.RLock()
    	defer globalObjLayerMutex.RUnlock()
    	return globalConsoleSrv
    }
    
    func setConsoleSrv(srv *consoleapi.Server) {
    	globalObjLayerMutex.Lock()
    	globalConsoleSrv = srv
    	globalObjLayerMutex.Unlock()
    }
    
    func newObjectLayerFn() ObjectLayer {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 23.3K bytes
    - Viewed (0)
  4. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

                    // Expected
                }
            }
    
            assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should be OPEN");
    
            // Try to execute - should be blocked with CIFSException
            CIFSException exception = assertThrows(CIFSException.class, () -> {
                circuitBreaker.executeWithCircuitBreaker(() -> "should not execute");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.2K bytes
    - Viewed (0)
  5. cmd/metrics-v3-types.go

    		ch <- metric
    	}
    }
    
    // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns
    // a function to unlock the buckets.
    func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() {
    	mg.bucketsLock.Lock()
    	mg.buckets = buckets
    	return func() {
    		mg.bucketsLock.Unlock()
    	}
    }
    
    // MetricFQN - returns the fully qualified name for the given metric name.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Feb 28 19:33:08 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  6. cmd/data-scanner.go

    			if serverDebugLog {
    				if obj.VersionID != "" {
    					console.Debugf(applyActionsLogPrefix+" lifecycle: %s v(%s) is locked, not deleting\n", obj.Name, obj.VersionID)
    				} else {
    					console.Debugf(applyActionsLogPrefix+" lifecycle: %s is locked, not deleting\n", obj.Name)
    				}
    			}
    			return lifecycle.Event{Action: lifecycle.NoneAction}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  7. src/main/java/jcifs/util/SmbCircuitBreaker.java

     * Prevents cascading failures by temporarily blocking requests to a failing service.
     *
     * The circuit breaker has three states:
     * - CLOSED: Normal operation, requests pass through
     * - OPEN: Service is failing, requests are blocked
     * - HALF_OPEN: Testing if service has recovered
     */
    public class SmbCircuitBreaker {
    
        private static final Logger log = LoggerFactory.getLogger(SmbCircuitBreaker.class);
    
        /**
         * Circuit breaker states
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java

            @Override
            public boolean isBlocked() {
                return false;
            }
    
            @Override
            public void setBlocked(boolean blocked) {}
        }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  9. src/packaging/deb/init.d/fess

    # Heap new generation
    #FESS_HEAP_NEWSIZE=
    
    # max direct memory
    #FESS_DIRECT_SIZE=
    
    # Additional Java OPTS
    #FESS_JAVA_OPTS=
    
    # Maximum number of open files
    MAX_OPEN_FILES=65535
    
    # Maximum amount of locked memory
    #MAX_LOCKED_MEMORY=
    
    # Fess log directory
    LOG_DIR=${packaging.fess.log.dir}
    
    # Fess data directory
    DATA_DIR=${packaging.fess.var.dir}
    
    # Fess configuration directory
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  10. docs/bucket/lifecycle/DESIGN.md

              "X-Amz-Restore-Request-Date": "Mon, 22 Feb 2021 21:10:09 GMT",
              "x-amz-restore": "ongoing-request=false, expiry-date=Sat, 27 Feb 2021 00:00:00 GMT",
    ...
    ```
    
    ### Encrypted/Object locked objects
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 4.2K bytes
    - Viewed (0)
Back to top