hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Nog een poging...

Browse source
This commit is contained in:
Thulinma 2010-11-07 23:37:08 +01:00
parent 9fcecc9015
commit 4a6de43ed7
1 changed files with 17 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
Connector_RTMP/main.cpp
View file

@ -7,6 +7,7 @@
#include <signal.h> #include <signal.h>
#include <sys/types.h> #include <sys/types.h>
#include <sys/wait.h> #include <sys/wait.h>
#include <sys/epoll.h>
//for connection to server //for connection to server
#include "../sockets/SocketW.h" #include "../sockets/SocketW.h"
@ -65,10 +66,25 @@ int main(){
#ifdef DEBUG #ifdef DEBUG
fprintf(stderr, "Starting processing...\n"); fprintf(stderr, "Starting processing...\n");
#endif #endif
int retval;
int poller = epoll_create(1);
struct epoll_event ev;
ev.events = EPOLLIN | EPOLLOUT;
ev.data.fd = fileno(CONN);
epoll_ctl(poller, EPOLL_CTL_ADD, fileno(CONN), &ev);
struct epoll_event events[1];
while (!ferror(CONN)){ while (!ferror(CONN)){
//only parse input if available or not yet init'ed //only parse input if available or not yet init'ed
//rightnow = getNowMS(); //rightnow = getNowMS();
if ((!ready4data || (snd_cnt - snd_window_at >= snd_window_size)) && !stopparsing){ retval = epoll_wait(poller, events, 1, 1000);
if (retval){
fprintf(stderr, "Socket %i is now state %i, in is %i, out is %i\n", events[0].data.fd, events[0].events, EPOLLIN, EPOLLOUT);
parseChunk(); parseChunk();
fflush(CONN); fflush(CONN);
} }