Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 471 - 480 of 726 for lastN (0.04 seconds)

  1. internal/event/target/kafka.go

    	if err = target.init(); err != nil {
    		return err
    	}
    	switch {
    	case key.ItemCount == 1:
    		var event event.Event
    		event, err = target.store.Get(key)
    		if err != nil {
    			// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    			// Such events will not exist and wouldve been already been sent successfully.
    			if os.IsNotExist(err) {
    				return nil
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  2. cmd/admin-heal-ops.go

    	// channel signaled by background routine when traversal has
    	// completed
    	traverseAndHealDoneCh chan error
    
    	// canceler to cancel heal sequence.
    	cancelCtx context.CancelFunc
    
    	// the last result index sent to client
    	lastSentResultIndex int64
    
    	// Number of total items scanned against item type
    	scannedItemsMap map[madmin.HealItemType]int64
    
    	// Number of total items healed against item type
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

         *
         * Current strategy is based on failure count. In the future, this could be enhanced to consider:
         * - Recent event frequency (successful notifications)
         * - Time since last successful notification
         * - Events per unit time for more adaptive behavior
         *
         * @param handle notification handle
         * @return polling interval in milliseconds
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 13.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/cache/LoadingCache.java

       * {@link #get} instead.
       *
       * @throws UncheckedExecutionException if an exception was thrown while loading the value. (As
       *     explained in the last paragraph above, this should be an unchecked exception only.)
       * @throws ExecutionError if an error was thrown while loading the value
       */
      @CanIgnoreReturnValue // TODO(b/27479612): consider removing this?
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 8.3K bytes
    - Click Count (0)
  5. src/main/resources/fess_message_de.properties

    # ========================================================================================
    # Framework Default
    # =================
    # ----------------------------------------------------------
    # Lasta Taglib
    # ------------
    errors.header = <ul class="has-error">
    errors.footer = </ul>
    errors.prefix = <li><i class="fa fa-exclamation-circle"></i>
    errors.suffix = </li>
    # ----------------------------------------------------------
    # Javax Validator
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sat Jul 05 02:36:47 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/ObjectArrays.java

       * @param element the element to append to the end
       * @return an array whose size is one larger than {@code array}, with the same contents as {@code
       *     array}, plus {@code element} occupying the last position.
       */
      public static <T extends @Nullable Object> T[] concat(T[] array, @ParametricNullness T element) {
        T[] result = Arrays.copyOf(array, array.length + 1);
        result[array.length] = element;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Dec 09 15:48:28 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/collect/FilteredCollectionsTestUtil.java

        }
    
        public void testLast() {
          for (List<Integer> contents : SAMPLE_INPUTS) {
            C filtered = filter(createUnfiltered(contents), EVEN);
    
            try {
              Integer first = filtered.last();
              assertFalse(filtered.isEmpty());
              assertEquals(Ordering.natural().max(filtered), first);
            } catch (NoSuchElementException e) {
              assertTrue(filtered.isEmpty());
            }
          }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  8. cmd/erasure-decode.go

    			if p.buf[bufIdx] == nil {
    				// Reading first time on this disk, hence the buffer needs to be allocated.
    				// Subsequent reads will reuse this buffer.
    				p.buf[bufIdx] = make([]byte, p.shardSize)
    			}
    			// For the last shard, the shardsize might be less than previous shard sizes.
    			// Hence the following statement ensures that the buffer size is reset to the right size.
    			p.buf[bufIdx] = p.buf[bufIdx][:p.shardSize]
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 29 01:40:52 GMT 2024
    - 9.5K bytes
    - Click Count (0)
  9. src/main/resources/fess_message_es.properties

    # ========================================================================================
    # Framework Default
    # =================
    # ----------------------------------------------------------
    # Lasta Taglib
    # ------------
    errors.header = <ul class="has-error">
    errors.footer = </ul>
    errors.prefix = <li><i class="fa fa-exclamation-circle"></i>
    errors.suffix = </li>
    # ----------------------------------------------------------
    # Javax Validator
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Jul 10 04:56:21 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  10. internal/event/target/postgresql.go

    			if IsConnErr(err) {
    				return store.ErrNotConnected
    			}
    			return err
    		}
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
Back to Top