output_push.cpp File Reference

#include "output_push.h"
#include <mist/http_parser.h>
#include <mist/shared_memory.h>
#include <sys/stat.h>
#include <mist/tinythread.h>

Namespaces
	Mist
	Recording to file.

Macros
#define	PUSH_INDEX_SIZE   5

Functions
void	parseURI (const std::string &uri, std::string &host, long long &port, std::string &url)
void	proxyToPost (Socket::Connection &src, const std::string &srcUrl, Socket::Connection &dst, const std::string &dstUrl)
void	pushFirstElement (std::string qId)
	Push the first registered segment for this quality. More...
void	pushThread (void *nullPointer)
	Thread used to push data. More...

Variables
std::string	baseURL
std::string	dstHost
long long	dstPort
std::string	dstUrl
std::map< std::string, int >	latestNumber
std::map< std::string, bool >	parsing
Util::Config *	pConf
std::map< std::string, std::map< int, int > >	pushableDurations
std::map< std::string, std::map< int, std::string > >	pushableSegments
std::map< std::string, std::map< int, int > >	pushableTimes
std::map< std::string, std::deque< int > >	qualityBeginTimes
std::map< std::string, std::string >	qualityIndex
std::map< std::string, std::string >	qualitySegment
std::string	sName
std::string	srcHost
long long	srcPort

Macro Definition Documentation

#define PUSH_INDEX_SIZE   5

Function Documentation

void parseURI	(	const std::string &	uri,
		std::string &	host,
		long long &	port,
		std::string &	url
	)

void proxyToPost	(	Socket::Connection &	src,
		const std::string &	srcUrl,
		Socket::Connection &	dst,
		const std::string &	dstUrl
	)

void pushFirstElement

(

std::string

qId

)

Push the first registered segment for this quality.

Todo:

Make the dstConn "persistent" for each thread?

void pushThread

(

void *

nullPointer

)

Thread used to push data.

Variable Documentation

std::string baseURL

std::string dstHost

long long dstPort

std::string dstUrl

std::map<std::string, int> latestNumber

std::map<std::string, bool> parsing

Util::Config* pConf

std::map<std::string, std::map<int, int> > pushableDurations

std::map<std::string, std::map<int, std::string> > pushableSegments

std::map<std::string, std::map<int, int> > pushableTimes

std::map<std::string, std::deque<int> > qualityBeginTimes

std::map<std::string, std::string> qualityIndex

std::map<std::string, std::string> qualitySegment

std::string sName

std::string srcHost

long long srcPort