Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for removeEntry (0.14 sec)

  1. cmd/local-locker.go

    			// Unless it is a write lock reject it.
    			err = fmt.Errorf("unlock attempted on a read locked entity: %s", resource)
    			continue
    		}
    		if ok {
    			reply = l.removeEntry(resource, args, &lri) || reply
    		}
    	}
    	return reply, err
    }
    
    // removeEntry based on the uid of the lock message, removes a single entry from the
    // lockRequesterInfo array or the whole array from the map (in case of a write lock
    // or last read lock)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/AbstractMapBasedMultiset.java

        if (oldCount > occurrences) {
          numberRemoved = occurrences;
          backingMap.setValue(entryIndex, oldCount - occurrences);
        } else {
          numberRemoved = oldCount;
          backingMap.removeEntry(entryIndex);
        }
        size -= numberRemoved;
        return oldCount;
      }
    
      @CanIgnoreReturnValue
      @Override
      public final int setCount(@ParametricNullness E element, int count) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 05 23:15:58 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. internal/event/target/elasticsearch.go

    type esClient interface {
    	isAtleastV7() bool
    	createIndex(ElasticsearchArgs) error
    	ping(context.Context, ElasticsearchArgs) (bool, error)
    	stop()
    	entryExists(context.Context, string, string) (bool, error)
    	removeEntry(context.Context, string, string) error
    	updateEntry(context.Context, string, string, event.Event) error
    	addEntry(context.Context, string, event.Event) error
    }
    
    // ElasticsearchArgs - Elasticsearch target arguments.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/HashBiMap.java

        }
      }
    
      /** Removes the entry at the specified index with no additional data. */
      private void removeEntry(int entry) {
        removeEntryKeyHashKnown(entry, Hashing.smearedHash(keys[entry]));
      }
    
      /** Removes the entry at the specified index, given the hash of its key and value. */
      private void removeEntry(int entry, int keyHash, int valueHash) {
        checkArgument(entry != ABSENT);
        deleteFromTableKToV(entry, keyHash);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Dec 16 14:46:34 UTC 2025
    - 37.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/ObjectCountHashMap.java

              return oldValue;
            }
          }
          last = next;
          next = getNext(entries[next]);
        } while (next != UNSET);
        return 0;
      }
    
      @CanIgnoreReturnValue
      int removeEntry(int entryIndex) {
        return remove(keys[entryIndex], getHash(entries[entryIndex]));
      }
    
      /**
       * Moves the last entry in the entry array into {@code dstIndex}, and nulls out its old position.
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 14.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/LocalCache.java

          ReferenceEntry<K, V> e;
          while ((e = writeQueue.peek()) != null && map.isExpired(e, now)) {
            if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
              throw new AssertionError();
            }
          }
          while ((e = accessQueue.peek()) != null && map.isExpired(e, now)) {
            if (!removeEntry(e, e.getHash(), RemovalCause.EXPIRED)) {
              throw new AssertionError();
            }
          }
        }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 19:35:11 UTC 2025
    - 148.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        // remove absent
        assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isFalse();
    
        // remove live
        segment.recordWrite(entry, 1, map.ticker.read());
        table.set(0, entry);
        segment.count = 1;
        assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isTrue();
        assertNotificationEnqueued(map, key, value);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 117.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        // remove absent
        assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isFalse();
    
        // remove live
        segment.recordWrite(entry, 1, map.ticker.read());
        table.set(0, entry);
        segment.count = 1;
        assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isTrue();
        assertNotificationEnqueued(map, key, value);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 115.9K bytes
    - Viewed (0)
Back to top