Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 770 for NEXT (0.04 sec)

  1. internal/grid/connection.go

    				return
    			}
    			var next []byte
    			next, remain, err = msgp.ReadBytesZC(remain)
    			if err != nil {
    				if !xnet.IsNetworkOrHostDown(err, true) {
    					gridLogIf(ctx, fmt.Errorf("ws read merged: %w", err))
    				}
    				return
    			}
    
    			m.Payload = nil
    			subID, _, err = m.parse(next)
    			if err != nil {
    				if !xnet.IsNetworkOrHostDown(err, true) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. src/archive/tar/writer.go

    	fileState
    
    	ReadFrom(io.Reader) (int64, error)
    }
    
    // Flush finishes writing the current file's block padding.
    // The current file must be fully written before Flush can be called.
    //
    // This is unnecessary as the next call to [Writer.WriteHeader] or [Writer.Close]
    // will implicitly flush out the file's padding.
    func (tw *Writer) Flush() error {
    	if tw.err != nil {
    		return tw.err
    	}
    	if nb := tw.curr.logicalRemaining(); nb > 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/collect/RangeTest.java

      }
    
      private static final DiscreteDomain<Integer> UNBOUNDED_DOMAIN =
          new DiscreteDomain<Integer>() {
            @Override
            public Integer next(Integer value) {
              return integers().next(value);
            }
    
            @Override
            public Integer previous(Integer value) {
              return integers().previous(value);
            }
    
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/google/MultimapTestSuiteBuilder.java

            Iterator<V> valueItr = valueIterators.get(key);
            if (valueItr == null) {
              valueIterators.put(key, valueItr = sampleValuesIterator());
            }
            entries[i] = mapEntry(key, valueItr.next());
          }
          return multimapGenerator.create((Object[]) entries).keys();
        }
    
        private Iterator<V> sampleValuesIterator() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. cmd/bucket-metadata-sys.go

    				bucket := buckets[i].Name
    				updated := false
    
    				meta, err := loadBucketMetadata(ctx, sys.objAPI, bucket)
    				if err != nil {
    					internalLogIf(ctx, err, logger.WarningKind)
    					wait() // wait to proceed to next entry.
    					continue
    				}
    
    				sys.Lock()
    				// Update if the bucket metadata in the memory is older than on-disk one
    				if lu := sys.metadataMap[bucket].lastUpdate(); lu.Before(meta.lastUpdate()) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/smb1/Trans2FindFirst2Response.java

                 * or to the start of the entry containing the
                 * filename(e.g. NT). Ahhrg! In either case the
                 * lastNameOffset falls between the start of the
                 * entry and the next entry.
                 */
    
                if( lastNameBufferIndex >= bufferIndex && ( e.nextEntryOffset == 0 ||
                            lastNameBufferIndex < ( bufferIndex + e.nextEntryOffset ))) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 8.5K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/google/MultimapPutTester.java

          Iterator<Entry<K, Collection<V>>> asMapItr = multimap().asMap().entrySet().iterator();
          Collection<V> collection = null;
          while (asMapItr.hasNext()) {
            Entry<K, Collection<V>> asMapEntry = asMapItr.next();
            if (key.equals(asMapEntry.getKey())) {
              collection = asMapEntry.getValue();
              break;
            }
          }
          assertNotNull(collection);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionAddAllTester.java

            ConcurrentModificationException.class,
            () -> {
              Iterator<E> iterator = collection.iterator();
              assertTrue(collection.addAll(MinimalCollection.of(e3(), e0())));
              iterator.next();
            });
      }
    
      @CollectionFeature.Require(absent = SUPPORTS_ADD)
      @CollectionSize.Require(absent = ZERO)
      public void testAddAll_unsupportedAllPresent() {
        try {
          assertFalse(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt

    class WebSocketRecorder(
      private val name: String,
    ) : WebSocketListener() {
      private val events = LinkedBlockingQueue<Any>()
      private var delegate: WebSocketListener? = null
    
      /** Sets a delegate for handling the next callback to this listener. Cleared after invoked.  */
      fun setNextEventDelegate(delegate: WebSocketListener?) {
        this.delegate = delegate
      }
    
      override fun onOpen(
        webSocket: WebSocket,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/collect/testing/google/MultimapPutTester.java

          Iterator<Entry<K, Collection<V>>> asMapItr = multimap().asMap().entrySet().iterator();
          Collection<V> collection = null;
          while (asMapItr.hasNext()) {
            Entry<K, Collection<V>> asMapEntry = asMapItr.next();
            if (key.equals(asMapEntry.getKey())) {
              collection = asMapEntry.getValue();
              break;
            }
          }
          assertNotNull(collection);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7.2K bytes
    - Viewed (0)
Back to top