- Sort Score
- Result 10 results
- Languages All
Results 531 - 540 of 940 for torrent (0.26 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* Our solution is for threads to CAS seenExceptions from null to a Set populated with _the * initial exception_, no matter which thread does the work. This ensures that seenExceptions * always contains not just the current thread's exception but also the initial thread's. */ Set<Throwable> seenExceptionsLocal = seenExceptions; if (seenExceptionsLocal == null) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
// and when it is done will run the listeners. if (hasListeners.compareAndSet(false, true)) { if (delegate.isDone()) { // If the delegate is already done, run the execution list immediately on the current // thread. executionList.execute(); return; } // TODO(lukes): handle RejectedExecutionException adapterExecutor.execute( () -> {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
guava/src/com/google/common/escape/CharEscaper.java
// Loop through the rest of the string, replacing when needed into the // destination buffer, which gets grown as needed as well. for (; index < slen; index++) { // Get a replacement for the current character. char[] r = escape(s.charAt(index)); // If no replacement is needed, just continue. if (r == null) { continue; } int rlen = r.length;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jan 18 20:55:09 UTC 2022 - 6.7K bytes - Viewed (0) -
cmd/admin-handler-utils.go
// When nil ObjectLayer has been returned an error has always been sent to w. func validateAdminReq(ctx context.Context, w http.ResponseWriter, r *http.Request, actions ...policy.AdminAction) (ObjectLayer, auth.Credentials) { // Get current object layer instance. objectAPI := newObjectLayerFn() if objectAPI == nil || globalNotificationSys == nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return nil, auth.Credentials{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 03 07:17:20 UTC 2024 - 8.4K bytes - Viewed (0) -
src/bufio/scan_test.go
lines := []string{ "abcdefghijklmn", "opqrstuvwxyz", "", } testNoNewline(text, lines, t) } var testError = errors.New("testError") // Test the correct error is returned when the split function errors out. func TestSplitError(t *testing.T) { // Create a split function that delivers a little data, then a predictable error. numSplits := 0 const okCount = 7
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Sep 22 16:22:42 UTC 2023 - 14.3K bytes - Viewed (0) -
src/cmd/api/main_test.go
} } // export emits the exported package features. func (w *Walker) export(pkg *apiPackage) { if verbose { log.Println(pkg) } pop := w.pushScope("pkg " + pkg.Path()) w.current = pkg w.collectDeprecated() scope := pkg.Scope() for _, name := range scope.Names() { if token.IsExported(name) { w.emitObj(scope.Lookup(name)) } } pop() }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Sep 04 18:16:59 UTC 2024 - 31.4K bytes - Viewed (0) -
docs/en/docs/management-tasks.md
For Spanish, as I'm a native speaker and it's a language close to me, I will give it a final review myself and in most cases tweak the PR a bit before merging it. For the other languages, confirm that: * The title is correct following the instructions above. * It has the labels `lang-all` and `lang-{lang code}`. * The PR changes only one Markdown file adding a translation.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Aug 16 21:56:33 UTC 2024 - 14.2K bytes - Viewed (0) -
cmd/metacache-bucket.go
if !ok { return update, errFileNotFound } existing.update(update) b.caches[update.id] = existing b.updated = true return existing, nil } // cloneCaches will return a clone of all current caches. func (b *bucketMetacache) cloneCaches() (map[string]metacache, map[string][]string) { b.mu.RLock() defer b.mu.RUnlock() dst := make(map[string]metacache, len(b.caches)) for k, v := range b.caches {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.6K bytes - Viewed (0) -
android/guava/src/com/google/common/escape/CharEscaper.java
// Loop through the rest of the string, replacing when needed into the // destination buffer, which gets grown as needed as well. for (; index < slen; index++) { // Get a replacement for the current character. char[] r = escape(s.charAt(index)); // If no replacement is needed, just continue. if (r == null) { continue; } int rlen = r.length;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jan 18 20:55:09 UTC 2022 - 6.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
} // We reschedule ourselves with a lock held for two reasons. 1. we want to make sure that // cancel calls cancel on the correct future. 2. we want to make sure that the assignment // to currentFuture doesn't race with itself so that currentFuture is assigned in the // correct order. Throwable scheduleFailure = null; Cancellable toReturn; lock.lock(); try {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 16:22:21 UTC 2024 - 27.8K bytes - Viewed (0)