Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 591 - 600 of 1,560 for remote (0.05 seconds)

  1. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

         * @param key lease key
         */
        public void releaseLease(Smb2LeaseKey key) {
            lock.writeLock().lock();
            try {
                LeaseEntry entry = leases.remove(key);
                if (entry != null) {
                    pathToLease.remove(entry.getPath());
                    log.debug("Released lease for path: {} with key: {}", entry.getPath(), key);
                }
            } finally {
                lock.writeLock().unlock();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 18.8K bytes
    - Click Count (0)
  2. internal/lru/lru.go

    		}
    		return ent.Value, true
    	}
    	return
    }
    
    // Remove removes the provided key from the cache, returning if the
    // key was contained.
    func (c *LRU[K, V]) Remove(key K) bool {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	if ent, ok := c.items[key]; ok {
    		c.removeElement(ent)
    		return true
    	}
    	return false
    }
    
    // RemoveOldest removes the oldest item from the cache.
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/LinkedHashMultimap.java

              nextEntry = entry.successorInValueSet;
              return result;
            }
    
            @Override
            public void remove() {
              checkForComodification();
              checkState(toRemove != null, "no calls to next() since the last call to remove()");
              ValueSet.this.remove(toRemove.getValue());
              expectedModCount = modCount;
              toRemove = null;
            }
          };
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:08:09 GMT 2025
    - 19.2K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/LinkedHashMultimap.java

              nextEntry = entry.successorInValueSet;
              return result;
            }
    
            @Override
            public void remove() {
              checkForComodification();
              checkState(toRemove != null, "no calls to next() since the last call to remove()");
              ValueSet.this.remove(toRemove.getValue());
              expectedModCount = modCount;
              toRemove = null;
            }
          };
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 20:08:09 GMT 2025
    - 20K bytes
    - Click Count (0)
  5. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

        E[] items = this.items;
        E x = items[takeIndex];
        items[takeIndex] = null;
        takeIndex = inc(takeIndex);
        --count;
        return x;
      }
    
      /**
       * Utility for remove and iterator.remove: Delete item at position i. Call only when occupying
       * monitor.
       */
      void removeAt(int i) {
        E[] items = this.items;
        // if removing front item, just advance
        if (i == takeIndex) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 22.4K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/cisupport/CIDetectorHelper.java

    import org.apache.maven.api.cli.cisupport.CIInfo;
    
    /**
     * CI detector helper: it uses service discovery to discover {@link CIDetector}s. If resulting list has more than
     * one element, it will remove the {@link GenericCIDetector} result, assuming a more specific one is also present.
     */
    public final class CIDetectorHelper {
        private CIDetectorHelper() {}
    
        public static List<CIInfo> detectCI() {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sun Apr 13 18:50:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  7. internal/bucket/lifecycle/lifecycle_test.go

    			objectName:     "foxdir/fooobject/foo.txt",
    			objectModTime:  time.Now().UTC().Add(-10 * 24 * time.Hour), // Created 10 days ago
    			expectedAction: DeleteAction,
    		},
    		// Too early to remove (test Days)
    		{
    			inputConfig:    `<LifecycleConfiguration><Rule><Filter><Prefix>foodir/</Prefix></Filter><Status>Enabled</Status><Expiration><Days>5</Days></Expiration></Rule></LifecycleConfiguration>`,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 55.5K bytes
    - Click Count (0)
  8. internal/event/targetlist.go

    }
    
    // TargetIDResult returns result of Remove/Send operation, sets err if
    // any for the associated TargetID
    type TargetIDResult struct {
    	// ID where the remove or send were initiated.
    	ID TargetID
    	// Stores any error while removing a target or while sending an event.
    	Err error
    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

          } else {
            readyQueues.remove(taskQueue)
          }
        }
    
        if (coordinatorWaiting) {
          backend.coordinatorNotify(this@TaskRunner)
        } else {
          startAnotherThread()
        }
      }
    
      private fun beforeRun(task: Task) {
        assertLockHeld()
    
        task.nextExecuteNanoTime = -1L
        val queue = task.queue!!
        queue.futureTasks.remove(task)
        readyQueues.remove(queue)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Aug 30 11:30:11 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  10. internal/store/queuestore.go

    			continue
    		}
    		if fi, err := file.Info(); err == nil {
    			store.entries[file.Name()] = fi.ModTime().UnixNano()
    		}
    	}
    
    	return nil
    }
    
    // Delete - Remove the store directory from disk
    func (store *QueueStore[_]) Delete() error {
    	return os.Remove(store.directory)
    }
    
    // PutMultiple - puts an item to the store.
    func (store *QueueStore[I]) PutMultiple(items []I) (Key, error) {
    	// Generate a new UUID for the key.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
Back to Top