- Sort Score
- Num 10 results
- Language All
Results 341 - 350 of 844 for remote (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava-tests/test/com/google/common/cache/NullCacheTest.java
.build(constantLoader(computed)); Object key = new Object(); assertThat(cache.getUnchecked(key)).isSameInstanceAs(computed); RemovalNotification<Object, Object> notification = listener.remove(); assertThat(notification.getKey()).isSameInstanceAs(key); assertThat(notification.getValue()).isSameInstanceAs(computed); assertThat(notification.getCause()).isEqualTo(RemovalCause.SIZE);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 4.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/IteratorsTest.java
assertTrue(cycle.hasNext()); assertThrows(IllegalStateException.class, () -> cycle.remove()); } public void testCycleRemoveSameElementTwice() { Iterator<String> cycle = Iterators.cycle("a", "b"); cycle.next(); cycle.remove(); assertThrows(IllegalStateException.class, () -> cycle.remove()); } public void testCycleWhenRemoveIsNotSupported() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:44:53 GMT 2025 - 56.7K bytes - Click Count (0) -
cmd/peer-s3-server.go
State: beforeState[i], }) } // check dangling and delete bucket only if its not a meta bucket if !isMinioMetaBucketName(bucket) && !isAllBucketsNotFound(errs) && opts.Remove { g := errgroup.WithNErrs(len(localDrives)) for index := range localDrives { g.Go(func() error { if localDrives[index] == nil { return errDiskNotFound }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.2K bytes - Click Count (0) -
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 Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 22.4K bytes - Click Count (0) -
cmd/os-instrumented.go
func Lstat(name string) (info os.FileInfo, err error) { defer updateOSMetrics(osMetricLstat, name)(err) return os.Lstat(name) } // Remove captures time taken to call os.Remove func Remove(deletePath string) (err error) { defer updateOSMetrics(osMetricRemove, deletePath)(err) return os.Remove(deletePath) } // Stat captures time taken to call os.Stat func Stat(name string) (info os.FileInfo, err error) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 6.2K bytes - Click Count (0) -
internal/ioutil/ioutil_test.go
f, err := os.CreateTemp(t.TempDir(), "") if err != nil { t.Fatal(err) } name1 := f.Name() defer os.Remove(name1) f.WriteString("aaaaaaaaaa") f.Close() f, err = os.CreateTemp(t.TempDir(), "") if err != nil { t.Fatal(err) } name2 := f.Name() defer os.Remove(name2) f.WriteString("bbbbbbbbbb") f.Close() if err = AppendFile(name1, name2, false); err != nil { t.Error(err)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 5.6K bytes - Click Count (0) -
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 Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Aug 30 11:30:11 GMT 2025 - 10.4K bytes - Click Count (0) -
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 Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 7.8K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/IteratorFeature.java
* * <p>This enum is GWT compatible. * * @author Chris Povirk */ @GwtCompatible public enum IteratorFeature { /** Support for {@link Iterator#remove()}. */ SUPPORTS_REMOVE, /** * Support for {@link ListIterator#add(Object)}; ignored for plain {@link Iterator} * implementations. */ SUPPORTS_ADD, /**Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 03 18:22:43 GMT 2023 - 1.9K bytes - Click Count (0) -
api/README
Each file is a list of API features, one per line. go1.txt (and similarly named files) are frozen once a version has been shipped. Each file adds new lines but does not remove any. except.txt lists features that may disappear without breaking true compatibility. Starting with go1.19.txt, each API feature line must end in "#nnnnn" giving the GitHub issue number of the proposal issue that accepted
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Wed Jan 31 19:22:50 GMT 2024 - 1.2K bytes - Click Count (0)