File content as of revision 94:61d44636f020:

#include <stdio.h>
#include <ctype.h>
#include "PollingThread.h"
#include "lex.h"
#include "logging.h"

bool PollingThread::handshake()
{
        int l = snprintf(buf2, SMARRESTBODY_SIZE, "%s", "80\r\n");
        l = snprintf(buf, SMARTREST_SIZE, getSmartRestFmt(), uri, l, buf2);
        l = sock.sendAndReceive(buf, l, SMARTREST_SIZE);
        if (l < 0)
                return false;
        size_t i = 0;
        for (const char* p = skipHTTPHeader(buf); isalnum(*p); ++p, ++i) {
                bayeuxId[i] = *p;
        }
        bayeuxId[i] = '\0';
        return bayeuxId[0];
}

bool PollingThread::subscribe()
{
        int l = snprintf(buf2, SMARRESTBODY_SIZE, "81,%s,/%s\r\n", bayeuxId, chn);
        l = snprintf(buf, SMARTREST_SIZE, getSmartRestFmt(), uri, l, buf2);
        l = sock.sendAndReceive(buf, l, SMARTREST_SIZE);
        return l>=0;
}

bool PollingThread::connect()
{
        int l = snprintf(buf2, SMARRESTBODY_SIZE, "83,%s\r\n", bayeuxId);
        l = snprintf(buf, SMARTREST_SIZE, getSmartRestFmt(), uri, l, buf2);
        l = sock.sendAndReceive(buf, l, SMARTREST_SIZE);
        return l>=0;
}

void PollingThread::threadFunc()
{
        uint8_t state = 1;
        aInfo("Polling thread: %p\n", Thread::gettid());
        while (true) {
                switch (state) {
                case 1: if (!handshake()) {
                                aCritical("Poll: handshake fail!\n");
                                break;
                        }
                case 2: if(!subscribe()) {
                                aCritical("Poll: subscribe fail!\n");
                                state = 1;
                                break;
                        }
                case 3: if(!connect()) {
                                aCritical("Poll: connect fail!\n");
                                state = 1;
                                break;
                        }
                default: parser.handleControlMessage(buf);
                        if (parser.getBayeuxAdvice() == BA_HANDSHAKE)
                                state = 1;
                        else
                                state = 3;
                }
        }
}