Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 462 for slop (0.03 sec)

  1. guava-tests/test/com/google/common/collect/AbstractImmutableSetTest.java

      }
    
      @GwtIncompatible // slow (~40s)
      public void testIterator_oneElement() {
        new IteratorTester<String>(
            5, UNMODIFIABLE, singleton("a"), IteratorTester.KnownOrder.KNOWN_ORDER) {
          @Override
          protected Iterator<String> newTargetIterator() {
            return of("a").iterator();
          }
        }.test();
      }
    
      @GwtIncompatible // slow (~30s)
      public void testIterator_general() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    	}
    
    	st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload)
    	if err != nil {
    		return
    	}
    	st.Results(func(b []byte) error {
    		select {
    		case traceCh <- b:
    		default:
    			// Do not block on slow receivers.
    			// Just recycle the buffer.
    			grid.PutByteBuffer(b)
    		}
    		return nil
    	})
    }
    
    func (client *peerRESTClient) doListen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
       * method to cancel pending work and then call {@link #notifyStopped} to stop the service.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
       * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  4. internal/grid/muxclient.go

    			xioutil.SafeClose(respHandler)
    		}
    	}()
    	var pingTimer <-chan time.Time
    	if m.deadline == 0 || m.deadline > m.clientPingInterval {
    		ticker := time.NewTicker(m.clientPingInterval)
    		defer ticker.Stop()
    		pingTimer = ticker.C
    		atomic.StoreInt64(&m.LastPong, time.Now().UnixNano())
    	}
    	defer m.parent.deleteMux(false, m.MuxID)
    	for {
    		select {
    		case <-m.ctx.Done():
    			if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

                    } else if (logger.isDebugEnabled()) {
                        logger.debug("Terminated process {}.", p);
                    }
                } catch (final Exception e) {
                    logger.warn("Failed to stop destroyer.", e);
                }
            }
    
            public boolean isExecuted() {
                return executed.get();
            }
        }
    
        public void setCommandList(final List<String> commandList) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
             * If we have spun a lot, just park ourselves. This will save CPU while we wait for a slow
             * interrupting thread. In theory, interruptTask() should be very fast, but due to
             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  7. cmd/veeam-sos-api.go

    //     higher task limit).
    //
    //     <S3ConcurrentTaskLimit>
    //
    //   - Defines how many S3 operations are executed parallel within one Repository Task Slot (and within one backup object
    //     that gets offloaded). The same registry key setting overwrites the storage-defined setting.
    //     Optional value, default 64, range: 1-unlimited
    //
    //   - <S3MultiObjectDeleteLimit>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. android/guava/pom.xml

                <!-- Even after we stop using JSR305 annotations in our own code, we'll want this link so that NullPointerTester's docs can link to @CheckForNull and friends... at least once we start using this config for guava-testlib. -->
                <offlineLink>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 18:53:31 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. internal/logger/target/http/http.go

    	// The Send() method will then re-direct entries
    	// to the new target when the current one
    	// has been set to status "statusClosed".
    	// Once the glogal target slice has been migrated
    	// the current target will stop receiving entries.
    	migrateTarget *Target
    
    	// Number of events per HTTP send to webhook target
    	// this is ideally useful only if your endpoint can
    	// support reading multiple events on a stream for example
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

            }
    
            logger.info("Finished SuggestCreator.");
            System.exit(exitCode);
        }
    
        private static void destroyContainer() {
            TimeoutManager.getInstance().stop();
            synchronized (SingletonLaContainerFactory.class) {
                SingletonLaContainerFactory.destroy();
            }
        }
    
        private static int process(final Options options) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top