Description

Data Structures
class	Policy

class	Executor< InT >

class	ReservationExpirationTimerTask

class	ReservationStartTimerTask

class	ReservationPreStartTimerTask

class	PendingRequestTimeoutTimerTask

class	ServerMessageProcessor
	#include <QObject> More...

Macros
#define	_USE_THREADPOOL_ 1

#define	TUNER_REFRESH_INTERVAL 5000

#define	TOTAL_TUNER_NUMBER 4

#define	TOTAL_DEVICE_NUMBER 5

#define	TOTAL_LOCATOR_NUMBER 7

#define	RESERVATION_BAR_WIDTH 550

#define	RBW RESERVATION_BAR_WIDTH

#define	SECOND_SCALE 1

Enumerations
enum

Functions
void	printThread (const char *func)

int	main (int argc, char *argv[])

TRM_BEGIN_NAMESPACE std::string	GetDeviceId ()

void	FindConflictsForRequestedLive (const ReserveTuner &request, ReserveTunerResponse::ConflictCT &conflicts)

void	FindConflictsForRequestedRecord (const ReserveTuner &request, ReserveTunerResponse::ConflictCT &conflicts)

void	reserveLive (const ReserveTuner &request, ReserveTunerResponse &response, int32_t clientId)

void	renewRecord (const ReserveTuner &request, ReserveTunerResponse &response, int32_t clientId)

void	reserveRecord (const ReserveTuner &request, ReserveTunerResponse &response, int32_t clientId)

TRM_BEGIN_NAMESPACE void	Execute (Executor< ReserveTuner > &exec)

void	Execute (Executor< ReleaseTunerReservation > &exec)

void	Execute (Executor< ValidateTunerReservation > &exec)

void	Execute (Executor< CancelRecording > &exec)

void	Execute (Executor< CancelRecordingResponse > &exec)

void	Execute (Executor< GetAllTunerIds > &exec)

void	Execute (Executor< GetAllTunerStates > &exec)

void	Execute (Executor< GetAllReservations > &exec)

void	Execute (Executor< ReserveTuner > &exec, const std::string &parentTunerId)

void	Execute (Executor< GetVersion > &exec)

void	Execute (Executor< UpdateTunerActivityStatus > &exec)

void	Execute (Executor< CancelLive > &exec)

void	Execute (Executor< CancelLiveResponse > &exec)

void	Execute (Executor< ReserveTuner > &)

void	Execute (Executor< ReleaseTunerReservation > &)

void	Execute (Executor< ValidateTunerReservation > &)

void	Execute (Executor< CancelRecording > &)

void	Execute (Executor< CancelRecordingResponse > &)

void	Execute (Executor< GetAllTunerIds > &)

void	Execute (Executor< GetAllTunerStates > &)

void	Execute (Executor< GetAllReservations > &)

void	Execute (Executor< ReserveTuner > &, const std::string &)

void	Execute (Executor< GetVersion > &exec)

void	Execute (Executor< CancelLive > &exec)

void	Execute (Executor< CancelLiveResponse > &exec)

void	Execute (Executor< UpdateTunerActivityStatus > &exec)

template<>
TRM_BEGIN_NAMESPACE Tuner::IdList &	Filter< ByTunerId > (const std::string &tunerId, Tuner::IdList &tuners)

template<>
Tuner::IdList &	Filter< ByTunerState > (const Enum< TunerState > &state, Tuner::IdList &tuners)

template<>
Tuner::IdList &	Filter< ByTunerLocator > (const std::string &serviceLocator, Tuner::IdList &tuners)

template<>
Tuner::IdList &	Filter< ByTunerEndBefore > (const uint64_t &endTime, Tuner::IdList &tuners)

template<>
TunerReservation::TokenList &	Filter< ByActivity > (const Enum< Activity > &activity, TunerReservation::TokenList &reservations)

template<>
TunerReservation::TokenList &	Filter< ByStartAfter > (const uint64_t &startTime, TunerReservation::TokenList &reservations)

template<>
TunerReservation::TokenList &	Filter< ByReservationEndBefore > (const uint64_t &endTime, TunerReservation::TokenList &reservations)

template<>
TunerReservation::TokenList &	Filter< ByToken > (const std::string &token, TunerReservation::TokenList &reservations)

template<>
TunerReservation::TokenList &	Filter< ByDevice > (const std::string &device, TunerReservation::TokenList &reservations)

template<>
TunerReservation::TokenList &	Filter< ByInConflict > (const bool &inConflict, TunerReservation::TokenList &reservations)

template<>
TunerReservation::TokenList &	Filter< ByReservationLocator > (const std::string &serviceLocator, TunerReservation::TokenList &reservations)

template<>
TunerReservation::TokenList &	Filter< ByReservationState > (const int &state, TunerReservation::TokenList &reservations)

Tuner::IdList &	Filter_ByTunerId (const std::string &tunerId, Tuner::IdList &tuners)

Tuner::IdList &	Filter_ByTunerState (const Enum< TunerState > &state, Tuner::IdList &tuners)

Tuner::IdList &	Filter_ByTunerLocator (const std::string &serviceLocator, Tuner::IdList &tuners)

Tuner::IdList &	Filter_ByTunerEndBefore (const uint64_t &endTime, Tuner::IdList &tuners, const Activity &activity)

TunerReservation::TokenList &	Filter_ByActivity (const Enum< Activity > &activity, TunerReservation::TokenList &reservations)

TunerReservation::TokenList &	Filter_ByStartAfter (const uint64_t &startTime, TunerReservation::TokenList &reservations)

TunerReservation::TokenList &	Filter_ByReservationEndBefore (const uint64_t &endTime, TunerReservation::TokenList &reservations)

TunerReservation::TokenList &	Filter_ReservationByToken (const std::string &token, TunerReservation::TokenList &reservations)

TunerReservation::TokenList &	Filter_ReservationByDevice (const std::string &device, TunerReservation::TokenList &reservations)

TunerReservation::TokenList &	Filter_ReservationByAttribute (const bool &inConflict, TunerReservation::TokenList &reservations)

TunerReservation::TokenList &	Filter_ByReservationLocator (const std::string &serviceLocator, TunerReservation::TokenList &reservations)

TunerReservation::TokenList &	Filter_ByReservationState (int state, TunerReservation::TokenList &reservations)

template<int i, typename T1 , class T2 >
T2 &	Filter (const T1 &, T2 &t2)

	TRM::Connection::Connection (QTcpSocket &_tcpSocket)

void	TRM::Connection::send (const std::vector< uint8_t > &out) const

void	TRM::Connection::sendAsync (const std::vector< uint8_t > &out) const

void	TRM::Connection::sendMessage (const QByteArray &outgoingMessage) const

void	TRM::Connection::recvMessage (QByteArray &recvBuffer) const

const QByteArray &	TRM::Connection::recvMessage (void) const

QByteArray &	TRM::Connection::IdleState::read (QAbstractSocket &socket, QByteArray &readBuffer)

QByteArray &	TRM::Connection::WaitHeaderState::read (QAbstractSocket &socket, QByteArray &readBuffer)

QByteArray &	TRM::Connection::WaitPayloadState::read (QAbstractSocket &socket, QByteArray &readBuffer)

virtual QByteArray &	TRM::Connection::State::read (QAbstractSocket &socket, QByteArray &readBuffer)=0

	TRM::Client::Client (const char *ipaddress, int portNumber)

	TRM::Client::Client (const QHostAddress &address, quint16 port)

	TRM::TRMMonitor::TRMMonitor (const QHostAddress &address, quint16 port, uint32_t clientId)

const std::list< std::string > &	TRM::TRMMonitor::getTunerIds (void) const

void	TRM::TRMMonitor::sendTunerReserve (const QString &device, qint64 startTime, qint64 duration, const QString &locator, const QString &activity, const QString &token)

void	TRM::TRMMonitor::sendGetAllTunerIds (void)

void	TRM::TRMMonitor::sendGetAllTunerStates (void)

void	TRM::TRMMonitor::sendGetAllReservations (void)

void	TRM::TRMMonitor::sendReleaseTunerReservation (const QString &reservationToken)

void	TRM::TRMMonitor::sendValidateTunerReservation (const QString &device, const QString &reservationToken)

void	TRM::TRMMonitor::sendCancelRecording (const QString &device, const QString &reservationToken)

void	TRM::TRMMonitor::sendCancelRecordingResponse (const QString &uuid, const QString &device, const QString &reservationToken, uint32_t outClientId)

void	TRM::TRMMonitor::operator() (const ReserveTunerResponse &msg)

void	TRM::TRMMonitor::operator() (const ReleaseTunerReservationResponse &msg)

void	TRM::TRMMonitor::operator() (const ValidateTunerReservationResponse &msg)

void	TRM::TRMMonitor::operator() (const CancelRecording &msg)

void	TRM::TRMMonitor::operator() (const CancelRecordingResponse &msg)

void	TRM::TRMMonitor::operator() (const GetAllTunerStatesResponse &msg)

void	TRM::TRMMonitor::operator() (const GetAllTunerIdsResponse &msg)

void	TRM::TRMMonitor::operator() (const GetAllReservationsResponse &msg)

void	TRM::TRMMonitor::operator() (const NotifyTunerReservationUpdate &msg)

void	TRM::TRMMonitor::operator() (const NotifyTunerReservationRelease &msg)

void	TRM::TRMMonitor::operator() (const NotifyTunerReservationConflicts &msg)

void	TRM::TRMMonitor::operator() (const NotifyTunerStatesUpdate &msg)

void	TRM::TRMMonitor::operator() (const NotifyTunerPretune &msg)

	TRM::TRMMonitorGUI::TRMMonitorGUI (const QHostAddress &address, quint16 port, const QString &clientId, const QString &barWidth, QObject *parent=0)

void	TRM::TRMMonitorGUI::drawReservationBar (QLabel label, TunerReservation reservation)

void	TRM::TRMMonitorGUI::setTunerStateIndicator (const QString &tunerId, const TunerState &state)

	ReservationExpirationTimerTask::ReservationExpirationTimerTask (Timer &timer, const std::string &reservationToken)

void	ReservationExpirationTimerTask::run (void)

Timer &	ReservationExpirationTimerTask::getTimer (void)

	ReservationStartTimerTask::ReservationStartTimerTask (Timer &timer, const std::string &reservationToken)

void	ReservationStartTimerTask::run (void)

Timer &	ReservationStartTimerTask::getTimer (void)

	ReservationPreStartTimerTask::ReservationPreStartTimerTask (Timer &timer, const std::string &reservationToken)

void	ReservationPreStartTimerTask::run (void)

Timer &	ReservationPreStartTimerTask::getTimer (void)

	PendingRequestTimeoutTimerTask::PendingRequestTimeoutTimerTask (Timer &timer, const std::string &uuid)

void	PendingRequestTimeoutTimerTask::run (void)

Timer &	PendingRequestTimeoutTimerTask::getTimer (void)

void	TRM::Server::close (void)

const Connection &	TRM::Server::getConnection (uint32_t clientId) const

void	TRM::Server::getConnections (std::list< const Connection * > &) const

	TRM::Server::Server (const QHostAddress &address, quint16 port)

void	ServerMessageProcessor::operator() (const ReserveTuner &msg)

void	ServerMessageProcessor::operator() (const ReleaseTunerReservation &msg)

void	ServerMessageProcessor::operator() (const ValidateTunerReservation &msg)

void	ServerMessageProcessor::operator() (const CancelRecordingResponse &msg)

void	ServerMessageProcessor::operator() (const CancelRecording &msg)

void	ServerMessageProcessor::operator() (const GetAllTunerIds &msg)

void	ServerMessageProcessor::operator() (const GetAllTunerStates &msg)

void	ServerMessageProcessor::operator() (const GetAllReservations &msg)

void	ServerMessageProcessor::operator() (const GetVersion &msg)

void	ServerMessageProcessor::operator() (const CancelLive &msg)

void	ServerMessageProcessor::operator() (const CancelLiveResponse &msg)

void	ServerMessageProcessor::operator() (const UpdateTunerActivityStatus &msg)

Variables
int	RESERVATION_BAR_TIME_WIDTH = 0

const char *	deviceNames [5]

const char *	locatorNames [7]

LOCAL_END_NAMESPACE Server *	serverInstance

Server *	serverInstance = 0

TRM::Server *	serverInstance

TRM::Server *	serverInstance

Public Slots
void	TRM::Connection::onBytesWritten (qint64 bytes)

void	TRM::Connection::onConnected ()

void	TRM::Connection::onHasMessageToSend (const std::vector< uint8_t > out) const

void	TRM::Connection::onReadyRead (void)

void	TRM::Connection::onDisconnected (void)

void	TRM::Connection::onSocketError (QAbstractSocket::SocketError socketError)

void	TRM::Connection::onStateChanged (QAbstractSocket::SocketState socketState)

Private Slots
void	TRM::Client::onDisconnected (Connection *_connection)

void	TRM::Client::onMessageReceived (const Connection &fromConnection)

void	TRM::TRMMonitorGUI::onReserveButtonClicked (void)

void	TRM::TRMMonitorGUI::onTimestampTimerTimeout (void)

void	TRM::TRMMonitorGUI::onTunerStateUpdateTimerTimeout (void)

void	TRM::TRMMonitorGUI::onTunerIdsUpdated (std::list< std::string >)

void	TRM::TRMMonitorGUI::onTunerStatesUpdated (std::map< std::string, std::string >)

void	TRM::TRMMonitorGUI::onTunerReservationsUpdated (std::map< std::string, std::list< TunerReservation > >)

void	TRM::TRMMonitorGUI::onReleaseTunerReservationActionTriggered (void)

void	TRM::TRMMonitorGUI::onValidateTunerReservationActionTriggered (void)

void	TRM::TRMMonitorGUI::onCancelRecordingActionTriggered (void)

void	TRM::TRMMonitorGUI::onRenewTunerReservationActionTriggered (void)

void	TRM::TRMMonitorGUI::onStatusMessageReceived (std::string)

void	TRM::TRMMonitorGUI::onConflictsReceived (ReserveTunerResponse::ConflictCT)

void	TRM::Server::onDisconnected (Connection *connection)

void	TRM::Server::onMessageReceived (const Connection &fromConnection)

void	TRM::Server::onHasMessageToSend (const std::vector< uint8_t > out)

void	TRM::Server::onNewConnection (void)

void	TRM::Server::onReservationUpdated (void)

Data Structure Documentation

◆ Policy

class Policy

Definition at line 54 of file Executors.cpp.

Collaboration diagram for Policy:

Static Public Member Functions
static bool	RequireTokenInRequest (void)

static bool	allowLinearRecordSharing (void)

static bool	enableConflictsForHotRecording (void)

static bool	allowOverlapRecordings (void)

◆ Executor

class Executor

template<class InT>
class Executor< InT >

Definition at line 44 of file Executors.h.

Collaboration diagram for Executor< InT >:

Public Types
typedef InT::ResponseType	OutT

Public Member Functions
	Executor (const InT &messageIn, uint32_t clientId)

const InT &	getRequest (void) const

const OutT &	getResponse (void) const

void	operator() (void)

uint32_t	getClientId (void) const

Private Attributes
const InT &	messageIn

OutT	messageOut

uint32_t	clientId

Friends
void	Execute (Executor< InT > &)

void	Execute (Executor< ReserveTuner > &, const std::string &)

◆ ReservationExpirationTimerTask

class ReservationExpirationTimerTask

Definition at line 37 of file ReservationTimerTask.h.

Inheritance diagram for ReservationExpirationTimerTask:

Collaboration diagram for ReservationExpirationTimerTask:

Public Member Functions
	ReservationExpirationTimerTask (Timer &timer, const std::string &reservationToken)

TimerTask *	clone ()

void	run (void)

Timer &	getTimer (void)

Private Attributes
Timer &	timer

const std::string	reservationToken

◆ ReservationStartTimerTask

class ReservationStartTimerTask

Definition at line 52 of file ReservationTimerTask.h.

Inheritance diagram for ReservationStartTimerTask:

Collaboration diagram for ReservationStartTimerTask:

Public Member Functions
	ReservationStartTimerTask (Timer &timer, const std::string &reservationToken)

TimerTask *	clone ()

void	run (void)

Timer &	getTimer (void)

Private Attributes
Timer &	timer

const std::string	reservationToken

◆ ReservationPreStartTimerTask

class ReservationPreStartTimerTask

Definition at line 67 of file ReservationTimerTask.h.

Inheritance diagram for ReservationPreStartTimerTask:

Collaboration diagram for ReservationPreStartTimerTask:

Public Member Functions
	ReservationPreStartTimerTask (Timer &timer, const std::string &reservationToken)

TimerTask *	clone ()

void	run (void)

Timer &	getTimer (void)

Private Attributes
Timer &	timer

const std::string	reservationToken

◆ PendingRequestTimeoutTimerTask

class PendingRequestTimeoutTimerTask

Definition at line 82 of file ReservationTimerTask.h.

Inheritance diagram for PendingRequestTimeoutTimerTask:

Collaboration diagram for PendingRequestTimeoutTimerTask:

Public Member Functions
	PendingRequestTimeoutTimerTask (Timer &timer, const std::string &uuid)

TimerTask *	clone ()

void	run (void)

Timer &	getTimer (void)

Private Attributes
Timer &	timer

const std::string	uuid

◆ ServerMessageProcessor

class ServerMessageProcessor

#include <QObject>

Definition at line 48 of file ServerMessageProcessor.h.

Inheritance diagram for ServerMessageProcessor:

Collaboration diagram for ServerMessageProcessor:

Public Member Functions
	ServerMessageProcessor (const Connection *connection=0, int clientId=0)

template<class MsgT >
void	process (const MsgT &msg)

void	operator() (const ReserveTuner &msg)

void	operator() (const ReleaseTunerReservation &msg)

void	operator() (const ValidateTunerReservation &msg)

void	operator() (const CancelRecording &msg)

void	operator() (const CancelRecordingResponse &msg)

void	operator() (const GetAllTunerIds &msg)

void	operator() (const GetAllTunerStates &msg)

void	operator() (const GetAllReservations &msg)

void	operator() (const GetVersion &msg)

void	operator() (const CancelLive &msg)

void	operator() (const CancelLiveResponse &msg)

void	operator() (const UpdateTunerActivityStatus &msg)

Public Member Functions inherited from MessageProcessor
virtual void	process (const ActiveSource &msg, const Header &header)

virtual void	process (const InActiveSource &msg, const Header &header)

virtual void	process (const ImageViewOn &msg, const Header &header)

virtual void	process (const TextViewOn &msg, const Header &header)

virtual void	process (const RequestActiveSource &msg, const Header &header)

virtual void	process (const Standby &msg, const Header &header)

virtual void	process (const GetCECVersion &msg, const Header &header)

virtual void	process (const CECVersion &msg, const Header &header)

virtual void	process (const SetMenuLanguage &msg, const Header &header)

virtual void	process (const GiveOSDName &msg, const Header &header)

virtual void	process (const GivePhysicalAddress &msg, const Header &header)

virtual void	process (const GiveDeviceVendorID &msg, const Header &header)

virtual void	process (const SetOSDString &msg, const Header &header)

virtual void	process (const SetOSDName &msg, const Header &header)

virtual void	process (const RoutingChange &msg, const Header &header)

virtual void	process (const RoutingInformation &msg, const Header &header)

virtual void	process (const SetStreamPath &msg, const Header &header)

virtual void	process (const GetMenuLanguage &msg, const Header &header)

virtual void	process (const ReportPhysicalAddress &msg, const Header &header)

virtual void	process (const DeviceVendorID &msg, const Header &header)

virtual void	process (const GiveDevicePowerStatus &msg, const Header &header)

virtual void	process (const ReportPowerStatus &msg, const Header &header)

virtual void	process (const FeatureAbort &msg, const Header &header)

virtual void	process (const Abort &msg, const Header &header)

virtual void	process (const Polling &msg, const Header &header)

virtual void	process (const InitiateArc &msg, const Header &header)

virtual void	process (const TerminateArc &msg, const Header &header)

virtual void	process (const RequestShortAudioDescriptor &msg, const Header &header)

virtual void	process (const ReportShortAudioDescriptor &msg, const Header &header)

virtual void	process (const SystemAudioModeRequest &msg, const Header &header)

virtual void	process (const SetSystemAudioMode &msg, const Header &header)

virtual void	process (const ReportAudioStatus &msg, const Header &header)

Private Attributes
const Connection *	connection

int	clientId

Variable Documentation

◆ deviceNames

const char* deviceNames[5]

Initial value:

= {
                "Xi3 Family Room",
                "Xi3 Living Room",
                "Xi3 Bedroom",
                "Xi3 Kitchen",
                "Xi3 Dining Room",
}

Definition at line 56 of file TRMMonitorGUI.cpp.

◆ locatorNames

const char* locatorNames[7]

Initial value:

= {
                "ocap://0xCNN",
                "ocap://0xABC",
                "ocap://0xCBS",
                "ocap://0xNBC",
                "ocap://0xFOX",
                "ocap://0xHBO",
                "ocap://QVC",
}

Definition at line 64 of file TRMMonitorGUI.cpp.

Description

Data Structures

Macros

Enumerations

Functions

Variables

Public Slots

Private Slots

Data Structure Documentation

◆ Policy

Static Public Member Functions

◆ Executor

template<class InT> class Executor< InT >

Public Types

Public Member Functions

Private Attributes

Friends

◆ ReservationExpirationTimerTask

Public Member Functions

Private Attributes

◆ ReservationStartTimerTask

Public Member Functions

Private Attributes

◆ ReservationPreStartTimerTask

Public Member Functions

Private Attributes

◆ PendingRequestTimeoutTimerTask

Public Member Functions

Private Attributes

◆ ServerMessageProcessor

Public Member Functions

Private Attributes

Variable Documentation

◆ deviceNames

◆ locatorNames

template<class InT>
class Executor< InT >