Converts between VoipStreamPacket and binary (network byte order) Udp header. More...

#include <VoipStreamPacketSerializer.h>

Inheritance diagram for inet::VoipStreamPacketSerializer:

Public Member Functions
	VoipStreamPacketSerializer ()

Public Member Functions inherited from inet::FieldsChunkSerializer
virtual void	serialize (MemoryOutputStream &stream, const Ptr< const Chunk > &chunk, b offset, b length) const override
	Serializes a chunk into a stream by writing the bytes representing the chunk at the end of the stream. More...

virtual const Ptr< Chunk >	deserialize (MemoryInputStream &stream, const std::type_info &typeInfo) const override
	Deserializes a chunk from a stream by reading the bytes at the current position of the stream. More...

Protected Member Functions
virtual void	serialize (MemoryOutputStream &stream, const Ptr< const Chunk > &chunk) const override
	Serializes a chunk into a stream by writing all bytes representing the chunk at the end of the stream. More...

virtual const Ptr< Chunk >	deserialize (MemoryInputStream &stream) const override
	Deserializes a chunk from a stream by reading the bytes at the current position of the stream. More...

Additional Inherited Members
Static Public Attributes inherited from inet::ChunkSerializer
static b	totalSerializedLength = b(0)

static b	totalDeserializedLength = b(0)

Detailed Description

Converts between VoipStreamPacket and binary (network byte order) Udp header.

Constructor & Destructor Documentation

◆ VoipStreamPacketSerializer()

inet::VoipStreamPacketSerializer::VoipStreamPacketSerializer ( )

inline

25 : FieldsChunkSerializer() {}

Member Function Documentation

◆ deserialize()

const Ptr< Chunk > inet::VoipStreamPacketSerializer::deserialize ( MemoryInputStream & stream ) const

overrideprotectedvirtual

Deserializes a chunk from a stream by reading the bytes at the current position of the stream.

The current stream position is updated according to the length of the returned chunk.

Implements inet::FieldsChunkSerializer.

 {
     auto startPosition = stream.getPosition();
     auto voipStreamPacket = makeShared<VoipStreamPacket>();
     int headerLength = stream.readByte();
     voipStreamPacket->setHeaderLength(headerLength);
     VoipStreamPacketType type = static_cast<VoipStreamPacketType>(stream.readByte());
     voipStreamPacket->setType(type);
     voipStreamPacket->setCodec(stream.readUint32Be());
     voipStreamPacket->setSampleBits(stream.readUint16Be());
     voipStreamPacket->setSampleRate(stream.readUint16Be());
     voipStreamPacket->setTransmitBitrate(stream.readUint32Be());
     voipStreamPacket->setSamplesPerPacket(stream.readUint16Be());
     voipStreamPacket->setSeqNo(stream.readUint16Be());
     voipStreamPacket->setTimeStamp(stream.readUint32Be());
     voipStreamPacket->setSsrc(stream.readUint32Be());
     if (type == VOICE)
         voipStreamPacket->setDataLength(stream.readUint16Be());
  
     B remainders = B(headerLength) - (stream.getPosition() - startPosition);
     if (remainders.get() < 0) {
         voipStreamPacket->markIncorrect();
         return voipStreamPacket;
     }
     stream.readByteRepeatedly('?', B(remainders).get());
     return voipStreamPacket;
 }

◆ serialize()

void inet::VoipStreamPacketSerializer::serialize	(	MemoryOutputStream &	stream,
		const Ptr< const Chunk > &	chunk
	)		const

overrideprotectedvirtual

Serializes a chunk into a stream by writing all bytes representing the chunk at the end of the stream.

Implements inet::FieldsChunkSerializer.

 {
     auto startPosition = stream.getLength();
     const auto& voipStreamPacket = staticPtrCast<const VoipStreamPacket>(chunk);
     stream.writeByte(voipStreamPacket->getHeaderLength());
     VoipStreamPacketType type = voipStreamPacket->getType();
     stream.writeByte(type);
     stream.writeUint32Be(voipStreamPacket->getCodec());
     stream.writeUint16Be(voipStreamPacket->getSampleBits());
     stream.writeUint16Be(voipStreamPacket->getSampleRate());
     stream.writeUint32Be(voipStreamPacket->getTransmitBitrate());
     stream.writeUint16Be(voipStreamPacket->getSamplesPerPacket());
     stream.writeUint16Be(voipStreamPacket->getSeqNo());
     stream.writeUint32Be(voipStreamPacket->getTimeStamp());
     stream.writeUint32Be(voipStreamPacket->getSsrc());
     if (type == VOICE)
         stream.writeUint16Be(voipStreamPacket->getDataLength());
  
     int64_t remainders = B(voipStreamPacket->getHeaderLength()).get() - B((stream.getLength() - startPosition)).get();
     if (remainders < 0)
         throw cRuntimeError("voipStreamPacket length = %d smaller than required %d bytes, try to increment the 'voipHeaderSize' parameter", (int)B(voipStreamPacket->getChunkLength()).get(), (int)B(stream.getLength() - startPosition).get());
     stream.writeByteRepeatedly('?', remainders);
 }

The documentation for this class was generated from the following files:

Public Member Functions