Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 138 for lockers (0.03 sec)

  1. 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)
  2. 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">
    
    ```console
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Mon Mar 31 08:13:15 UTC 2025
    - 8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top