WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/Atom/Socket/asyncsocket.cpp

  *  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 "socketeventcallback.h"
 #include "asyncsocket.h"
 int socketCount = 1;
+{
     myId = socketCount++;
     mySocket = -1;
     myReconnectTimeout = 0;
     myForceReconnect = false;
+    myEventCallback = NULL;
+}
 AsyncSocket::~AsyncSocket()
+{
     stop();
         // If we have choosen to not use automatic reconnect do not start reconnect loop
         if (myReconnectTimeout == 0)
+        {
             // Connect to somewhere
             connect();
         }
         else
+        {
             // Start the reconnect loop
             reconnectLoop();
         }
     }
     bool loop = true;
     try
+    {
         while (loop)
+        {
+    }
     catch (SocketException *e)
+    {
         // Something bad happend and we can not continue
         eventAdd(SocketEvent::TYPE_CONNECTION_DIED, e->getDescription());
     }
     // Clean up socket if we would want to restart
     silentClose();
+}
             case EINTR:
             throw new SocketException("The receive was interrupted by delivery of a signal before any data were available; see signal(7).");
             case EINVAL:
             throw new SocketException("Invalid argument passed.");
             case ENOMEM:
             throw new SocketException("Could not allocate memory for recvmsg().");
             case ENOTCONN:
             throw new SocketException("The socket is associated with a connection-oriented protocol and has not been connected (see connect(2) and accept(2)).");
                 reconnectLoop();
+            }
             else
+            {
                 // Otherwise we would like to end the main loop
                 return false;
             }
             break;
             default:
             throw new SocketException("Unknow exception: " + itos(errno));
             break;
         }
     }
     else if (status == 0)
+    {
         // Remote host have done a normal shutdown
         eventAdd(SocketEvent::TYPE_CONNECTION_CLOSED);
         if (myReconnectTimeout > 0)
         {
             reconnectLoop();
         }
         else
+        {
             return false;
         }
     }
     else if (status > 0)
+    {
         // We have received data
         eventAdd(SocketEvent::TYPE_DATA, buffer);
+    }
+}
 void AsyncSocket::reconnectLoop()
+{
     while (true)
     {
         try
+        {
             connect();
             return;
+        }
         catch (SocketException *e)
         {
             eventAdd(SocketEvent::TYPE_CONNECTION_FAILED, e->getDescription());
             eventAdd(SocketEvent::TYPE_WAITING_RECONNECT);
             sleep(myReconnectTimeout);
+        }
+    }
             default:
             throw new SocketException("Unknow exception: " + itos(errno));
             break;
+        }
     }
 }
 bool AsyncSocket::accept(AsyncSocket* newSocket)
+{
     int addr_length = sizeof(myAddressStruct);
     int socket = ::accept(mySocket, (sockaddr*)&myAddressStruct, (socklen_t*)&addr_length);
         newSocket->setSocket(socket);
         return true;
+    }
     return false;
 }
 void AsyncSocket::connect()
+{
     eventAdd(SocketEvent::TYPE_CONNECTING);
     create();
     memset(&myAddressStruct, 0, sizeof(myAddressStruct));
     myAddressStruct.sin_family = AF_INET;
     myAddressStruct.sin_port = htons(myPort);
         silentClose();
         throw new SocketException("Connect: Could not resolv ip address");
+    }
     memcpy(&myAddressStruct.sin_addr, hptr->h_addr, hptr->h_length);
     int status = ::connect(mySocket, (sockaddr*)&myAddressStruct, sizeof(myAddressStruct));
     if (status == -1)
+    {
         silentClose();
             case EADDRINUSE:
             throw new SocketException("Local address is already in use.");
             case EAFNOSUPPORT:
             throw new SocketException("The passed address didn't have the correct address family in its sa_family field.");
             case EAGAIN:
             throw new SocketException("No more free local ports or insufficient entries in the routing cache. For AF_INET see the net.ipv4.ip_local_port_range sysctl in ip(7) on how to increase the number of local ports.");
             case EALREADY:
             throw new SocketException("The socket is non-blocking and a previous connection attempt has not yet been completed.");
+}
 void AsyncSocket::eventAdd(unsigned int eventType, string eventData)
+{
     SocketEvent socketEvent(eventType, eventData);
+    if (myEventCallback == NULL)
+    {
-    myEventQueue.push(socketEvent);
+        myEventQueue.push(socketEvent);
-    myEventSemaphore.broadcast();
+        myEventSemaphore.broadcast();
+    }
+    else
+    {
+        myEventCallback->handleEvent(myId, socketEvent);
+    }
+}
+void AsyncSocket::eventSetCallback(SocketEventCallback* eventCallback)
+{
+    myEventCallback = eventCallback;
+}

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom/Socket/asyncsocket.cpp @ 999 – Rev 984 → 999