ConsistencyWriter

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total778 of 7780%74 of 740%65651581582828
barrierForGlobalStrong(RxDocumentServiceRequest, StoreResponse)1050%100%66191911
writePrivateAsync(RxDocumentServiceRequest, TimeoutHelper, boolean)960%120%77191911
lambda$writePrivateAsync$4(RxDocumentServiceRequest, Uri, Throwable)690%60%44131311
lambda$waitForWriteBarrierAsync$14(long, AtomicLong, RxDocumentServiceRequest, AtomicInteger, List)670%120%77141411
writeAsync(RxDocumentServiceRequest, TimeoutHelper, boolean)450%60%449911
lambda$writePrivateAsync$5(AtomicReference, RxDocumentServiceRequest, Uri)390%60%44101011
ConsistencyWriter(DiagnosticsClientContext, AddressSelector, ISessionContainer, TransportClient, IAuthorizationTokenProvider, GatewayServiceConfigurationReader, boolean)360%n/a11111111
lambda$waitForWriteBarrierAsync$15(RxDocumentServiceRequest, long, AtomicLong, AtomicInteger)320%20%225511
getLsnAndGlobalCommittedLsn(StoreResponse, Utils.ValueHolder, Utils.ValueHolder)310%40%337711
isGlobalStrongRequest(RxDocumentServiceRequest, StoreResponse)290%80%556611
lambda$writeAsync$1(RxDocumentServiceRequest, String, Signal)250%n/a115511
waitForWriteBarrierAsync(RxDocumentServiceRequest, long)240%n/a115511
lambda$barrierForGlobalStrong$10(RxDocumentServiceRequest, Boolean)220%20%225511
lambda$writePrivateAsync$3(RxDocumentServiceRequest, List)220%n/a116611
lambda$writePrivateAsync$7(RxDocumentServiceRequest, Boolean)200%20%224411
lambda$waitForWriteBarrierAsync$16(AtomicInteger, Long)180%20%227711
lambda$writePrivateAsync$6(RxDocumentServiceRequest, AtomicReference, StoreResponse)170%n/a112211
startBackgroundAddressRefresh(RxDocumentServiceRequest)130%n/a114411
lambda$barrierForGlobalStrong$11(RxDocumentServiceRequest, RxDocumentServiceRequest)130%n/a112211
lambda$writePrivateAsync$8(RxDocumentServiceRequest, RxDocumentServiceRequest)110%n/a112211
lambda$waitForWriteBarrierAsync$12(long, StoreResult)90%20%221111
lambda$startBackgroundAddressRefresh$19(Throwable)80%n/a112211
lambda$writePrivateAsync$2(List, AddressInformation)70%n/a111111
lambda$writeAsync$0(RxDocumentServiceRequest, TimeoutHelper, boolean)60%n/a111111
lambda$waitForWriteBarrierAsync$17(AtomicInteger, Flux)50%n/a111111
lambda$waitForWriteBarrierAsync$13(StoreResult)40%n/a111111
lambda$writePrivateAsync$9(RxDocumentServiceRequest)40%n/a111111
lambda$startBackgroundAddressRefresh$18(Uri)10%n/a111111