summaryrefslogtreecommitdiff
path: root/vdr-smarttvweb/smarttvfactory.c
diff options
context:
space:
mode:
Diffstat (limited to 'vdr-smarttvweb/smarttvfactory.c')
-rwxr-xr-xvdr-smarttvweb/smarttvfactory.c408
1 files changed, 0 insertions, 408 deletions
diff --git a/vdr-smarttvweb/smarttvfactory.c b/vdr-smarttvweb/smarttvfactory.c
deleted file mode 100755
index 3478e9d..0000000
--- a/vdr-smarttvweb/smarttvfactory.c
+++ /dev/null
@@ -1,408 +0,0 @@
-/*
- * smarttvfactory.h: VDR on Smart TV plugin
- *
- * Copyright (C) 2012 T. Lohmar
- *
- * 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.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with this program; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
- * Or, point your browser to http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
- *
- */
-
-#ifndef STANDALONE
-#include <vdr/recording.h>
-#include <vdr/videodir.h>
-#endif
-
-#include <iostream>
-
-#include <stdio.h>
-#include <unistd.h>
-#include <stdlib.h>
-#include <time.h>
-#include <sys/socket.h>
-#include <sys/stat.h>
-#include <sys/select.h>
-#include <sys/ioctl.h>
-#include <netinet/in.h>
-#include <arpa/inet.h>
-#include <net/if.h>
-#include <netdb.h>
-#include <fcntl.h>
-#include <errno.h>
-#include <dirent.h>
-
-#include <iostream>
-#include <fstream>
-
-
-#include "smarttvfactory.h"
-
-#ifndef STANDALONE
-#define PORT 8000
-#else
-#define PORT 9000
-#endif
-
-#define OKAY 0
-#define ERROR (-1)
-
-#define DEBUG
-
-
-using namespace std;
-
-void SmartTvServerStartThread(void* arg) {
- SmartTvServer* m = (SmartTvServer*)arg;
- m->threadLoop();
- delete m;
- pthread_exit(NULL);
-}
-
-SmartTvServer::SmartTvServer(): mRequestCount(0), isInited(false), serverPort(PORT), mServerFd(-1),
- mSegmentDuration(10), mHasMinBufferTime(40), mLiveChannels(20),
- clientList(), mActiveSessions(0), mConfig(NULL) {
-}
-
-
-SmartTvServer::~SmartTvServer() {
-
- if (mConfig != NULL)
- delete mConfig;
-}
-
-void SmartTvServer::cleanUp() {
- // close listening ports
- for (uint idx= 0; idx < clientList.size(); idx++) {
- if (clientList[idx] != NULL) {
- close(idx);
- delete clientList[idx];
- clientList[idx] = NULL;
- }
- }
-
- // close server port
- close(mServerFd);
-
- // Leave thread
- pthread_cancel(mThreadId);
- pthread_join(mThreadId, NULL);
-
- mLog.shutdown();
-}
-
-int SmartTvServer::runAsThread() {
- int res = pthread_create(&mThreadId, NULL, (void*(*)(void*))SmartTvServerStartThread, (void *)this);
- if (res != 0) {
- *(mLog.log()) << " Error creating thread. res= " << res
- << endl;
- return 0;
- }
- return 1;
-}
-
-void SmartTvServer::threadLoop() {
- *(mLog.log()) << " SmartTvServer Thread Started " << endl;
-
- loop();
-
- *(mLog.log()) << " SmartTvServer Thread Stopped " << endl;
-}
-
-
-void SmartTvServer::loop() {
- socklen_t addr_size = 0;
- int rfd;
- sockaddr_in sadr;
- int req_id = 0;
- int ret = 0;
- struct timeval timeout;
-
- int maxfd;
-
- fd_set read_set;
- fd_set write_set;
-
- FD_ZERO(&read_set);
- FD_ZERO(&write_set);
-
- FD_ZERO(&mReadState);
- FD_ZERO(&mWriteState);
-
- FD_SET(mServerFd, &mReadState);
- maxfd = mServerFd;
-
- *(mLog.log()) << "mServerFd= " << mServerFd << endl;
-
- int handeled_fds = 0;
-
- for (;;) {
- FD_ZERO(&read_set);
- FD_ZERO(&write_set);
- read_set = mReadState;
- write_set = mWriteState;
-
- if (ret != handeled_fds) {
- // Only ok, when the server has closed a handing HTTP connection
- *(mLog.log()) << "WARNING: Select-ret= " << ret
- << " != handeled_fds= " << handeled_fds << endl;
- /* FD_ZERO(&mReadState);
- FD_ZERO(&mWriteState);
- FD_SET(mServerFd, &mReadState);
- maxfd = mServerFd;
-
- read_set = mReadState;
- write_set = mWriteState;
- for (uint idx= 0; idx < clientList.size(); idx++) {
- if (clientList[idx] != NULL) {
- close(idx);
- delete clientList[idx];
- clientList[idx] = NULL;
- }
- }
- mActiveSessions = 0;
-*/
- }
-
- handeled_fds = 0;
- timeout.tv_sec = 5;
- timeout.tv_usec = 0;
-
- ret = select(maxfd + 1, &read_set, &write_set, NULL, &timeout);
-
- if (ret == 0) {
- // timeout: Check for dead TCP connections
- for (uint idx= 0; idx < clientList.size(); idx++) {
- if (clientList[idx] != NULL)
- if (clientList[idx]->checkStatus() == ERROR) {
- close(idx);
- delete clientList[idx];
- clientList[idx] = NULL;
- mActiveSessions--;
- FD_CLR(idx, &mReadState); /* dead client */
- FD_CLR(idx, &mWriteState);
- *(mLog.log()) << "WARNING: Timeout - Dead Client fd=" << idx << endl;
- }
- }
- continue;
- } // timeout
-
- if (ret < 0){
- *(mLog.log()) << "ERROR: select error " << errno << endl;
- continue;
- } // Error
-
- // new accept
- if (FD_ISSET(mServerFd, &read_set)) {
- handeled_fds ++;
- if((rfd = accept(mServerFd, (sockaddr*)&sadr, &addr_size))!= -1){
- req_id ++;
-
-#ifndef DEBUG
- *(mLog.log()) << "fd= " << rfd
- << " --------------------- Received connection ---------------------" << endl;
-#endif
-
- FD_SET(rfd, &mReadState);
- FD_SET(rfd, &mWriteState);
-
- if (rfd > maxfd) {
- maxfd = rfd;
- }
-
- if (clientList.size() < (rfd+1)) {
- clientList.resize(rfd+1, NULL); // Check.
- }
- clientList[rfd] = new cHttpResource(rfd, req_id, serverPort, this);
- mActiveSessions ++;
- *(mLog.log()) << " + mActiveSessions= " << mActiveSessions << endl;
- }
- else{
- *(mLog.log()) << "Error accepting " << errno << endl;
- }
- }
-
- // Check for data on already accepted connections
- for (rfd = 0; rfd < clientList.size(); rfd++) {
- if (clientList[rfd] == NULL)
- continue;
- if (FD_ISSET(rfd, &read_set)) {
- handeled_fds ++;
- // HandleRead
- if (clientList[rfd] == NULL) {
- *(mLog.log()) << "ERROR in Check Read: oops - no cHttpResource anymore fd= " << rfd << endl;
- close(rfd);
- FD_CLR(rfd, &mReadState); /* remove dead client */
- FD_CLR(rfd, &mWriteState);
- continue;
- }
- if ( clientList[rfd]->handleRead() < 0){
-#ifndef DEBUG
- *(mLog.log()) << "fd= " << rfd << " --------------------- Check Read: Closing ---------------------" << endl;
-#endif
- close(rfd);
- delete clientList[rfd];
- clientList[rfd] = NULL;
- mActiveSessions--;
- *(mLog.log()) << " - Check Read: mActiveSessions= " << mActiveSessions << endl;
- FD_CLR(rfd, &mReadState); /* dead client */
- FD_CLR(rfd, &mWriteState);
- }
- }
- }
-
- // Check for write
- for (rfd = 0; rfd < clientList.size(); rfd++) {
- if (clientList[rfd] == NULL)
- continue;
- if (FD_ISSET(rfd, &write_set)) {
- handeled_fds++;
- // HandleWrite
- if (clientList[rfd] == NULL) {
- close(rfd);
- FD_CLR(rfd, &mReadState);
- FD_CLR(rfd, &mWriteState);
- continue;
- }
- if ( clientList[rfd]->handleWrite() < 0){
-#ifndef DEBUG
- *(mLog.log()) << "fd= " << rfd << " --------------------- Check Write: Closing ---------------------" << endl;
-#endif
- close(rfd);
- delete clientList[rfd];
- clientList[rfd] = NULL;
- mActiveSessions--;
- *(mLog.log()) << " - Check Write: mActiveSessions= " << mActiveSessions << endl;
- FD_CLR(rfd, &mReadState);
- FD_CLR(rfd, &mWriteState);
- }
- }
- }
-
- // selfcheck
- /* *(mLog.log()) << "Select Summary: ret= " << ret
- << " handeled_fds=" << handeled_fds
- << " mActiveSessions= " << mActiveSessions
- << " clientList.size()= " << clientList.size()
- << endl;
-*/
- //Check for active sessions
- /*
- *(mLog.log()) << "checking number of active sessions clientList.size()= " << clientList.size() << endl;
-
- int act_ses = 0;
- for (uint idx= 0; idx < clientList.size(); idx++) {
- if (clientList[idx] != NULL)
- act_ses++;
- }
- if (act_ses != mActiveSessions) {
- *(mLog.log()) << "ERROR: Lost somewhere a session: "
- << "mActiveSessions= " << mActiveSessions
- << "act_ses= " << act_ses
- << endl;
- mActiveSessions = act_ses;
- }
- *(mLog.log()) << "checking number of active sessions - done mActiveSessions= " << mActiveSessions << endl;
-*/
- } // for (;;)
-} // org bracket
-
-int SmartTvServer::isServing() {
- return (mActiveSessions != 0 ? true : false);
-}
-
-void SmartTvServer::initServer(string dir) {
- /* This function initialtes the listening socket for the server
- * and sets isInited to true
- */
- mConfigDir = dir;
- int ret;
- struct sockaddr_in sock;
- int yes = 1;
-
-
-#ifndef STANDALONE
- mConfig = new cSmartTvConfig(dir);
- mLog.init(mConfig->getLogFile());
- esyslog("SmartTvWeb: Logfile created");
-
- *(mLog.log()) << mConfig->getLogFile() << endl;
-
-#else
- mConfig = new cSmartTvConfig(".");
- mLog.init(mConfig->getLogFile());
- cout << "SmartTvWeb: Logfile created" << endl;
- cout << "SmartTvWeb: Listening on port= " << PORT << endl;
-
-#endif
-
- // mConfig->printConfig();
-
- mSegmentDuration= mConfig->getSegmentDuration();
- mHasMinBufferTime= mConfig->getHasMinBufferTime();
- mLiveChannels = mConfig->getLiveChannels();
-
- *(mLog.log()) <<"HTTP server listening on port " << serverPort << endl;
-
- mServerFd = socket(PF_INET, SOCK_STREAM, 0);
- if (mServerFd <0) {
- *(mLog.log()) << "Error: Cannot create serving socket, exit" << endl;
- exit(1);
- }
-
- ret = setsockopt(mServerFd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int));
- if (ret <0) {
- *(mLog.log()) << "Error: Cannot set sockopts on serving socket, exit" << endl;
- exit(1);
- }
-
- memset((char *) &sock, 0, sizeof(sock));
- sock.sin_family = AF_INET;
-
- if (mConfig->getServerAddress() == "")
- sock.sin_addr.s_addr = htonl(INADDR_ANY);
- else {
- *(mLog.log()) << "Binding Server to " << mConfig->getServerAddress() << endl;
- sock.sin_addr.s_addr = inet_addr(mConfig->getServerAddress().c_str());
- }
- sock.sin_port = htons(serverPort);
-
- ret = bind(mServerFd, (struct sockaddr *) &sock, sizeof(sock));
- if (ret !=0) {
- *(mLog.log()) << "Error: Cannot bind serving socket, exit" << endl;
- exit(1);
- }
-
- /*
- struct ifreq ifr;
-
- ifr.ifr_addr.sa_family = AF_INET;
- strncpy(ifr.ifr_name, "eth0", IFNAMSIZ-1);
- ioctl(mServerFd, SIOCGIFADDR, &ifr);
- string own_ip = inet_ntoa(((struct sockaddr_in *)&ifr.ifr_addr)->sin_addr);
- *(mLog.log()) << " own if ip= " << own_ip << endl;
-*/
-
- ret = listen(mServerFd, 5);
- if (ret <0) {
- *(mLog.log()) << "Error: Cannot set listening on serving socket, exit" << endl;
- exit(1);
- }
-
- isInited = true;
-}
-
-
-
-
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-31 17:06:40 +0000