devel/libmdw/trunk/libmdw/src/Tokeniser.cpp

/***************************************************************************
 *   Copyright (C) 2010 by Jean-Baptiste Wons   *
 *   wonsjb@gmail.com   *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program 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 General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/
#include <cassert>
#include "Tokeniser.h"

using namespace std;

namespace mdw
{

Tokeniser::Tokeniser (StreamSizeServer &server) : _server (server)
{
}


Tokeniser::~Tokeniser()
{
}

void Tokeniser::accept (TokeniserVisitor &visitor, int secondTimeOut, int microTimeOut)
{
    _currentVisitor = &visitor;
    _server.accept (*this, secondTimeOut, microTimeOut);
}

void Tokeniser::visitRead (char * buffer, int size, int currentOffset,
                           int currentTotalSize, StreamInfo &info)
{
    assert (currentOffset == 0);
    assert (currentTotalSize == size);
    vector<string> tokens;
    State_t state = OutToken_e;
    string *currentToken;
    for (int i = 0; i < size; ++i)
    {
        char current = buffer[i];
        switch (state)
        {
            case OutToken_e:
                if (current == ' ' || current == '\t' || current == '\r' || current == '\n')
                {
                    // Ignore
                }
                else
                {
                    string aStr;
                    tokens.push_back (aStr);
                    currentToken = &*tokens.rbegin();
                    currentToken->push_back (current);
                    state = InToken_e;
                }
                break;
            case InToken_e:
                if (current == ' ' || current == '\t' || current == '\r' || current == '\n')
                {
                    state = OutToken_e;
                }
                else
                {
                    currentToken->push_back (current);
                }
                break;
        }
    }
    if (!tokens.empty())
    {
        _currentVisitor->visitTokens (tokens, info);
    }

}
void Tokeniser::visitConnect (StreamInfo &info)
{
    _currentVisitor->visitConnect (info);
}
void Tokeniser::visitDisconnect (StreamInfo &info)
{
    _currentVisitor->visitDisconnect (info);
}

Stream &Tokeniser::outStream(StreamInfo &info)
{
    return _server.outStream(info.getStreamId());
}
}

---