Search Options

Results per page
Sort
Preferred Languages
Advance

Results 521 - 530 of 627 for nwait (0.05 sec)

  1. 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:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:52:31 UTC 2024
    - 172.2K bytes
    - Viewed (0)
  2. CHANGELOG/CHANGELOG-1.31.md

    - Add --for=create option to kubectl wait ([#125868](https://github.com/kubernetes/kubernetes/pull/125868), [@soltysh](https://github.com/soltysh)) [SIG CLI and Testing]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 12:18:32 UTC 2024
    - 315.4K bytes
    - Viewed (0)
  3. tensorflow/c/eager/c_api_experimental_test.cc

      //
      // 1. Create a variable on `remote_device`, using `ctx_0`.
      TFE_TensorHandle* handle_0 =
          CreateVariable(ctx_0, 1.2, remote_device, /*variable_name=*/"var");
    
      // 2. Wait for `var` to be created and initialized on the worker.
      TF_Status* status = TF_NewStatus();
      TFE_ContextAsyncWait(ctx_0, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TF_DeleteStatus(status);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 03:14:26 UTC 2023
    - 31.5K bytes
    - Viewed (0)
  4. istioctl/pkg/dashboard/dashboard.go

    		ClosePortForwarderOnInterrupt(fw)
    
    		log.Debugf(fmt.Sprintf("port-forward to %s pod ready", flavor))
    		openBrowser(fmt.Sprintf(urlFormat, fw.Address()), writer, browser)
    
    		// Wait for stop
    		fw.WaitForStop()
    
    		return nil
    	}
    
    	return fmt.Errorf("failure running port forward process: %v", err)
    }
    
    func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) {
    	go func() {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbTransport.java

                                resp.expiration = System.currentTimeMillis() + timeout;
                                while( resp.hasMoreElements() ) {
                                    wait( timeout );
                                    timeout = resp.expiration - System.currentTimeMillis();
                                    if (timeout <= 0) {
                                        throw new TransportException( this +
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 31.2K bytes
    - Viewed (0)
  6. helm-releases/minio-3.5.4.tgz

    failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 14 06:04:53 UTC 2022
    - 17.2K bytes
    - Viewed (0)
  7. helm-releases/minio-3.5.5.tgz

    failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 16 19:44:53 UTC 2022
    - 17.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * {@link #runOneIteration} that will be executed periodically as specified by its {@link
     * Scheduler}. When this service is asked to stop via {@link #stopAsync} it will cancel the periodic
     * task (but not interrupt it) and wait for it to stop before running the {@link #shutDown} method.
     *
     * <p>Subclasses are guaranteed that the life cycle methods ({@link #runOneIteration}, {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/netbios/NbtAddress.java

                    LOOKUP_TABLE.put( name, name );
                    return null;
                }
                while( LOOKUP_TABLE.containsKey( name )) {
                    try {
                        LOOKUP_TABLE.wait();
                    } catch( InterruptedException e ) {
                    }
                }
            }
            obj = getCachedAddress( name );
            if( obj == null ) {
                synchronized( LOOKUP_TABLE ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 30.1K bytes
    - Viewed (0)
  10. helm-releases/minio-1.0.2.tgz

    failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for Minio service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 24 18:58:05 UTC 2021
    - 13.6K bytes
    - Viewed (0)
Back to top