- Sort Score
- Num 10 results
- Language All
Results 651 - 660 of 813 for mock (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/test-utils_test.go
} // sets globalObjectAPI to `nil`. func resetGlobalObjectAPI() { 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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 77K bytes - Click Count (0) -
src/main/assemblies/files/fess.in.bat
set FESS_MIN_MEM=%FESS_HEAP_SIZE% set FESS_MAX_MEM=%FESS_HEAP_SIZE% ) REM min and max heap sizes should be set to the same value to avoid REM stop-the-world GC pauses during resize, and so that we can lock the REM heap in memory on startup to prevent any of it from being swapped REM out. set FESS_JAVA_OPTS=%FESS_JAVA_OPTS% -Xms%FESS_MIN_MEM% -Xmx%FESS_MAX_MEM%
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 27 03:48:59 GMT 2025 - 4.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/entity/ChatSession.java
/** The timestamp when the session was last accessed. */ private volatile LocalDateTime lastAccessedAt; /** The list of messages in this session. */ private List<ChatMessage> messages; /** Lock object for thread-safe message operations. */ private final Object messagesLock = new Object(); /** * Default constructor. */ public ChatSession() {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 07 01:53:06 GMT 2026 - 6.7K bytes - Click Count (0) -
src/main/assemblies/files/fess.in.sh
#FESS_JAVA_OPTS="$FESS_JAVA_OPTS -Djavax.net.ssl.trustStorePassword=changeit" # min and max heap sizes should be set to the same value to avoid # stop-the-world GC pauses during resize, and so that we can lock the # heap in memory on startup to prevent any of it from being swapped # out. FESS_JAVA_OPTS="$FESS_JAVA_OPTS -Xms${FESS_MIN_MEM}" FESS_JAVA_OPTS="$FESS_JAVA_OPTS -Xmx${FESS_MAX_MEM}"Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 27 03:48:59 GMT 2025 - 5.3K bytes - Click Count (0) -
cmd/dynamic-timeouts.go
func (dt *dynamicTimeout) logEntry(duration time.Duration) { if duration < 0 { return } entries := int(atomic.AddInt64(&dt.entries, 1)) index := entries - 1 if index < dynamicTimeoutLogSize { dt.mutex.Lock() dt.log[index] = duration // We leak entries while we copy if entries == dynamicTimeoutLogSize { // Make copy on stack in order to call adjust() logCopy := [dynamicTimeoutLogSize]time.Duration{}
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 4.5K bytes - Click Count (0) -
internal/config/subnet/config.go
} os.Setenv("CONSOLE_SUBNET_URL", c.BaseURL) } // Update - in-place update with new license and registration information. func (c *Config) Update(ncfg Config, isDevEnv bool) { configLock.Lock() defer configLock.Unlock() c.License = ncfg.License c.APIKey = ncfg.APIKey c.Proxy = ncfg.Proxy c.transport = ncfg.transport c.BaseURL = baseURL if isDevEnv {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 3.9K bytes - Click Count (0) -
internal/config/storageclass/storage-class.go
Value: "", HiddenIfEmpty: true, }, } ) // StorageClass - holds storage class information type StorageClass struct { Parity int } // ConfigLock is a global lock for storage-class config var ConfigLock sync.RWMutex // Config storage class configuration type Config struct { Standard StorageClass `json:"standard"` RRS StorageClass `json:"rrs"`Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.3K bytes - Click Count (0) -
src/main/java/jcifs/util/transport/Transport.java
protected String name = "Transport" + id++; private volatile Thread thread; private volatile TransportException te; /** * Lock object for synchronizing input operations */ protected final Object inLock = new Object(); /** * Lock object for synchronizing output operations */ protected final Object outLock = new Object(); /**
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 27.8K bytes - Click Count (0) -
internal/config/heal/heal.go
func (opts Config) GetWorkers() int { configMutex.RLock() defer configMutex.RUnlock() return opts.DriveWorkers } // Update updates opts with nopts func (opts *Config) Update(nopts Config) { configMutex.Lock() defer configMutex.Unlock() opts.Bitrot = nopts.Bitrot opts.IOCount = nopts.IOCount opts.Sleep = nopts.Sleep opts.DriveWorkers = nopts.DriveWorkers
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Nov 04 19:06:02 GMT 2024 - 4.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lock/Smb2LeaseBreakNotification.java
* License along with this library; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package jcifs.internal.smb2.lock; import jcifs.Configuration; import jcifs.internal.SMBProtocolDecodingException; import jcifs.internal.smb2.ServerMessageBlock2Response; import jcifs.internal.smb2.lease.Smb2LeaseKey; import jcifs.internal.util.SMBUtil;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 4.8K bytes - Click Count (0)