Add VideoEncoder stats (#17)

lib/VideoDecoder.js

@@ -25,6 +25,36 @@ class VideoDecoder extends Emitter
 			this.detach();
 		};
 	}
+
+	getStats()
+	{
+		//Get stats from 
+		const stats = this.decoder.GetStats();
+
+		//Ensure they are not too old
+		if (stats.timestamp + 1000 < new Date().time)
+			//Nothing
+			return null;
+
+		//Return encoder stats
+		return {
+			timestamp		: new Date(stats.timestamp),
+			totalDecodedFrames	: stats.totalDecodedFrames,
+			fps			: stats.fps,
+			decodingTime : {
+				max		: stats.maxDecodingTime,
+				avg		: stats.avgDecodingTime,
+			},
+			waitingFrameTime : {
+				max		: stats.maxWaitingFrameTime,
+				avg		: stats.avgWaitingFrameTime,
+			},
+			deinterlacingTime : {
+				max		: stats.maxDeinterlacingTime,
+				avg		: stats.avgDeinterlacingTime,
+			}
+		};
+	}
 
 	detach()
 	{

lib/VideoEncoder.js

@@ -55,6 +55,33 @@ class VideoEncoder extends Emitter
 		this.pipe.SetMaxDelay(delayms);
 	}
 
+	getStats()
+	{
+		//Get stats from 
+		const stats = this.encoder.GetStats();
+
+		//Ensure they are not too old
+		if (stats.timestamp + 1000 < new Date().time)
+			//Nothing
+			return null;
+
+		//Return encoder stats
+		return {
+			timestamp		: new Date(stats.timestamp),
+			totalEncodedFrames	: stats.totalEncodedFrames,
+			fps			: stats.fps,
+			bitrate			: stats.bitrate,
+			encodingTime : {
+				max		: stats.maxEncodingTime,
+				avg		: stats.avgEncodingTime,
+			},
+			capturingTime : {
+				maxa		: stats.maxCapturingTime,
+				avg		: stats.avgCapturingTime,
+			}
+		};
+	}
+
 	createIncomingStreamTrack(trackId, frameDispatchCoordinator)
 	{
 		//Create the source
@@ -89,6 +116,7 @@ class VideoEncoder extends Emitter
 		//Not attached
 		this.attached = null;
 	}
+
 
 	attachTo(decoder)
 	{

src/VideoDecoderWorker.i

@@ -1,11 +1,30 @@
 %include "MediaFrame.i"
 
+%{
+using VideoDecoderWorkerStats = VideoDecoderWorker::Stats;
+%}
+
+struct VideoDecoderWorkerStats
+{
+	uint64_t timestamp		= 0;
+	uint64_t totalDecodedFrames	= 0;
+	uint16_t fps			= 0;
+	uint16_t maxDecodingTime	= 0;
+	uint16_t avgDecodingTime	= 0;
+	uint16_t maxWaitingFrameTime	= 0;
+	uint16_t avgWaitingFrameTime	= 0;
+	uint16_t maxDeinterlacingTime	= 0;
+	uint16_t avgDeinterlacingTime	= 0;
+};
+
 struct VideoDecoderWorker : public MediaFrameListener
 {
 	int Start();
 	void AddVideoOutput(VideoOutput* ouput);
 	void RemoveVideoOutput(VideoOutput* ouput);
 	int Stop();
+
+	VideoDecoderWorkerStats GetStats();
 };
 
 SHARED_PTR_BEGIN(VideoDecoderWorker)

src/VideoEncoderFacade.i

@@ -5,6 +5,7 @@
 %include "VideoInput.i"
 
 %{
+using VideoEncoderStats = VideoEncoderWorker::Stats;
 
 class VideoEncoderFacade : 
 	public VideoEncoderWorker,
@@ -42,6 +43,18 @@ private:
 };
 %}
 
+struct VideoEncoderStats
+{
+	uint64_t timestamp		= 0;
+	uint64_t totalEncodedFrames	= 0;
+	uint16_t fps			= 0;
+	uint32_t bitrate		= 0;
+	uint16_t maxEncodingTime	= 0;
+	uint16_t avgEncodingTime	= 0;
+	uint16_t maxCapturingTime	= 0;
+	uint16_t avgCapturingTime	= 0;
+};
+
 struct VideoEncoderFacade : public RTPReceiver
 {
 	VideoEncoderFacade();
@@ -54,5 +67,6 @@ struct VideoEncoderFacade : public RTPReceiver
 	int End();
 	int IsEncoding();
 
+	VideoEncoderStats GetStats();
 	TimeService& GetTimeService();
 };