Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 609 for await (0.07 sec)

  1. cmd/erasure.go

    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    // nsScanner will start scanning buckets and send updated totals as they are traversed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/util/transport/Transport.java

                te = null;
                thread = new Thread( this, name );
                thread.setDaemon( true );
    
                synchronized (thread) {
                    thread.start();
                    thread.wait( timeout );          /* wait for doConnect */
    
                    switch (state) {
                        case 1: /* doConnect never returned */
                            state = 0;
                            thread = null;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * @param timeoutDuration with timeoutUnit, the maximum length of time that callers are willing to
       *     wait on each method call to the proxy
       * @param timeoutUnit with timeoutDuration, the maximum length of time that callers are willing to
       *     wait on each method call to the proxy
       * @return a time-limiting proxy
       * @throws IllegalArgumentException if {@code interfaceType} is a regular class, enum, or
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  4. prepare_stmt.go

    		db.Mux.RUnlock()
    		// wait for other goroutines prepared
    		<-stmt.prepared
    		if stmt.prepareErr != nil {
    			return Stmt{}, stmt.prepareErr
    		}
    
    		return *stmt, nil
    	}
    	db.Mux.RUnlock()
    
    	db.Mux.Lock()
    	// double check
    	if stmt, ok := db.Stmts[query]; ok && (!stmt.Transaction || isTransaction) {
    		db.Mux.Unlock()
    		// wait for other goroutines prepared
    		<-stmt.prepared
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. cmd/mrf.go

    			}
    
    			now := time.Now()
    			if now.Sub(u.Queued) < time.Second {
    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    			wait := healSleeper.Timer(context.Background())
    
    			scan := madmin.HealNormalScan
    			if u.BitrotScan {
    				scan = madmin.HealDeepScan
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  6. docs/en/docs/release-notes.md

    * Fix typos in Async docs. PR [#1423](https://github.com/tiangolo/fastapi/pull/1423).
    
    ## 0.54.2
    
    * Add translation to Spanish for [Concurrency and async / await - Concurrencia y async / await](https://fastapi.tiangolo.com/es/async/). PR [#1290](https://github.com/tiangolo/fastapi/pull/1290) by [@alvaropernas](https://github.com/alvaropernas).
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Nov 01 11:25:57 UTC 2024
    - 460.3K bytes
    - Viewed (0)
  7. cmd/prepare-storage.go

    		}
    
    		tries++
    		switch {
    		case errors.Is(err, errNotFirstDisk):
    			// Fresh setup, wait for first server to be up.
    			logger.Info("Waiting for the first server to format the drives (elapsed %s)\n", getElapsedTime())
    		case errors.Is(err, errFirstDiskWait):
    			// Fresh setup, wait for other servers to come up.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  8. buildscripts/verify-healing-empty-erasure-set.sh

    	export MC_HOST_myminio="http://minio:minio123@127.0.0.1:$((start_port + 1))"
    
    	timeout 15m /tmp/mc ready myminio || fail
    
    	# Wait for all drives to be online and formatted
    	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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

            } catch (final ExecutionException e) {
                // no thing to do
            }
    
            long elapsed = (System.nanoTime() - time) / 1000000;
            long wait = waittime * (numTasks - 1);
            assertTrue(elapsed + " >= " + wait, elapsed + 1L >= wait);
        }
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

         * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.
         * Wait for the interrupting thread to set DONE. (See interruptTask().) We want to wait so that
         * the interrupting thread doesn't interrupt the _next_ thing to run on this thread.
         *
         * Note: We don't reset the interrupted bit, just wait for it to be set. If this is a thread
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top