cygnal.cpp File Reference

#include <sys/stat.h>
#include <list>
#include <map>
#include <iostream>
#include <sstream>
#include <csignal>
#include <vector>
#include <sys/mman.h>
#include <cerrno>
#include <sys/types.h>
#include <fcntl.h>
#include "GnashSleep.h"
#include "revno.h"
#include "GnashSystemIOHeaders.h"
#include <boost/shared_ptr.hpp>
#include "network.h"
#include "log.h"
#include "crc.h"
#include "proc.h"
#include "rtmp.h"
#include "buffer.h"
#include "utility.h"
#include "limits.h"
#include "netstats.h"
#include "statistics.h"
#include "gmemory.h"
#include "diskstream.h"
#include "arg_parser.h"
#include "GnashException.h"
#include "URL.h"
#include "rtmp_client.h"
#include "rtmp_server.h"
#include "http_server.h"
#include "handler.h"
#include "cache.h"
#include "cygnal.h"
#include <boost/date_time/gregorian/gregorian.hpp>
#include <boost/date_time/time_zone_base.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/thread/thread.hpp>
#include <boost/bind.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/thread/condition.hpp>
#include <boost/thread/tss.hpp>

Defines
#define	POLLRDHUP   0
Functions
int	getopt (int, char *const *, const char *)
void	connection_handler (Network::thread_params_t *args)
void	event_handler (Network::thread_params_t *args)
void	admin_handler (Network::thread_params_t *args)
int	main (int argc, char *argv[])
Variables
int	optind
char *	optarg
struct sigaction act1	act2
int	thread_retries = 10
const int	ADMINPKTSIZE = 80
ThreadCounter	tids
map< int, Network * >	networks
const char *	proto_str []

---

Define Documentation

#define POLLRDHUP   0

---

Function Documentation

void admin_handler

(

Network::thread_params_t *

args

)

References _, ADMINPKTSIZE, CLOCK_REALTIME, gnash::Network::closeConnection(), gnash::Network::closeNet(), gnash::Network::createServer(), data, cygnal::handlers, cygnal::Handler::INTERVAL, gnash::Network::newConnection(), cygnal::Handler::POLL, gnash::Network::thread_params_t::port, cygnal::Handler::QUIT, gnash::Network::readNet(), cygnal::Handler::STATUS, and gnash::Network::writeNet().

void connection_handler

(

Network::thread_params_t *

args

)

References _, cygnal::Handler::addClient(), cygnal::Cygnal::addHandler(), gnash::Network::thread_params_t::buffer, gnash::Network::closeNet(), gnash::Network::createServer(), gnash::Network::thread_params_t::entry, event_handler(), cygnal::Cygnal::peer_t::fd, gnash::Network::thread_params_t::filespec, cygnal::Cygnal::findHandler(), cygnal::Cygnal::getActive(), cygnal::CRcInitFile::getCgiRoot(), cygnal::CRcInitFile::getDocumentRoot(), cygnal::CRcInitFile::getFDThread(), gnash::HTTP::getField(), gnash::HTTP::getFilespec(), cygnal::Handler::getKey(), cygnal::RTMPServer::getNetConnection(), cygnal::CRcInitFile::getThreadingFlag(), gnash::Network::thread_params_t::handler, LOG_ONCE, gnash::Network::thread_params_t::netfd, gnash::Network::newConnection(), cygnal::ThreadCounter::num_of_tids(), cygnal::Handler::parseFirstRequest(), gnash::HTTP::peekChunk(), gnash::Network::thread_params_t::port, cygnal::RTMPServer::processClientHandShake(), gnash::HTTP::processHeaderFields(), proto_str, gnash::Network::thread_params_t::protocol, gnash::HTTP::setDocRoot(), cygnal::RTMPServer::setNetConnection(), gnash::Network::setPort(), tids, gnash::Network::toggleDebug(), and url.

void event_handler

(

Network::thread_params_t *

args

)

References gnash::Network::thread_params_t::buffer, gnash::Network::closeNet(), cygnal::ThreadCounter::decrement(), gnash::Network::thread_params_t::entry, gnash::Network::thread_params_t::filespec, gnash::Cache::findFile(), cygnal::Handler::getActiveDiskStreams(), cygnal::Handler::getClient(), cygnal::Handler::getClients(), cygnal::Handler::getDiskStream(), cygnal::Handler::getHTTPHandler(), cygnal::Handler::getProtocol(), gnash::Network::thread_params_t::handler, gnash::key::i, cygnal::ThreadCounter::increment(), gnash::Network::thread_params_t::netfd, cygnal::ThreadCounter::num_of_tids(), gnash::Network::thread_params_t::port, proto_str, gnash::Network::thread_params_t::protocol, cygnal::Handler::removeClient(), cygnal::rtmp_handler(), gnash::Network::setTimeout(), tids, and gnash::Network::waitForNetData().

int getopt	(	int	,
		char *const *	,
		const char *
	)

int main	(	int	argc,
		char *	argv[]
	)

References _, act2, admin_handler(), gnash::ADMIN_PORT, Arg_parser::argument(), Arg_parser::arguments(), bindtextdomain, Arg_parser::code(), connection_handler(), cygnal::dbglogfile, cygnal::CRcInitFile::dump(), Arg_parser::error(), EXIT_SUCCESS, gnash::Network::thread_params_t::filespec, gnash::RcInitFile::getDebugLog(), cygnal::CRcInitFile::getDocumentRoot(), cygnal::CRcInitFile::getPortOffset(), cygnal::CRcInitFile::getThreadingFlag(), gnash::HTTP_PORT, gnash::key::i, cygnal::Cygnal::loadPeersFile(), LOG_ONCE, gnash::Network::thread_params_t::netfd, Arg_parser::no, gnash::Network::thread_params_t::port, cygnal::Cygnal::probePeers(), gnash::Network::thread_params_t::protocol, gnash::RTMP_PORT, cygnal::CRcInitFile::setDocumentRoot(), gnash::LogFile::setLogFilename(), gnash::LogFile::setNetwork(), cygnal::CRcInitFile::setPortOffset(), cygnal::CRcInitFile::setTestingFlag(), cygnal::CRcInitFile::setThreadingFlag(), gnash::LogFile::setVerbosity(), textdomain, gnash::Network::thread_params_t::tid, gnash::RcInitFile::verbosityLevel(), and Arg_parser::yes.

---

Variable Documentation

struct sigaction act1 act2

const int ADMINPKTSIZE = 80

map<int, Network *> networks

char* optarg

int optind

const char* proto_str[]

Initial value:

 {
    "NONE",
    "HTTP",
    "HTTPS",
    "RTMP",
    "RTMPT",
    "RTMPTS",
    "RTMPE",
    "RTMPS",
    "DTN"
}

int thread_retries = 10

ThreadCounter tids