- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 48 for Pairing (0.23 sec)
-
cmd/typed-errors.go
// error returned by disks which are to be initialized are waiting for the // first server to initialize them in distributed set to initialize them. var errNotFirstDisk = errors.New("Not first drive") // error returned by first disk waiting to initialize other servers. var errFirstDiskWait = errors.New("Waiting on other drives") // error returned for a negative actual size.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
docs/debugging/pprofgoparser/main.go
// User input flags searchText string goTime, less, margin time.Duration ) func init() { flag.DurationVar(&less, "less", 0, "goroutine waiting less than the specified time") flag.DurationVar(&goTime, "time", 0, "goroutine waiting for exactly the specified time") flag.DurationVar(&margin, "margin", 0, "margin time") flag.StringVar(&searchText, "search", "", "Regex to search for a text in one goroutine stacktrace")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Mar 06 11:43:16 GMT 2024 - 3.4K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_api_requests_rejected_invalid_total` | `counter` | Total number of invalid requests | `type,pool_index,server` | | `minio_api_requests_waiting_total` | `gauge` | Total number of requests in the waiting queue | `type,pool_index,server` |
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 26K bytes - Viewed (0) -
internal/config/certs.go
// Read certificate file. var data []byte if data, err = os.ReadFile(certFile); err != nil { return nil, err } // Trimming leading and tailing white spaces. data = bytes.TrimSpace(data) // Parse all certs in the chain. current := data for len(current) > 0 { var pemBlock *pem.Block if pemBlock, current = pem.Decode(current); pemBlock == nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/leak-detect_test.go
} // DetectLeak - Creates a snapshot of runtime stack and compares it with the initial stack snapshot. func (initialSnapShot LeakDetect) DetectLeak(t TestErrHandler) { if t.Failed() { return } // Loop, waiting for goroutines to shut down. // Wait up to 5 seconds, but finish as quickly as possible. deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
| `minio_s3_requests_total` | Total number S3 requests. | | `minio_s3_requests_waiting_total` | Number of S3 requests in the waiting queue. | | `minio_s3_requests_ttfb_seconds_distribution` | Distribution of the time to first byte across API calls. |
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
docs/metrics/prometheus/grafana/node/minio-node.json
"uid": "${DS_PROMETHEUS}" }, "exemplar": true, "expr": "minio_node_drive_io_waiting{job=~\"$scrape_jobs\",server=\"$server\"}", "interval": "", "legendFormat": "[{{drive}}]", "refId": "B" } ], "title": "IO Operations Waiting", "type": "timeseries" } ], "refresh": "", "schemaVersion": 39, "tags": [
Json - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 28 15:14:26 GMT 2024 - 23.1K bytes - Viewed (0) -
internal/dsync/dsync_test.go
}, } code := m.Run() stopLockServers() os.Exit(code) } func TestSimpleLock(t *testing.T) { dm := NewDRWMutex(ds, "test") dm.Lock(id, source) // fmt.Println("Lock acquired, waiting...") time.Sleep(testDrwMutexRefreshCallTimeout) dm.Unlock(context.Background()) } func TestSimpleLockUnlockMultipleTimes(t *testing.T) { dm := NewDRWMutex(ds, "test") dm.Lock(id, source)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
internal/grid/connection.go
continue } c.reconnectMu.Lock() remoteUUID := uuid.UUID(r.ID) if c.remoteID != nil { c.reconnected() } c.remoteID = &remoteUUID if debugPrint { fmt.Println(c.Local, "Connected Waiting for Messages") } // Handle messages... c.handleMessages(c.ctx, conn) // Reconnect unless we are shutting down (debug only). if c.State() == StateShutdown { conn.Close() return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/api-router.go
// ListBuckets apiRouter.Methods(http.MethodGet).Path(SlashSeparator). HandlerFunc(s3APIMiddleware(api.ListBucketsHandler)) // S3 browser with signature v4 adds '//' for ListBuckets request, so rather // than failing with UnknownAPIRequest we simply handle it for now. apiRouter.Methods(http.MethodGet).Path(SlashSeparator + SlashSeparator). HandlerFunc(s3APIMiddleware(api.ListBucketsHandler))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0)