Search Options

Results per page
Sort
Preferred Languages
Advance

Results 711 - 720 of 1,818 for Pong (0.05 sec)

  1. src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java

            final IndexResponse response = builder.execute().actionGet(indexTimeout);
            final long seqNo = response.getSeqNo();
            if (seqNo != SequenceNumbers.UNASSIGNED_SEQ_NO) {
                esEntity.asDocMeta().seqNo(seqNo);
            }
            final long primaryTerm = response.getPrimaryTerm();
            if (primaryTerm != SequenceNumbers.UNASSIGNED_PRIMARY_TERM) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

       */
      val requestCount: Int
        get() = atomicRequestCount.get()
    
      /** The number of bytes of the POST body to keep in memory to the given limit. */
      var bodyLimit: Long = Long.MAX_VALUE
    
      var serverSocketFactory: ServerSocketFactory? = null
        @Synchronized get() {
          if (field == null && started) {
            field = ServerSocketFactory.getDefault() // Build the default value lazily.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      private val forbiddenLocks = mutableListOf<Any>()
    
      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

          object : Source {
            private var cacheRequestClosed = false
    
            @Throws(IOException::class)
            override fun read(
              sink: Buffer,
              byteCount: Long,
            ): Long {
              val bytesRead: Long
              try {
                bytesRead = source.read(sink, byteCount)
              } catch (e: IOException) {
                if (!cacheRequestClosed) {
                  cacheRequestClosed = true
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Mar 22 07:09:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/base/internal/Finalizer.java

        String threadName = Finalizer.class.getName();
        Thread thread = null;
        if (bigThreadConstructor != null) {
          try {
            boolean inheritThreadLocals = false;
            long defaultStackSize = 0;
            thread =
                bigThreadConstructor.newInstance(
                    (ThreadGroup) null, finalizer, threadName, defaultStackSize, inheritThreadLocals);
          } catch (Throwable t) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Aug 23 12:54:09 UTC 2023
    - 9.4K bytes
    - Viewed (0)
  6. docs_src/sql_databases_peewee/sql_app/main.py

    )
    def read_slow_users(skip: int = 0, limit: int = 100):
        global sleep_time
        sleep_time = max(0, sleep_time - 1)
        time.sleep(sleep_time)  # Fake long processing request
        users = crud.get_users(skip=skip, limit=limit)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 2.2K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/options.go

    	// since the IP is normally the same), we SNAT identified host probes in the host netns to a fixed
    	// APIPA/"link-local" IP.
    	//
    	// It doesn't matter what this IP is, so long as it's not routable and doesn't collide with anything else.
    	//
    	// IPv6 link local ranges are designed to be collision-resistant by default, and so probably never need to be overridden
    	DefaultHostProbeSNATIP   = "169.254.7.127"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/io/Smb2ReadRequest.java

        private byte[] fileId;
        private final byte[] outputBuffer;
        private final int outputBufferOffset;
        private byte padding;
        private byte readFlags;
        private int readLength;
        private long offset;
        private int minimumCount;
        private int channel;
        private int remainingBytes;
    
    
        /**
         * @param config
         * @param fileId
         * @param outputBuffer
         * @param outputBufferOffset
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 5.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/TreeMultiset.java

          }
        };
    
        abstract int nodeAggregate(AvlNode<?> node);
    
        abstract long treeAggregate(@CheckForNull AvlNode<?> root);
      }
    
      private long aggregateForEntries(Aggregate aggr) {
        AvlNode<E> root = rootReference.get();
        long total = aggr.treeAggregate(root);
        if (range.hasLowerBound()) {
          total -= aggregateBelowRange(aggr, root);
        }
        if (range.hasUpperBound()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/service/ScheduledJobService.java

                op.rangeSize(fessConfig.getPagingPageRangeSizeAsInteger());
            }).createPageNumberList());
    
            return scheduledJobList;
        }
    
        public List<ScheduledJob> getScheduledJobListAfter(final long updateTime) {
            return scheduledJobBhv.selectPage(cb -> {
                cb.fetchFirst(fessConfig.getPageScheduledJobMaxFetchSizeAsInteger());
                cb.query().setAvailable_Equal(Boolean.TRUE);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top