- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 365 for cancels (0.07 sec)
-
docs/en/docs/deployment/manually.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Aug 25 02:44:06 UTC 2024 - 7.8K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
if objectAPI == nil { return } pools, ok := objectAPI.(*erasureServerPools) if !ok { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL) return } // Cancel any ongoing rebalance operation globalNotificationSys.StopRebalance(r.Context()) writeSuccessResponseHeadersOnly(w) adminLogIf(ctx, pools.saveRebalanceStats(GlobalContext, 0, rebalSaveStoppedAt))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 00:22:30 UTC 2024 - 10.9K bytes - Viewed (0) -
docs/pt/docs/tutorial/extra-models.md
/// ## Reduzir duplicação Reduzir a duplicação de código é uma das ideias principais no **FastAPI**. A duplicação de código aumenta as chances de bugs, problemas de segurança, problemas de desincronização de código (quando você atualiza em um lugar, mas não em outros), etc. E esses modelos estão compartilhando muitos dos dados e duplicando nomes e tipos de atributos.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 7.8K bytes - Viewed (0) -
docs/en/docs/tutorial/extra-models.md
/// ## Reduce duplication Reducing code duplication is one of the core ideas in **FastAPI**. As code duplication increments the chances of bugs, security issues, code desynchronization issues (when you update in one place but not in the others), etc. And these models are all sharing a lot of the data and duplicating attribute names and types.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 7.7K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public static final field INSTANCE Lmockwebserver3/SocketPolicy$StallSocketAtStart; } public abstract interface class mockwebserver3/Stream { public abstract fun cancel ()V public abstract fun getRequestBody ()Lokio/BufferedSource; public abstract fun getResponseBody ()Lokio/BufferedSink; } public abstract interface class mockwebserver3/StreamHandler {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0) -
cmd/peer-rest-server.go
srvCfg, err := getValidConfig(objAPI) if err != nil { return np, grid.NewRemoteErr(err) } subSys := vars.Get(peerRESTSubSys) // Apply dynamic values. ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defer cancel() if subSys == "" { err = applyDynamicConfig(ctx, objAPI, srvCfg) } else { err = applyDynamicConfigForSubSys(ctx, objAPI, srvCfg, subSys) } if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 53.2K bytes - Viewed (0) -
internal/kms/kes.go
func (c *kesConn) Status(ctx context.Context) (map[string]madmin.ItemState, error) { if len(c.client.Endpoints) == 1 { if _, err := c.client.Status(ctx); err != nil { if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { return nil, err } if errors.Is(err, kes.ErrNotAllowed) { return nil, ErrPermission } return map[string]madmin.ItemState{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/site-replication-utils.go
} } } // returns overall resync status from individual bucket resync status map func siteResyncStatus(currSt ResyncStatusType, m map[string]ResyncStatusType) ResyncStatusType { // avoid overwriting canceled resync status if currSt != ResyncStarted { return currSt } totBuckets := len(m) var cmpCount, failCount int for _, st := range m { switch st { case ResyncCompleted: cmpCount++
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/post-policy_test.go
// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(rec, req) ctx, cancel := context.WithCancel(GlobalContext) defer cancel() // Now check if we actually wrote to backend (regardless of the response // returned by the server). z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/iam.go
sys.iamRefreshInterval = iamRefreshInterval // Initialize IAM store sys.initStore(objAPI, etcdClient) sys.Unlock() retryCtx, cancel := context.WithCancel(ctx) // Indicate to our routine to exit cleanly upon return. defer cancel() r := rand.New(rand.NewSource(time.Now().UnixNano())) // Migrate storage format if needed. for { // Migrate IAM configuration, if necessary.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 29 16:01:48 UTC 2024 - 74.6K bytes - Viewed (0)