| 833 | } |
| 834 | |
| 835 | Reference<ILogSystem::IPeekCursor> TagPartitionedLogSystem::peek(UID dbgid, |
| 836 | Version begin, |
| 837 | Optional<Version> end, |
| 838 | Tag tag, |
| 839 | bool parallelGetMore) { |
| 840 | if (!tLogs.size()) { |
| 841 | TraceEvent("TLogPeekNoLogSets", dbgid).detail("Tag", tag.toString()).detail("Begin", begin); |
| 842 | return makeReference<ILogSystem::ServerPeekCursor>( |
| 843 | Reference<AsyncVar<OptionalInterface<TLogInterface>>>(), tag, begin, getPeekEnd(), false, false); |
| 844 | } |
| 845 | |
| 846 | if (tag.locality == tagLocalityRemoteLog) { |
| 847 | return peekRemote(dbgid, begin, end, tag, parallelGetMore); |
| 848 | } else { |
| 849 | return peekAll(dbgid, begin, getPeekEnd(), tag, parallelGetMore); |
| 850 | } |
| 851 | } |
| 852 | |
| 853 | Reference<ILogSystem::IPeekCursor> TagPartitionedLogSystem::peek(UID dbgid, |
| 854 | Version begin, |
no test coverage detected