Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 316 for Sleeps (0.03 sec)

  1. buildscripts/verify-healing-empty-erasure-set.sh

    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
    	# Wait for all drives to be healed
    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].healing | select(. != null) | select(. == true)' | wc -l) -gt 0 ]; do sleep 1; done
    
    	# Wait for Status: in MinIO output
    	while true; do
    		rv=$(check_online)
    		if [ "$rv" != "1" ]; then
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                    }
                    Thread.sleep(50);
                }
                assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus());
                for (int i = 0; i < 100; i++) {
                    if (crawler2.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
                        break;
                    }
                    Thread.sleep(50);
                }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  3. tests/lru_test.go

    	}
    
    	lc.Add("key1", "val1")
    
    	time.Sleep(100 * time.Millisecond) // not enough to expire
    	if lc.Len() != 1 {
    		t.Fatalf("length differs from expected")
    	}
    
    	v, ok = lc.Get("key1")
    	if v != "val1" {
    		t.Fatalf("value differs from expected")
    	}
    	if !ok {
    		t.Fatalf("should be true")
    	}
    
    	time.Sleep(200 * time.Millisecond) // expire
    	v, ok = lc.Get("key1")
    	if ok {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

            .build(),
        )
        val webSocket: WebSocket = newWebSocket()
        clientListener.assertOpen()
        val server = serverListener.assertOpen()
    
        // Sleep longer than the HTTP client's read timeout.
        Thread.sleep((client.readTimeoutMillis + 500).toLong())
        server.send("abc")
        clientListener.assertTextMessage("abc")
        closeWebSockets(webSocket, server)
      }
    
      @Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  5. cmd/metacache-set.go

    					o.objectPath(0), "", ReadOptions{})
    				if err != nil {
    					time.Sleep(retryDelay250)
    					retries++
    					continue
    				}
    				break
    			}
    		}
    		retryWait := func() {
    			retries++
    			if retries == 1 {
    				time.Sleep(retryDelay)
    			} else {
    				time.Sleep(retryDelay250)
    			}
    		}
    		// Load first part metadata...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  6. docs/bucket/replication/setup_ilm_expiry_replication.sh

    ./mc ready sitea
    ./mc ready siteb
    ./mc ready sitec
    ./mc ready sited
    
    ./mc mb sitea/bucket
    ./mc mb sitec/bucket
    
    ## Setup site replication
    ./mc admin replicate add sitea siteb --replicate-ilm-expiry
    
    sleep 10s
    
    ## Add warm tier
    ./mc ilm tier add minio sitea WARM-TIER --endpoint http://localhost:9006 --access-key minio --secret-key minio123 --bucket bucket
    
    ## Add ILM rules
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

          this.everyMillis = everyMillis;
          this.interruptee = interruptee;
        }
    
        @Override
        public void run() {
          while (true) {
            try {
              Thread.sleep(everyMillis);
            } catch (InterruptedException e) {
              // ok. just stop sleeping.
            }
            if (shouldStop) {
              break;
            }
            interruptee.interrupt();
          }
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache2/RelayTest.kt

        val relay = edit(file, pipe.source, metadata, 5)
        val future1 = executor.submit(sourceReader(relay.newSource()))
        val future2 = executor.submit(sourceReader(relay.newSource()))
        Thread.sleep(500)
        sink.writeUtf8("abcdefghij")
        Thread.sleep(500)
        sink.writeUtf8("klmnopqrst")
        sink.close()
        assertThat<ByteString>(future1.get())
          .isEqualTo("abcdefghijklmnopqrst".encodeUtf8())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  9. cmd/last-minute.go

    func (a AccElem) asTimedAction() madmin.TimedAction {
    	return madmin.TimedAction{AccTime: uint64(a.Total), Count: uint64(a.N), Bytes: uint64(a.Size)}
    }
    
    // lastMinuteLatency keeps track of last minute latency.
    type lastMinuteLatency struct {
    	Totals  [60]AccElem
    	LastSec int64
    }
    
    // Merge data of two lastMinuteLatency structure
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jul 05 17:40:45 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

                            if (file.exists()) {
                                if (!file.delete()) {
                                    // sleep for 10ms just in case this is windows holding a file lock
                                    try {
                                        Thread.sleep(10);
                                    } catch (InterruptedException ie) {
                                        // ignore
                                    }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 18.9K bytes
    - Viewed (0)
Back to top