Fixed first page under Windows not being correct size for pushing (Bad, Erik, bad!)

This commit is contained in:
Thulinma 2014-07-24 15:11:14 +02:00
parent 9d2c71e4df
commit e0d6a18f70

View file

@ -158,7 +158,7 @@ namespace Mist {
INFO_MSG("Buffer has indicated that incoming track %d should start writing on track %d, page %d", tid, finalTid, firstPage); INFO_MSG("Buffer has indicated that incoming track %d should start writing on track %d, page %d", tid, finalTid, firstPage);
memset(pageName, 0, 100); memset(pageName, 0, 100);
sprintf(pageName, "%s%d_%d", streamName.c_str(), finalTid, firstPage); sprintf(pageName, "%s%d_%d", streamName.c_str(), finalTid, firstPage);
curPages[finalTid].init(pageName, 8 * 1024 * 1024); curPages[finalTid].init(pageName, 25 * 1024 * 1024);
trackMap[tid] = finalTid; trackMap[tid] = finalTid;
bookKeeping[finalTid] = DTSCPageData(); bookKeeping[finalTid] = DTSCPageData();
} }
@ -205,7 +205,7 @@ namespace Mist {
char nextPage[100]; char nextPage[100];
sprintf(nextPage, "%s%llu_%d", streamName.c_str(), tNum, bookKeeping[tNum].pageNum + bookKeeping[tNum].keyNum); sprintf(nextPage, "%s%llu_%d", streamName.c_str(), tNum, bookKeeping[tNum].pageNum + bookKeeping[tNum].keyNum);
INFO_MSG("Continuing track %llu on page %d", tNum, bookKeeping[tNum].pageNum + bookKeeping[tNum].keyNum); INFO_MSG("Continuing track %llu on page %d", tNum, bookKeeping[tNum].pageNum + bookKeeping[tNum].keyNum);
curPages[tNum].init(nextPage, 26 * 1024 * 1024); curPages[tNum].init(nextPage, 25 * 1024 * 1024);
bookKeeping[tNum].pageNum += bookKeeping[tNum].keyNum; bookKeeping[tNum].pageNum += bookKeeping[tNum].keyNum;
bookKeeping[tNum].keyNum = 0; bookKeeping[tNum].keyNum = 0;
bookKeeping[tNum].curOffset = 0; bookKeeping[tNum].curOffset = 0;