isQuorumMet(List, int, boolean, boolean, Utils.ValueHolder, Utils.ValueHolder, Utils.ValueHolder) | | 0% | | 0% | 23 | 23 | 36 | 36 | 1 | 1 |
lambda$readPrimaryAsync$15(int, RxDocumentServiceRequest, StoreResult) | | 0% | | 0% | 8 | 8 | 19 | 19 | 1 | 1 |
lambda$ensureQuorumSelectedStoreResponse$12(int, RxDocumentServiceRequest, List) | | 0% | | 0% | 7 | 7 | 15 | 15 | 1 | 1 |
lambda$readStrongAsync$3(RxDocumentServiceRequest, int, ReadMode, MutableVolatile, MutableVolatile, QuorumReader.ReadQuorumResult) | | 0% | | 0% | 5 | 5 | 16 | 16 | 1 | 1 |
lambda$waitForPrimaryLsnAsync$17(int, long, StoreResult) | | 0% | | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
lambda$waitForReadBarrierAsync$21(long, int, long, AtomicLong, RxDocumentServiceRequest, AtomicInteger, List) | | 0% | | 0% | 8 | 8 | 13 | 13 | 1 | 1 |
lambda$readStrongAsync$2(MutableVolatile, MutableVolatile, int, QuorumReader.ReadPrimaryResult) | | 0% | | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
lambda$readStrongAsync$0(QuorumReader.ReadQuorumResult, int, RxDocumentServiceRequest, Boolean) | | 0% | | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
ensureQuorumSelectedStoreResponse(RxDocumentServiceRequest, int, boolean, ReadMode) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
lambda$waitForReadBarrierAsync$27(long, int, long, AtomicLong, AtomicInteger, List) | | 0% | | 0% | 7 | 7 | 12 | 12 | 1 | 1 |
lambda$readQuorumAsync$9(RxDocumentServiceRequest, int, ReadMode, Pair) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
waitForReadBarrierAsync(RxDocumentServiceRequest, boolean, int, long, long, ReadMode) | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
QuorumReader(DiagnosticsClientContext, Configs, TransportClient, AddressSelector, StoreReader, GatewayServiceConfigurationReader, IAuthorizationTokenProvider) | | 0% | | n/a | 1 | 1 | 14 | 14 | 1 | 1 |
lambda$readPrimaryAsync$13(RxDocumentServiceRequest, StoreResult, QuorumReader.PrimaryReadOutcome) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
readStrongAsync(DiagnosticsClientContext, RxDocumentServiceRequest, int, ReadMode) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
lambda$waitForReadBarrierAsync$22(RxDocumentServiceRequest, boolean, int, ReadMode, long, long, AtomicLong, AtomicInteger) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$waitForReadBarrierAsync$28(RxDocumentServiceRequest, boolean, int, ReadMode, long, long, AtomicLong, AtomicInteger) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$readStrongAsync$4(RxDocumentServiceRequest, MutableVolatile, int, ReadMode, MutableVolatile) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
lambda$waitForReadBarrierAsync$31(Boolean, long, RxDocumentServiceRequest, boolean, int, ReadMode, long, AtomicLong, AtomicInteger) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
lambda$readQuorumAsync$7(RxDocumentServiceRequest, long, long, StoreResult, List, Boolean) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$waitForPrimaryLsnAsync$18(RxDocumentServiceRequest, int, long) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
readPrimaryAsync(RxDocumentServiceRequest, int, boolean) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$waitForReadBarrierAsync$29(AtomicInteger, Long) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
readQuorumAsync(RxDocumentServiceRequest, int, boolean, ReadMode) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$readQuorumAsync$8(int, long, long, ReadMode, RxDocumentServiceRequest, StoreResult, List, RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$readStrongAsync$6(int) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$readStrongAsync$1(int, QuorumReader.ReadQuorumResult, ReadMode, RxDocumentServiceRequest, RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
waitForPrimaryLsnAsync(RxDocumentServiceRequest, long, int) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$waitForReadBarrierAsync$32(long, RxDocumentServiceRequest, boolean, int, ReadMode, long, AtomicLong, AtomicInteger, Boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$readPrimaryAsync$14(long, int, RxDocumentServiceRequest, StoreResult, RxDocumentServiceRequest) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
static {...} | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
QuorumReader(DiagnosticsClientContext, TransportClient, AddressSelector, StoreReader, GatewayServiceConfigurationReader, IAuthorizationTokenProvider, Configs) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$waitForReadBarrierAsync$33(long, AtomicLong) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$waitForReadBarrierAsync$23(Long) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$isQuorumMet$36(long, StoreResult) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$waitForReadBarrierAsync$26(long, StoreResult) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$waitForReadBarrierAsync$20(long, StoreResult) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$readStrongAsync$5(MutableVolatile, StoreResponse) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$waitForReadBarrierAsync$30(AtomicInteger, Flux) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$waitForReadBarrierAsync$24(Flux) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$isQuorumMet$35(StoreResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$isQuorumMet$37(StoreResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$isQuorumMet$34(StoreResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$waitForReadBarrierAsync$25(StoreResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$waitForReadBarrierAsync$19(StoreResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$ensureQuorumSelectedStoreResponse$11(StoreResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$ensureQuorumSelectedStoreResponse$10(StoreResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$waitForPrimaryLsnAsync$16(Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |