Function demoworkerthread

source/src/server.cpp:874–949

sl_semaphore sem_demoworkerthread(1, NULL); // trigger demoworkerthread

int demoworkerthread(void *logfileprefix) // demo worker thread: compress demo data and write demo files
{
    int len;
    while(1)
    {
        loopi(MAXDEMOS) if(demos[i].sequence)
        {
            demo_s &s = demos[i];
            while(s.gz && s.rb && (len = s.rb->length()))
            { // compress until rb is empty
                uchar *rbp = s.rb->peek(&len);
                if(len != s.gz->write(rbp, len)) s.error = true;
                s.rb->remove(&len);
            }
            if(s.finish && s.gz && s.rb && !s.rb->length())
            { // close and copy zip file
                if(demo_debug) tlog(ACLOG_INFO, "demoworkerthread(): close slot %d, sequence #%d", i, s.sequence);
                tigerhash_finish(s.tiger, s.tigerstate);
                s.tigerstate = NULL;
                string msg;
                bin2hex(msg, s.tiger, TIGERHASHSIZE);
                defformatstring(text)("SERVDEMOEND<%s>", msg);
                ed25519_sign((uchar*)msg, NULL, (uchar*)text, strlen(text), ssk);
                int stamp[3] = { -1, -1, TIGERHASHSIZE + 64 };
                lilswap(stamp, 3);
                s.gz->write(stamp, sizeof(stamp));
                s.gz->write(s.tiger, TIGERHASHSIZE);
                s.gz->write(msg, 64);
                DELETEP(s.gz);
                s.len = s.dbs->size();
                s.data = new uchar[s.len];
                s.dbs->seek(0, SEEK_SET);
                s.dbs->read(s.data, s.len);
                if(s.save)
                {
                    stream *demo = openfile(s.filename, "wb");
                    if(demo)
                    {
                        int wlen = (int) demo->write(s.data, s.len);
                        delete demo;
                        tlog(ACLOG_INFO, "demo #%d written to file \"%s\" (%d bytes)", s.sequence, s.filename, wlen);
                    }
                    else
                    {
                        tlog(ACLOG_INFO, "failed to write demo #%d to file \"%s\"", s.sequence, s.filename);
                    }
                }
                else tlog(ACLOG_INFO, "recording demo #%d \"%s\" (%d bytes) finished, not saved to file", s.sequence, s.filename, s.len);
                s.done = true;
            }
            if(s.finish || s.error || s.remove)
            { // cleanup demo slot
                if(demo_debug) tlog(ACLOG_INFO, "demoworkerthread(): cleanup slot %d, sequence #%d", i, s.sequence);
                if(s.error || s.remove) s.done = false;
                DELETEP(s.gz);
                DELETEP(s.dbs);
                if(s.db)
                { // keep the demo buffer for the next recording