Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for nwait (0.03 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

          thread.start();
          // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load
          // (in startSignal.await()), and the others waiting for that thread's result.
          while (thread.isAlive() && thread.getState() != Thread.State.WAITING) {
            Thread.yield();
          }
        }
        gettersStartedSignal.countDown();
        gettersComplete.await();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

              fail("")
            }
          },
        )
        assertThat(server.takeRequest().sequenceNumber)
          .isEqualTo(expectedSequenceNumber)
        responseDequeuedLatch!!.await()
        call.cancel()
        requestCanceledLatch!!.countDown()
        latch.await()
      }
    
      @ParameterizedTest
      @ArgumentsSource(ProtocolParamProvider::class)
      fun noRecoveryFromRefusedStreamWithRetryDisabled(
        protocol: Protocol,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        peer.acceptFrame() // RST_STREAM
        peer.acceptFrame() // DEGRADED PING
        peer.acceptFrame() // AWAIT PING
        peer.sendFrame().ping(true, Http2Connection.DEGRADED_PING, 1) // DEGRADED PONG
        peer.sendFrame().ping(true, Http2Connection.AWAIT_PING, 0) // AWAIT PONG
        peer.play()
    
        // Play it back.
        val connection = connect(peer)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    		g.Go(func() error {
    			// Get the set where it would be placed.
    			storageInfos[index] = getDiskInfos(ctx, pool.getHashedSet(object).getDisks()...)
    			return nil
    		}, index)
    	}
    
    	// Wait for the go routines.
    	g.Wait()
    
    	for i, zinfo := range storageInfos {
    		if zinfo == nil {
    			serverPools[i] = poolAvailableSpace{Index: i}
    			continue
    		}
    		var available uint64
    		if !isMinioMetaBucketName(bucket) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  5. internal/s3select/select_test.go

    				t.Error(err)
    				return
    			}
    			gotS := strings.TrimSpace(string(got))
    			if !reflect.DeepEqual(gotS, testCase.wantResult) {
    				t.Errorf("received response does not match with expected reply. Query: %s\ngot: %s\nwant:%s", testCase.query, gotS, testCase.wantResult)
    			}
    		})
    		t.Run("simd-"+testCase.name, func(t *testing.T) {
    			if !simdjson.SupportedCPU() {
    				t.Skip("No CPU support")
    			}
    			testReq := testCase.requestXML
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    				// persist in-memory state to disk after every 10secs.
    				batchLogIf(ctx, ri.updateAfter(ctx, api, 10*time.Second, job))
    
    				if wait := globalBatchConfig.ReplicationWait(); wait > 0 {
    					time.Sleep(wait)
    				}
    			}()
    		}
    		wk.Wait()
    
    		ri.RetryAttempts = attempts
    		ri.Complete = ri.ObjectsFailed == 0
    		ri.Failed = ri.ObjectsFailed > 0
    
    		globalBatchJobsMetrics.save(job.ID, ri)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    			if err != nil {
    				return err
    			}
    			diskVersions[index] = resp.Sign
    			dataDirs[index] = resp.OldDataDir
    			return nil
    		}, index)
    	}
    
    	// Wait for all renames to finish.
    	errs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	if err != nil {
    		dg := errgroup.WithNErrs(len(disks))
    		for index, nerr := range errs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  8. cmd/peer-rest-server.go

    	if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) {
    		go globalBootstrapTracer.Publish(ctx, globalTrace)
    	}
    
    	// Wait for remote to cancel and SubscribeJSON to exit.
    	wg.Wait()
    	return nil
    }
    
    func (s *peerRESTServer) BackgroundHealStatusHandler(_ *grid.MSS) (*grid.JSON[madmin.BgHealState], *grid.RemoteErr) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbTransportImpl.java

                                }
                            }
                            else {
                                resp.wait();
                                if ( log.isTraceEnabled() ) {
                                    log.trace("Wait returned " + isDisconnected());
                                }
                                if ( isDisconnected() ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

         * values must be between 1 and [Integer.MAX_VALUE] when converted to milliseconds.
         *
         * The close timeout is the maximum amount of time after the client calls [WebSocket.close] to
         * wait for a graceful shutdown. If the server doesn't respond the web socket will be canceled.
         * The default value is 60 seconds.
         */
        fun webSocketCloseTimeout(
          timeout: Long,
          unit: TimeUnit,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
Back to top