mirror of
https://github.com/rofafor/vdr-plugin-iptv.git
synced 2023-10-10 13:37:03 +02:00
512 lines
16 KiB
C
512 lines
16 KiB
C
/*
|
|
* protocolcurl.c: IPTV plugin for the Video Disk Recorder
|
|
*
|
|
* See the README file for copyright information and how to reach the author.
|
|
*
|
|
*/
|
|
|
|
#include "common.h"
|
|
#include "config.h"
|
|
#include "protocolcurl.h"
|
|
|
|
#define iptv_curl_easy_setopt(X, Y, Z) \
|
|
if ((res = curl_easy_setopt((X), (Y), (Z))) != CURLE_OK) { error("curl_easy_setopt(%s, %s, %s) failed: %d\n", #X, #Y, #Z, res); }
|
|
|
|
#define iptv_curl_easy_perform(X) \
|
|
if ((res = curl_easy_perform((X))) != CURLE_OK) { error("curl_easy_perform(%s) failed: %d\n", #X, res); }
|
|
|
|
cIptvProtocolCurl::cIptvProtocolCurl()
|
|
: streamUrlM(""),
|
|
streamParamM(0),
|
|
mutexM(),
|
|
handleM(NULL),
|
|
multiM(NULL),
|
|
headerListM(NULL),
|
|
ringBufferM(new cRingBufferLinear(MEGABYTE(IptvConfig.GetTsBufferSize()), 7 * TS_SIZE)),
|
|
rtspControlM(),
|
|
modeM(eModeUnknown),
|
|
connectedM(false),
|
|
pausedM(false)
|
|
{
|
|
debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
if (ringBufferM)
|
|
ringBufferM->SetTimeouts(100, 0);
|
|
Connect();
|
|
}
|
|
|
|
cIptvProtocolCurl::~cIptvProtocolCurl()
|
|
{
|
|
debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
Disconnect();
|
|
// Free allocated memory
|
|
DELETE_POINTER(ringBufferM);
|
|
}
|
|
|
|
size_t cIptvProtocolCurl::WriteCallback(void *ptrP, size_t sizeP, size_t nmembP, void *dataP)
|
|
{
|
|
cIptvProtocolCurl *obj = reinterpret_cast<cIptvProtocolCurl *>(dataP);
|
|
size_t len = sizeP * nmembP;
|
|
//debug("cIptvProtocolCurl::%s(%zu)", __FUNCTION__, len);
|
|
|
|
if (obj && !obj->PutData((unsigned char *)ptrP, (int)len))
|
|
return CURL_WRITEFUNC_PAUSE;
|
|
|
|
return len;
|
|
}
|
|
|
|
size_t cIptvProtocolCurl::WriteRtspCallback(void *ptrP, size_t sizeP, size_t nmembP, void *dataP)
|
|
{
|
|
cIptvProtocolCurl *obj = reinterpret_cast<cIptvProtocolCurl *>(dataP);
|
|
size_t len = sizeP * nmembP;
|
|
unsigned char *p = (unsigned char *)ptrP;
|
|
//debug("cIptvProtocolCurl::%s(%zu)", __FUNCTION__, len);
|
|
|
|
// validate packet header ('$') and channel (0)
|
|
if (obj && (p[0] == 0x24 ) && (p[1] == 0)) {
|
|
int length = (p[2] << 8) | p[3];
|
|
if (length > 3) {
|
|
// skip interleave header
|
|
p += 4;
|
|
// http://tools.ietf.org/html/rfc3550
|
|
// http://tools.ietf.org/html/rfc2250
|
|
// version
|
|
unsigned int v = (p[0] >> 6) & 0x03;
|
|
// extension bit
|
|
unsigned int x = (p[0] >> 4) & 0x01;
|
|
// cscr count
|
|
unsigned int cc = p[0] & 0x0F;
|
|
// payload type: MPEG2 TS = 33
|
|
//unsigned int pt = p[1] & 0x7F;
|
|
// header lenght
|
|
unsigned int headerlen = (3 + cc) * (unsigned int)sizeof(uint32_t);
|
|
// check if extension
|
|
if (x) {
|
|
// extension header length
|
|
unsigned int ehl = (((p[headerlen + 2] & 0xFF) << 8) |(p[headerlen + 3] & 0xFF));
|
|
// update header length
|
|
headerlen += (ehl + 1) * (unsigned int)sizeof(uint32_t);
|
|
}
|
|
// Check that rtp is version 2 and payload contains multiple of TS packet data
|
|
if ((v == 2) && (((length - headerlen) % TS_SIZE) == 0) && (p[headerlen] == TS_SYNC_BYTE)) {
|
|
// Set argument point to payload in read buffer
|
|
obj->PutData(&p[headerlen], (length - headerlen));
|
|
}
|
|
}
|
|
}
|
|
|
|
return len;
|
|
}
|
|
|
|
size_t cIptvProtocolCurl::DescribeCallback(void *ptrP, size_t sizeP, size_t nmembP, void *dataP)
|
|
{
|
|
cIptvProtocolCurl *obj = reinterpret_cast<cIptvProtocolCurl *>(dataP);
|
|
size_t len = sizeP * nmembP;
|
|
//debug("cIptvProtocolCurl::%s(%zu)", __FUNCTION__, len);
|
|
|
|
cString control = "";
|
|
char *p = (char *)ptrP;
|
|
char *r = strtok(p, "\r\n");
|
|
|
|
while (r) {
|
|
//debug("cIptvProtocolCurl::%s(%zu): %s", __FUNCTION__, len, r);
|
|
if (strstr(r, "a=control")) {
|
|
char *s = NULL;
|
|
if (sscanf(r, "a=control:%64ms", &s) == 1)
|
|
control = compactspace(s);
|
|
free(s);
|
|
}
|
|
r = strtok(NULL, "\r\n");
|
|
}
|
|
|
|
if (!isempty(*control) && obj)
|
|
obj->SetRtspControl(*control);
|
|
|
|
return len;
|
|
}
|
|
|
|
size_t cIptvProtocolCurl::HeaderCallback(void *ptrP, size_t sizeP, size_t nmembP, void *dataP)
|
|
{
|
|
//cIptvProtocolCurl *obj = reinterpret_cast<cIptvProtocolCurl *>(dataP);
|
|
size_t len = sizeP * nmembP;
|
|
//debug("cIptvProtocolCurl::%s(%zu)", __FUNCTION__, len);
|
|
|
|
char *p = (char *)ptrP;
|
|
char *r = strtok(p, "\r\n");
|
|
|
|
while (r) {
|
|
//debug("cIptvProtocolCurl::%s(%zu): %s", __FUNCTION__, len, r);
|
|
r = strtok(NULL, "\r\n");
|
|
}
|
|
|
|
return len;
|
|
}
|
|
|
|
void cIptvProtocolCurl::SetRtspControl(const char *controlP)
|
|
{
|
|
cMutexLock MutexLock(&mutexM);
|
|
debug("cIptvProtocolCurl::%s(%s)", __FUNCTION__, controlP);
|
|
rtspControlM = controlP;
|
|
}
|
|
|
|
bool cIptvProtocolCurl::PutData(unsigned char *dataP, int lenP)
|
|
{
|
|
cMutexLock MutexLock(&mutexM);
|
|
//debug("cIptvProtocolCurl::%s(%d)", __FUNCTION__, lenP);
|
|
if (pausedM)
|
|
return false;
|
|
if (ringBufferM && (lenP >= 0)) {
|
|
// should be pause the transfer?
|
|
if (ringBufferM->Free() < (2 * CURL_MAX_WRITE_SIZE)) {
|
|
debug("cIptvProtocolCurl::%s(pause): free=%d available=%d len=%d", __FUNCTION__, ringBufferM->Free(), ringBufferM->Available(), lenP);
|
|
pausedM = true;
|
|
return false;
|
|
}
|
|
int p = ringBufferM->Put(dataP, lenP);
|
|
if (p != lenP)
|
|
ringBufferM->ReportOverflow(lenP - p);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
void cIptvProtocolCurl::DelData(int lenP)
|
|
{
|
|
cMutexLock MutexLock(&mutexM);
|
|
//debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
if (ringBufferM && (lenP >= 0))
|
|
ringBufferM->Del(lenP);
|
|
}
|
|
|
|
void cIptvProtocolCurl::ClearData()
|
|
{
|
|
//debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
if (ringBufferM)
|
|
ringBufferM->Clear();
|
|
}
|
|
|
|
unsigned char *cIptvProtocolCurl::GetData(unsigned int *lenP)
|
|
{
|
|
cMutexLock MutexLock(&mutexM);
|
|
//debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
unsigned char *p = NULL;
|
|
*lenP = 0;
|
|
if (ringBufferM) {
|
|
int count = 0;
|
|
p = ringBufferM->Get(count);
|
|
#if 0
|
|
if (p && count >= TS_SIZE) {
|
|
if (*p != TS_SYNC_BYTE) {
|
|
for (int i = 1; i < count; ++i) {
|
|
if (p[i] == TS_SYNC_BYTE) {
|
|
count = i;
|
|
break;
|
|
}
|
|
}
|
|
error("IPTV skipped %d bytes to sync on TS packet\n", count);
|
|
ringBufferM->Del(count);
|
|
*lenP = 0;
|
|
return NULL;
|
|
}
|
|
}
|
|
#endif
|
|
count -= (count % TS_SIZE);
|
|
*lenP = count;
|
|
}
|
|
|
|
return p;
|
|
}
|
|
|
|
bool cIptvProtocolCurl::Connect()
|
|
{
|
|
cMutexLock MutexLock(&mutexM);
|
|
debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
if (connectedM)
|
|
return true;
|
|
|
|
// initialize the curl session
|
|
if (!handleM)
|
|
handleM = curl_easy_init();
|
|
if (!multiM)
|
|
multiM = curl_multi_init();
|
|
|
|
if (handleM && multiM && !isempty(*streamUrlM)) {
|
|
CURLcode res = CURLE_OK;
|
|
cString netrc = cString::sprintf("%s/netrc", IptvConfig.GetConfigDirectory());
|
|
|
|
#ifdef DEBUG
|
|
// verbose output
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_VERBOSE, 1L);
|
|
#endif
|
|
|
|
// set callbacks
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_WRITEFUNCTION, cIptvProtocolCurl::WriteCallback);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_WRITEDATA, this);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_HEADERFUNCTION, cIptvProtocolCurl::HeaderCallback);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_WRITEHEADER, this);
|
|
|
|
// no progress meter and no signaling
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_NOPROGRESS, 1L);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_NOSIGNAL, 1L);
|
|
|
|
// support netrc
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_NETRC, (long)CURL_NETRC_OPTIONAL);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_NETRC_FILE, *netrc);
|
|
|
|
// set timeout
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_CONNECTTIMEOUT, (long)eConnectTimeoutS);
|
|
|
|
// set user-agent
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_USERAGENT, *cString::sprintf("vdr-%s/%s", PLUGIN_NAME_I18N, VERSION));
|
|
|
|
// set url
|
|
//char *p = curl_easy_unescape(handleM, *streamUrlM, 0, NULL);
|
|
//streamUrlM = p;
|
|
//curl_free(p);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_URL, *streamUrlM);
|
|
|
|
// protocol specific initializations
|
|
switch (modeM) {
|
|
case eModeRtsp:
|
|
{
|
|
cString uri, control, transport, range;
|
|
|
|
// request server options
|
|
uri = cString::sprintf("%s", *streamUrlM);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_STREAM_URI, *uri);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_OPTIONS);
|
|
iptv_curl_easy_perform(handleM);
|
|
|
|
// request session description - SDP is delivered in message body and not in the header!
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_WRITEFUNCTION, cIptvProtocolCurl::DescribeCallback);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_WRITEDATA, this);
|
|
uri = cString::sprintf("%s", *streamUrlM);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_STREAM_URI, *uri);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_DESCRIBE);
|
|
iptv_curl_easy_perform(handleM);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_WRITEFUNCTION, NULL);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_WRITEDATA, NULL);
|
|
|
|
// setup media stream
|
|
uri = cString::sprintf("%s/%s", *streamUrlM, *rtspControlM);
|
|
transport = "RTP/AVP/TCP;unicast;interleaved=0-1";
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_STREAM_URI, *uri);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_TRANSPORT, *transport);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_SETUP);
|
|
iptv_curl_easy_perform(handleM);
|
|
|
|
// start playing
|
|
uri = cString::sprintf("%s/", *streamUrlM);
|
|
range = "0.000-";
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_STREAM_URI, *uri);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RANGE, *range);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_PLAY);
|
|
iptv_curl_easy_perform(handleM);
|
|
|
|
// start receiving
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_INTERLEAVEFUNCTION, cIptvProtocolCurl::WriteRtspCallback);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_INTERLEAVEDATA, this);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_RECEIVE);
|
|
iptv_curl_easy_perform(handleM);
|
|
}
|
|
break;
|
|
|
|
case eModeHttp:
|
|
case eModeHttps:
|
|
{
|
|
// limit download speed (bytes/s)
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_MAX_RECV_SPEED_LARGE, eMaxDownloadSpeedMBits * 131072L);
|
|
|
|
// follow location
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_FOLLOWLOCATION, 1L);
|
|
|
|
// fail if HTTP return code is >= 400
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_FAILONERROR, 1L);
|
|
|
|
// set additional headers to prevent caching
|
|
headerListM = curl_slist_append(headerListM, "Cache-Control: no-store, no-cache, must-revalidate");
|
|
headerListM = curl_slist_append(headerListM, "Cache-Control: post-check=0, pre-check=0");
|
|
headerListM = curl_slist_append(headerListM, "Pragma: no-cache");
|
|
headerListM = curl_slist_append(headerListM, "Expires: Mon, 26 Jul 1997 05:00:00 GMT");
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_HTTPHEADER, headerListM);
|
|
}
|
|
break;
|
|
|
|
case eModeFile:
|
|
case eModeUnknown:
|
|
default:
|
|
break;
|
|
}
|
|
|
|
// add handle into multi set
|
|
curl_multi_add_handle(multiM, handleM);
|
|
|
|
connectedM = true;
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
bool cIptvProtocolCurl::Disconnect()
|
|
{
|
|
cMutexLock MutexLock(&mutexM);
|
|
debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
if (handleM) {
|
|
// mode specific tricks
|
|
switch (modeM) {
|
|
case eModeRtsp:
|
|
{
|
|
CURLcode res = CURLE_OK;
|
|
// teardown rtsp session
|
|
cString uri = cString::sprintf("%s/", *streamUrlM);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_STREAM_URI, *uri);
|
|
iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_REQUEST, (long)CURL_RTSPREQ_TEARDOWN);
|
|
iptv_curl_easy_perform(handleM);
|
|
rtspControlM = "";
|
|
}
|
|
break;
|
|
|
|
case eModeHttp:
|
|
case eModeHttps:
|
|
case eModeFile:
|
|
case eModeUnknown:
|
|
default:
|
|
break;
|
|
}
|
|
|
|
// cleanup curl stuff
|
|
if (headerListM) {
|
|
curl_slist_free_all(headerListM);
|
|
headerListM = NULL;
|
|
}
|
|
curl_multi_remove_handle(multiM, handleM);
|
|
curl_multi_cleanup(multiM);
|
|
multiM = NULL;
|
|
curl_easy_cleanup(handleM);
|
|
handleM = NULL;
|
|
}
|
|
|
|
ClearData();
|
|
connectedM = false;
|
|
return true;
|
|
}
|
|
|
|
bool cIptvProtocolCurl::Open(void)
|
|
{
|
|
debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
return Connect();
|
|
}
|
|
|
|
bool cIptvProtocolCurl::Close(void)
|
|
{
|
|
debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
Disconnect();
|
|
return true;
|
|
}
|
|
|
|
int cIptvProtocolCurl::Read(unsigned char* bufferAddrP, unsigned int bufferLenP)
|
|
{
|
|
//debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
int len = 0;
|
|
if (ringBufferM) {
|
|
// fill up the buffer
|
|
if (handleM && multiM) {
|
|
switch (modeM) {
|
|
case eModeRtsp:
|
|
{
|
|
//CURLcode res = CURLE_OK;
|
|
//iptv_curl_easy_setopt(handleM, CURLOPT_RTSP_REQUEST, CURL_RTSPREQ_RECEIVE);
|
|
//iptv_curl_easy_perform(handleM);
|
|
// @todo - how to detect eof?
|
|
}
|
|
break;
|
|
|
|
case eModeFile:
|
|
break;
|
|
|
|
case eModeHttp:
|
|
case eModeHttps:
|
|
{
|
|
CURLMcode res;
|
|
int running_handles;
|
|
|
|
do {
|
|
res = curl_multi_perform(multiM, &running_handles);
|
|
} while (res == CURLM_CALL_MULTI_PERFORM);
|
|
|
|
// shall be continue filling up the buffer?
|
|
mutexM.Lock();
|
|
if (pausedM && (ringBufferM->Free() > ringBufferM->Available())) {
|
|
debug("cIptvProtocolCurl::%s(continue): free=%d available=%d", __FUNCTION__, ringBufferM->Free(), ringBufferM->Available());
|
|
pausedM = false;
|
|
curl_easy_pause(handleM, CURLPAUSE_CONT);
|
|
}
|
|
mutexM.Unlock();
|
|
|
|
// check end of file
|
|
if (running_handles == 0) {
|
|
int msgcount;
|
|
CURLMsg *msg = curl_multi_info_read(multiM, &msgcount);
|
|
if (msg && (msg->msg == CURLMSG_DONE)) {
|
|
debug("cIptvProtocolCurl::%s(done): %s (%d)", __FUNCTION__, curl_easy_strerror(msg->data.result), msg->data.result);
|
|
Disconnect();
|
|
Connect();
|
|
}
|
|
}
|
|
}
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
// ... and try to empty it
|
|
unsigned char *p = GetData(&bufferLenP);
|
|
if (p && (bufferLenP > 0)) {
|
|
memcpy(bufferAddrP, p, bufferLenP);
|
|
DelData(bufferLenP);
|
|
len = bufferLenP;
|
|
//debug("cIptvProtocolCurl::%s(): get %d bytes", __FUNCTION__, len);
|
|
}
|
|
}
|
|
|
|
return len;
|
|
}
|
|
|
|
bool cIptvProtocolCurl::Set(const char* locationP, const int parameterP, const int indexP)
|
|
{
|
|
debug("cIptvProtocolCurl::%s(%s, %d, %d)", __FUNCTION__, locationP, parameterP, indexP);
|
|
if (!isempty(locationP)) {
|
|
// Disconnect
|
|
Disconnect();
|
|
// Update stream URL: colons (%3A) and pipes (%7C) shall be decoded
|
|
char *s = strdup(locationP);
|
|
strreplace(s, "%3A", ":");
|
|
strreplace(s, "%7C", "|");
|
|
streamUrlM = s;
|
|
free(s);
|
|
if (startswith(*streamUrlM, "rtsp") || startswith(*streamUrlM, "RTSP"))
|
|
modeM = eModeRtsp;
|
|
else if (startswith(*streamUrlM, "https") || startswith(*streamUrlM, "HTTPS"))
|
|
modeM = eModeHttp;
|
|
else if (startswith(*streamUrlM, "http") || startswith(*streamUrlM, "HTTP"))
|
|
modeM = eModeHttps;
|
|
else if (startswith(*streamUrlM, "file") || startswith(*streamUrlM, "FILE"))
|
|
modeM = eModeFile;
|
|
else
|
|
modeM = eModeUnknown;
|
|
// Update stream parameter
|
|
streamParamM = parameterP;
|
|
// Reconnect
|
|
Connect();
|
|
}
|
|
return true;
|
|
}
|
|
|
|
cString cIptvProtocolCurl::GetInformation(void)
|
|
{
|
|
//debug("cIptvProtocolCurl::%s()", __FUNCTION__);
|
|
return cString::sprintf("%s [%d]", *streamUrlM, streamParamM);
|
|
}
|