PublishQueuePosixRK Library Issues

Edge Systems
,
1

I’ve been successfully using the PublishQueuePosixRK Library without issue until recently. I use the following during setup:

// PosixQueue variables
const int ramQueueSize = 0;
const int fileQueueSize = 240;
const char * fileDirPath = "/publishQueue/test";
bool publishReady = false;
char publishBuffer[particle::protocol::MAX_EVENT_DATA_LENGTH+1];

void setup()
{
    PublishQueuePosix::instance().setup();
    PublishQueuePosix::instance().withRamQueueSize(ramQueueSize);
    PublishQueuePosix::instance().withFileQueueSize(fileQueueSize);
    PublishQueuePosix::instance().withDirPath(fileDirPath);
}

Use it as follows during loop:

void loop()
{
    // Update Tracker
    Tracker::instance().loop();

    // Update Publish Queue
    PublishQueuePosix::instance().loop();
}

And cache publishes here:

int postPublishCallback(CloudServiceStatus status, JSONValue * value, const char * someStr, const void *context){
    Log.info("Publish cloud service returned: %i. 0=Success,1=Fail,2=Timeout", status);
    Log.info("SomeStr field: %s ", someStr);
    if(status != CloudServiceStatus::SUCCESS){
        PublishQueuePosix::instance().publish("cloc",someStr,WITH_ACK);
    }
    return 1;
}

The log statements in the above code trigger when the device is offline but when it comes back online the cache publishing fails to retrieve from the flash storage. It seems the first cached entry will occasionally return and publish correctly but the rest error out in the logs below:

0000248989 [app.seqfile] TRACE: getFileFromQueue returned 1
0000248990 [app.pubq] TRACE: fileNum=1 size=536898020
0000248991 [app.pubq] TRACE: readQueueFile 1 bad magic=00000000 version=21 headerSize=66 nameLen=5
0000248991 [app.pubq] INFO: discarding corrupted file 1
0000248992 [app.seqfile] TRACE: getFileFromQueue returned 1
0000248993 [app.seqfile] TRACE: removed /publishQueue/test/00000001
0000248994 [app.seqfile] TRACE: getFileFromQueue returned 2
0000248995 [app.pubq] TRACE: fileNum=2 size=536898020
0000248995 [app.pubq] TRACE: readQueueFile 2 bad magic=00000000 version=21 headerSize=66 nameLen=5
0000248996 [app.pubq] INFO: discarding corrupted file 2
0000248997 [app.seqfile] TRACE: getFileFromQueue returned 2
0000248998 [app.seqfile] TRACE: removed /publishQueue/test/00000002
0000248999 [app.seqfile] TRACE: getFileFromQueue returned 3
0000249000 [app.pubq] TRACE: fileNum=3 size=536898020
0000249000 [app.pubq] TRACE: readQueueFile 3 bad magic=00000000 version=21 headerSize=66 nameLen=5
0000249001 [app.pubq] INFO: discarding corrupted file 3
0000249002 [app.seqfile] TRACE: getFileFromQueue returned 3
0000249003 [app.seqfile] TRACE: removed /publishQueue/test/00000003
0000249004 [app.seqfile] TRACE: getFileFromQueue returned 4
0000249006 [app.pubq] TRACE: fileNum=4 size=536898020
0000249009 [app.seqfile] TRACE: getFileFromQueue returned 5                        ze=66 nameLen=5
0000249010 [app.pubq] TRACE: fileNum=5 size=536898020
0000249010 [app.pubq] TRACE: readQueueFile 5 bad magic=00000000 version=21 headerSize=66 nameLen=5
0000249011 [app.pubq] INFO: discarding corrupted file 5
0000249012 [app.seqfile] TRACE: getFileFromQueue returned 5
0000249013 [app.seqfile] TRACE: removed /publishQueue/test/00000005                ze=66 nameLen=5
0000249013 [app.seqfile] TRACE: getFileFromQueue returned 6
0000249015 [app.pubq] TRACE: fileNum=6 size=536898020
0000249015 [app.pubq] TRACE: readQueueFile 6 bad magic=00000000 version=21 headerSize=66 nameLen=5
0000249016 [app.pubq] INFO: discarding corrupted file 6
0000249016 [app.seqfile] TRACE: getFileFromQueue returned 6
0000249017 [app.seqfile] TRACE: removed /publishQueue/test/00000006
0000249018 [app.seqfile] TRACE: getFileFromQueue returned 7
0000249019 [app.pubq] TRACE: fileNum=7 size=536898020
0000249020 [app.pubq] TRACE: readQueueFile 7 bad magic=00000000 version=21 headerSize=66 nameLen=5
0000249020 [app.pubq] INFO: discarding corrupted file 7
0000249021 [app.seqfile] TRACE: getFileFromQueue returned 7
0000249022 [app.seqfile] TRACE: removed /publishQueue/test/00000007
0000249023 [app.seqfile] TRACE: getFileFromQueue returned 8
0000249024 [app.pubq] TRACE: fileNum=8 size=536898020
0000249024 [app.pubq] TRACE: readQueueFile 8 bad magic=00000000 version=21 headerSize=66 nameLen=5
0000249025 [app.pubq] INFO: discarding corrupted file 8
0000249026 [app.seqfile] TRACE: getFileFromQueue returned 8
0000249033 [app.seqfile] TRACE: removed /publishQueue/test/00000008