38 #ifndef __JACKTRIPWORKER_H__
39 #define __JACKTRIPWORKER_H__
43 #include <QThreadPool>
46 #include <QHostAddress>
87 QString client_address,
91 bool connectDefaultAudioPorts
103 mSimulatedLossRate = loss;
104 mSimulatedJitterRate = jitter;
105 mSimulatedDelayRel = delay_rel;
107 void setBroadcast(
int broadcast_queue) {mBroadcastQueue = broadcast_queue;}
111 void setIOStatStream(QSharedPointer<std::ofstream> statStream) { mIOStatStream = statStream; }
115 { std::cout <<
"--- JackTripWorker TEST SLOT ---" << std::endl; }
122 int setJackTripFromClientHeader(
JackTrip& jacktrip);
127 QString mClientAddress;
129 bool m_connectDefaultAudioPorts;
134 int mBufferQueueLength;
140 volatile bool mSpawning;
148 double mSimulatedLossRate;
149 double mSimulatedJitterRate;
150 double mSimulatedDelayRel;
151 bool mUseRtUdpPriority;
154 QSharedPointer<std::ofstream> mIOStatStream;
Main class to creates a SERVER (to listen) or a CLIENT (to connect to a listening server) to send aud...
Definition: JackTrip.h:72
connectionModeT
Enum for Connection Mode (in packet header)
Definition: JackTrip.h:106
underrunModeT
Enum for the JackTrip Underrun Mode, when packets.
Definition: JackTrip.h:94
@ WAVETABLE
Loops on the last received packet.
Definition: JackTrip.h:95
Prototype of the worker class that will be cloned through sending threads to the Thread Pool.
Definition: JackTripWorker.h:68
JackTripWorker(UdpHubListener *udphublistener, int BufferQueueLength=gDefaultQueueLength, JackTrip::underrunModeT UnderRunMode=JackTrip::WAVETABLE, QString clientName="")
The class constructor.
Definition: JackTripWorker.cpp:61
int getID()
Definition: JackTripWorker.h:95
void setBufferStrategy(int BufferStrategy)
Definition: JackTripWorker.h:100
void setIOStatTimeout(int timeout)
Definition: JackTripWorker.h:110
bool isSpawning()
Check if the Thread is Spawning.
Definition: JackTripWorker.cpp:346
void setIOStatStream(QSharedPointer< std::ofstream > statStream)
Definition: JackTripWorker.h:111
virtual ~JackTripWorker()
The class destructor.
Definition: JackTripWorker.cpp:89
void setNetIssuesSimulation(double loss, double jitter, double delay_rel)
Definition: JackTripWorker.h:101
void setUseRtUdpPriority(bool use)
Definition: JackTripWorker.h:108
void signalRemoveThread()
void run()
Implements the Thread Loop. To start the thread, call start() ( DO NOT CALL run() ).
Definition: JackTripWorker.cpp:119
void setBroadcast(int broadcast_queue)
Definition: JackTripWorker.h:107
void stopThread()
Stop and remove thread from pool.
Definition: JackTripWorker.cpp:354
void setJackTrip(int id, QString client_address, uint16_t server_port, uint16_t client_port, int num_channels, bool connectDefaultAudioPorts)
Sets the JackTripWorker properties.
Definition: JackTripWorker.cpp:96
Hub UDP listener on the Server.
Definition: UdpHubListener.h:70
const int gDefaultQueueLength
Definition: jacktrip_globals.h:86
quint16 uint16_t
Typedef for unsigned short. This type is guaranteed to be 16-bit.
Definition: jacktrip_types.h:71