- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 592 for isync (0.06 sec)
-
internal/dsync/drwmutex.go
} func (g *Granted) isLocked() bool { return isLocked(g.lockUID) } func isLocked(uid string) bool { return len(uid) > 0 } // NewDRWMutex - initializes a new dsync RW mutex. func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex { restClnts, _ := clnt.GetLockers() sort.Strings(names) return &DRWMutex{ writeLocks: make([]string, len(restClnts)),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
src/runtime/chanbarrier_test.go
package runtime_test import ( "runtime" "sync" "testing" ) type response struct { } type myError struct { } func (myError) Error() string { return "" } func doRequest(useSelect bool) (*response, error) { type async struct { resp *response err error } ch := make(chan *async, 0) done := make(chan struct{}, 0) if useSelect { go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 17:50:18 UTC 2024 - 1.4K bytes - Viewed (0) -
cmd/local-locker.go
// Unexpected inconsistency, delete. delete(l.lockUID, mapID) idx++ continue } reply = true l.removeEntry(resource, dsync.LockArgs{UID: args.UID}, &lris) idx++ } } } func (l *localLocker) Refresh(ctx context.Context, args dsync.LockArgs) (refreshed bool, err error) { select { case <-ctx.Done(): return false, ctx.Err() default: l.mutex.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 10.6K bytes - Viewed (0) -
cmd/erasure-sets.go
// Reset the timer for next interval monitor.Reset(monitorInterval) } } } func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) { return func() ([]dsync.NetLocker, string) { lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex])) copy(lockers, s.erasureLockers[setIndex]) return lockers, s.erasureLockOwner } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0) -
tests/test_dependency_contextmanager.py
class OtherDependencyError(Exception): pass async def asyncgen_state(state: Dict[str, str] = Depends(get_state)): state["/async"] = "asyncgen started" yield state["/async"] state["/async"] = "asyncgen completed" def generator_state(state: Dict[str, str] = Depends(get_state)): state["/sync"] = "generator started" yield state["/sync"] state["/sync"] = "generator completed"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Feb 24 23:06:37 UTC 2024 - 11.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultExecutionPlanParallelTest.groovy
Task finalizer1 = task("finalizer1", type: Async, dependsOn: [finalizerDep1]) Task finalizerDep2 = task("finalizerDep2", type: Async, dependsOn: [finalizer1]) Task finalizer2 = task("finalizer2", type: Async, dependsOn: [finalizerDep2]) Task a = task("a", type: Async, finalizedBy: [finalizer1]) Task b = task("b", type: Async, finalizedBy: [finalizer2], dependsOn: [a])
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 93.5K bytes - Viewed (0) -
ci/official/upload.sh
# "/path/bar". This script uses "gsutil rsync" instead, which acts on directory # contents. About arguments to gsutil: # "gsutil -m rsync" runs in parallel. # "gsutil rsync -r" is recursive and makes directories work. # "gsutil rsync -d" is "sync and delete files from destination if not present in source" DOWNLOADS="$(mktemp -d)" mkdir -p "$DOWNLOADS" gsutil -m rsync -r "$TFCI_ARTIFACT_STAGING_GCS_URI" "$DOWNLOADS"
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jan 24 20:52:12 UTC 2024 - 2.8K bytes - Viewed (0) -
docs/en/docs/how-to/sql-databases-peewee.md
```Python some_var.get() ``` ### Set context variables in the `async` dependency `reset_db_state()` If some part of the async code sets the value with `some_var.set("updated in function")` (e.g. like the `async` dependency), the rest of the code in it and the code that goes after (including code inside of `async` functions called with `await`) will see that new value.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Jan 16 13:23:25 UTC 2024 - 23.6K bytes - Viewed (0) -
docs_src/custom_docs_ui/tutorial001.py
) @app.get(app.swagger_ui_oauth2_redirect_url, include_in_schema=False) async def swagger_ui_redirect(): return get_swagger_ui_oauth2_redirect_html() @app.get("/redoc", include_in_schema=False) async def redoc_html(): return get_redoc_html( openapi_url=app.openapi_url, title=app.title + " - ReDoc",
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu May 23 22:59:02 UTC 2024 - 1.1K bytes - Viewed (0) -
fastapi/datastructures.py
@app.post("/files/") async def create_file(file: Annotated[bytes, File()]): return {"file_size": len(file)} @app.post("/uploadfile/") async def create_upload_file(file: UploadFile): return {"filename": file.filename} ``` """ file: Annotated[ BinaryIO, Doc("The standard Python file object (non-async)."), ]
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 5.6K bytes - Viewed (0)