110 lines
3.6 KiB
C++
110 lines
3.6 KiB
C++
//debugging level 0 = nothing
|
|
//debugging level 1 = critical errors
|
|
//debugging level 2 = errors
|
|
//debugging level 3 = status information
|
|
//debugging level 4 = extremely verbose status information
|
|
#define DEBUG 3
|
|
|
|
#include <iostream>
|
|
#include <cstdlib>
|
|
#include <cstdio>
|
|
#include <cmath>
|
|
#include <unistd.h>
|
|
#include <sys/types.h>
|
|
#include <sys/wait.h>
|
|
#include <sys/epoll.h>
|
|
#include <getopt.h>
|
|
|
|
#define DEFAULT_PORT 80
|
|
#include "../util/server_setup.cpp"
|
|
#include "../util/http_parser.cpp"
|
|
|
|
int mainHandler(int CONN_fd){
|
|
bool ready4data = false;//set to true when streaming starts
|
|
bool inited = false;
|
|
int ss;
|
|
char streamname[200];
|
|
FLV_Pack * tag = 0;
|
|
HTTPReader HTTP_R;
|
|
|
|
int retval;
|
|
int poller = epoll_create(1);
|
|
int sspoller = epoll_create(1);
|
|
struct epoll_event ev;
|
|
ev.events = EPOLLIN;
|
|
ev.data.fd = CONN_fd;
|
|
epoll_ctl(poller, EPOLL_CTL_ADD, CONN_fd, &ev);
|
|
struct epoll_event events[1];
|
|
|
|
while (!socketError && !All_Hell_Broke_Loose){
|
|
//only parse input if available or not yet init'ed
|
|
retval = epoll_wait(poller, events, 1, 1);
|
|
if ((retval > 0) || !ready4data){
|
|
if (HTTP_R.ReadSocket(CONN_fd)){
|
|
printf("Puddingbroodjes!\n");
|
|
//ERIK: we hebben nu een hele HTTP request geparsed - verwerken mag hier, door aanroepen naar
|
|
//ERIK: bijvoorbeeld HTTP_R.GetHeader("headernaam") (voor headers) of HTTP_R.GetVar("varnaam") (voor GET/POST vars)
|
|
//ERIK: of HTTP_R.method of HTTP_R.url of HTTP_R.protocol....
|
|
//ERIK: zie ook ../util/http_parser.cpp - de class definitie bovenaan zou genoeg moeten zijn voor je
|
|
HTTP_R.Clean(); //maak schoon na verwerken voor eventuele volgende requests...
|
|
}
|
|
}
|
|
if (ready4data){
|
|
if (!inited){
|
|
//we are ready, connect the socket!
|
|
ss = DDV_OpenUnix(streamname);
|
|
if (ss <= 0){
|
|
#if DEBUG >= 1
|
|
fprintf(stderr, "Could not connect to server!\n");
|
|
#endif
|
|
socketError = 1;
|
|
break;
|
|
}
|
|
ev.events = EPOLLIN;
|
|
ev.data.fd = ss;
|
|
epoll_ctl(sspoller, EPOLL_CTL_ADD, ss, &ev);
|
|
#if DEBUG >= 3
|
|
fprintf(stderr, "Everything connected, starting to send video data...\n");
|
|
#endif
|
|
inited = true;
|
|
}
|
|
|
|
retval = epoll_wait(sspoller, events, 1, 1);
|
|
switch (DDV_ready(ss)){
|
|
case 0:
|
|
socketError = true;
|
|
#if DEBUG >= 1
|
|
fprintf(stderr, "Source socket is disconnected.\n");
|
|
#endif
|
|
break;
|
|
case -1: break;//not ready yet
|
|
default:
|
|
if (FLV_GetPacket(tag, ss)){//able to read a full packet?
|
|
//ERIK: "tag" bevat nu een FLV tag (video, audio, of metadata), de header hebben we al weggelezen, np.
|
|
//ERIK: Dit is het punt waarop je eventueel data mag/kan gaan sturen en/of parsen. Leef je uit.
|
|
//ERIK: je kan een HTTPReader aanmaken en gebruiken om je HTTP request op te bouwen (via SetBody, SetHeader, etc)
|
|
//ERIK: en dan met de .BuildResponse("200", "OK"); call een std::string met de hele response maken, klaar voor versturen
|
|
//ERIK: Note: hergebruik echter NIET de HTTP_R die ik al heb gemaakt hierboven, want er kunnen meerdere requests binnenkomen!
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
close(CONN_fd);
|
|
if (inited) close(ss);
|
|
#if DEBUG >= 1
|
|
if (All_Hell_Broke_Loose){fprintf(stderr, "All Hell Broke Loose\n");}
|
|
fprintf(stderr, "User %i disconnected.\n", CONN_fd);
|
|
if (inited){
|
|
fprintf(stderr, "Status was: inited\n");
|
|
}else{
|
|
if (ready4data){
|
|
fprintf(stderr, "Status was: ready4data\n");
|
|
}else{
|
|
fprintf(stderr, "Status was: connected\n");
|
|
}
|
|
}
|
|
#endif
|
|
return 0;
|
|
}
|
|
|