Path Lines of Code Sources/Runtime/Microsoft.Psi.Interop/Format/CsvFormat.cs 168 Sources/Runtime/Microsoft.Psi.Interop/Format/JsonFormat.cs 95 Sources/Runtime/Microsoft.Psi.Interop/Format/MessagePackFormat.cs 68 Sources/Runtime/Microsoft.Psi.Interop/Serialization/IFormatDeserializer.cs 9 Sources/Runtime/Microsoft.Psi.Interop/Serialization/IFormatSerializer.cs 9 Sources/Runtime/Microsoft.Psi.Interop/Serialization/IPersistentFormatDeserializer.cs 11 Sources/Runtime/Microsoft.Psi.Interop/Serialization/IPersistentFormatSerializer.cs 12 Sources/Runtime/Microsoft.Psi.Interop/Transport/FileSource.cs 36 Sources/Runtime/Microsoft.Psi.Interop/Transport/FileWriter.cs 37 Sources/Runtime/Microsoft.Psi.Interop/Transport/NetMQSource.cs 81 Sources/Runtime/Microsoft.Psi.Interop/Transport/NetMQWriter.cs 44 Sources/Runtime/Microsoft.Psi.Interop/Transport/NetMQWriter{T}.cs 17 Sources/Runtime/Microsoft.Psi.Windows/PerfCounterCollection.cs 39 Sources/Runtime/Microsoft.Psi.Windows/PerfCounterManager.cs 119 Sources/Runtime/Microsoft.Psi.Windows/PerfCounters.cs 39 Sources/Runtime/Microsoft.Psi/Common/Arrays/DiscreteIndexDefinition.cs 55 Sources/Runtime/Microsoft.Psi/Common/Arrays/IndexDefinition.cs 38 Sources/Runtime/Microsoft.Psi/Common/Arrays/Indexer.cs 21 Sources/Runtime/Microsoft.Psi/Common/Arrays/Indexer2d.cs 85 Sources/Runtime/Microsoft.Psi/Common/Arrays/IndexerNd.cs 105 Sources/Runtime/Microsoft.Psi/Common/Arrays/Range.cs 52 Sources/Runtime/Microsoft.Psi/Common/Arrays/RangeIndexDefinition.cs 79 Sources/Runtime/Microsoft.Psi/Common/BatchProcessingTaskAttribute.cs 26 Sources/Runtime/Microsoft.Psi/Common/BufferEx.cs 88 Sources/Runtime/Microsoft.Psi/Common/BufferReader.cs 330 Sources/Runtime/Microsoft.Psi/Common/BufferWriter.cs 347 Sources/Runtime/Microsoft.Psi/Common/Clock.cs 60 Sources/Runtime/Microsoft.Psi/Common/DeliveryPolicy.cs 97 Sources/Runtime/Microsoft.Psi/Common/DeliveryPolicy{T}.cs 54 Sources/Runtime/Microsoft.Psi/Common/Envelope.cs 47 Sources/Runtime/Microsoft.Psi/Common/IConsumer.cs 8 Sources/Runtime/Microsoft.Psi/Common/IProducer.cs 8 Sources/Runtime/Microsoft.Psi/Common/IStreamMetadata.cs 27 Sources/Runtime/Microsoft.Psi/Common/Interpolators/AdjacentValuesInterpolator.cs 70 Sources/Runtime/Microsoft.Psi/Common/Interpolators/Available.cs 89 Sources/Runtime/Microsoft.Psi/Common/Interpolators/FirstAvailableInterpolator.cs 66 Sources/Runtime/Microsoft.Psi/Common/Interpolators/FirstReproducibleInterpolator.cs 79 Sources/Runtime/Microsoft.Psi/Common/Interpolators/GreedyInterpolator{TIn,TResult}.cs 7 Sources/Runtime/Microsoft.Psi/Common/Interpolators/GreedyInterpolator{T}.cs 7 Sources/Runtime/Microsoft.Psi/Common/Interpolators/InterpolationResult.cs 52 Sources/Runtime/Microsoft.Psi/Common/Interpolators/Interpolator{TIn,TResult}.cs 13 Sources/Runtime/Microsoft.Psi/Common/Interpolators/LastAvailableInterpolator.cs 56 Sources/Runtime/Microsoft.Psi/Common/Interpolators/LastReproducibleInterpolator.cs 80 Sources/Runtime/Microsoft.Psi/Common/Interpolators/NearestAvailableInterpolator.cs 57 Sources/Runtime/Microsoft.Psi/Common/Interpolators/NearestReproducibleInterpolator.cs 78 Sources/Runtime/Microsoft.Psi/Common/Interpolators/Reproducible.cs 108 Sources/Runtime/Microsoft.Psi/Common/Interpolators/ReproducibleInterpolator{TIn,TResult}.cs 7 Sources/Runtime/Microsoft.Psi/Common/Interpolators/ReproducibleInterpolator{T}.cs 16 Sources/Runtime/Microsoft.Psi/Common/Intervals/IInterval.cs 37 Sources/Runtime/Microsoft.Psi/Common/Intervals/IIntervalEndpoint.cs 10 Sources/Runtime/Microsoft.Psi/Common/Intervals/IntInterval.cs 103 Sources/Runtime/Microsoft.Psi/Common/Intervals/Interval.cs 259 Sources/Runtime/Microsoft.Psi/Common/Intervals/IntervalEndpoint.cs 30 Sources/Runtime/Microsoft.Psi/Common/Intervals/RealInterval.cs 103 Sources/Runtime/Microsoft.Psi/Common/Intervals/RelativeTimeInterval.cs 148 Sources/Runtime/Microsoft.Psi/Common/Intervals/TimeInterval.cs 109 Sources/Runtime/Microsoft.Psi/Common/KeyedSharedPool.cs 33 Sources/Runtime/Microsoft.Psi/Common/MathExtensions.cs 125 Sources/Runtime/Microsoft.Psi/Common/Message.cs 82 Sources/Runtime/Microsoft.Psi/Common/Metadata.cs 76 Sources/Runtime/Microsoft.Psi/Common/ObjectDisposedWithHistoryException.cs 39 Sources/Runtime/Microsoft.Psi/Common/PerfCounters/IPerfCounterCollection.cs 13 Sources/Runtime/Microsoft.Psi/Common/PerfCounters/IPerfCounters.cs 19 Sources/Runtime/Microsoft.Psi/Common/Platform.cs 236 Sources/Runtime/Microsoft.Psi/Common/PsiStreamMetadata.cs 211 Sources/Runtime/Microsoft.Psi/Common/ReplayDescriptor.cs 43 Sources/Runtime/Microsoft.Psi/Common/RuntimeInfo.cs 28 Sources/Runtime/Microsoft.Psi/Common/Security/AdditionalAssembliesWarning.cs 11 Sources/Runtime/Microsoft.Psi/Common/Shared.cs 176 Sources/Runtime/Microsoft.Psi/Common/SharedArrayPool.cs 12 Sources/Runtime/Microsoft.Psi/Common/SharedContainer.cs 105 Sources/Runtime/Microsoft.Psi/Common/SharedPool.cs 111 Sources/Runtime/Microsoft.Psi/Common/StreamMetadataBase.cs 49 Sources/Runtime/Microsoft.Psi/Common/TickCalibration.cs 132 Sources/Runtime/Microsoft.Psi/Common/Time.cs 36 Sources/Runtime/Microsoft.Psi/Common/TypeResolutionHelper.cs 37 Sources/Runtime/Microsoft.Psi/Common/UnmanagedArray.cs 374 Sources/Runtime/Microsoft.Psi/Common/UnmanagedBuffer.cs 216 Sources/Runtime/Microsoft.Psi/Components/Aggregator.cs 25 Sources/Runtime/Microsoft.Psi/Components/AsyncConsumerProducer.cs 20 Sources/Runtime/Microsoft.Psi/Components/BranchTerminationPolicy.cs 56 Sources/Runtime/Microsoft.Psi/Components/ConsumerProducer.cs 17 Sources/Runtime/Microsoft.Psi/Components/DynamicWindow.cs 115 Sources/Runtime/Microsoft.Psi/Components/EventSource.cs 40 Sources/Runtime/Microsoft.Psi/Components/Fuse.cs 135 Sources/Runtime/Microsoft.Psi/Components/Generator.cs 90 Sources/Runtime/Microsoft.Psi/Components/Generator{T}.cs 125 Sources/Runtime/Microsoft.Psi/Components/IConsumerProducer.cs 7 Sources/Runtime/Microsoft.Psi/Components/ISourceComponent.cs 10 Sources/Runtime/Microsoft.Psi/Components/Join.cs 18 Sources/Runtime/Microsoft.Psi/Components/Join{TPrimary,TSecondary,TOut}.cs 18 Sources/Runtime/Microsoft.Psi/Components/Merge.cs 22 Sources/Runtime/Microsoft.Psi/Components/Merger.cs 29 Sources/Runtime/Microsoft.Psi/Components/Pair.cs 45 Sources/Runtime/Microsoft.Psi/Components/ParallelFixedLength.cs 66 Sources/Runtime/Microsoft.Psi/Components/ParallelSparseDo.cs 24 Sources/Runtime/Microsoft.Psi/Components/ParallelSparseSelect.cs 50 Sources/Runtime/Microsoft.Psi/Components/ParallelSparseSplitter.cs 102 Sources/Runtime/Microsoft.Psi/Components/ParallelVariableLength.cs 78 Sources/Runtime/Microsoft.Psi/Components/Processor.cs 18 Sources/Runtime/Microsoft.Psi/Components/RelativeIndexWindow.cs 48 Sources/Runtime/Microsoft.Psi/Components/RelativeTimeWindow.cs 93 Sources/Runtime/Microsoft.Psi/Components/SerializerComponent.cs 27 Sources/Runtime/Microsoft.Psi/Components/SimpleConsumer.cs 13 Sources/Runtime/Microsoft.Psi/Components/Splitter.cs 36 Sources/Runtime/Microsoft.Psi/Components/Timer.cs 70 Sources/Runtime/Microsoft.Psi/Components/Timer{TOut}.cs 21 Sources/Runtime/Microsoft.Psi/Components/Zip.cs 58 Sources/Runtime/Microsoft.Psi/Configuration/ConfigurationHelper.cs 55 Sources/Runtime/Microsoft.Psi/Connectors/Connector.cs 26 Sources/Runtime/Microsoft.Psi/Connectors/IConnector.cs 10 Sources/Runtime/Microsoft.Psi/Connectors/MessageConnector.cs 25 Sources/Runtime/Microsoft.Psi/Connectors/MessageEnvelopeConnector.cs 25 Sources/Runtime/Microsoft.Psi/Data/Exporter.cs 138 Sources/Runtime/Microsoft.Psi/Data/IStreamReader.cs 29 Sources/Runtime/Microsoft.Psi/Data/Importer.cs 222 Sources/Runtime/Microsoft.Psi/Data/IndexEntry.cs 25 Sources/Runtime/Microsoft.Psi/Data/PsiExporter.cs 13 Sources/Runtime/Microsoft.Psi/Data/PsiImporter.cs 12 Sources/Runtime/Microsoft.Psi/Data/PsiStore.cs 405 Sources/Runtime/Microsoft.Psi/Data/PsiStoreStreamReader.cs 270 Sources/Runtime/Microsoft.Psi/Data/StreamReader.cs 19 Sources/Runtime/Microsoft.Psi/Data/StreamReaderAttribute.cs 16 Sources/Runtime/Microsoft.Psi/Diagnostics/DiagnosticsCollector.cs 167 Sources/Runtime/Microsoft.Psi/Diagnostics/DiagnosticsConfiguration.cs 22 Sources/Runtime/Microsoft.Psi/Diagnostics/DiagnosticsQueryExtensions.cs 119 Sources/Runtime/Microsoft.Psi/Diagnostics/DiagnosticsSampler.cs 67 Sources/Runtime/Microsoft.Psi/Diagnostics/PipelineDiagnostics.cs 263 Sources/Runtime/Microsoft.Psi/Diagnostics/PipelineDiagnosticsInternal.cs 150 Sources/Runtime/Microsoft.Psi/Diagnostics/PipelineElementKind.cs 11 Sources/Runtime/Microsoft.Psi/Executive/ComponentCompletedEventArgs.cs 15 Sources/Runtime/Microsoft.Psi/Executive/DebugExtensions.cs 130 Sources/Runtime/Microsoft.Psi/Executive/KeyValueStore.cs 41 Sources/Runtime/Microsoft.Psi/Executive/Pipeline.cs 808 Sources/Runtime/Microsoft.Psi/Executive/PipelineCompletedEventArgs.cs 18 Sources/Runtime/Microsoft.Psi/Executive/PipelineElement.cs 232 Sources/Runtime/Microsoft.Psi/Executive/PipelineExceptionNotHandledEventArgs.cs 13 Sources/Runtime/Microsoft.Psi/Executive/PipelineRunEventArgs.cs 13 Sources/Runtime/Microsoft.Psi/Executive/Subpipeline.cs 104 Sources/Runtime/Microsoft.Psi/Operators/Aggregators.cs 48 Sources/Runtime/Microsoft.Psi/Operators/Connectors.cs 35 Sources/Runtime/Microsoft.Psi/Operators/Converters.cs 12 Sources/Runtime/Microsoft.Psi/Operators/Enumerable.cs 88 Sources/Runtime/Microsoft.Psi/Operators/Fuses.cs 247 Sources/Runtime/Microsoft.Psi/Operators/Generators.cs 71 Sources/Runtime/Microsoft.Psi/Operators/Interpolators.cs 77 Sources/Runtime/Microsoft.Psi/Operators/Joins.cs 787 Sources/Runtime/Microsoft.Psi/Operators/Merges.cs 28 Sources/Runtime/Microsoft.Psi/Operators/Observable.cs 62 Sources/Runtime/Microsoft.Psi/Operators/Pairs.cs 252 Sources/Runtime/Microsoft.Psi/Operators/Pickers.cs 33 Sources/Runtime/Microsoft.Psi/Operators/Processors.cs 87 Sources/Runtime/Microsoft.Psi/Operators/Statistical.cs 1406 Sources/Runtime/Microsoft.Psi/Operators/Time.cs 23 Sources/Runtime/Microsoft.Psi/Operators/Timers.cs 17 Sources/Runtime/Microsoft.Psi/Operators/VectorProcessors.cs 295 Sources/Runtime/Microsoft.Psi/Operators/Windows.cs 76 Sources/Runtime/Microsoft.Psi/Operators/Zips.cs 28 Sources/Runtime/Microsoft.Psi/Persistence/InfiniteFileReader.cs 192 Sources/Runtime/Microsoft.Psi/Persistence/InfiniteFileWriter.cs 191 Sources/Runtime/Microsoft.Psi/Persistence/MessageReader.cs 70 Sources/Runtime/Microsoft.Psi/Persistence/MessageWriter.cs 70 Sources/Runtime/Microsoft.Psi/Persistence/MetadataCache.cs 170 Sources/Runtime/Microsoft.Psi/Persistence/PageIndexCache.cs 97 Sources/Runtime/Microsoft.Psi/Persistence/PsiStoreCommon.cs 103 Sources/Runtime/Microsoft.Psi/Persistence/PsiStoreReader.cs 270 Sources/Runtime/Microsoft.Psi/Persistence/PsiStoreWriter.cs 187 Sources/Runtime/Microsoft.Psi/Properties/AssemblyInfo.cs 6 Sources/Runtime/Microsoft.Psi/Remoting/RemoteExporter.cs 323 Sources/Runtime/Microsoft.Psi/Remoting/RemoteImporter.cs 203 Sources/Runtime/Microsoft.Psi/Remoting/Transport/DataChunker.cs 36 Sources/Runtime/Microsoft.Psi/Remoting/Transport/DataUnchunker.cs 57 Sources/Runtime/Microsoft.Psi/Remoting/Transport/ITransport.cs 15 Sources/Runtime/Microsoft.Psi/Remoting/Transport/ITransportClient.cs 12 Sources/Runtime/Microsoft.Psi/Remoting/Transport/NamedPipesTransport.cs 92 Sources/Runtime/Microsoft.Psi/Remoting/Transport/TcpTransport.cs 88 Sources/Runtime/Microsoft.Psi/Remoting/Transport/Transport.cs 73 Sources/Runtime/Microsoft.Psi/Remoting/Transport/TransportKind.cs 10 Sources/Runtime/Microsoft.Psi/Remoting/Transport/UdpTransport.cs 115 Sources/Runtime/Microsoft.Psi/Scheduling/FutureWorkItemQueue.cs 17 Sources/Runtime/Microsoft.Psi/Scheduling/PriorityQueue.cs 187 Sources/Runtime/Microsoft.Psi/Scheduling/PriorityQueuePerfCounters.cs 14 Sources/Runtime/Microsoft.Psi/Scheduling/Scheduler.cs 425 Sources/Runtime/Microsoft.Psi/Scheduling/SchedulerContext.cs 50 Sources/Runtime/Microsoft.Psi/Scheduling/SchedulerPerfCounters.cs 14 Sources/Runtime/Microsoft.Psi/Scheduling/SimpleSemaphore.cs 46 Sources/Runtime/Microsoft.Psi/Scheduling/SynchronizationLock.cs 42 Sources/Runtime/Microsoft.Psi/Scheduling/WorkItem.cs 20 Sources/Runtime/Microsoft.Psi/Scheduling/WorkItemQueue.cs 15 Sources/Runtime/Microsoft.Psi/Serialization/ArraySerializer.cs 70 Sources/Runtime/Microsoft.Psi/Serialization/BufferSerializer.cs 61 Sources/Runtime/Microsoft.Psi/Serialization/ByteArraySerializer.cs 57 Sources/Runtime/Microsoft.Psi/Serialization/ClassSerializer.cs 87 Sources/Runtime/Microsoft.Psi/Serialization/CloningFlags.cs 13 Sources/Runtime/Microsoft.Psi/Serialization/DynamicMessageDeserializer.cs 123 Sources/Runtime/Microsoft.Psi/Serialization/EnumerableSerializer.cs 81 Sources/Runtime/Microsoft.Psi/Serialization/Generator.cs 390 Sources/Runtime/Microsoft.Psi/Serialization/IRecyclingPool.cs 11 Sources/Runtime/Microsoft.Psi/Serialization/ISerializer.cs 20 Sources/Runtime/Microsoft.Psi/Serialization/ImmutableSerializer.cs 50 Sources/Runtime/Microsoft.Psi/Serialization/KnownSerializers.cs 356 Sources/Runtime/Microsoft.Psi/Serialization/MemoryStreamSerializer.cs 130 Sources/Runtime/Microsoft.Psi/Serialization/NonSerializer.cs 36 Sources/Runtime/Microsoft.Psi/Serialization/RecyclingPool.cs 94 Sources/Runtime/Microsoft.Psi/Serialization/RefHandler.cs 187 Sources/Runtime/Microsoft.Psi/Serialization/SerializationContext.cs 123 Sources/Runtime/Microsoft.Psi/Serialization/SerializationHandler.cs 70 Sources/Runtime/Microsoft.Psi/Serialization/Serializer.cs 100 Sources/Runtime/Microsoft.Psi/Serialization/SerializerAttribute.cs 14 Sources/Runtime/Microsoft.Psi/Serialization/SimpleArraySerializer.cs 52 Sources/Runtime/Microsoft.Psi/Serialization/SimpleSerializer.cs 39 Sources/Runtime/Microsoft.Psi/Serialization/StringArraySerializer.cs 50 Sources/Runtime/Microsoft.Psi/Serialization/StringSerializer.cs 34 Sources/Runtime/Microsoft.Psi/Serialization/StructHandler.cs 81 Sources/Runtime/Microsoft.Psi/Serialization/StructSerializer.cs 45 Sources/Runtime/Microsoft.Psi/Serialization/TypeMemberSchema.cs 23 Sources/Runtime/Microsoft.Psi/Serialization/TypeSchema.cs 255 Sources/Runtime/Microsoft.Psi/Streams/DeliveryQueue.cs 173 Sources/Runtime/Microsoft.Psi/Streams/EmitterPerfCounters.cs 9 Sources/Runtime/Microsoft.Psi/Streams/Emitter{T}.cs 181 Sources/Runtime/Microsoft.Psi/Streams/IEmitter.cs 17 Sources/Runtime/Microsoft.Psi/Streams/IReceiver.cs 14 Sources/Runtime/Microsoft.Psi/Streams/ReceiverPerfCounters.cs 21 Sources/Runtime/Microsoft.Psi/Streams/Receiver{T}.cs 315 Sources/Runtime/Test.Psi.Windows/APITester.cs 22 Sources/Runtime/Test.Psi.Windows/ConsoleMain.cs 15 Sources/Runtime/Test.Psi/APITester.cs 145 Sources/Runtime/Test.Psi/ArrayTests.cs 121 Sources/Runtime/Test.Psi/CloningTester.cs 228 Sources/Runtime/Test.Psi/CommonTester.cs 117 Sources/Runtime/Test.Psi/ConsoleMain.cs 15 Sources/Runtime/Test.Psi/CrossFrameworkSerializationTester.cs 268 Sources/Runtime/Test.Psi/CrossProcTester.cs 16 Sources/Runtime/Test.Psi/CustomSerializationTester.cs 83 Sources/Runtime/Test.Psi/DebuggingTest.cs 24 Sources/Runtime/Test.Psi/DeliveryPolicyTest.cs 260 Sources/Runtime/Test.Psi/DynamicDeserializationTests.cs 140 Sources/Runtime/Test.Psi/EmitterTester.cs 302 Sources/Runtime/Test.Psi/FunctionalTests.cs 356 Sources/Runtime/Test.Psi/GeneratorSample.cs 40 Sources/Runtime/Test.Psi/GeneratorsTests.cs 492 Sources/Runtime/Test.Psi/InteropTests.cs 295 Sources/Runtime/Test.Psi/InterpolateTests.cs 35 Sources/Runtime/Test.Psi/InterpolatorTests.cs 906 Sources/Runtime/Test.Psi/IntervalTests.cs 791 Sources/Runtime/Test.Psi/JoinTests.cs 265 Sources/Runtime/Test.Psi/MemoryAccessPerf.cs 218 Sources/Runtime/Test.Psi/MemoryAccessTests.cs 98 Sources/Runtime/Test.Psi/MemoryStreamTester.cs 144 Sources/Runtime/Test.Psi/OpProcessorTests.cs 58 Sources/Runtime/Test.Psi/OperatorTests.cs 1136 Sources/Runtime/Test.Psi/PairTests.cs 309 Sources/Runtime/Test.Psi/PersistenceTest.cs 1304 Sources/Runtime/Test.Psi/PipelineTest.cs 1710 Sources/Runtime/Test.Psi/ReceiverTest.cs 64 Sources/Runtime/Test.Psi/RemotingTests.cs 128 Sources/Runtime/Test.Psi/SampleTests.cs 44 Sources/Runtime/Test.Psi/SchedulerTester.cs 302 Sources/Runtime/Test.Psi/SerializationTester.cs 861 Sources/Runtime/Test.Psi/SharedTester.cs 353 Sources/Runtime/Test.Psi/StatisticalTests.cs 894 Sources/Runtime/Test.Psi/TimeTester.cs 202 Sources/Runtime/Test.Psi/TypeResolutionTests.cs 56 Sources/Runtime/Test.Psi/UdpChunkingTest.cs 148 Sources/Runtime/Test.Psi/VectorTests.cs 458