ConsistencyWriter

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total435 of 76843%43 of 6634%3961771571328
barrierForGlobalStrong(RxDocumentServiceRequest, StoreResponse)95109%8220%56171901
lambda$waitForWriteBarrierAsync$14(long, AtomicLong, RxDocumentServiceRequest, AtomicInteger, List)670%120%77141411
lambda$writePrivateAsync$4(RxDocumentServiceRequest, Uri, Throwable)403949%5116%3461701
lambda$waitForWriteBarrierAsync$15(RxDocumentServiceRequest, long, AtomicLong, AtomicInteger)320%20%225511
waitForWriteBarrierAsync(RxDocumentServiceRequest, long)240%n/a115511
lambda$barrierForGlobalStrong$10(RxDocumentServiceRequest, Boolean)220%20%225511
writePrivateAsync(RxDocumentServiceRequest, TimeoutHelper, boolean)206476%1787%1531701
lambda$writeAsync$1(RxDocumentServiceRequest, String, Signal)20520%n/a012501
lambda$writePrivateAsync$7(RxDocumentServiceRequest, Boolean)200%20%224411
lambda$waitForWriteBarrierAsync$16(AtomicInteger, Long)160%20%223311
lambda$writePrivateAsync$5(AtomicReference, RxDocumentServiceRequest, Uri)152461%4233%3441001
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$6(RxDocumentServiceRequest, AtomicReference, StoreResponse)62177%n/a012601
lambda$waitForWriteBarrierAsync$17(AtomicInteger, Flux)50%n/a111111
lambda$writePrivateAsync$3(RxDocumentServiceRequest, List)41881%n/a012601
lambda$waitForWriteBarrierAsync$13(StoreResult)40%n/a111111
lambda$writePrivateAsync$9(RxDocumentServiceRequest)40%n/a111111
ConsistencyWriter(DiagnosticsClientContext, AddressSelector, ISessionContainer, TransportClient, IAuthorizationTokenProvider, GatewayServiceConfigurationReader, boolean)36100%n/a0101101
getLsnAndGlobalCommittedLsn(StoreResponse, Utils.ValueHolder, Utils.ValueHolder)31100%2250%230701
writeAsync(RxDocumentServiceRequest, TimeoutHelper, boolean)29100%2100%020601
isGlobalStrongRequest(RxDocumentServiceRequest, StoreResponse)29100%1787%150601
startBackgroundAddressRefresh(RxDocumentServiceRequest)13100%n/a010401
lambda$writePrivateAsync$2(List, AddressInformation)7100%n/a010101
lambda$writeAsync$0(RxDocumentServiceRequest, TimeoutHelper, boolean)6100%n/a010101
lambda$startBackgroundAddressRefresh$18(Uri)1100%n/a010101