--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/hti/PC_Tools/DataGateway/SRC/Socket.cpp Wed Oct 13 16:17:58 2010 +0300
@@ -0,0 +1,325 @@
+/*
+* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description:
+* This file contains implemention of Socket, SocketClient, SocketServer and
+* SocketSelect classes.
+*/
+
+#include <iostream>
+#include <sstream>
+#include <errno.h>
+
+#include "Socket.h"
+#include "Util.h"
+
+using namespace std;
+
+//**********************************************************************************
+// Class Socket
+//
+// This class encapsulates Windows Sockets API Socket functionality
+//**********************************************************************************
+
+int Socket::nofSockets_= 0;
+
+void Socket::Start() {
+ if (!nofSockets_) {
+ WSADATA info;
+ if (WSAStartup(MAKEWORD(2,0), &info)) {
+ throw "Could not start WSA";
+ }
+ }
+ ++nofSockets_;
+}
+
+void Socket::End() {
+ WSACleanup();
+}
+
+
+Socket::Socket() : s_(0) {
+ Start();
+ // UDP: use SOCK_DGRAM instead of SOCK_STREAM
+ s_ = socket(AF_INET,SOCK_STREAM,0);
+
+ refCounter_ = new int(1);
+}
+
+Socket::Socket(SOCKET s) : s_(s) {
+ Start();
+ refCounter_ = new int(1);
+};
+
+
+Socket::~Socket() {
+ if (! --(*refCounter_)) {
+ Close();
+ delete refCounter_;
+ }
+
+ --nofSockets_;
+ if (!nofSockets_) End();
+}
+
+Socket::Socket(const Socket& o) {
+ refCounter_=o.refCounter_;
+ (*refCounter_)++;
+ s_ =o.s_;
+
+ nofSockets_++;
+}
+
+Socket& Socket::operator =(Socket& o) {
+ (*o.refCounter_)++;
+
+ refCounter_=o.refCounter_;
+ s_ =o.s_;
+
+ nofSockets_++;
+
+ return *this;
+}
+
+
+void Socket::Close() {
+ closesocket(s_);
+}
+
+/*
+ * This method is used to receive data bytes socket. The method reads all available and combines them to returned String object
+ */
+String Socket::ReceiveBytes() {
+ String ret;
+ char buf[1024];
+ int rv;
+ while ((rv=recv(s_, buf, 1024,0)) == WSAEMSGSIZE) {
+ String t;
+ t.assign(buf,1024);
+ ret +=t;
+ }
+
+ String t;
+ t.assign(buf, 0, rv);
+ ret += t;
+
+ printf("t = %s, rv = %d", t.c_str(), rv);
+
+ return ret;
+}
+
+/*
+ * This method reads up to maximum amount of bytes from socket to the Data object given as parameter
+ * The maximum amount is given as parameter
+ */
+int Socket::ReceiveBytes(BYTE *data, int bytes) {
+ int rv = SOCKET_ERROR;
+
+ while (rv == SOCKET_ERROR)
+ {
+ rv = recv(s_, (char *)data, bytes, 0);
+ if (rv == 0 || rv == WSAECONNRESET)
+ return -1;
+ else
+ break;
+ }
+ return rv;
+}
+
+
+/*
+ * This method is used to read characters from socket until line separator is encountered
+ * Returns String including line separator
+ */
+String Socket::ReceiveLine() {
+ String ret;
+ while (1) {
+ char r;
+
+ switch(recv(s_, &r, 1, 0)) {
+ case 0: // not connected anymore;
+ return "";
+ //SOCKET_ERROR == -1
+ case -1:
+ if (errno == EAGAIN) {
+ return ret;
+ } else {
+ // not connected anymore
+ return "";
+ }
+ }
+
+ ret += r;
+ if (r == '\n') return ret;
+ }
+}
+
+
+/*
+*This method is used to send String as a line
+*The parameter of SendLine is not a const reference
+*because SendLine modifes the String passed.
+*/
+void Socket::SendLine(String s) {
+ s += '\n';
+ send(s_,s.c_str(),s.length(),0);
+}
+
+/*
+ * This method is used to send String as bytes
+ */
+void Socket::SendBytes(const String& s) {
+ send(s_,s.c_str(),s.length(),0);
+}
+
+/*
+ * This method is used to send specific amount of bytes of String
+ * The parameter is a const reference
+ * because the methos does not modify the String passed
+ * (in contrast to SendLine).
+ */
+int Socket::SendBytes(const BYTE* data, int bytes)
+{
+ if (bytes <= 0) return 0;
+ send(s_,(char *)data, bytes, 0);
+ return 0;
+}
+
+//**********************************************************************************
+// Class SocketServer
+//
+// This class is used to:
+// -listen for incoming connections to a Socket
+// -connect to socket
+//**********************************************************************************
+
+SocketServer::SocketServer() {
+}
+
+/*
+ * This method binds and opens the given socket to listening mode
+ */
+void SocketServer::Accept( Socket*& s,int port, int connections, String& remoteHost ) {
+
+ sockaddr_in sa;
+ memset(&sa, 0, sizeof(sa)); /* clear our address */
+ sa.sin_family = PF_INET;
+ sa.sin_port = htons(port);
+
+ // Use the given socket for listening
+ Socket* listenSocket = s;
+
+ // bind the socket to the internet address
+ if (bind(listenSocket->s_, (sockaddr *)&sa, sizeof(sockaddr_in)) ==
+ SOCKET_ERROR) {
+ throw "INVALID_SOCKET";
+ }
+ //place a socket in a state in which it is listening for an incoming connection
+ listen(listenSocket->s_, connections);
+
+ sockaddr_in remoteAddr;
+ int remoteAddrLen = sizeof(sockaddr_in);
+
+ //extract the first connection on the queue of pending connections on socket
+ //accept blocks if socket is marked blocking
+ SOCKET new_sock = accept(listenSocket->s_, (sockaddr*) &remoteAddr, &remoteAddrLen);
+ if (new_sock == INVALID_SOCKET)
+ {
+ throw "Invalid Socket";
+ }
+
+ // Return remote host and port to caller
+ stringstream msg;
+ msg<<inet_ntoa(remoteAddr.sin_addr)<<":"<<ntohs(remoteAddr.sin_port);
+ remoteHost.append( msg.str() );
+
+ s = new Socket(new_sock);
+ delete listenSocket;
+}
+
+/*
+ * This method establishes a connection to the socket
+ */
+void SocketServer::Connect(Socket* s, const char* remoteHost, int remotePort) {
+
+ Socket* connectSocket = s;
+ sockaddr_in sa;
+ memset(&sa, 0, sizeof(sa)); /* clear our address */
+ sa.sin_family = AF_INET;
+ if( isalpha(remoteHost[0]) )
+ {
+ HOSTENT* Hostent;
+ if( (Hostent = gethostbyname( remoteHost )) != 0 )
+ sa.sin_addr.s_addr = *(long*) Hostent->h_addr;
+ else
+ throw "Unknown host!";
+ }
+ else
+ sa.sin_addr.s_addr = inet_addr( remoteHost );
+
+ sa.sin_port = htons( remotePort );
+
+ // Connect to server.
+ if ( connect( connectSocket->s_, (SOCKADDR*) &sa, sizeof(sa) ) == SOCKET_ERROR) {
+ throw "SOCKET_ERROR";
+ }
+}
+
+//**********************************************************************************
+// Class SocketClient
+//
+//**********************************************************************************
+
+SocketClient::SocketClient(const String& host, int port) : Socket() {
+ String error;
+
+ hostent *he;
+ if ((he = gethostbyname(host.c_str())) == NULL) {
+ error = strerror(errno);
+ throw error;
+ }
+
+ sockaddr_in addr;
+ addr.sin_family = AF_INET;
+ addr.sin_port = htons(port);
+ addr.sin_addr = *((in_addr *)he->h_addr);
+ memset(&(addr.sin_zero), 0, 8);
+
+ if (::connect(s_, (sockaddr *) &addr, sizeof(sockaddr))) {
+ error = strerror(WSAGetLastError());
+ throw error;
+ }
+}
+
+//**********************************************************************************
+// Class SocketSelect
+//
+//**********************************************************************************
+
+SocketSelect::SocketSelect(Socket const * const s1, Socket const * const s2) {
+ FD_ZERO(&fds_);
+ FD_SET(const_cast<Socket*>(s1)->s_,&fds_);
+ FD_SET(const_cast<Socket*>(s2)->s_,&fds_);
+
+ if (select (0, &fds_, (fd_set*) 0, (fd_set*) 0, (timeval*) 0)
+ == SOCKET_ERROR) throw "Error in select";
+}
+
+
+bool SocketSelect::Readable(Socket const * const s) {
+ if (FD_ISSET(s->s_,&fds_)) return true;
+ return false;
+}
+
+// End of the file
+