- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for pendant (0.2 sec)
-
cmd/bucket-handlers.go
if dobj.ObjectName == "" { continue } defer globalCacheConfig.Delete(bucket, dobj.ObjectName) if replicateDeletes && (dobj.DeleteMarkerReplicationStatus() == replication.Pending || dobj.VersionPurgeStatus() == Pending) { // copy so we can re-add null ID. dobj := dobj if isDirObject(dobj.ObjectName) && dobj.VersionID == "" { dobj.VersionID = nullVersionID } dv := DeletedObjectReplicationInfo{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
ServerMessageBlock2Response resp = (ServerMessageBlock2Response) response; synchronized ( resp ) { if ( resp.isAsync() && !resp.isAsyncHandled() && resp.getStatus() == NtStatus.NT_STATUS_PENDING && resp.getAsyncId() != 0 ) { resp.setAsyncHandled(true); boolean first = !req.isAsync(); req.setAsyncId(resp.getAsyncId()); Long exp = resp.getExpiration();
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Wed Jan 18 23:47:00 GMT 2023 - 67K bytes - Viewed (0) -
cmd/batch-handlers.go
} _, err = api.CompleteMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, uploadedParts, opts) return err } // StartFromSource starts the batch replication job from remote source, resumes if there was a pending job via "job.ID" func (r *BatchJobReplicateV1) StartFromSource(ctx context.Context, api ObjectLayer, job BatchJobRequest) error { ri := &batchJobInfo{ JobID: job.ID, JobType: string(job.Type()),
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
InCompletionOrderState<T> localState = state; if (super.cancel(interruptIfRunning)) { /* * requireNonNull is generally safe: If cancel succeeded, then this Future was still * pending, so its `state` field hasn't been nulled out yet. * * OK, it's technically possible for this to fail in the presence of unsafe publishing, as
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java
final AtomicInteger callCount = new AtomicInteger(); // tells the computing thread when to start computing final CountDownLatch computeSignal = new CountDownLatch(1); // tells the main thread when computation is pending final CountDownLatch secondSignal = new CountDownLatch(1); // tells the main thread when the second get has started final CountDownLatch thirdSignal = new CountDownLatch(1);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} message += "delay)"; } // It's confusing to see a completed future in a timeout message; if isDone() returns false, // then we know it must have given a pending toString value earlier. If not, then the future // completed after the timeout expired, and the message might be success. if (isDone()) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
final AtomicInteger callCount = new AtomicInteger(); // tells the computing thread when to start computing final CountDownLatch computeSignal = new CountDownLatch(1); // tells the main thread when computation is pending final CountDownLatch secondSignal = new CountDownLatch(1); // tells the main thread when the second get has started final CountDownLatch thirdSignal = new CountDownLatch(1);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 86.2K bytes - Viewed (0) -
cmd/test-utils_test.go
} // return URL for a listing pending multipart uploads. func getListMultipartURL(endPoint, bucketName string) string { queryValue := url.Values{} queryValue.Set("uploads", "") return makeTestTargetURL(endPoint, bucketName, "", queryValue) } // return URL for listing pending multipart uploads with parameters.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 75.7K bytes - Viewed (0) -
cmd/xl-storage.go
} if sizeS.failedCount > 0 { res["repl-failed"] = fmt.Sprintf("%d versions, %d bytes", sizeS.failedCount, sizeS.failedSize) } if sizeS.pendingCount > 0 { res["repl-pending"] = fmt.Sprintf("%d versions, %d bytes", sizeS.pendingCount, sizeS.pendingSize) } for tgt, st := range sizeS.replTargetStats { res["repl-size-"+tgt] = strconv.FormatInt(st.replicatedSize, 10)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/erasure-server-pool.go
continue } return err } return InvalidUploadID{ Bucket: bucket, Object: object, UploadID: uploadID, } } // CompleteMultipartUpload - completes a pending multipart transaction, on hashedSet based on object name.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0)