1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
/***************************************************************************
engineshoutcast.h - description
-------------------
copyright : (C) 2007 by John Sully
(C) 2007 by Albert Santoni
(C) 2007 by Wesley Stessens
***************************************************************************/
/***************************************************************************
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation; either version 2 of the License, or *
* (at your option) any later version. *
* *
***************************************************************************/
#ifndef ENGINESHOUTCAST_H
#define ENGINESHOUTCAST_H
#include <QObject>
#include <QMessageBox>
#include <QTextCodec>
#include <QVector>
#include <QThread>
#include <QMutex>
#include <QSemaphore>
#include "configobject.h"
#include "controlobject.h"
#include "controlobjectslave.h"
#include "encoder/encodercallback.h"
#include "engine/sidechain/networkstreamworker.h"
#include "errordialoghandler.h"
#include "trackinfoobject.h"
#include "util/fifo.h"
class Encoder;
class ControlPushButton;
// Forward declare libshout structures to prevent leaking shout.h definitions
// beyond where they are needed.
struct shout;
typedef struct shout shout_t;
struct _util_dict;
typedef struct _util_dict shout_metadata_t;
class EngineShoutcast :
public QThread, public EncoderCallback, public NetworkStreamWorker {
Q_OBJECT
public:
enum StatusCOStates {
STATUSCO_UNCONNECTED = 0, // IDLE state, no error
STATUSCO_CONNECTING = 1, // 10 s max
STATUSCO_CONNECTED = 2, // On Air
STATUSCO_FAILURE = 3 // Happens when disconnected by an error
};
EngineShoutcast(ConfigObject<ConfigValue>* _config);
virtual ~EngineShoutcast();
// This is called by the Engine implementation for each sample. Encode and
// send the stream, as well as check for metadata changes.
void process(const CSAMPLE* pBuffer, const int iBufferSize);
void shutdown() {
}
// Called by the encoder in method 'encodebuffer()' to flush the stream to
// the server.
void write(unsigned char *header, unsigned char *body,
int headerLen, int bodyLen);
/** connects to server **/
bool serverConnect();
bool serverDisconnect();
bool isConnected();
virtual void outputAvailable();
virtual void setOutputFifo(FIFO<CSAMPLE>* pOutputFifo);
virtual bool threadWaiting();
virtual void run();
private slots:
void slotStatusCO(double v);
void slotEnableCO(double v);
signals:
void shoutcastDisconnected();
void shoutcastConnected();
private:
bool processConnect();
void processDisconnect();
// Update the libshout struct with info from Mixxx's shoutcast preferences.
void updateFromPreferences();
int getActiveTracks();
// Check if the metadata has changed since the previous check. We also
// check when was the last check performed to avoid using too much CPU and
// as well to avoid changing the metadata during scratches.
bool metaDataHasChanged();
// Update shoutcast metadata. This does not work for OGG/Vorbis and Icecast,
// since the actual OGG/Vorbis stream contains the metadata.
void updateMetaData();
// Common error dialog creation code for run-time exceptions. Notify user
// when connected or disconnected and so on
void errorDialog(QString text, QString detailedError);
void infoDialog(QString text, QString detailedError);
void serverWrite(unsigned char *header, unsigned char *body,
int headerLen, int bodyLen);
#ifndef __WINDOWS__
void ignoreSigpipe();
#endif
bool writeSingle(const unsigned char *data, size_t len);
QByteArray encodeString(const QString& string);
QTextCodec* m_pTextCodec;
TrackPointer m_pMetaData;
shout_t *m_pShout;
shout_metadata_t *m_pShoutMetaData;
int m_iMetaDataLife;
long m_iShoutStatus;
long m_iShoutFailures;
ConfigObject<ConfigValue>* m_pConfig;
Encoder* m_encoder;
ControlPushButton* m_pShoutcastEnabled;
ControlObjectSlave* m_pMasterSamplerate;
ControlObject* m_pStatusCO;
// static metadata according to prefereneces
bool m_custom_metadata;
QString m_customArtist;
QString m_customTitle;
QString m_metadataFormat;
// when static metadata is used, we only need calling shout_set_metedata
// once
bool m_firstCall;
bool m_format_is_mp3;
bool m_format_is_ov;
bool m_protocol_is_icecast1;
bool m_protocol_is_icecast2;
bool m_protocol_is_shoutcast;
bool m_ogg_dynamic_update;
QVector<struct shoutcastCacheObject *> m_pShoutcastCache;
QAtomicInt m_threadWaiting;
QSemaphore m_readSema;
FIFO<CSAMPLE>* m_pOutputFifo;
};
#endif
|
