Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 352 for awaited (0.07 seconds)

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

  1. src/test/java/org/codelibs/fess/job/ExecJobTest.java

                    execJob.jvmOptions("-Xms" + i + "m");
                }
                latch.countDown();
            });
    
            t1.start();
            t2.start();
    
            assertTrue(latch.await(5, TimeUnit.SECONDS));
            // The exact size may vary due to concurrent modifications, just check it's not empty
            assertTrue(execJob.jvmOptions.size() > 0);
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 24.8K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      }
    
      /** For testing: force this web socket to release its threads. */
      @Throws(InterruptedException::class)
      fun tearDown() {
        taskQueue.shutdown()
        taskQueue.idleLatch().await(10, TimeUnit.SECONDS)
      }
    
      @Synchronized fun sentPingCount(): Int = sentPingCount
    
      @Synchronized fun receivedPingCount(): Int = receivedPingCount
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

              request: Request,
            ) {
              // Wait for the server to send the duplex response before acting on the 301 response
              // and resetting the stream.
              duplexResponseSent.await()
            }
          }
        client =
          client
            .newBuilder()
            .eventListener(eventRecorder.eventListener + requestHeadersEndListener)
            .build()
        val body =
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  4. cmd/xl-storage-format-v2_gen.go

    	var zb0001 uint32
    	zb0001, err = dc.ReadArrayHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if zb0001 != 7 {
    		err = msgp.ArrayError{Wanted: 7, Got: zb0001}
    		return
    	}
    	err = dc.ReadExactBytes((z.VersionID)[:])
    	if err != nil {
    		err = msgp.WrapError(err, "VersionID")
    		return
    	}
    	z.ModTime, err = dc.ReadInt64()
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 55.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

        if (lastElementAt == index) {
          // 'actualLastElement' is now at 'lastElementAt', and the element that was at 'lastElementAt'
          // is now at the end of queue. If that's the element we wanted to remove in the first place,
          // don't try to (incorrectly) trickle it. Instead, just delete it and we're done.
          queue[size] = null;
          return null;
        }
        E toTrickle = elementData(size);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 34K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/base/Converter.java

     * guarantee that as long as we also require the input type to be non-null[*] (which is a
     * requirement that existing callers already fulfill).
     *
     * Disclaimer: Part of the reason that callers are so well adapted to `Function<A, B>` may be that
     * that is how the signature looked even prior to this comment! So naturally any change can break
     * existing users, but it can't *fix* existing users because any users who needed
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jun 18 21:43:06 GMT 2025
    - 22.8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/primitives/Doubles.java

        double[] toDoubleArray() {
          return Arrays.copyOfRange(array, start, end);
        }
    
        @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;
      }
    
      /**
       * This is adapted from the regex suggested by {@link Double#valueOf(String)} for prevalidating
       * inputs. All valid inputs must pass this regex, but it's semantically fine if not all inputs
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 16:38:16 GMT 2026
    - 27.8K bytes
    - Click Count (0)
  8. src/archive/tar/common.go

    		if wantFormat.has(FormatPAX) && !preferPAX {
    			wantFormat.mayBe(FormatUSTAR) // PAX implies USTAR allowed too
    		}
    		format.mayOnlyBe(wantFormat) // Set union of formats allowed and format wanted
    	}
    	if format == FormatUnknown {
    		switch h.Format {
    		case FormatUSTAR:
    			err = headerError{"Format specifies USTAR", whyNoUSTAR, whyOnlyPAX, whyOnlyGNU}
    		case FormatPAX:
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Oct 07 19:46:36 GMT 2025
    - 24.5K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/MinMaxPriorityQueue.java

        if (lastElementAt == index) {
          // 'actualLastElement' is now at 'lastElementAt', and the element that was at 'lastElementAt'
          // is now at the end of queue. If that's the element we wanted to remove in the first place,
          // don't try to (incorrectly) trickle it. Instead, just delete it and we're done.
          queue[size] = null;
          return null;
        }
        E toTrickle = elementData(size);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 13:11:08 GMT 2026
    - 34K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

                latch.countDown();
            }).error(t -> {
                t.printStackTrace();
                latch.countDown();
                fail();
            });
            latch.await();
            assertEquals(num, numObInputDoc.get());
    
            SuggestResponse response = suggester.suggest().setQuery("test").setSuggestDetail(true).execute().getResponse();
            assertEquals(1, response.getNum());
        }
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 37.1K bytes
    - Click Count (0)
Back to Top