- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 194 for proceed (0.19 sec)
-
buildscripts/verify-healing-empty-erasure-set.sh
cat "${WORK_DIR}/dist-minio-server$i.log" done echo "FAILED" purge "$WORK_DIR" exit 1 fi sleep 1 if pgrep minio; then # forcibly killing, to proceed further properly. if ! pkill -9 minio; then echo "no minio process running anymore, proceed." fi fi } function check_online() { if ! grep -q 'Status:' ${WORK_DIR}/dist-minio-*.log; then echo "1" fi } function purge() {
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 3.2K bytes - Viewed (0) -
buildscripts/verify-healing.sh
cat "${WORK_DIR}/dist-minio-server$i.log" done echo "FAILED" purge "$WORK_DIR" exit 1 fi sleep 1 if pgrep minio; then # forcibly killing, to proceed further properly. if ! pkill -9 minio; then echo "no minio process running anymore, proceed." fi fi } function check_heal() { if ! grep -q 'Status:' ${WORK_DIR}/dist-minio-*.log; then return 1 fi for ((i = 0; i < 20; i++)); do
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 4.2K bytes - Viewed (1) -
samples/guide/src/main/java/okhttp3/recipes/CheckHandshake.java
String pin = CertificatePinner.pin(certificate); if (denylist.contains(pin)) { throw new IOException("Denylisted peer certificate: " + pin); } } return chain.proceed(chain.request()); } }; private final OkHttpClient client = new OkHttpClient.Builder() .addNetworkInterceptor(CHECK_HANDSHAKE_INTERCEPTOR) .build(); public void run() throws Exception {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 2.1K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/templates/clusterrole.yaml
verbs: ["get", "list", "watch", "update"] # istio configuration # removing CRD permissions can break older versions of Istio running alongside this control plane (https://github.com/istio/istio/issues/29382) # please proceed with caution - apiGroups: ["config.istio.io", "security.istio.io", "networking.istio.io", "authentication.istio.io", "rbac.istio.io", "telemetry.istio.io", "extensions.istio.io"] verbs: ["get", "watch", "list"]
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 16:44:32 GMT 2024 - 5.7K bytes - Viewed (0) -
cmd/global-heal.go
if versionNotFound == len(fivs.Versions) { return } select { case <-ctx.Done(): return case results <- healEntryDone(entry.name): } // Wait and proceed if there are active requests waitForLowHTTPReq() } // How to resolve partial results. resolver := metadataResolutionParams{ dirQuorum: 1, objQuorum: 1, bucket: bucket, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
manifests/charts/istiod-remote/templates/clusterrole.yaml
verbs: ["get", "list", "watch", "update"] # istio configuration # removing CRD permissions can break older versions of Istio running alongside this control plane (https://github.com/istio/istio/issues/29382) # please proceed with caution - apiGroups: ["config.istio.io", "security.istio.io", "networking.istio.io", "authentication.istio.io", "rbac.istio.io", "telemetry.istio.io", "extensions.istio.io"] verbs: ["get", "watch", "list"]
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 16:44:32 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
wait := sleeper.Timer(ctx) meta, err := loadBucketMetadata(ctx, sys.objAPI, buckets[i].Name) if err != nil { internalLogIf(ctx, err, logger.WarningKind) wait() // wait to proceed to next entry. continue } sys.Lock() sys.metadataMap[buckets[i].Name] = meta sys.Unlock() // Initialize the failed buckets
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
cmd/format-erasure.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/data-scanner.go
// healing attempt on this drive. item.heal.enabled = item.heal.enabled && f.healObjectSelect > 0 sz, err := f.getSize(item) if err != nil && err != errIgnoreFileContrib { wait() // wait to proceed to next entry. if err != errSkipFile && f.dataUsageScannerDebug { console.Debugf(scannerLogPrefix+" getSize \"%v/%v\" returned err: %v\n", bucket, item.objectPath(), err) } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
currentTask = coordinatorTask taskRunner.condition.signalAll() } } // Let the coordinator process its interruption. runTasks() } /** Ask a single task to proceed. Used by the test thread only. */ fun runNextTask() { taskRunner.assertThreadDoesntHoldLock() taskRunner.lock.withLock {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0)