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

Fixed a bug. (DTSC lib mistakenly wiped metadata when seeking backwards, re-re-fixed proc child signal problems)

Browse source
This commit is contained in:
Thulinma 2013-07-23 15:52:34 +02:00
parent 6a72fddf7b
commit 9cdf8d92a1
2 changed files with 6 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/dtsc.cpp
View file

@ -193,7 +193,7 @@ void DTSC::Stream::addPacket(JSON::Value & newPack){
livePos newPos;
newPos.trackID = newPack["trackid"].asInt();
newPos.seekTime = newPack["time"].asInt();
if (buffers.size() > 0){
if (buffercount > 1 && buffers.size() > 0){
livePos lastPos = buffers.rbegin()->first;
if (newPos < lastPos){
if ((lastPos.seekTime > 1000) && newPos.seekTime < lastPos.seekTime - 1000){
@ -314,11 +314,11 @@ void DTSC::Stream::addPacket(JSON::Value & newPack){
}
while (buffers.size() > buffercount){
if (keyframes[buffers.begin()->first.trackID].count(buffers.begin()->first)){
if (buffercount > 1 && keyframes[buffers.begin()->first.trackID].count(buffers.begin()->first)){
updateMeta = true;
//if there are < 3 keyframes, throwing one away would mean less than 2 left.
if (keyframes[buffers.begin()->first.trackID].size() < 3){
std::cout << "Warning - track " << buffers.begin()->first.trackID << " doesn't have enough keyframes to be reliably served." << std::endl;
std::cerr << "Warning - track " << buffers.begin()->first.trackID << " doesn't have enough keyframes to be reliably served." << std::endl;
}
std::string track = trackMapping[buffers.begin()->first.trackID];
keyframes[buffers.begin()->first.trackID].erase(buffers.begin()->first);

12
lib/procs.cpp
View file

@ -91,19 +91,11 @@ void Util::Procs::childsig_handler(int signum){
return;
}
int status;
pid_t ret = waitpid( -1, &status, WNOHANG);
if (ret == 0){ //ignore, would block otherwise
return;
}else if (ret < 0){
if (errno == EINTR){
pid_t ret = waitpid( -1, &status, 0);
if (ret <= 0){
childsig_handler(signum);
return;
}
#if DEBUG >= 3
std::cerr << "SIGCHLD received, but no child died";
#endif
return;
}
int exitcode;
if (WIFEXITED(status)){
exitcode = WEXITSTATUS(status);