- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 679 for Continued (0.12 sec)
-
cmd/object-api-putobject_test.go
t.Errorf("Test %d: %s: Expected to pass, but failed with: error %s.", i, instanceType, actualErr.Error()) continue } if actualErr == nil && testCase.expectedError != nil { t.Errorf("Test %d: %s: Expected to fail with error \"%s\", but passed instead.", i, instanceType, testCase.expectedError.Error()) continue } // Failed as expected, but does it fail for the expected reason.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 25.8K bytes - Viewed (0) -
bin/check_samples.sh
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Nov 04 01:54:50 UTC 2023 - 1010 bytes - Viewed (0) -
cmd/admin-handlers.go
enc := json.NewEncoder(&buf) for { select { case <-ctx.Done(): return case li := <-logCh: if !li.SendLog(node, logKind) { continue } buf.Reset() if err := enc.Encode(li); err != nil { continue } select { case <-ctx.Done(): return case encodedCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...): } } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
if (oldValue == 0L) { // don't compareAndSet a zero if (map.replace(key, atomic, new AtomicLong(delta))) { return delta; } // atomic replaced continue outer; } long newValue = oldValue + delta; if (atomic.compareAndSet(oldValue, newValue)) { return newValue; } // value changed } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 14.1K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
// instead of serializing the Go routines. sys.Lock() for i, meta := range bucketMetas { if errs[i] != nil { continue } sys.metadataMap[buckets[i]] = meta } sys.Unlock() for i, meta := range bucketMetas { if errs[i] != nil { continue } globalEventNotifier.set(buckets[i], meta) // set notification targets
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
cmd/bucket-targets.go
if t.Type == tgt.Type { if t.Arn == tgt.Arn { if !update { return BucketRemoteAlreadyExists{Bucket: t.TargetBucket} } newtgts[idx] = *tgt found = true continue } // fail if endpoint is already present in list of targets and not a matching ARN if t.Endpoint == tgt.Endpoint { return BucketRemoteAlreadyExists{Bucket: t.TargetBucket} } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 20.9K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
seenClient := set.NewStringSet() var clnts []*bootstrapRESTClient for _, ep := range endpointServerPools { for _, endpoint := range ep.Endpoints { if endpoint.IsLocal { continue } if seenClient.Contains(endpoint.Host) { continue } seenClient.Add(endpoint.Host) clnts = append(clnts, &bootstrapRESTClient{gm.Connection(endpoint.GridHost())}) } } return clnts
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 8.4K bytes - Viewed (0) -
src/bytes/reader_test.go
pos, err := r.Seek(tt.off, tt.seek) if err == nil && tt.seekerr != "" { t.Errorf("%d. want seek error %q", i, tt.seekerr) continue } if err != nil && err.Error() != tt.seekerr { t.Errorf("%d. seek error = %q; want %q", i, err.Error(), tt.seekerr) continue } if tt.wantpos != 0 && tt.wantpos != pos { t.Errorf("%d. pos = %d, want %d", i, pos, tt.wantpos) } buf := make([]byte, tt.n)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/UniAddress.java
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 16.2K bytes - Viewed (0) -
internal/grid/connection.go
atomic.StoreInt64(&c.LastPong, time.Now().UnixNano()) continue } toSend, err = pingFrame.MarshalMsg(GetByteBuffer()[:0]) if err != nil { gridLogIf(ctx, err) // Fake it... Though this should never fail. atomic.StoreInt64(&c.LastPong, time.Now().UnixNano()) continue } case toSend = <-c.outQueue: if len(toSend) == 0 { continue } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0)