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

Merge branch 'development' into LTS_development

Browse source
This commit is contained in:
Thulinma 2015-06-16 12:33:53 +02:00
commit ab222cb766
1 changed files with 32 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

51
src/io.cpp
View file

@ -91,19 +91,22 @@ namespace Mist {
//Initialize the bookkeeping entry, and set the current offset to 0, to allow for using it in bufferNext() //Initialize the bookkeeping entry, and set the current offset to 0, to allow for using it in bufferNext()
pagesByTrack[tid][pageNumber].curOffset = 0; pagesByTrack[tid][pageNumber].curOffset = 0;
//Register this page on the meta page if (myMeta.live){
bool inserted = false; //Register this page on the meta page
for (int i = 0; i < 1024; i++) { //NOTE: It is important that this only happens if the stream is live....
int * tmpOffset = (int *)(metaPages[tid].mapped + (i * 8)); bool inserted = false;
if ((tmpOffset[0] == 0 && tmpOffset[1] == 0)) { for (int i = 0; i < 1024; i++) {
tmpOffset[0] = htonl(curPageNum[tid]); int * tmpOffset = (int *)(metaPages[tid].mapped + (i * 8));
if (pagesByTrack[tid][pageNumber].dataSize == (25 * 1024 * 1024)){ if ((tmpOffset[0] == 0 && tmpOffset[1] == 0)) {
tmpOffset[1] = htonl(1000); tmpOffset[0] = htonl(curPageNum[tid]);
} else { if (pagesByTrack[tid][pageNumber].dataSize == (25 * 1024 * 1024)){
tmpOffset[1] = htonl(pagesByTrack[tid][pageNumber].keyNum); tmpOffset[1] = htonl(1000);
} else {
tmpOffset[1] = htonl(pagesByTrack[tid][pageNumber].keyNum);
}
inserted = true;
break;
} }
inserted = true;
break;
} }
} }
@ -263,17 +266,27 @@ namespace Mist {
for (int i = 0; i < 1024; i++) { for (int i = 0; i < 1024; i++) {
int * tmpOffset = (int *)(metaPages[tid].mapped + (i * 8)); int * tmpOffset = (int *)(metaPages[tid].mapped + (i * 8));
int keyNum = ntohl(tmpOffset[0]); int keyNum = ntohl(tmpOffset[0]);
int keyAmount = ntohl(tmpOffset[1]);
if (!inserted){
if (myMeta.live){
if(keyNum == curPageNum[tid] && keyAmount == 1000){
tmpOffset[1] = htonl(pagesByTrack[tid][curPageNum[tid]].keyNum);
inserted = true;
}
}else{
//in case of vod, insert at the first "empty" spot
if(keyNum == 0){
tmpOffset[0] = htonl(curPageNum[tid]);
tmpOffset[1] = htonl(pagesByTrack[tid][curPageNum[tid]].keyNum);
inserted = true;
}
}
}
keyNum = ntohl(tmpOffset[0]);
if (!keyNum) continue; if (!keyNum) continue;
if (!lowest || keyNum < lowest){ if (!lowest || keyNum < lowest){
lowest = keyNum; lowest = keyNum;
} }
int keyAmount = ntohl(tmpOffset[1]);
if (!inserted && keyNum == curPageNum[tid]){
if (keyAmount == 1000){
tmpOffset[1] = htonl(pagesByTrack[tid][curPageNum[tid]].keyNum);
}
inserted = true;
}
} }
#if defined(__CYGWIN__) || defined(_WIN32) #if defined(__CYGWIN__) || defined(_WIN32)