- Sort Score
 - Result 10 results
 - Languages All
 
Results 241 - 250 of 852 for lock (0.22 sec)
- 
				
				
docs/ru/docs/deployment/docker.md
В ней будет создан файл `requirements.txt` 3. На этом шаге установите Poetry. 4. Скопируйте файлы `pyproject.toml` и `poetry.lock` в директорию `/tmp`. Поскольку название файла написано как `./poetry.lock*` (с `*` в конце), то ничего не сломается, если такой файл не будет найден. 5. Создайте файл `requirements.txt`.Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Thu Dec 12 22:48:28 UTC 2024 - 57.6K bytes - Viewed (0) - 
				
				
docs/pt/docs/deployment/docker.md
Aqui é onde geraremos o arquivo `requirements.txt` 3. Instale o Poetry nesse estágio do Docker. 4. Copie os arquivos `pyproject.toml` e `poetry.lock` para o diretório `/tmp`. Porque está usando `./poetry.lock*` (terminando com um `*`), não irá falhar se esse arquivo ainda não estiver disponível. 5. Gere o arquivo `requirements.txt`.Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 37.4K bytes - Viewed (0) - 
				
				
cmd/iam-object-store.go
objAPI: objAPI, usersSysType: usersSysType, } } func (iamOS *IAMObjectStore) rlock() *iamCache { iamOS.RLock() return iamOS.iamCache } func (iamOS *IAMObjectStore) runlock() { iamOS.RUnlock() } func (iamOS *IAMObjectStore) lock() *iamCache { iamOS.Lock() return iamOS.iamCache } func (iamOS *IAMObjectStore) unlock() { iamOS.Unlock() }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 26.6K bytes - Viewed (0) - 
				
				
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
/** * A connection to a remote web server capable of carrying 1 or more concurrent streams. * * Connections are shared in a connection pool. Accesses to the connection's state must be guarded * by holding a lock on the connection. */ class RealConnection internal constructor( val taskRunner: TaskRunner, val connectionPool: RealConnectionPool, override val route: Route, /** The low-level TCP socket. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 14.9K bytes - Viewed (0) - 
				
				
src/test/java/jcifs/internal/smb2/lock/Smb2OplockBreakNotificationTest.java
package jcifs.internal.smb2.lock; import static org.junit.jupiter.api.Assertions.assertArrayEquals; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.mock; import java.lang.reflect.Field; import java.util.Arrays;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) - 
				
				
cmd/sftp-server-driver.go
wg *sync.WaitGroup buffer map[int64][]byte err error nextOffset int64 m sync.Mutex } func (w *writerAt) WriteAt(b []byte, offset int64) (n int, err error) { w.m.Lock() defer w.m.Unlock() if w.nextOffset == offset { n, err = w.w.Write(b) w.nextOffset += int64(n) } else { if offset > w.nextOffset+ftpMaxWriteOffset {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0) - 
				
				
android/guava/src/com/google/common/cache/CacheBuilder.java
* value, you should always choose it explicitly. * * <p>The current implementation uses the concurrency level to create a fixed number of hashtable * segments, each governed by its own write lock. The segment lock is taken once for each explicit * write, and twice for each cache loading computation (once prior to loading the new value, and * once after loading completes). Much internal cache management is performed at the segment
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 51.7K bytes - Viewed (0) - 
				
				
cmd/metrics-v3-types.go
mg.ExtraLabels) for _, metric := range promMetrics { 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() } }Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Feb 28 19:33:08 UTC 2025 - 15.6K bytes - Viewed (0) - 
				
				
cmd/erasure-healing.go
lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return result, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } // Re-read when we have lock... partsMetadata, errs := readAllFileInfo(ctx, storageDisks, "", bucket, object, versionID, true, true) if isAllNotFound(errs) { err := errFileNotFound if versionID != "" { err = errFileVersionNotFound }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.6K bytes - Viewed (0) - 
				
				
cmd/bucket-policy-handlers_test.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.9K bytes - Viewed (0)