Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 23 for iowait (0.08 seconds)

  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. CHANGELOG/CHANGELOG-1.4.md

    * portfordwardtester: avoid data loss during send+close+exit ([#37103](https://github.com/kubernetes/kubernetes/pull/37103), [@sttts](https://github.com/sttts))
    * Wait for the port to be ready before starting ([#38260](https://github.com/kubernetes/kubernetes/pull/38260), [@fraenkel](https://github.com/fraenkel))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 133.5K bytes
    - Click Count (0)
  9. 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)
  10. CHANGELOG/CHANGELOG-1.5.md

      * User-written controllers that reuse names of pod objects should evaluate this change.
      * When deleting an object with `kubectl delete ... --grace-period=0`, the client will
        begin a graceful deletion and wait until the resource is fully deleted.  To force
        deletion immediately, use the `--force` flag. This prevents users from accidentally
        allowing two Stateful Set pods to share the same persistent volume which could lead to data
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 136.4K bytes
    - Click Count (0)
Back to Top