- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 138 for lockers (0.03 sec)
-
docs/de/docs/deployment/server-workers.md
* **Neustarts** * Replikation (die Anzahl der laufenden Prozesse) * **Arbeitsspeicher** * **Schritte vor dem Start** ## Container und Docker { #containers-and-docker } Im nächsten Kapitel über [FastAPI in Containern – Docker](docker.md){.internal-link target=_blank} werde ich einige Strategien erläutern, die Sie für den Umgang mit den anderen **Deployment-Konzepten** verwenden können.
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Dec 02 17:32:56 UTC 2025 - 8.8K bytes - Viewed (0) -
docs/zh/docs/deployment/server-workers.md
如果您正在使用容器,例如 Docker 或 Kubernetes,我将在下一章中告诉您更多相关信息:[容器中的 FastAPI - Docker](docker.md){.internal-link target=_blank}。 比较特别的是,在 **Kubernetes** 环境中运行时,您通常**不需要**使用多个工作进程,而是**每个容器运行一个 Uvicorn 进程**。不过,我会在本章节的后续部分详细介绍这一点。 /// ## 多个工作进程 您可以使用 `--workers` 命令行选项来启动多个工作进程: //// tab | `fastapi` 如果您使用 `fastapi` 命令: <div class="termy"> ```consoleRegistered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Mon Mar 31 08:13:15 UTC 2025 - 8K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
func (restClient *ReconnectRESTClient) RLock(ctx context.Context, args LockArgs) (status bool, err error) { return restClient.Call("/v1/rlock", args) } func (restClient *ReconnectRESTClient) Lock(ctx context.Context, args LockArgs) (status bool, err error) { return restClient.Call("/v1/lock", args) } func (restClient *ReconnectRESTClient) RUnlock(ctx context.Context, args LockArgs) (status bool, err error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Jan 20 17:36:09 UTC 2022 - 4.4K bytes - Viewed (0) -
cmd/shared-lock.go
}) type sharedLock struct { lockContext chan LockContext } func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) { for { locker := objAPI.NewNSLock(minioMetaBucket, lockName) lkctx, err := locker.GetLock(ctx, sharedLockTimeout) if err != nil { continue } keepLock: for { select { case <-ctx.Done(): return case <-lkctx.Context().Done():Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
} // Attempt all calls. _, err = lkClient.RLock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") } _, err = lkClient.Lock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Lock to fail") } _, err = lkClient.RUnlock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for RUnlock to fail") }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 2K bytes - Viewed (0) -
internal/stmt_store/stmt_store.go
// locker: A synchronization lock that is unlocked after initialization to avoid deadlocks. // Returns: // *Stmt: A newly created statement object for executing SQL operations. // error: An error if the statement preparation fails. New(ctx context.Context, key string, isTransaction bool, connPool ConnPool, locker sync.Locker) (*Stmt, error)
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun Apr 27 06:05:16 UTC 2025 - 6K bytes - Viewed (0) -
cmd/local-locker_test.go
rng := rand.New(rand.NewSource(0)) quorum := 0 // Numbers of unique locks for _, locks := range []int{100, 1000, 1e6} { if testing.Short() && locks > 100 { continue } t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) { // Number of readers per lock... for _, readers := range []int{1, 10, 100} { if locks > 1000 && readers > 1 { continue }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.8K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
return false, fmt.Errorf("Unlock attempted on a read locked entity: %s (%d read locks active)", args.Resources[0], locksHeld) } delete(l.lockMap, args.Resources[0]) // Remove the write lock return true, nil } const ReadLock = 1 func (l *lockServer) RLock(args *LockArgs) (reply bool, err error) { if d := atomic.LoadInt64(&l.responseDelay); d != 0 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/ErrorToWarnRewritePolicy.java
import org.apache.logging.log4j.core.impl.Log4jLogEvent; /** * Log4j rewrite policy that converts ERROR level log events to WARN level for specified loggers. * This policy is useful for downgrading the severity of log events from certain loggers * to prevent them from being treated as critical errors. */ @Plugin(name = "ErrorToWarnRewritePolicy", category = Core.CATEGORY_NAME, elementType = "rewritePolicy", printObject = true)
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/webapp/WEB-INF/env/crawler/resources/log4j2.xml
<DefaultRolloverStrategy fileIndex="max" min="1" max="${backup.max.history}" compressionLevel="9" /> </RollingFile> <Rewrite name="AppFile"> <AppenderRef ref="AppRollingFile" /> <ErrorToWarnRewritePolicy loggers="org.apache.fontbox,org.apache.pdfbox,org.apache.poi" /> </Rewrite> <RollingFile name="StatsFile" fileName="${log.file.basedir}/fess-urls.log" filePattern="${log.file.basedir}/fess-urls${backup.date.suffix}-%i.log.gz">
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Mon Feb 20 13:05:30 UTC 2023 - 2.4K bytes - Viewed (0)