Subversion Repositories HomeAutomation

Rev

Rev 976 | Rev 984 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | SVN | RSS feed

Rev 976 Rev 983
Line 24... Line 24...
24 
 
 24 
 
25 
SocketThread::SocketThread(string address, int port, unsigned int reconnectTimeout)
 25 
SocketThread::SocketThread(string address, int port, unsigned int reconnectTimeout)
26 
{
 26 
{
27 
    myId = time(NULL);
 27 
    myId = time(NULL);
28 
 
 28 
 
- 
 
 29 
    mySocket = new AsyncSocket();
- 
 
 30 
 
29 
    mySocket.setAddress(address, port);
 31 
    mySocket->setAddress(address, port);
30 
    mySocket.setReconnectTimeout(reconnectTimeout);
 32 
    mySocket->setReconnectTimeout(reconnectTimeout);
31 
 
 33 
 
32 
    Thread<SocketThread>();
 34 
    Thread<SocketThread>();
33 
}
 35 
}
34 
 
 36 
 
35 
SocketThread::~SocketThread()
 37 
SocketThread::~SocketThread()
36 
{
 38 
{
37 
    stop();
 39 
    if (!stop())
- 
 
 40 
    {
- 
 
 41 
        cout << "~SocketThread() :: Failed to stop thread :: Error code is " + itos(getError()) + "\n";
- 
 
 42 
 
- 
 
 43 
    }
- 
 
 44 
    else
- 
 
 45 
    {
- 
 
 46 
    //  cout << "~SocketThread() :: Successfully stopped thread\n";
- 
 
 47 
    }
- 
 
 48 
    delete mySocket;
38 
}
 49 
}
39 
 
 50 
 
40 
void SocketThread::run()
 51 
void SocketThread::run()
41 
{
 52 
{
42 
    SyslogStream &slog = SyslogStream::getInstance();
 53 
    //SyslogStream &slog = SyslogStream::getInstance();
43 
    VirtualMachine &vm = VirtualMachine::getInstance();
 54 
    VirtualMachine &vm = VirtualMachine::getInstance();
44 
 
 55 
 
45 
    mySocket.start();
 56 
    mySocket->start();
46 
 
 57 
 
47 
    mySocket.startEvent();
 58 
    mySocket->startEvent();
48 
 
 59 
 
49 
    while (1)
 60 
    while (1)
50 
    {
 61 
    {
51 
        mySocket.waitForEvent();
 62 
        mySocket->waitForEvent();
52 
 
 63 
 
- 
 
 64 
        while (mySocket->availableEvent())
- 
 
 65 
        {
53 
        int event = mySocket.getEvent();
 66 
            int event = mySocket->getEvent();
54 
 
 67 
 
55 
        if (event == ASYNCSOCKET_EVENT_DATA)
 68 
            if (event == ASYNCSOCKET_EVENT_DATA)
56 
        {
 69 
            {
57 
            while (mySocket.availableData())
 70 
                while (mySocket->availableData())
58 
            {
 71 
                {
59 
                string data = mySocket.getData();
 72 
                    string data = mySocket->getData();
60 
                vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_DATA', '" + escape(data) + "');");
 73 
                    vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_DATA', '" + escape(data) + "');");
61 
            }
 74 
                }
- 
 
 75 
            }
- 
 
 76 
            else if (event == ASYNCSOCKET_EVENT_CONNECTED)
- 
 
 77 
            {
- 
 
 78 
                vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_CONNECTED', '');");
62 
        }
 79 
            }
63 
        else if (event == ASYNCSOCKET_EVENT_CLOSED)
 80 
            else if (event == ASYNCSOCKET_EVENT_CLOSED)
64 
        {
 81 
            {
65 
            vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_CLOSED', '');");
 82 
                vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_CLOSED', '');");
66 
        }
 83 
            }
67 
        else if (event == ASYNCSOCKET_EVENT_DIED)
 84 
            else if (event == ASYNCSOCKET_EVENT_DIED)
68 
        {
 85 
            {
69 
            vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_DIED', '');");
 86 
                vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_DIED', '');");
70 
            break;
 87 
                break;
- 
 
 88 
            }
- 
 
 89 
            else if (event == ASYNCSOCKET_EVENT_RESET)
- 
 
 90 
            {
- 
 
 91 
                vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_RESET', '');");
- 
 
 92 
                break;
71 
        }
 93 
            }
72 
        else if (event == ASYNCSOCKET_EVENT_INACTIVITY)
 94 
            else if (event == ASYNCSOCKET_EVENT_INACTIVITY)
73 
        {
 95 
            {
74 
            vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_INACTIVITY', '');");
 96 
                vm.queueExpression("Socket.triggerSocketCallback(" + itos(myId) + ", 'EVENT_INACTIVITY', '');");
- 
 
 97 
            }
75 
        }
 98 
        }
76 
    }
 99 
    }
77 
 
 100 
 
78 
    mySocket.stopEvent();
 101 
    mySocket->stopEvent();
79 
}
 102 
}
80 
 
 103 
 
81 
void SocketThread::send(string data)
 104 
void SocketThread::send(string data)
82 
{
 105 
{
- 
 
 106 
 
83 
    mySocket.sendData(data);
 107 
    mySocket->sendData(data);
84 
}
 108 
}
85 
 
 109