Method writeDataToOutputDevice

src/output/StreamThreadRtpTcp.cpp:78–111

}

bool StreamThreadRtpTcp::writeDataToOutputDevice(mpegts::PacketBuffer &buffer, StreamClient &client) {
	// update sequence number and timestamp
	const long timestamp = base::TimeCounter::getTicks() * 90;
	++_cseq;
	buffer.tagRTPHeaderWith(_cseq, timestamp);

	static constexpr size_t dataSize = buffer.getBufferSize();
	static constexpr size_t len = dataSize + mpegts::PacketBuffer::RTP_HEADER_LEN;

	// RTP packet octet count (Bytes)
	_stream.addRtpData(dataSize, timestamp);

	unsigned char header[4];
	header[0] = 0x24;
	header[1] = 0x00;
	header[2] = (len >> 8) & 0xFF;
	header[3] = (len >> 0) & 0xFF;

	iovec iov[2];
	iov[0].iov_base = header;
	iov[0].iov_len = 4;
	iov[1].iov_base = buffer.getReadBufferPtr();
	iov[1].iov_len = len;

	// send the RTP/TCP packet
	if (!client.writeHttpData(iov, 2)) {
		if (!client.isSelfDestructing()) {
			SI_LOG_ERROR("Stream: %d, Error sending RTP/TCP Stream Data to %s", _stream.getStreamID(),
				client.getIPAddressOfStream().c_str());
			client.selfDestruct();
		}
	}
	return true;
}

} // namespace output