Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 731 - 740 of 744 for badsync (0.05 seconds)

  1. docs/en/docs/tutorial/bigger-applications.md

    As the path of each *path operation* has to start with `/`, like in:
    
    ```Python hl_lines="1"
    @router.get("/{item_id}")
    async def read_item(item_id: str):
        ...
    ```
    
    ...the prefix must not include a final `/`.
    
    So, the prefix in this case is `/items`.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 10 08:55:32 GMT 2025
    - 18.6K bytes
    - Click Count (0)
  2. docs/zh/docs/tutorial/bigger-applications.md

    ```Python hl_lines="5-10  16  21" title="app/routers/items.py"
    {!../../docs_src/bigger_applications/app/routers/items.py!}
    ```
    
    由于每个*路径操作*的路径都必须以 `/` 开头,例如:
    
    ```Python hl_lines="1"
    @router.get("/{item_id}")
    async def read_item(item_id: str):
        ...
    ```
    
    ...前缀不能以 `/` 作为结尾。
    
    因此,本例中的前缀为 `/items`。
    
    我们还可以添加一个 `tags` 列表和额外的 `responses` 列表,这些参数将应用于此路由器中包含的所有*路径操作*。
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun May 11 13:37:26 GMT 2025
    - 18.4K bytes
    - Click Count (0)
  3. cmd/admin-handlers.go

    	z, ok := objectAPI.(*erasureServerPools)
    	if !ok {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    
    	var args dsync.LockArgs
    	var lockers []dsync.NetLocker
    	for path := range strings.SplitSeq(vars["paths"], ",") {
    		if path == "" {
    			continue
    		}
    		args.Resources = append(args.Resources, path)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  4. cmd/metrics-v2.go

    				Description: MetricDescription{
    					Namespace: minioNamespace,
    					Subsystem: notifySubsystem,
    					Name:      "current_send_in_progress",
    					Help:      "Number of concurrent async Send calls active to all targets (deprecated, please use 'minio_notify_target_current_send_in_progress' instead)",
    					Type:      gaugeMetric,
    				},
    				Value: float64(nstats.CurrentSendCalls),
    			})
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  5. internal/config/notify/parse.go

    				clusterIDEnv = clusterIDEnv + config.Default + k
    			}
    			natsArgs.Streaming.Enable = streamingEnabled
    			natsArgs.Streaming.ClusterID = env.Get(clusterIDEnv, kv.Get(target.NATSStreamingClusterID))
    			natsArgs.Streaming.Async = env.Get(asyncEnv, kv.Get(target.NATSStreamingAsync)) == config.EnableOn
    			natsArgs.Streaming.MaxPubAcksInflight = maxPubAcksInflight
    		}
    
    		if err = natsArgs.Validate(); err != nil {
    			return nil, err
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  6. cmd/common-main.go

    func contextCanceled(ctx context.Context) bool {
    	select {
    	case <-ctx.Done():
    		return true
    	default:
    		return false
    	}
    }
    
    // bgContext returns a context that can be used for async operations.
    // Cancellation/timeouts are removed, so parent cancellations/timeout will
    // not propagate from parent.
    // Context values are preserved.
    // This can be used for goroutines that live beyond the parent context.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  7. cmd/storage-rest-server.go

    				globalLocalSetDrives[endpoint.PoolIdx][endpoint.SetIdx][endpoint.DiskIdx] = storage
    				return true
    			}
    
    			if createStorage(endpoint) {
    				continue
    			}
    
    			// Start async goroutine to create storage.
    			go func(endpoint Endpoint) {
    				for {
    					time.Sleep(3 * time.Second)
    					if createStorage(endpoint) {
    						return
    					}
    				}
    			}(endpoint)
    		}
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  8. cmd/xl-storage.go

    	if sync {
    		// Perform DirectIO along with fdatasync for larger xl.meta, mostly when
    		// xl.meta has "inlined data" we prefer writing O_DIRECT and then doing
    		// fdatasync() at the end instead of opening the file with O_DSYNC.
    		//
    		// This is an optimization mainly to ensure faster I/O.
    		if len(b) > xioutil.DirectioAlignSize {
    			r := bytes.NewReader(b)
    			return s.writeAllDirect(ctx, filePath, r.Size(), r, flags, skipParent, true)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  9. api/go1.16.txt

    pkg syscall (darwin-arm64), const O_DP_GETRAWENCRYPTED = 1
    pkg syscall (darwin-arm64), const O_DP_GETRAWENCRYPTED ideal-int
    pkg syscall (darwin-arm64), const O_DSYNC = 4194304
    pkg syscall (darwin-arm64), const O_DSYNC ideal-int
    pkg syscall (darwin-arm64), const O_EVTONLY = 32768
    pkg syscall (darwin-arm64), const O_EVTONLY ideal-int
    pkg syscall (darwin-arm64), const O_EXCL = 2048
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Dec 02 16:30:41 GMT 2022
    - 479.2K bytes
    - Click Count (0)
  10. api/go1.13.txt

    pkg syscall (netbsd-arm64-cgo), const O_DIRECTORY = 2097152
    pkg syscall (netbsd-arm64-cgo), const O_DIRECTORY ideal-int
    pkg syscall (netbsd-arm64-cgo), const O_DSYNC = 65536
    pkg syscall (netbsd-arm64-cgo), const O_DSYNC ideal-int
    pkg syscall (netbsd-arm64-cgo), const O_EXCL = 2048
    pkg syscall (netbsd-arm64-cgo), const O_EXLOCK = 32
    pkg syscall (netbsd-arm64-cgo), const O_EXLOCK ideal-int
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Aug 08 18:44:16 GMT 2019
    - 452.6K bytes
    - Click Count (0)
Back to Top