Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for removeEntry (0.08 sec)

  1. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 3.2K 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        // remove absent
        assertFalse(segment.removeEntry(entry, hash, RemovalCause.COLLECTED));
    
        // remove live
        segment.recordWrite(entry, 1, map.ticker.read());
        table.set(0, entry);
        segment.count = 1;
        assertTrue(segment.removeEntry(entry, hash, RemovalCause.COLLECTED));
        assertNotificationEnqueued(map, key, value);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        // remove absent
        assertFalse(segment.removeEntry(entry, hash, RemovalCause.COLLECTED));
    
        // remove live
        segment.recordWrite(entry, 1, map.ticker.read());
        table.set(0, entry);
        segment.count = 1;
        assertTrue(segment.removeEntry(entry, hash, RemovalCause.COLLECTED));
        assertNotificationEnqueued(map, key, value);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
Back to top