File content as of revision 126:e1fcf720c63a:

#include <stdio.h>
#include <ctype.h>
#include "PollThread.h"
#include "logging.h"

static size_t _volSend = 0;
static size_t _volRecv = 0;

bool PollThread::handshake()
{
        int l = snprintf(buf2, sizeof(buf2), "%s", "80\r\n");
        l = snprintf(buf, sizeof(buf), fmtSmartRest, uri, l, buf2);
        sock.setBlocking(3000);
        _volSend += l;
        l = sock.sendAndReceive(buf, l, sizeof(buf));
        if (l <= 0) return false;
        _volRecv += l;
        const char* p = skipHTTPHeader(buf);
        if (p == NULL) return false;
        size_t i = 0;
        for (; isalnum(*p); ++p, ++i) {
                bayeuxId[i] = *p;
        }
        bayeuxId[i] = 0;
        return bayeuxId[0];
}

bool PollThread::subscribe()
{
        int l = snprintf(buf2, sizeof(buf2), "81,%s,%s\r\n", bayeuxId, chn);
        l = snprintf(buf, sizeof(buf), fmtSmartRest, uri, l, buf2);
        sock.setBlocking(3000);
        _volSend += l;
        l = sock.sendAndReceive(buf, l, sizeof(buf));
        if (l <= 0) return false;
        _volRecv += l;
        const char *p = skipHTTPHeader(buf);
        if (p == NULL) return false;
        for (; *p && !isgraph(*p); ++p);
        return *p == 0;
}

bool PollThread::connect()
{
        int l = snprintf(buf2, sizeof(buf2), "83,%s\r\n", bayeuxId);
        l = snprintf(buf, sizeof(buf), fmtSmartRest, uri, l, buf2);
        sock.setBlocking(300000); // Timeout after 5 minutes
        _volSend += l;
        aInfo("[SEND] poll: %d\n", _volSend);
        l = sock.sendAndReceive(buf, l, sizeof(buf));
        _volRecv += l;
        aInfo("[RECV] poll: %d\n", _volRecv);
        return l>0;
}

void PollThread::threadFunc()
{
        unsigned short state = 1;
        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.parse(buf);
                        if (parser.getBayeuxAdvice() == BA_HANDSHAKE)
                                state = 1;
                        else
                                state = 3;
                }
        }
}