Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 517 for bgwait (0.04 sec)

  1. docs/fr/docs/index.md

        return {"item_id": item_id, "q": q}
    ```
    
    <details markdown="1">
    <summary>Ou utilisez <code>async def</code> ...</summary>
    
    Si votre code utilise `async` / `await`, utilisez `async def` :
    
    ```Python hl_lines="9  14"
    from typing import Union
    
    from fastapi import FastAPI
    
    app = FastAPI()
    
    
    @app.get("/")
    async def read_root():
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 22K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                settingsBuilder.put("http.cors.allow-origin", "*");
                settingsBuilder.put("discovery.type", "single-node");
            }).build(newConfigs().clusterName(clusterName).numOfNode(1));
    
            // wait for yellow status
            runner.ensureYellow();
    
            System.setProperty(FesenClient.HTTP_ADDRESS, "localhost:" + runner.node().settings().get("http.port", "9201"));
    
            super.setUp();
    
            // logging
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  3. cmd/sftp-server-driver.go

    		return nil, err
    	}
    
    	return obj, nil
    }
    
    // TransferError will catch network errors during transfer.
    // When TransferError() is called Close() will also
    // be called, so we do not need to Wait() here.
    func (w *writerAt) TransferError(err error) {
    	_ = w.w.CloseWithError(err)
    	_ = w.r.CloseWithError(err)
    	w.err = err
    }
    
    func (w *writerAt) Close() (err error) {
    	switch {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  4. src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

            try {
                rateLimiter.checkAttempt(username, ip);
                fail("Should be locked out");
            } catch (SmbException e) {
                // Expected
            }
    
            // Wait for lockout to expire
            Thread.sleep(2100); // Lockout is 2 seconds in test setup
    
            // Should be allowed again
            assertTrue(rateLimiter.checkAttempt(username, ip), "Should be allowed after lockout expiry");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  5. docs/em/docs/advanced/custom-response.md

        , ⚫️ 🚂 🔢 👈 📨 "🏭" 👷 🕳 🙆 🔘.
    
        🔨 ⚫️ 👉 🌌, 👥 💪 🚮 ⚫️ `with` 🍫, &amp; 👈 🌌, 🚚 👈 ⚫️ 📪 ⏮️ 🏁.
    
    /// tip
    
    👀 👈 📥 👥 ⚙️ 🐩 `open()` 👈 🚫 🐕‍🦺 `async` &amp; `await`, 👥 📣 ➡ 🛠️ ⏮️ 😐 `def`.
    
    ///
    
    ### `FileResponse`
    
    🔁 🎏 📁 📨.
    
    ✊ 🎏 ⚒ ❌ 🔗 🌘 🎏 📨 🆎:
    
    * `path` - 📁 📁 🎏.
    * `headers` - 🙆 🛃 🎚 🔌, 📖.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. docs/bucket/replication/delete-replication.sh

    ./mc cp README.md myminio1/foobucket/dir/file
    
    versionId="$(./mc ls --json --versions myminio1/foobucket/dir/ | jq -r .versionId)"
    
    kill ${pid2} && wait ${pid2} || true
    
    aws s3api --endpoint-url http://localhost:9001 delete-object --bucket foobucket --key dir/file --version-id "$versionId"
    
    out="$(./mc ls myminio1/foobucket/dir/)"
    if [ "$out" != "" ]; then
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/eventbus/EventBus.java

     *       <a href="https://developer.android.com/studio/build/shrink-code">R8 and Proguard</a>.
     *   <li>It doesn't offer a way to wait for multiple events before taking action. For example, it
     *       doesn't offer a way to wait for multiple producers to all report that they're "ready," nor
     *       does it offer a way to batch multiple events from a single producer together.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

        /**
         * Context object containing crawler state and configuration.
         */
        protected CrawlerContext crawlerContext;
    
        /**
         * Flag indicating whether to wait on folder operations.
         */
        protected boolean noWaitOnFolder = false;
    
        /**
         * Increments the active thread count.
         */
        protected void startCrawling() {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/netbios/NameServiceClientImpl.java

                    this.inFlightLookups.add(name);
                    return null;
                }
                while (this.inFlightLookups.contains(name)) {
                    try {
                        this.inFlightLookups.wait();
                    } catch (final InterruptedException e) {
                        log.trace("Interrupted", e);
                    }
                }
            }
            obj = getCachedAddress(name);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 38.5K bytes
    - Viewed (0)
  10. cmd/erasure-healing.go

    						Name:    volInfo.Name,
    						Created: volInfo.Created,
    						count:   1,
    					}, false
    				})
    			}
    
    			return nil
    		}, index)
    	}
    
    	if err := reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum); err != nil {
    		return err
    	}
    
    	healBuckets.Range(func(volName string, volInfo VolInfo) bool {
    		if volInfo.count < readQuorum {
    			healBuckets.Delete(volName)
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
Back to top