Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for removeEntry (0.19 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

        initialize()
    
        checkNotClosed()
        validateKey(key)
        val entry = lruEntries[key] ?: return false
        val removed = removeEntry(entry)
        if (removed && size <= maxSize) mostRecentTrimFailed = false
        return removed
      }
    
      @Throws(IOException::class)
      internal fun removeEntry(entry: Entry): Boolean {
        // If we can't delete files that are still open, mark this entry as a zombie so its files will
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 34.7K bytes
    - Viewed (0)
  2. 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
    }
    
    // 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)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  3. cmd/lock-rest-server-common_test.go

    		lockRequesterInfo1,
    		lockRequesterInfo2,
    	}
    
    	lri := locker.ll.lockMap["name"]
    
    	// test unknown uid
    	if locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "unknown-uid",
    	}, &lri) {
    		t.Errorf("Expected %#v, got %#v", false, true)
    	}
    
    	if !locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "0123-4567",
    	}, &lri) {
    		t.Errorf("Expected %#v, got %#v", true, false)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 23 17:26:21 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  4. 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.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/HashBiMap.java

        }
      }
    
      /** Removes the entry at the specified index with no additional data. */
      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);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Mar 06 16:06:58 GMT 2023
    - 36.4K bytes
    - Viewed (0)
  6. 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) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Mar 06 16:06:58 GMT 2023
    - 8.2K bytes
    - Viewed (0)
  7. 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.
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Jun 01 22:07:10 GMT 2021
    - 15K bytes
    - Viewed (0)
  8. android/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();
            }
          }
        }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 144.7K bytes
    - Viewed (0)
  9. 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();
            }
          }
        }
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 150.3K bytes
    - Viewed (0)
  10. maven-core/src/test/resources/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar

    public String toString(); public java.util.Collection values(); public java.util.Set entrySet(); public java.util.Set keySet(); protected void sizeChanged(); private static int keyHash(Object); private void addEntry(Object, Object); private void removeEntry(FastMap$EntryImpl); private void initialize(int); private void readObject(java.io.ObjectInputStream) throws java.io.IOException, ClassNotFoundExcepti; private void writeObject(java.io.ObjectOutputStream) throws java.io.IOException; } org/codeha...
    Archive
    - Registered: Sun Mar 31 03:35:09 GMT 2024
    - Last Modified: Tue Oct 16 20:15:40 GMT 2007
    - 164.6K bytes
    - Viewed (0)
Back to top