topic Re: RE: CSocketReader implementation for MPEG TS in Intel® Integrated Performance Primitives

RE: CSocketReader implementation for MPEG TS

pushkar_p — Mon, 08 Sep 2008 22:34:02 GMT

Hello,

I have implemented CSocketReader class derived from DataReader that reads a UDP based MPEG TS stream. I have adhered to UMC coding style as much as possible. I would like to contribute this to the IPP library or to other people who are interested.

If anyone is interested please let me know and where to upload the files?

Re: RE: CSocketReader implementation for MPEG TS

Vladimir_Dudnik — Tue, 09 Sep 2008 04:33:23 GMT

Hello,

Thanks you for help to the community. I think you can attach your implementation to this thread, so people can take your implementation from here.

Regards,
Vladimir

Re: RE: CSocketReader implementation for MPEG TS

pushkar_p — Tue, 09 Sep 2008 18:05:26 GMT

Hello,

I am posting the code in the attached zip file, there are 4 files:

SocketReader.h, SocketReade.cpp: Derived from UMC::DataReader. Internally it creates a socket, spawns a new thread which writes the incoming TS packetsto a circular buffer. The demuxer thread picks up the data through the normal ReadData, CacheData, and MovePosition operations.

CircularBuffer.h, .cpp: I downloadedthis circular buffer code from codeproject.com (original author and copyright notice included).I made the following changes to the original code:

Fixed race condition and memory leakbugs,

Replaced allWindows specific API with standardC++. (E.g. variable typedefs, synchronization objects, etc.)

Instead of using mutexes to synchronize read/write operations from multiple threads I use the one byte open strategy to prevent data corruption. (http://en.wikipedia.org/wiki/Circular_buffer). Thisis sufficientfor the one reader thread and one writer thread model.

Note: The socket code is Windows specific and I have not tested the multicast option.

Re: RE: CSocketReader implementation for MPEG TS

pushkar_p — Tue, 09 Sep 2008 22:34:34 GMT

Hello,

I just found a serious bug in my code, I was calling WSACleanup() multiple times, which was causing later stream playbacks to fail. WSACleanup() should be called only once for each call to WSAStartup(...). So I am updating the attachment.