vos/corelibs/vos/messageblock.cc

Go to the documentation of this file.

/*
    This file is part of the Virtual Object System of
    the Interreality project (http://interreality.org).

    Copyright (C) 2001-2003 Peter Amstutz

    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Lesser General Public
    License as published by the Free Software Foundation; either
    version 2 of the License, or (at your option) any later version.

    This library is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public
    License along with this library; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA

    Peter Amstutz <tetron@interreality.org>
*/

#include "messageblock.hh"
#include "message.hh"
#include "msglexer.hh"
#include "log.hh"

#include "parsemessage_parser.h"

#include <deque>

using namespace VOS;

MessageBlock::MessageBlock()
    : formattedString(0)
{
    parsestate.m=this;
    parsestate.chars_read=0;
    parsestate.expected_length=0;
    parsestate.done=false;
    parsestate.extra=0;
    parsestate.read_quoted=0;
}

MessageBlock::~MessageBlock()
{
    LOG("refcount", 5, "start deleting messageblock with messages:");
    if(formattedString) delete formattedString;
    for(deque<Message*>::iterator i = messages.begin(); i != messages.end(); i++) {
        LOG("refcount", 5, "msg: [" << (*i)->refcount_debug << "]  count " << (*i)->getCount());
        (*i)->release(); // acquired by: insertMessage()
    }
    LOG("refcount", 5, "done deleting messageblock");
}

string MessageBlock::getName()
{
    return name;
}

void MessageBlock::setName(const string& n)
{
    name=n;
}

void MessageBlock::insertMessage(int n, Message* m)
{
    m->acquire(); // released by: this destructor
    if(messages.size() > 0 && n > -1 && (unsigned int)n >= messages.size()) n = n % (int)messages.size();
    if(n < 0) n = (int)messages.size() + n + 1;
    messages.insert(messages.begin() + n, m);
}

Message* MessageBlock::getMessage(int n)
{
    if(n < 0) n = (int)messages.size() + n + 1;
    if(n < 0 || n >= (int)messages.size()) return 0;
    messages[n]->acquire(); // released by: the caller of this method
    return messages[n];
}

Message* MessageBlock::lastMessage()
{
    if(messages.size() == 0) return 0;
    messages.back()->acquire(); // released by: the caller of this method
    return messages.back();
}

int MessageBlock::numMessages()
{
    return (int)messages.size();
}

const string& MessageBlock::getString()
{
    if(formattedString) delete formattedString;

    if(messages.size() == 1 && name == "") {
        formattedString = new string;
        *formattedString = lastMessage()->getFormattedString(true);
        return *formattedString;
    }

    string* s = new string();

    *s += "<messageblock length=\"\"";
    if(name != "") {
        *s += " name=\"";
        *s += name;
        *s += "\"";
    }
    *s += ">\n";
    for(deque<Message*>::const_iterator f = messages.begin();
        f != messages.end();
        f++) {
        *s += (*f)->getFormattedString(false) + "\n";
    }
    *s += "</messageblock>";

    unsigned int size = (unsigned int)s->size();

    char len[16];
    int width = snprintf(len, sizeof(len), "%i", size);
    size += (unsigned int)strlen(len);
    if(width < snprintf(len, sizeof(len), "%i", size)) snprintf(len, sizeof(len), "%i", size+1);

    // '<messageblock length="' is 22 characters
    s->insert(22, len);

    formattedString = s;

    return *s;
}

int MessageBlock::parseUpdate(const string& s)
{
    unsigned int oldsize = (unsigned int)parse_buffer.size();
    parse_buffer.append(s);

    LOG("messageblock", 4, "parse_buffer.size() is " << (unsigned int)parse_buffer.size() << " and expected_length is " << parsestate.expected_length);

    if(parse_buffer.size() < parsestate.expected_length) return 0;

    msgFlexLexer fl(&parsestate);
    parsestate.extra=&fl;

#ifdef USE_STRSTREAM
    istrstream ss(parse_buffer.c_str(), parse_buffer.length());
    char blah[1024];
    ostrstream os(blah, sizeof(blah));
#else
    istringstream ss(parse_buffer);
    string blah;
    ostringstream os(blah);
#endif
    LOG("parser", 5, "siccing the parser on " << parse_buffer);
    if(parse_buffer.size() > 1000) LOG("parser", 5, "ending is  " << parse_buffer.substr(parse_buffer.size() - 1000, 1000));

    parsestate.input = &ss;

    fl.switch_streams(&ss, &os);
    parsestate.chars_read=0;
    parsestate.read_quoted=0;
    msgparse(&parsestate);

    if(parsestate.done) {
        parse_buffer.erase(parse_buffer.begin(), parse_buffer.end());
        if(formattedString != 0) {
            delete formattedString;
            formattedString=0;
        }
        return (parsestate.chars_read - oldsize);
    } else {
        for(deque<Message*>::iterator i = messages.begin(); i != messages.end(); i++) {
            (*i)->release(); // acquired by: this method
        }
        messages.resize(0);
        return 0;
    }
}

int VOS::msglex(char** lvalp, void* extra)
{
    struct parse_state_t* ps=(parse_state_t*)extra;

    msgFlexLexer* fl=(msgFlexLexer*)ps->extra;

    if(! ps->done) {
        int ret;
        *lvalp = 0;
        do {
            ret=fl->yylex();
            if(ret < 255 || ret == SPACE || ret == COMMENT) *lvalp = (char*)fl->YYText();
            else *lvalp = strdup(fl->YYText());
            //*lvalp = fl->YYText();

            if(! ps->read_quoted) ps->chars_read += fl->YYLeng();

            LOG("lexer", 6, "lexer called, got a " << *lvalp << " (len " << fl->YYLeng()
                << ") and returning " << ret);
        } while(ret == COMMENT);
        return ret;
    }
    return 0;
}

void VOS::msgerror(char* blah)
{
    LOG("parser", 4, "Message parse error (probably because entire message has beeen received yet): " << blah);
}

---