frodovdr/vdr-plugin-streamdev
1
0
Fork 0
mirror of https://projects.vdr-developer.org/git/vdr-plugin-streamdev.git synced 2023-10-10 19:16:51 +02:00
Code Issues Releases Wiki Activity
efeac825cc
vdr-plugin-streamdev/server/connectionHTTP.c

205 lines
5.2 KiB
C
Raw Normal View History

Initial revision
2004-12-30 23:43:55 +01:00
/*
Set DSCP 41 on stream data packets. WMM capable WLAN accesspoints should understand this and give precedence. For Internet streaming it could be used by traffic shapers. Suggested by ollo@vdrportal (#237). Modified Files: server/connectionHTTP.c server/connectionVTP.c tools/socket.c tools/socket.h
2007-05-09 11:12:42 +02:00
* $Id: connectionHTTP.c,v 1.12 2007/05/09 09:12:42 schmirl Exp $
Initial revision
2004-12-30 23:43:55 +01:00
*/
- some compilers complained about missing declarations, added <ctype.h>
2005-04-24 18:26:14 +02:00
#include <ctype.h>
Initial revision
2004-12-30 23:43:55 +01:00
#include "server/connectionHTTP.h"
#include "server/setup.h"
- transfer
2005-02-11 17:44:14 +01:00
cConnectionHTTP::cConnectionHTTP(void):
cServerConnection("HTTP"),
m_Status(hsRequest),
m_LiveStreamer(NULL),
m_Channel(NULL),
m_Apid(0),
m_StreamType((eStreamType)StreamdevServerSetup.HTTPStreamType),
m_ListChannel(NULL)
{
Dprintf("constructor hsRequest\n");
Initial revision
2004-12-30 23:43:55 +01:00
}
- transfer
2005-02-11 17:44:14 +01:00
cConnectionHTTP::~cConnectionHTTP()
{
delete m_LiveStreamer;
Initial revision
2004-12-30 23:43:55 +01:00
}
- transfer
2005-02-11 17:44:14 +01:00
bool cConnectionHTTP::Command(char *Cmd)
{
Dprintf("command %s\n", Cmd);
Initial revision
2004-12-30 23:43:55 +01:00
switch (m_Status) {
case hsRequest:
- transfer
2005-02-11 17:44:14 +01:00
Dprintf("Request\n");
m_Request = Cmd;
m_Status = hsHeaders;
return true;
Initial revision
2004-12-30 23:43:55 +01:00
case hsHeaders:
if (*Cmd == '\0') {
- transfer
2005-02-11 17:44:14 +01:00
m_Status = hsBody;
return ProcessRequest();
}
Dprintf("header\n");
return true;
Use compiler flag -Wall. Cleanup code as necessary. (#171 Thanks to Rolf Ahrenberg) Modified Files: Makefile streamdev-server.c server/connection.h server/connectionHTTP.c server/connectionVTP.c tools/source.c
2007-04-16 13:01:02 +02:00
default:
break;
- transfer
2005-02-11 17:44:14 +01:00
}
return false; // ??? shouldn't happen
}
- added TS compatibility mode
2005-05-09 22:22:29 +02:00
bool cConnectionHTTP::ProcessRequest(void)
{
- transfer
2005-02-11 17:44:14 +01:00
Dprintf("process\n");
if (m_Request.substr(0, 4) == "GET " && CmdGET(m_Request.substr(4))) {
switch (m_Job) {
case hjListing:
return Respond("HTTP/1.0 200 OK")
&& Respond("Content-Type: text/html")
&& Respond("")
&& Respond("<html><head><title>VDR Channel Listing</title></head>")
&& Respond("<body><ul>");
case hjTransfer:
if (m_Channel == NULL) {
Initial revision
2004-12-30 23:43:55 +01:00
DeferClose();
return Respond("HTTP/1.0 404 not found");
}
- transfer
2005-02-11 17:44:14 +01:00
Initial revision
2004-12-30 23:43:55 +01:00
m_LiveStreamer = new cStreamdevLiveStreamer(0);
cDevice *device = GetDevice(m_Channel, 0);
if (device != NULL) {
device->SwitchChannel(m_Channel, false);
- implemented audio track selection for http
2005-02-10 23:24:26 +01:00
if (m_LiveStreamer->SetChannel(m_Channel, m_StreamType, m_Apid)) {
- transfer
2005-02-08 20:54:52 +01:00
m_LiveStreamer->SetDevice(device);
Set DSCP 41 on stream data packets. WMM capable WLAN accesspoints should understand this and give precedence. For Internet streaming it could be used by traffic shapers. Suggested by ollo@vdrportal (#237). Modified Files: server/connectionHTTP.c server/connectionVTP.c tools/socket.c tools/socket.h
2007-05-09 11:12:42 +02:00
if (!SetDSCP())
LOG_ERROR_STR("unable to set DSCP sockopt");
- transfer
2005-02-11 17:44:14 +01:00
if (m_StreamType == stES && (m_Apid != 0 || ISRADIO(m_Channel))) {
Initial revision
2004-12-30 23:43:55 +01:00
return Respond("HTTP/1.0 200 OK")
- transfer
2005-02-11 17:44:14 +01:00
&& Respond("Content-Type: audio/mpeg")
- added TS compatibility mode
2005-05-09 22:22:29 +02:00
&& Respond("icy-name: %s", true, m_Channel->Name())
- transfer
2005-02-11 17:44:14 +01:00
&& Respond("");
Initial revision
2004-12-30 23:43:55 +01:00
} else {
return Respond("HTTP/1.0 200 OK")
- transfer
2005-02-11 17:44:14 +01:00
&& Respond("Content-Type: video/mpeg")
&& Respond("");
Initial revision
2004-12-30 23:43:55 +01:00
}
}
}
DELETENULL(m_LiveStreamer);
DeferClose();
- fixed http error response
2006-01-26 20:40:18 +01:00
return Respond("HTTP/1.0 409 Channel not available")
&& Respond("");
Initial revision
2004-12-30 23:43:55 +01:00
}
}
- transfer
2005-02-11 17:44:14 +01:00
DeferClose();
- fixed http error response
2006-01-26 20:40:18 +01:00
return Respond("HTTP/1.0 400 Bad Request")
&& Respond("");
Initial revision
2004-12-30 23:43:55 +01:00
}
- added TS compatibility mode
2005-05-09 22:22:29 +02:00
void cConnectionHTTP::Flushed(void)
{
- transfer
2005-02-11 17:44:14 +01:00
std::string line;
if (m_Status != hsBody)
return;
switch (m_Job) {
case hjListing:
Initial revision
2004-12-30 23:43:55 +01:00
if (m_ListChannel == NULL) {
Respond("</ul></body></html>");
DeferClose();
- transfer
2005-02-11 17:44:14 +01:00
m_Status = hsFinished;
Initial revision
2004-12-30 23:43:55 +01:00
return;
}
if (m_ListChannel->GroupSep())
- transfer
2005-02-08 18:22:35 +01:00
line = (std::string)"<li>--- " + m_ListChannel->Name() + "---</li>";
- transfer
2005-02-11 17:44:14 +01:00
else {
int index = 1;
- transfer
2005-02-08 18:22:35 +01:00
line = (std::string)"<li><a href=\"http://" + LocalIp() + ":"
+ (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"
- transfer
2005-02-11 17:44:14 +01:00
+ StreamTypes[m_StreamType] + "/"
- transfer
2005-02-08 18:22:35 +01:00
+ (const char*)m_ListChannel->GetChannelID().ToString() + "\">"
- transfer
2005-02-11 17:44:14 +01:00
+ m_ListChannel->Name() + "</a> ";
for (int i = 0; m_ListChannel->Apid(i) != 0; ++i, ++index) {
line += "<a href=\"http://" + LocalIp() + ":"
+ (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"
+ StreamTypes[m_StreamType] + "/"
+ (const char*)m_ListChannel->GetChannelID().ToString() + "+"
+ (const char*)itoa(index) + "\">("
+ m_ListChannel->Alang(i) + ")</a> ";
}
for (int i = 0; m_ListChannel->Dpid(i) != 0; ++i, ++index) {
line += "<a href=\"http://" + LocalIp() + ":"
+ (const char*)itoa(StreamdevServerSetup.HTTPServerPort) + "/"
+ StreamTypes[m_StreamType] + "/"
+ (const char*)m_ListChannel->GetChannelID().ToString() + "+"
+ (const char*)itoa(index) + "\">("
+ m_ListChannel->Dlang(i) + ")</a> ";
}
line += "</li>";
}
- added TS compatibility mode
2005-05-09 22:22:29 +02:00
if (!Respond(line.c_str()))
Initial revision
2004-12-30 23:43:55 +01:00
DeferClose();
m_ListChannel = Channels.Next(m_ListChannel);
- transfer
2005-02-11 17:44:14 +01:00
break;
case hjTransfer:
Initial revision
2004-12-30 23:43:55 +01:00
Dprintf("streamer start\n");
m_LiveStreamer->Start(this);
- transfer
2005-02-11 17:44:14 +01:00
m_Status = hsFinished;
break;
Initial revision
2004-12-30 23:43:55 +01:00
}
}
- added TS compatibility mode
2005-05-09 22:22:29 +02:00
bool cConnectionHTTP::CmdGET(const std::string &Opts)
{
- transfer
2005-02-11 17:44:14 +01:00
const char *sp = Opts.c_str(), *ptr = sp, *ep;
- implemented audio track selection for http
2005-02-10 23:24:26 +01:00
const cChannel *chan;
Use compiler flag -Wall. Cleanup code as necessary. (#171 Thanks to Rolf Ahrenberg) Modified Files: Makefile streamdev-server.c server/connection.h server/connectionHTTP.c server/connectionVTP.c tools/source.c
2007-04-16 13:01:02 +02:00
int apid = 0;
Initial revision
2004-12-30 23:43:55 +01:00
- transfer
2005-02-11 17:44:14 +01:00
ptr = skipspace(ptr);
while (*ptr == '/')
++ptr;
Initial revision
2004-12-30 23:43:55 +01:00
- transfer
2005-02-11 17:44:14 +01:00
if (strncasecmp(ptr, "PS/", 3) == 0) {
Initial revision
2004-12-30 23:43:55 +01:00
m_StreamType = stPS;
- transfer
2005-02-11 17:44:14 +01:00
ptr += 3;
} else if (strncasecmp(ptr, "PES/", 4) == 0) {
Initial revision
2004-12-30 23:43:55 +01:00
m_StreamType = stPES;
- transfer
2005-02-11 17:44:14 +01:00
ptr += 4;
} else if (strncasecmp(ptr, "TS/", 3) == 0) {
Initial revision
2004-12-30 23:43:55 +01:00
m_StreamType = stTS;
- transfer
2005-02-11 17:44:14 +01:00
ptr += 3;
} else if (strncasecmp(ptr, "ES/", 3) == 0) {
Initial revision
2004-12-30 23:43:55 +01:00
m_StreamType = stES;
- transfer
2005-02-11 17:44:14 +01:00
ptr += 3;
} else if (strncasecmp(ptr, "Extern/", 3) == 0) {
m_StreamType = stExtern;
ptr += 7;
Initial revision
2004-12-30 23:43:55 +01:00
}
- transfer
2005-02-11 17:44:14 +01:00
while (*ptr == '/')
++ptr;
for (ep = ptr + strlen(ptr); ep >= ptr && !isspace(*ep); --ep)
Initial revision
2004-12-30 23:43:55 +01:00
;
- transfer
2005-02-11 17:44:14 +01:00
std::string filespec = Opts.substr(ptr - sp, ep - ptr);
Dprintf("substr: %s\n", filespec.c_str());
Initial revision
2004-12-30 23:43:55 +01:00
- implemented audio track selection for http
2005-02-10 23:24:26 +01:00
Dprintf("before channelfromstring\n");
- transfer
2005-02-11 17:44:14 +01:00
if (filespec == "" || filespec.substr(0, 12) == "channels.htm") {
Initial revision
2004-12-30 23:43:55 +01:00
m_ListChannel = Channels.First();
- transfer
2005-02-11 17:44:14 +01:00
m_Job = hjListing;
} else if ((chan = ChannelFromString(filespec.c_str(), &apid)) != NULL) {
Initial revision
2004-12-30 23:43:55 +01:00
m_Channel = chan;
- implemented audio track selection for http
2005-02-10 23:24:26 +01:00
m_Apid = apid;
Dprintf("Apid is %d\n", apid);
- transfer
2005-02-11 17:44:14 +01:00
m_Job = hjTransfer;
Initial revision
2004-12-30 23:43:55 +01:00
}
- implemented audio track selection for http
2005-02-10 23:24:26 +01:00
Dprintf("after channelfromstring\n");
Initial revision
2004-12-30 23:43:55 +01:00
return true;
}
Reference in New Issue Copy Permalink