Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 19 for iowait (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        input.set("value");
        inFunction.await();
        futureResult.cancel(true);
        shouldCompleteFunction.countDown();
        assertThrows(CancellationException.class, () -> futureResult.get());
        // TODO(cpovirk): implement interruption, updating this test:
        // https://github.com/google/guava/issues/1989
        assertEquals(1, gotException.getCount());
        // gotException.await();
        service.shutdown();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        input.set("value");
        inFunction.await();
        futureResult.cancel(true);
        shouldCompleteFunction.countDown();
        assertThrows(CancellationException.class, () -> futureResult.get());
        // TODO(cpovirk): implement interruption, updating this test:
        // https://github.com/google/guava/issues/1989
        assertEquals(1, gotException.getCount());
        // gotException.await();
        service.shutdown();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        callback.await(server.url("/a")).assertBody("abc")
        client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback)
        callback.await(server.url("/b")).assertBody("def")
        client.newCall(Request.Builder().url(server.url("/c")).build()).enqueue(callback)
        callback.await(server.url("/c")).assertBody("ghi")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
  4. fastapi/routing.py

                                            with anyio.fail_after(_PING_INTERVAL):
                                                data = await receive_stream.receive()
                                            await send_keepalive.send(data)
                                        except TimeoutError:
                                            await send_keepalive.send(KEEPALIVE_COMMENT)
                                except anyio.EndOfStream:
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 193K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

          }
        }.start();
    
        try {
          computingSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        map.put(one, two);
        assertThat(map.get(one)).isSameInstanceAs(two);
        startSignal.countDown();
    
        try {
          doneSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 114.9K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/cache/LocalCacheTest.java

          }
        }.start();
    
        try {
          computingSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        map.put(one, two);
        assertThat(map.get(one)).isSameInstanceAs(two);
        startSignal.countDown();
    
        try {
          doneSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 116.4K bytes
    - Click Count (0)
  7. fastapi/applications.py

            app = FastAPI()
    
            @app.websocket("/ws")
            async def websocket_endpoint(websocket: WebSocket):
                await websocket.accept()
                while True:
                    data = await websocket.receive_text()
                    await websocket.send_text(f"Message text was: {data}")
            ```
            """
    
            def decorator(func: DecoratedCallable) -> DecoratedCallable:
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Apr 01 16:16:24 GMT 2026
    - 178.6K bytes
    - Click Count (0)
  8. cmd/admin-handlers.go

    				if failedClients[idx] {
    					continue
    				}
    				client := client
    				ng.Go(ctx, func() error {
    					return client.CommitBinary(ctx)
    				}, idx, *client.host)
    			}
    
    			for _, nerr := range ng.Wait() {
    				if nerr.Err != nil {
    					prs, ok := peerResults[nerr.Host.String()]
    					if ok {
    						prs.Err = nerr.Err.Error()
    						peerResults[nerr.Host.String()] = prs
    					} else {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

         *
         * @param fromIndex        the source index name
         * @param toIndex          the destination index name
         * @param waitForCompletion whether to wait for the operation to complete
         * @return true if the copy operation was successful, false otherwise
         */
        public boolean copyDocIndex(final String fromIndex, final String toIndex, final boolean waitForCompletion) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 138.6K bytes
    - Click Count (1)
  10. CHANGELOG/CHANGELOG-1.36.md

    - Adding multiple conditions support to kubectl wait command. ([#136855](https://github.com/kubernetes/kubernetes/pull/136855), [@ardaguclu](https://github.com/ardaguclu)) [SIG CLI and Testing]
    - Adds metrics for constrained impersonation as described in https://kep.k8s.io/5284
      
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Mar 19 23:38:00 GMT 2026
    - 142.1K bytes
    - Click Count (0)
Back to Top