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

Re-unified coding style.

Browse source
This commit is contained in:
Thulinma 2013-03-25 12:25:36 +01:00
parent fd1c2ff2f4
commit 14ba7f835a
4 changed files with 16 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/buffer/player.cpp
View file

@ -80,10 +80,11 @@ int main(int argc, char** argv){
std::string meta_str = meta.toNetPacked(); std::string meta_str = meta.toNetPacked();
in_out.Send(meta_str); in_out.Send(meta_str);
if ( !(meta.isMember("keytime") && meta.isMember("keybpos") && meta.isMember("keynum") && meta.isMember("keylen") && meta.isMember("frags")) && meta.isMember("video")){ if ( !(meta.isMember("keytime") && meta.isMember("keybpos") && meta.isMember("keynum") && meta.isMember("keylen") && meta.isMember("frags"))
&& meta.isMember("video")){
//file needs to be DTSCFix'ed! Run MistDTSCFix executable on it first //file needs to be DTSCFix'ed! Run MistDTSCFix executable on it first
std::cerr << "Calculating / writing / updating VoD metadata..." << std::endl; std::cerr << "Calculating / writing / updating VoD metadata..." << std::endl;
Util::Procs::Start("Fixer", Util::getMyPath() + "MistDTSCFix "+conf.getString("filename")); Util::Procs::Start("Fixer", Util::getMyPath() + "MistDTSCFix " + conf.getString("filename"));
while (Util::Procs::isActive("Fixer")){ while (Util::Procs::isActive("Fixer")){
Util::sleep(5000); Util::sleep(5000);
} }

3
src/controller/controller.cpp
View file

@ -298,7 +298,8 @@ int main(int argc, char ** argv){
if (Request.isMember("vod")){ if (Request.isMember("vod")){
std::string thisfile = Request["vod"]["filename"]; std::string thisfile = Request["vod"]["filename"];
for (JSON::ObjIter oit = Controller::Storage["streams"].ObjBegin(); oit != Controller::Storage["streams"].ObjEnd(); ++oit){ for (JSON::ObjIter oit = Controller::Storage["streams"].ObjBegin(); oit != Controller::Storage["streams"].ObjEnd(); ++oit){
if ((oit->second.isMember("source") && oit->second["source"].asString() == thisfile) || (oit->second.isMember("channel") && oit->second["channel"]["URL"].asString() == thisfile)){ if ((oit->second.isMember("source") && oit->second["source"].asString() == thisfile)
|| (oit->second.isMember("channel") && oit->second["channel"]["URL"].asString() == thisfile)){
Controller::lastBuffer[oit->first] = Util::epoch(); Controller::lastBuffer[oit->first] = Util::epoch();
if (Request["vod"].isMember("meta")){ if (Request["vod"].isMember("meta")){
Controller::Storage["streams"][oit->first]["meta"] = Request["vod"]["meta"]; Controller::Storage["streams"][oit->first]["meta"] = Request["vod"]["meta"];

7
src/controller/controller_streams.cpp
View file

@ -10,7 +10,7 @@ namespace Controller {
std::map<std::string, int> lastBuffer; ///< Last moment of contact with all buffers. std::map<std::string, int> lastBuffer; ///< Last moment of contact with all buffers.
bool streamsEqual(JSON::Value & one, JSON::Value & two){ bool streamsEqual(JSON::Value & one, JSON::Value & two){
if (!one.isMember("source") || !two.isMember("source") || one["source"] != two["source"]){ if ( !one.isMember("source") || !two.isMember("source") || one["source"] != two["source"]){
return false; return false;
} }
return true; return true;
@ -82,7 +82,8 @@ namespace Controller {
startStream(jit->first, jit->second); startStream(jit->first, jit->second);
} }
if (currTime - lastBuffer[jit->first] > 5){ if (currTime - lastBuffer[jit->first] > 5){
if (jit->second.isMember("source") && jit->second["source"].asString().substr(0, 1) == "/" && jit->second.isMember("error") && jit->second["error"].asString() == "Available"){ if (jit->second.isMember("source") && jit->second["source"].asString().substr(0, 1) == "/" && jit->second.isMember("error")
&& jit->second["error"].asString() == "Available"){
jit->second["online"] = 2; jit->second["online"] = 2;
}else{ }else{
if (jit->second.isMember("error") && jit->second["error"].asString() == "Available"){ if (jit->second.isMember("error") && jit->second["error"].asString() == "Available"){
@ -95,7 +96,7 @@ namespace Controller {
jit->second.removeMember("error"); jit->second.removeMember("error");
jit->second["online"] = 1; jit->second["online"] = 1;
// check if source is valid // check if source is valid
if ( jit->second.isMember("live") && !jit->second.isMember("meta") || !jit->second["meta"]){ if (jit->second.isMember("live") && !jit->second.isMember("meta") || !jit->second["meta"]){
jit->second["online"] = 0; jit->second["online"] = 0;
jit->second["error"] = "No (valid) source connected"; jit->second["error"] = "No (valid) source connected";
}else{ }else{

7
src/converters/dtscfix.cpp
View file

@ -21,7 +21,8 @@ namespace Converters {
return 1; return 1;
} }
if (oriheader["moreheader"].asInt() > 0){ if (oriheader["moreheader"].asInt() > 0){
if ((meta.isMember("keytime") && meta.isMember("keybpos") && meta.isMember("keynum") && meta.isMember("keylen") && meta.isMember("frags")) || !meta.isMember("video")){ if ((meta.isMember("keytime") && meta.isMember("keybpos") && meta.isMember("keynum") && meta.isMember("keylen") && meta.isMember("frags"))
|| !meta.isMember("video")){
std::cerr << "This file was already fixed or doesn't need fixing - cancelling." << std::endl; std::cerr << "This file was already fixed or doesn't need fixing - cancelling." << std::endl;
return 0; return 0;
} }
@ -53,7 +54,7 @@ namespace Converters {
if (F.getJSON()["keyframe"].asInt() != 0){ if (F.getJSON()["keyframe"].asInt() != 0){
meta["keytime"].append(F.getJSON()["time"]); meta["keytime"].append(F.getJSON()["time"]);
meta["keybpos"].append(F.getLastReadPos()); meta["keybpos"].append(F.getLastReadPos());
meta["keynum"].append(++keynum); meta["keynum"].append( ++keynum);
if (meta["keytime"].size() > 1){ if (meta["keytime"].size() > 1){
meta["keylen"].append(F.getJSON()["time"].asInt() - meta["keytime"][meta["keytime"].size() - 2].asInt()); meta["keylen"].append(F.getJSON()["time"].asInt() - meta["keytime"][meta["keytime"].size() - 2].asInt());
} }
@ -87,7 +88,7 @@ namespace Converters {
long long int fragLen = 1; long long int fragLen = 1;
long long int fragDur = meta["keylen"][i].asInt(); long long int fragDur = meta["keylen"][i].asInt();
for (unsigned int j = i; j < meta["keytime"].size(); j++){ for (unsigned int j = i; j < meta["keytime"].size(); j++){
if (meta["keytime"][j].asInt() / 10000 > currFrag || j == meta["keytime"].size()-1){ if (meta["keytime"][j].asInt() / 10000 > currFrag || j == meta["keytime"].size() - 1){
JSON::Value thisFrag; JSON::Value thisFrag;
thisFrag["num"] = meta["keynum"][i]; thisFrag["num"] = meta["keynum"][i];
thisFrag["len"] = fragLen; thisFrag["len"] = fragLen;