JSocket.cpp

Go to the documentation of this file.

/***************************** License **********************************

 Copyright (C) 2008 by Communicative Machines
 http://www.cmlabs.com   All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Lesser General Public
 License as published by the Free Software Foundation; either
 version 2.1 of the License, or (at your option) any later version.

 This library is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 Lesser General Public License for more details.

 You should have received a copy of the GNU Lesser General Public
 License along with this library; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

************************************************************************/
/***************************** License **********************************

 Copyright (C) 2006 by Communicative Machines
 http://www.cmlabs.com   All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Lesser General Public
 License as published by the Free Software Foundation; either
 version 2.1 of the License, or (at your option) any later version.

 This library is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 Lesser General Public License for more details.

 You should have received a copy of the GNU Lesser General Public
 License along with this library; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

************************************************************************/


// Socket.cpp: implementation of the Socket class.
//
//////////////////////////////////////////////////////////////////////


#include "JSocket.h"


#ifdef WIN32
        #include "win32/JSocket_Win32.cpp"
#else
        #include "linux/JSocket_Linux.cpp"
#endif


// *****************************************************************
// Linux / Win32 Common Code
// *****************************************************************


namespace cmlabs {

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

JSocket::JSocket(JString addr, int portnumber, JString protocolname) {
        resetIOCounts();
        strcpy(charBuffer, "");
        isTerminating = false;
        currentUnsentBufferSize = 0;
        currentSentBufferSize = 0;
        currentUnreceivedBufferSize = 0;
        currentReceivedBufferSize = 0;
        charBufferCount = 0;
        charBuffer[0] = 0;
        location = TCPLocation(addr, portnumber, "");
        address = addr;
        port = portnumber;
        protocol = protocolname;
        lastErrorMessage = "";

        connected = false;
        lastErrorRecoverable = true;
        listening = false;

        ipnumber.a = 0;
        ipnumber.b = 0;
        ipnumber.c = 0;
        ipnumber.d = 0;

        setSocketNotValid();
}

JSocket::JSocket(const TCPLocation& loc, JString protocolname) {
        resetIOCounts();
        isTerminating = false;
        currentUnsentBufferSize = 0;
        currentSentBufferSize = 0;
        currentUnreceivedBufferSize = 0;
        currentReceivedBufferSize = 0;
        charBufferCount = 0;
        charBuffer[0] = 0;
        location = loc;
        address = loc.addr;
        port = loc.port;
        protocol = protocolname;
        lastErrorMessage = "";

        connected = false;
        lastErrorRecoverable = true;
        listening = false;

        ipnumber.a = loc.ipnumber.a;
        ipnumber.b = loc.ipnumber.b;
        ipnumber.c = loc.ipnumber.c;
        ipnumber.d = loc.ipnumber.d;

        setSocketNotValid();
}


JSocket::~JSocket() {
        isTerminating = true;
//      delete [] ipnumber;
//      delete [] charBuffer;
//      mutex.EnterMutex(100);
        terminate();
//      mutex.LeaveMutex();
//      wait(5);
}


long JSocket::getSendBufferSize() {
        return SENDBUFFERSIZE;
}
long JSocket::getReadBufferSize() {
        return BUFFERSIZE;
}

bool JSocket::terminate() {
        return disconnectNow();
}


bool JSocket::isListening() {
        return listening;
}

bool JSocket::isLastErrorRecoverable() {
        return lastErrorRecoverable;
}

JString JSocket::getLastErrorMessage() {
        return lastErrorMessage;
}

int JSocket::flush() {
        int c = 0;
        readIntoBuffer();
        while (charBufferCount > 0) {
                c += charBufferCount;
                charBufferCount = 0;
                readIntoBuffer();
        }
        strcpy(charBuffer, "Flushed!");
        return c;
}


int JSocket::read(char* buffer, int maxcount, long timeout) {

        int copyCount = 0;
        currentUnreceivedBufferSize = maxcount;

        // First see if we already have what we need in the buffer
        if (this->charBufferCount < maxcount) {
                waitForReadability(timeout);
                if (readIntoBuffer() == -1) {
                        currentUnreceivedBufferSize = 0;
                        currentReceivedBufferSize = 0;
                        return -1;
                }
        }

        if (charBufferCount == 0) {
                currentUnreceivedBufferSize = 0;
                currentReceivedBufferSize = 0;
                return 0;
        }
        
        int c=0;
        while (maxcount > copyCount) {
//              printf("[%d]    %d   %d   %d\n", c++, maxcount, copyCount, charBufferCount);
                if (maxcount >= copyCount + charBufferCount){
                        memcpy(buffer+copyCount, charBuffer, charBufferCount);
                        copyCount += charBufferCount;
                        charBufferCount = 0;
                }
                else {
                        int toRemainInBuffer = copyCount + charBufferCount - maxcount;
                        memcpy(buffer+copyCount, charBuffer, charBufferCount-toRemainInBuffer);
                        copyCount += charBufferCount-toRemainInBuffer;
//                      if (copyCount+toRemainInBuffer > BUFFERSIZE)
//                              printf("                         %d   %d   %d\n", copyCount, toRemainInBuffer, charBufferCount);
//                      else {
                        //      memcpy(charBuffer, charBuffer+charBufferCount-toRemainInBuffer, toRemainInBuffer);
                                memmove(charBuffer, charBuffer+charBufferCount-toRemainInBuffer, toRemainInBuffer);
                                charBufferCount = toRemainInBuffer;
//                      }
                }
                if (maxcount == copyCount) {
                        currentUnreceivedBufferSize = maxcount;
                        currentReceivedBufferSize = maxcount;
                        return copyCount;
                }

                if ((readIntoBuffer() == -1) || (charBufferCount <= 0)) {
                        waitForReadability(timeout);
                        if (readIntoBuffer() == -1) {
                                printf("INCOMPLETE2!!!");
                                currentUnreceivedBufferSize = copyCount;
                                currentReceivedBufferSize = copyCount;
                                return copyCount;
                        }
                }
        }
        
        if (charBufferCount >= maxcount)
                copyCount = maxcount;
        else
                copyCount = charBufferCount;

        currentUnreceivedBufferSize = copyCount;
        currentReceivedBufferSize = copyCount;

        int newCharBufferCount = charBufferCount - copyCount;

        memcpy(buffer, charBuffer, copyCount);

        if (newCharBufferCount == 0) {
                charBufferCount = 0;
        }
        else if (newCharBufferCount > 0) {
        //      memcpy(charBuffer, charBuffer+copyCount, newCharBufferCount);
                memmove(charBuffer, charBuffer+copyCount, newCharBufferCount);
                charBufferCount = newCharBufferCount;
        }
        
        return copyCount;
}


JString JSocket::readString(int count, long timeout) {

        JString text;

        if ( (currentUnreceivedBufferSize == 0) || (currentUnreceivedBufferSize == currentReceivedBufferSize) ) {
                currentUnreceivedBufferSize = count;
                currentReceivedBufferSize = 0;
        }

        if (count > BUFFERSIZE) {
                currentUnreceivedBufferSize = count;
                currentReceivedBufferSize = 0;
                JString str;
                text = readString(BUFFERSIZE, timeout);
                if (text.length() == 0) return "";
                int tcount = count - BUFFERSIZE;
                while (tcount > BUFFERSIZE) {
                        currentReceivedBufferSize = count - tcount;
                        str = readString(BUFFERSIZE, timeout);
                        tcount -= BUFFERSIZE;
                        if (str.length() == 0) return text;
                        else text += str;
                }
                str = readString(tcount, timeout);
                text += str;
                currentReceivedBufferSize = count;
                return text;
        }

        // First see if we already have what we need in the buffer
        if (this->charBufferCount < count) {
                waitForReadability(timeout);
                readIntoBuffer();
        }

        int newCharBufferCount = charBufferCount - count;

//      charBuffer[charBufferCount+1] = 0;
        charBuffer[charBufferCount] = 0;

        if (newCharBufferCount == 0) {
                text = charBuffer;
                charBufferCount = 0;
        }
        else if (newCharBufferCount > 0) {
                text = charBuffer;
                text = text.substring(0, count);
        //      memcpy(charBuffer, charBuffer+count, newCharBufferCount);
                memmove(charBuffer, charBuffer+count, newCharBufferCount);
                charBufferCount = newCharBufferCount;
        }

        if ( (currentUnreceivedBufferSize == count) && (currentReceivedBufferSize == 0) ) {
                currentUnreceivedBufferSize = newCharBufferCount;
                currentReceivedBufferSize = newCharBufferCount;
        }

        return text;
}

JString JSocket::readln(long timeout) {

//      JString text = "";
        JString str;
        JTime t;
        int m, n = -10;
        int count = 0;
        while ((JTime()-t < timeout) && (n < 0)) {
          //      printf("[%d]", count); fflush(stdout);
          count++;

                waitForReadability(timeout - (JTime()-t));
                if (charBufferCount >= BUFFERSIZE) {
                        charBuffer[charBufferCount] = 0;
                        stringBuffer += charBuffer;
                        //                      printf("\n   Got part of string length: %d \n", stringBuffer.length());
                        charBufferCount = 0;
                }

                
                // Read data into buffer
                if (readIntoBuffer() == -1) {
                        return "";
/*                      wait(10);
                        if (readIntoBuffer() == -1) {
                                printf("JSocket: Returning incomplete text after error...");
                                return "";
                        }*/
                }
                charBuffer[charBufferCount] = 0;
                n = (int)(strchr(charBuffer, 10) - charBuffer);
                if (n > charBufferCount) n = -1;
                // n = buffer.indexOf((char) 10);
        }

        if ((charBufferCount == 0) || (n < 0)) return "";

        // and analyze for <CR>
        m = (int)(strchr(charBuffer, 13) - charBuffer);
        // m = buffer.indexOf((char) 13);

        // Create String
        charBuffer[n] = 0;
        str = charBuffer;

        JString text = stringBuffer;

        // Do we have <CR><LF>
        if ((m >= 0) && (m == n-1))
                text += str.substring(0, m);
        // or just <LF>
        else
                text += str.substring(0, n);

        stringBuffer = "";

        int newCharBufferCount = charBufferCount-(n+1);
//      memcpy(charBuffer, charBuffer+n+1, newCharBufferCount);
        memmove(charBuffer, charBuffer+n+1, newCharBufferCount);
        charBufferCount = newCharBufferCount;
//      buffer = buffer.substring(n+1);
        
        text.isCRTerminated = true;

        return text;
}

int JSocket::write(JString str) {
        return writeString(str);
}

int JSocket::write(char* ch, int len) {
        return writeBuffer(ch, len);
}

int JSocket::writeln(JString str) {
        char ch[3];
        ch[0] = 13;
        ch[1] = 10;
        ch[2] = 0;

        return writeString(str + ch);
}



JString JSocket::getLocalIPAddress() {

        if (localIPAddress.length() > 0)
                return localIPAddress;

        int n;
        Collection addresses;
        
        Collection locals = getLocalIPAddresses();

        JString addr;
        for (n=0; n<locals.getCount(); n++) {
                addr = locals.get(n);
                if ( (addr.length() > 0) && (!addr.equalsIgnoreCase("127.0.0.1")) && (!addr.equalsIgnoreCase("0.0.0.0")) ) {
                        addresses.add(addr);
                }
        }

        if (addresses.length() > 0) {
                localIPAddress = addresses.getFirst();
        }
        else {
                localIPAddress = "127.0.0.1";
        }

        return localIPAddress;
}

Collection JSocket::getLocalIPAddresses() {

        if (localIPAddresses.getCount() > 0)
                return localIPAddresses;

        localIPAddresses.add("127.0.0.1");

        char szHostName[255];
//      JString ipaddr = "127.0.0.1";

        bool canAskHost = true;
        if( gethostname(szHostName, 255) != 0 ) {
                #ifdef WIN32
                        int err = getLastOSErrorNumber();
                        if (err == WSANOTINITIALISED) {
                                WSADATA info;
                                if (WSAStartup(MAKEWORD(1,1), &info) != 0) {
                                        printf("Could not startup network...\n");
                                        return localIPAddresses;
                                }
                                else {
                                        if( gethostname(szHostName, 255) != 0 ) {
                                                printf("Could not ask for local host name...\n");
                                                canAskHost = false;
                                                // return localIPAddresses;
                                        }
                                }
                        }
                        else {
                                printf("Could not ask for local host name...\n");
                                canAskHost = false;
                                // return localIPAddresses;
                        }
                #else // WIN32
                        printf("Could not ask for local host name...\n");
                        canAskHost = false;
                        // return localIPAddresses;
                #endif // WIN32
        }


        if (canAskHost) {
                // Get host adresses
                struct hostent * pHost;
                int i;

                #ifdef WIN32
                        pHost = gethostbyname(szHostName);
                #else // WIN32

                        #ifdef Darwin

                                pHost = gethostbyname(szHostName);
                                if (pHost == NULL) {
                                        // printf("getLocalIPAddress(): '%s' pHost NULL!\n", szHostName);
                                        return localIPAddresses;
                                }
                                else {}
                        #else // Darwin

                        pHost = new struct hostent;
                        char bf[2000];
                        int er;
                        int res = gethostbyname_r(szHostName, pHost, bf, 2000, &pHost, &er);
                        if ((er == 0) || (res != 0)) {
                                if (DEBUGLEVEL(HEARTBEAT)) {
                                        printf("gethostbyname_r success: %s!!!\n", szHostName);
                                }
                        }
                        else {
                                if (er == ERANGE) {
                                        if (DEBUGLEVEL(KITCHENSINK)) {
                                                printf("gethostbyname_r error %s: ERANGE\n", (char*) szHostName);
                                        }
                                        delete pHost;
                                        pHost = NULL;
                                }
                                else if (er == HOST_NOT_FOUND ) {
                                        if (DEBUGLEVEL(KITCHENSINK)) {
                                                printf("gethostbyname_r error %s: HOST_NOT_FOUND \n", (char*) szHostName);
                                        }
                                        delete pHost;
                                        pHost = NULL;
                                }
                                else if (er == NO_ADDRESS ) {
                                        if (DEBUGLEVEL(KITCHENSINK)) {
                                                printf("gethostbyname_r error %s: NO_ADDRESS \n", (char*) szHostName);
                                        }
                                        delete pHost;
                                        pHost = NULL;
                                }
                                else if (er == NO_DATA ) {
                                        if (DEBUGLEVEL(KITCHENSINK)) {
                                                printf("gethostbyname_r error %s: NO_DATA \n", (char*) szHostName);
                                        }
                                        delete pHost;
                                        pHost = NULL;
                                }
                                else if (er == NO_RECOVERY ) {
                                        if (DEBUGLEVEL(KITCHENSINK)) {
                                                printf("gethostbyname_r error %s: NO_RECOVERY \n", (char*) szHostName);
                                        }
                                        delete pHost;
                                        pHost = NULL;
                                }
                                else if (er == TRY_AGAIN ) {
                                        if (DEBUGLEVEL(KITCHENSINK)) {
                                                printf("gethostbyname_r error %s: TRY_AGAIN \n", (char*) szHostName);
                                        }
                                        delete pHost;
                                        pHost = NULL;
                                }
                                else {
        //                              if (DEBUGLEVEL(KITCHENSINK)) {
        //                                      printf("gethostbyname_r error %s: Something else: %d [%d][%d] \n", (char*) szHostName, er, res, (int)pHost);
        //                              }
                                        // Keep the pHost and hope for the best...
                                }
                        }

                        #endif // Darwin
                #endif // WIN32

                JString str;
                for( i = 0; pHost!= NULL && pHost->h_addr_list[i]!= NULL; i++ )
                {
                        int j;
                        str = "";       
                        for( j = 0; j < pHost->h_length; j++ )
                        {
                                // JString addr;
                
                                if( j > 0 )
                                        str += ".";
                
                                str += JString((int)((unsigned char*)pHost->h_addr_list[i])[j]);
                                // str += addr;
                        }
                        // str now contains one local IP address - do whatever you want to do with it (probably add it to a list)
                        if ( (str.length() > 0) && (!localIPAddresses.contains(str)) )
                                localIPAddresses.add(str);
                }

                if (DEBUGLEVEL(HEARTBEAT))
                        printf("gethostbyname_r found %d IPs: %s\n", localIPAddresses.getCount(), (char*) localIPAddresses.printListLine(","));

                #ifdef WIN32
                #else // WIN32
                #ifdef Darwin
                                endhostent();
                #else
                        delete pHost;
                #endif // Darwin
                #endif // WIN32
        }

        // If we only have localhost we need to look at the interfaces
        // ### Warning - seems to be buggy on some Linuxes - more in the function itself ###
//      if ( (localIPAddresses.getCount() == 1) && (localIPAddresses.getFirst().equalsIgnoreCase("127.0.0.1"))) {
                // Now add local interfaces if they have additional ip addresses
                Dictionary dict = getLocalInterfaceAddresses();
                JString addr;
                for (int n=0; n<dict.getCount(); n++) {
                        addr = dict.get(n);
                        if ( (addr.length() > 0) && (!localIPAddresses.contains(addr)) ) {
                                localIPAddresses.add(addr);
                        }
                }
//      }

        return localIPAddresses;
}

Dictionary JSocket::getLocalInterfaceAddresses() {

        Dictionary dict;

        #ifdef WIN32

                unsigned long size = 10000;
                void* mem = malloc(size);
                IP_ADAPTER_INFO* adaptors = (IP_ADAPTER_INFO*) mem;

                int res = GetAdaptersInfo(adaptors, &size);
                if (res != ERROR_SUCCESS) {
                        free(mem);
                        return dict;
                }

                JString adaptor, addr;
                while (adaptors != NULL) {
//                      if (adaptors->IpAddressList != NULL) {
                        //      dict.put(adaptors->Description, (char*) adaptors->CurrentIpAddress->IpAddress);
                                adaptor = adaptors->Description;
                                addr = adaptors->IpAddressList.IpAddress.String;
                                if (addr.length() > 0)
                                        dict.put(adaptor, addr);
//                      }
                        adaptors = (IP_ADAPTER_INFO*) adaptors->Next;
                }

                free(mem);

        #else
                int sock = 0;
                struct ifreq ifreq;
                struct sockaddr_in *saptr = NULL;
                struct if_nameindex *iflist = NULL, *listsave = NULL;

                //need a socket for ioctl()
                if( (sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
                        return dict;
                }

                //returns pointer to dynamically allocated list of structs
                iflist = listsave = if_nameindex();

                if (iflist == NULL) {
                        close(sock);
                        return dict;
                }

                JString key, addr;
                //walk thru the array returned and query for each
                //interface's address
                for(iflist; iflist->if_index != 0; iflist++) {
                        //copy in the interface name to look up address of
                        strncpy(ifreq.ifr_name, iflist->if_name, IF_NAMESIZE);
                        //get the address for this interface
                        if(ioctl(sock, SIOCGIFADDR, &ifreq) != 0) {
                                // ignore;
                                continue;
                        }
                        //print out the address
                        saptr = (struct sockaddr_in *)&ifreq.ifr_addr;
                //      printf( "%-5s :: %3d.%3d.%3d.%3d\n", ifreq.ifr_name, NIPQUAD(saptr->sin_addr.s_addr) );
                        key = ifreq.ifr_name;
                        addr = JString::format("%d.%d.%d.%d", NIPQUAD(saptr->sin_addr.s_addr));
                        dict.put(key, addr);
                }
                //free the dynamic memory kernel allocated for us
                if_freenameindex(listsave);
                close(sock); 

/*              struct ifaddrs *myaddrs, *ifa;
                struct sockaddr_in *s4;
                struct sockaddr_in6 *s6;
                int status;
                // buf must be big enough for an IPv6 address (e.g. 3ffe:2fa0:1010:ca22:020a:95ff:fe8a:1cf8)
                char buf[64];

                // ### Warning - seems to be buggy on some Linuxes ###
                // The getifaddrs function appears to have a mutex lock which when called by different
                // threads does not get released. I.e. the first time this is called, everything is fine
                // but when it is called in a different thread this call never returns. So far only
                // observed on dual CPU Linux Redhat 9 with a specific GLIBC version. Not seen on a newer
                // dual CPU Linux version and not in the same Linux version on a single CPU...

                status = getifaddrs(&myaddrs);
                if (status != 0)
                {
                        return dict;
                }

                for (ifa = myaddrs; ifa != NULL; ifa = ifa->ifa_next)
                {
                        if (ifa->ifa_addr == NULL) continue;
                        if ((ifa->ifa_flags & IFF_UP) == 0) continue;

                        if (ifa->ifa_addr->sa_family == AF_INET)
                        {
                                s4 = (struct sockaddr_in *)(ifa->ifa_addr);
                                if (inet_ntop(ifa->ifa_addr->sa_family, (void *)&(s4->sin_addr), buf, sizeof(buf)) == NULL)
                                {
                                //      printf("%s: inet_ntop failed!\n", ifa->ifa_name);
                                }
                                else
                                {
                                        dict.put(ifa->ifa_name, buf);
                                }
                        }
                }

                freeifaddrs(myaddrs);
*/
        #endif

        return dict;
}







JString JSocket::getLocalHostname() {


        #if defined(_WIN32_WCE)
                return getLocalIPAddress();
        #endif
        
        if (localhostName.length() > 0)
                return localhostName;

        char* hname = new char[1000];
        if (gethostname(hname, 1000) == 0) {
                localhostName = hname;
                delete [] hname;
                return localhostName;
        }
        delete [] hname;

        JString ipaddress = getLocalIPAddress();
        JString hostname = ipaddress;
        struct hostent* hent;
        if ( (ipaddress.equals("127.0.0.1")) || (ipaddress.equals("localhost")) ) {
                localhostName = "127.0.0.1";
                return localhostName;
        }

        #ifdef WIN32

                hent = gethostbyname((char*) ipaddress);
//              hent = gethostbyaddr((char*) ipaddress, ipaddress.length(), AF_INET);
                if (hent != NULL)
                        localhostName = JString(hent->h_name);
                else {
                        int err = WSAGetLastError();
//                      dealWithSocketError(err);
                        if (DEBUGLEVEL(KITCHENSINK)) {
                                printf("getLocalHostname(): gethostbyaddr error %d...\n", err);
                        }
                        localhostName = ipaddress;
                        return ipaddress;
                }

        #else // WIN32

                struct addrinfo hints, *res;
                int error;
                const char *cause = NULL;

                memset(&hints, 0, sizeof(hints));
                hints.ai_flags = AI_NUMERICHOST;
                hints.ai_family = PF_UNSPEC;
                hints.ai_socktype = SOCK_STREAM;
//              printf(""); fflush(stdout);
//              printf("call getaddrinfo: 1 '%s'\n", (char*) ipaddress); fflush(stdout);
                error = getaddrinfo(ipaddress, NULL, &hints, &res);
//              printf("call getaddrinfo: 2 %d\n", error); fflush(stdout);
                if (error != 0) {
                        localhostName = ipaddress;
                        return ipaddress;
                }
                else {
                        if (res->ai_canonname != NULL) {
                                localhostName = res->ai_canonname;
//                              printf("call getaddrinfo: 2 %d '%s'\n", error, (char*) hostname); fflush(stdout);
                        }
                        else
                                localhostName = ipaddress;
                }
                freeaddrinfo(res);




/*                      int er;
                        hent = getipnodebyname(ipaddress, AF_INET, 0, &er);

                        if (hent != NULL) {
                                if (hent->h_addr_list[0] == NULL) {
                                        printf("\n##### NETWORK CONFIGURATION ERROR: %s - address: NOT FOUND\n", (char*) hent->h_name, ipnumber.a, ipnumber.b, ipnumber.c, ipnumber.d);
                                }
                                else {
                                        hostname = JString(hent->h_name);
                                        // printf("\nSUCCESS getIPAddressFromName: %s - address: %d.%d.%d.%d\n", (char*) lookupName, ipnumber.a, ipnumber.b, ipnumber.c, ipnumber.d);
                                }
                                freehostent(hent);
                        }
*/
/*                      if (er == 0) {
                                hostname = JString(hent->h_name);
                        }
                        else {
                                if (er == ERANGE)
                                        printf("gethostbyname_r error %s: ERANGE\n", (char*) ipaddress);
                                else if (er == HOST_NOT_FOUND ) {
//                                      printf("gethostbyname_r error %s: HOST_NOT_FOUND \n", (char*) ipaddress);
                                }
                                else if (er == NO_ADDRESS )
                                        printf("gethostbyname_r error %s: NO_ADDRESS \n", (char*) ipaddress);
                                else if (er == NO_DATA )
                                        printf("gethostbyname_r error %s: NO_DATA \n", (char*) ipaddress);
                                else if (er == NO_RECOVERY )
                                        printf("gethostbyname_r error %s: NO_RECOVERY \n", (char*) ipaddress);
                                else if (er == TRY_AGAIN )
                                        printf("gethostbyname_r error %s: TRY_AGAIN \n", (char*) ipaddress);
                                else
                                        printf("gethostbyname_r error %s: Something else: %d \n", (char*) ipaddress, er);*/
//                      }
//                      delete(hent);

//              #endif // Darwin

        #endif // WIN32

        return localhostName;

/*
        char strc[100];
        JString hostname;
        struct hostent* hent;

        struct sockaddr_in localAddr;

        hostname = "";

        #ifdef WIN32
                int localAddrLen;
        #else
                #ifdef Darwin
                        int localAddrLen;
                #else
                        socklen_t localAddrLen;
                #endif
        #endif // WIN32

        localAddrLen = sizeof(struct sockaddr_in);

        if (getsockname(mySocket, (struct sockaddr*) &localAddr, &localAddrLen) == 0) {
                char* str = inet_ntoa(localAddr.sin_addr);
                hent = gethostbyname(str);
                if (hent != NULL)
                        hostname = JString(hent->h_name);
                else {
                        hostname = str;
                }
        }
        else {
//              int err2 = this->getLastOSErrorNumber();
//              if (err2 == EBADF)
//                      printf("getsockname failed with EBADF!!!\n");
//              else if (err2 == ENOTSOCK)
//                      printf("getsockname failed with ENOTSOCK!!!\n");
//              else if (err2 == ENOBUFS)
//                      printf("getsockname failed with ENOBUFS!!!\n");
//              else if (err2 == EFAULT)
//                      printf("getsockname failed with EFAULT!!!\n");
//      }

        if (hostname.length() == 0) {
                if (gethostname(strc, 99) != 0) {
                        int err = this->getLastOSErrorNumber();
                        dealWithSocketError(err, "");
                        printf("getLocalHostname(): gethostname error %d...\n", err);
                        return "";
                }

                #ifdef WIN32
                        hent = gethostbyname(strc);
                        if (hent != NULL)
                                hostname = JString(hent->h_name);
                        else {
                                printf("getLocalHostname(): gethostbyname error %d...\n", WSAGetLastError());
                                return "";
                        }
                                
                #else // WIN32

                        #ifdef Darwin
                                hent = gethostbyname(strc);
                                hostname = JString(hent->h_name);
                        #else // Darwin

                                hent = new struct hostent;
                        //      struct hostent *rhent;

                                char bf[1000];
                                int er;

                                // gethostbyname_r (const char *, hostent *, char *, unsigned int, hostent **, int *)

                                gethostbyname_r(strc, hent, bf, 1000, &hent, &er);

                                if (er == 0) {
                                        // printf("gethostbyname_r hent string pointer: %d\n", hent->h_name);
                                        // printf("gethostbyname_r hent string: %s\n", hent->h_name);
                                        hostname = JString(hent->h_name);
                                }
                                else {
                                        if (er == ERANGE)
                                                printf("gethostbyname_r error %s: ERANGE\n", strc);
                                        else if (er == HOST_NOT_FOUND )
                                                printf("gethostbyname_r error %s: HOST_NOT_FOUND \n", strc);
                                        else if (er == NO_ADDRESS )
                                                printf("gethostbyname_r error %s: NO_ADDRESS \n", strc);
                                        else if (er == NO_DATA )
                                                printf("gethostbyname_r error %s: NO_DATA \n", strc);
                                        else if (er == NO_RECOVERY )
                                                printf("gethostbyname_r error %s: NO_RECOVERY \n", strc);
                                        else if (er == TRY_AGAIN )
                                                printf("gethostbyname_r error %s: TRY_AGAIN \n", strc);
                                        else
                                                printf("gethostbyname_r error %s: Something else: %d \n", strc, er);
        
                                        // No matter what, try to recover by returning the simple hostname
                                        hostname = JString(strc);
                                }
                                delete(hent);

                        #endif // Darwin

                #endif // WIN32
        }

        return hostname;
*/
//      return JString(s);

/*      if (mySocket == NULL) return "";


        struct sockaddr_in localAddr;
        
        #ifdef WIN32
                int localAddrLen;
        #else
                socklen_t localAddrLen;
        #endif // WIN32

        localAddrLen = sizeof(struct sockaddr_in);

        if (getsockname(mySocket, (struct sockaddr*) &localAddr, &localAddrLen) == 0)
                return inet_ntoa(localAddr.sin_addr);
        else
                return ""; */
}

JString JSocket::getRemoteIPAddress() {

        if (!isSocketValid()) return "";

        JString ipaddr;

        struct sockaddr_in remoteAddr;
        
        #ifdef WIN32
                int remoteAddrLen;
        #else
                #ifdef Darwin
                        #if GCC_VERSION < 40000
                                int remoteAddrLen;
                        #else
                                socklen_t remoteAddrLen;
                        #endif // GCC_VERSION < 40000
                #else
                        socklen_t remoteAddrLen;
                #endif
        #endif // WIN32

        remoteAddrLen = sizeof(struct sockaddr_in);

        if (getpeername(mySocket, (struct sockaddr*) &remoteAddr, &remoteAddrLen) == 0) {
                ipaddr = inet_ntoa(remoteAddr.sin_addr);
                if ((ipaddr.equals("127.0.0.1")) || (ipaddr.equals("localhost"))) {
                        ipaddr = getLocalIPAddress();
                }
                this->address = ipaddr;
                this->port = (int) remoteAddr.sin_port;
        }
        return ipaddr;
}


JString JSocket::getRemoteHostname() {
        return getHostnameFromIPAddress(getRemoteIPAddress());
}


JString JSocket::getHostnameFromIPAddress(JString ipaddr) {

        #if defined(_WIN32_WCE)
                return ipaddr;
        #endif

        if (ipaddr.length() == 0)
                return ipaddr;

        JString hname = ipaddr;

        struct hostent *pHost;

        #ifdef WIN32
                pHost = gethostbyname(ipaddr);
                if (pHost == NULL)
                        return ipaddr;
                hname = pHost->h_name;
        #else // WIN32

                #ifdef Darwin
                    pHost = gethostbyname(ipaddr);
                    if (pHost == NULL)
                                return ipaddr;
                        else
                                hname = pHost->h_name;
                #else // Darwin

                        pHost = new struct hostent;
                        char bf[2000];
                        int er;
                        gethostbyname_r(ipaddr, pHost, bf, 2000, &pHost, &er);
                        if (er != 0) {
                                delete pHost;
                                return ipaddr;
                        }
                        else {
                                hname = pHost->h_name;
                                delete pHost;
                        }

                #endif // Darwin
        #endif // WIN32

        if ((hname.equals("127.0.0.1")) || (hname.equals("localhost"))) {
                hname = getLocalHostname();
        }
        return hname;
}








JSocket::JSocket(SOCKET new_sock) {

//      ipnumber = new unsigned char[4];
//      charBuffer = new char[BUFFERSIZE+2];
        charBufferCount = 0;
        charBuffer[0] = 0;
        mySocket = new_sock;
        protocol = "";
//      this->addUnitTestLog(JString::format("Getting remote hostname...\n"));
        getRemoteHostname();

//      this->addUnitTestLog(JString::format("Setting non blocking mode...\n"));
        setNonBlockingMode();

        connected = true;
        lastErrorMessage = "";
        lastErrorRecoverable = true;
        listening = false;
//      this->addUnitTestLog(JString::format("Sock created!\n"));
}




bool JSocket::setUpListening() {

        if ((isSocketValid()) || (isListening())) {
                if (DEBUGLEVEL(KITCHENSINK)) {
                        printf("****** CreateSocket failed, socket already there! *****/n");
                }
                return false;
        }

        listening = false;
        if (!createSocket()) {
                if (DEBUGLEVEL(KITCHENSINK)) {
                        printf("****** CreateSocket failed! *****/n");
                }
                return false;
        }

        if (!isSocketValid()) {
                if (DEBUGLEVEL(STATUS)) {
                        printf("Just created an invalid socket!/n");
                }
                wait(1000);
                return false;
        }

        //
        // Use SOCKADDR_IN to fill in address information
        //
        struct sockaddr_in saServer;

        saServer.sin_family = AF_INET;
        saServer.sin_addr.s_addr = INADDR_ANY;          // Since this is a server, any address will do
        saServer.sin_port = htons(port);                // Convert int 8888 to a value for the port field

        int res;

        #ifndef WIN32
                /*
                        This socket option tells the kernel that even if this port is busy (in
                        the TIME_WAIT state), go ahead and reuse it anyway.  If it is busy,
                        but with another state, you will still get an address already in use
                        error.  It is useful if your server has been shut down, and then
                        restarted right away while sockets are still active on its port.  You
                        should be aware that if any unexpected data comes in, it may confuse
                        your server, but while this is possible, it is not likely.
                */
                int one = 1;
                setsockopt(mySocket,SOL_SOCKET,SO_REUSEADDR,&one,sizeof(one));
        #endif

        /* bind the socket to the internet address */
        if ((res = bind(mySocket, (struct sockaddr *)&saServer, sizeof(struct sockaddr_in))) < 0) {
                if (DEBUGLEVEL(DETAILEDSTATUS)) {
                        printf("****** Bind not performed *****\n");
                }
                dealWithSocketError(getLastOSErrorNumber(), "Bind failed");
                disconnectNow();
                return false;
        }

        if ((res = listen(mySocket, SOMAXCONN)) < 0) {  /* max # of queued connects */
                if (DEBUGLEVEL(DETAILEDSTATUS)) {
                        printf("****** Listening not started *****\n");
                }
                dealWithSocketError(getLastOSErrorNumber(), "Listen failed");
                disconnectNow();
                return false;
        }

        listening = true;
        connected = false;

        return true;
}

JSocket* JSocket::waitForConnection(long timeout) {

        JTime now;

        JTime t;
        lastErrorMessage = "";
        
        // Is this a new Socket???
        if (!isSocketValid()) {
                if (DEBUGLEVEL(KITCHENSINK)) {
                        printf("######## WAITING for invalid socket %d!\n", mySocket);
                }
                wait(100);
                return NULL;
        }
        if (!isListening()) {
                if (DEBUGLEVEL(KITCHENSINK)) {
                        printf("######## WAITING for non-listening socket!\n");
                }
                wait(100);
                return NULL;
        }

        bool waitingForAccept = true;
        int w;

        SOCKET new_sock = INVALID_SOCKET;
        while (waitingForAccept) {

        //      now = JTime();
        //      this->addUnitTestLog(JString::format("Accept1: %s", (char*) now.printTime()));
                new_sock = accept(mySocket, NULL, NULL);
        //      now = JTime();
        //      this->addUnitTestLog(JString::format("Accept2: %s [%d]", (char*) now.printTime(), new_sock));

                if ((int) new_sock < 0) {
                        int wsaError = getLastOSErrorNumber();
                        if ((wsaError == WSAEWOULDBLOCK) || (wsaError == EINPROGRESS)) {
                                // No connection available right now, continue waiting
                                now = JTime();
                                w = timeout - (now-t);
                                // w = timeout - t.getAge(); // (now-t);
                                if (w > 0) {
                                        // wait(w);
                                //      this->addUnitTestLog(JString::format("Wait1: %s [%d]", (char*) now.printTime(), wsaError));
                                        waitForReadability(w);
                                //      now = JTime();
                                //      this->addUnitTestLog(JString::format("Wait2: %s [%d]", (char*) now.printTime(), wsaError));
                                }
                                else
                                        break;
                        }
                        else {
                        //      now = JTime();
                        //      this->addUnitTestLog(JString::format("SockErr: %s [%d]", (char*) now.printTime(), wsaError));
                                dealWithSocketError(wsaError, "Accept failed");
                                if (DEBUGLEVEL(KITCHENSINK)) {
                                        printf("######## JSocket : Accept failed %d ##########\n", wsaError);
                                }
                                wait(100);
                                disconnectNow();
                        //      now = JTime();
                        //      this->addUnitTestLog(JString::format("SockErrDis: %s [%d]", (char*) now.printTime(), wsaError));
                                return NULL;
                        }
                }
                else {
                        // We have a winner!
                //      now = JTime();
                //      this->addUnitTestLog(JString::format("SockGood1: %s", (char*) now.printTime()));
                        JSocket* s = new JSocket(new_sock);
                //      now = JTime();
                //      this->addUnitTestLog(JString::format("SockGood2: %s", (char*) now.printTime()));
                        return s;
                }
        }

//      now = JTime();
//      this->addUnitTestLog(JString::format("SockNULL: %s", (char*) now.printTime()));
        return NULL;
}
        




IPNumber JSocket::getIPNumberFromName(JString name) {

        IPNumber ipnum;
        ipnum.a = ipnum.b = ipnum.c = ipnum.d = 0;

        if (name.length() == 0) {
                ipnum.a = 127;
                ipnum.b = 0;
                ipnum.c = 0;
                ipnum.d = 1;
                return ipnum;
        }

        struct hostent* hent;
        JString lookupName = name;

        Collection col = lookupName.split(".");
        if (col.getCount() == 4) {
                int num = col.getFirst().toInt();
                if (num > 0) {
                        ipnum.a = num;
                        ipnum.b = col.getNext().toInt();
                        ipnum.c = col.getNext().toInt();
                        ipnum.d = col.getNext().toInt();
                        return ipnum;
                }
        }

//      printf("getIPAddressFromName: 1\n"); fflush(stdout);

        if ((name.equalsIgnoreCase("localhost") || name.equalsIgnoreCase("127.0.0.1"))) {
                lookupName = getLocalIPAddress();
                col = lookupName.split(".");
                if (col.getCount() == 4) {
                        ipnum.a = col.get(0).toInt();
                        ipnum.b = col.get(1).toInt();
                        ipnum.c = col.get(2).toInt();
                        ipnum.d = col.get(3).toInt();
                }
                else {
                        if (DEBUGLEVEL(STATUS)) {
                                printf("Unable to find IPNumber for localhost, defaulting to 127.0.0.1...");
                        //      printf("Unable to find IPNumber for localhost, defaulting to 127.0.0.1...", (char*) name);
                        }
                        ipnum.a = 127;
                        ipnum.b = 0;
                        ipnum.c = 0;
                        ipnum.d = 1;
                }
                return ipnum;
        }

        #ifdef WIN32
                
                hent = gethostbyname(lookupName);

                if (hent == NULL) {
                        dealWithSocketError(getLastOSErrorNumber(), "Hostname invalid in connectNow");
                }
                else
                        memcpy(&ipnum, hent->h_addr_list[0], 4);

        #else
                struct addrinfo hints, *res;
                int error;
                const char *cause = NULL;

//              printf("getIPAddressFromName: 4\n"); fflush(stdout);

                memset(&hints, 0, sizeof(hints));
                // hints.ai_flags = AI_NUMERICHOST; // AI_PASSIVE
                hints.ai_family = PF_UNSPEC;
                hints.ai_socktype = SOCK_STREAM;
//              printf("call getaddrinfo: 11 '%s'\n", (char*) lookupName); fflush(stdout);
                error = getaddrinfo(lookupName, NULL, &hints, &res);
//              printf("call getaddrinfo: 22 %d\n", error); fflush(stdout);
                if (!error) {
                        ipnum.a = res->ai_addr->sa_data[2];
                        ipnum.b = res->ai_addr->sa_data[3];
                        ipnum.c = res->ai_addr->sa_data[4];
                        ipnum.d = res->ai_addr->sa_data[5];
                        freeaddrinfo(res);
                }
                else {
                  if (DEBUGLEVEL(STATUS))
                    printf("getaddrinfo error: %d (%s)\n", error, gai_strerror(error));
                }
        #endif // WIN32

//      printf("getIPAddressFromName: 8\n"); fflush(stdout);

//      if (ipnum.a == 0) {
//              if (DEBUGLEVEL(STATUS)) {
//                      printf("Unable to find IPNumber for '%s', defaulting to localhost...\n", (char*) name);
//              }
//              ipnum = getIPNumberFromName("localhost");
//      }
                        
        return ipnum;
}

JString JSocket::getIPAddressFromName(JString name) {
        IPNumber ipnum = getIPNumberFromName(name);
        return JString::format("%d.%d.%d.%d", ipnum.a, ipnum.b, ipnum.c, ipnum.d);
}


//! Under the hood connectNow()
bool JSocket::connectNow(const IPNumber& ip, int port) {

        struct sockaddr_in saServer;
        saServer.sin_family = AF_INET;
        saServer.sin_port = htons(port);
        
        memcpy(&saServer.sin_addr, &ip, 4);

        // For now, set
        connected = true;
        listening = false;

        // Connect to the server
        int res;
        if ((res = connect(mySocket, (struct sockaddr*)&saServer, sizeof(struct sockaddr))) != 0) {

                int wsaError = getLastOSErrorNumber();
                if ((wsaError == WSAEWOULDBLOCK) || (wsaError == EINPROGRESS)) {
                        if (DEBUGLEVEL(DETAILEDSTATUS)) {
                                printf("Waiting for Socket to connect to %d.%d.%d.%d:%d [%d]...", ip.a, ip.b, ip.c, ip.d, port, wsaError);      
                        }
                        if (!didConnectionGoThrough(300)) {
                          if (DEBUGLEVEL(DETAILEDSTATUS))
                            printf(" FAILED\n");        
                                disconnectNow();
                                connected = false;
                                return false;
                        }
                        if (DEBUGLEVEL(DETAILEDSTATUS))
                                printf(" SUCCESS\n");   
                }
                else {
                        if (DEBUGLEVEL(DETAILEDSTATUS)) {
                                printf("Socket could not connect to %d.%d.%d.%d:%d [%d]...\n", ip.a, ip.b, ip.c, ip.d, port, wsaError); 
                        }
                        disconnectNow();
                        connected = false;
                        return false;
                }
        }

        connected = true;
        return true;

}


bool JSocket::connectNow() {

        if (!isSocketValid()) {
                if (!createSocket())
                        return false;
        }

        Collection addresses = this->location.getAllAddresses();

        bool res = false;
        IPNumber ip;
        JString conAddress;
        for (int n=0; n<addresses.getCount(); n++) {
                if ( (conAddress = addresses.get(n)).length() > 0) {
                        ip = getIPNumberFromName(conAddress);
                        if (ip.a > 0) {
                                res = connectNow(ip, port);
                                if (res) {
                                        ipnumber = ip;
                                        address = conAddress;
                                        return true;
                                }
                        }
                }
        }
        return res;
}



bool JSocket::disconnectNow() {
        if (isSocketValid())
                osCloseSocket(mySocket);
        setSocketNotValid();
        connected = listening = false;
        // Let other processes get a chance to finish their calls first...
//      wait(0);
        return true;
}

int JSocket::readChar(char* ch) {
        if (!isConnected())
                return -1;

        int res;
        int wsaError;

        if ((res = recv(mySocket, ch, 1, 0)) > 0) {
                ioCounts[0]++;
                return 1;
        }
        
        if (res == 0) {
                connected = false;
                return -1;
        }

        else {
                wsaError = getLastOSErrorNumber();
                if ((wsaError == WSAEWOULDBLOCK) || (wsaError == EINPROGRESS)) {
                        // we are OK, nothing ready to read yet...
                        return 0;
                }
                else if (wsaError == WSAEMSGSIZE) {
                        // buffer full, but more to read
                        ioCounts[0]++;
                        return 1;
                }
                else {
                        dealWithSocketError(wsaError, "Read failed");
                        if (!lastErrorRecoverable) {
                                disconnectNow();
                                return -1;
                        }
                        return 0;
                }
        }
}

int JSocket::peekIntoStream() {
        char peekBuffer[1];
        return peekIntoStream(peekBuffer, 1);
}

int JSocket::peekIntoStream(char* buffer, int maxcount) {
        if (!isSocketValid())
                return -1;
        int res = recv(mySocket, buffer, maxcount, MSG_PEEK);

        if (res <= 0) {
                int wsaError = getLastOSErrorNumber();
                if (((wsaError == WSAEWOULDBLOCK) || (wsaError == EINPROGRESS))) {
                        // no more to read, buffer is now as full as can be
                        return 0;
                }
                else {
                        if (wsaError == WSAENOTCONN) { // Windows needs this one...
                                // printf("Peek Temp Error OK: %d %d\n", res, wsaError);
                                // OK for now...
                        }
                        #ifdef WIN32
                        else if (wsaError == WSAEOPNOTSUPP) { // WinCE may need this one...???.
                                // printf("Peek Temp Error OK: %d %d\n", res, wsaError);
                                // OK for now...
                        }
                        //else if (wsaError == WSAECONNRESET) { // WinCE may need this one...???.
                        //      printf("Peek Temp Error OK: %d %d\n", res, wsaError);
                                // OK for now...
                        //}
                        #endif //WIN32
                        else {
                                // printf("Peek Error: %d %d\n", res, wsaError);
                                int so = (int) mySocket;
                                disconnectNow();
                                dealWithSocketError(wsaError, "Read failed");
                        }
                        return -1;
                }

        }
        return res;
}


int JSocket::readIntoBuffer() {
        if (!isSocketValid())
                return -1;
        int count = 0;
        unsigned int breakmax = BUFFERSIZE - charBufferCount;
        if (breakmax < 0) 
                return -2;
        else if (breakmax == 0)
                return 0;

        // Call isConnected with timeout = -1 to avoid circular referencing
        //if (!isConnected(-1))
        //      return -1;

        int res;
        int wsaError;
        JString text;

        while ((res = recv(mySocket, (char*)(charBuffer + charBufferCount), breakmax, 0)) > 0) {
                charBufferCount += res;
                count += res;
                //printf("[%d] readIntoBuffer: %d chars  --  count: %d  --  buffer: %d...\n", (int) this, res, count, charBufferCount); fflush(stdout);
                breakmax = BUFFERSIZE - charBufferCount;
                if (breakmax <= 0) {
                        ioCounts[0] += count;
                        return count;
                }
        }

        wsaError = getLastOSErrorNumber();

        if ((res < 0) && ((wsaError == WSAEWOULDBLOCK) || (wsaError == EINPROGRESS))) {
                // no more to read, buffer is now as full as can be
                ioCounts[0] += count;
                return count;
        }
        else if (res == 0) {
                if (count == 0)
                        count = -1;
                // but we might still have valid data in buffer
                // return count;
        }
        else {
                if (count == 0)
                        count = -1;

                if (wsaError == WSAEMSGSIZE) {
                        // Do we ever get this one?
                        ioCounts[0] += count;
                        return count;
                }
                else {
                        dealWithSocketError(wsaError, "Read failed");
                }
        }

        if (count < 0)
                disconnectNow();

        ioCounts[0] += count;
        return count;
}


int JSocket::writeString(JString text) {
        return writeBuffer(text, text.length());
}

int JSocket::writeBuffer(char* buf, int length) {
        int breakmax = SENDBUFFERSIZE;
        
        if (!isConnected()) return -1;
        if (length == 0) return 0;

        currentUnsentBufferSize = length;
        currentSentBufferSize = 0;

        int wsaError;
        int res = 0;

        setBlockingMode();

        JTime t1, t2;
        if (length <= breakmax) {
                res = send(mySocket, buf, length, 0);
                // t1 = JTime();
                waitForWriteability(1000);
                // t2 = JTime();
                // printf("waitForWriteability 1: %.3fms\n", (double)t2.microDifference(t1)/1000.0);
        }
        else {
                int subres = 0;
                char* lpbuffer = buf;
                int l = length;
                int n = l / breakmax;
                for (int i=0; i < n; i++) {
                        subres = send(mySocket, &lpbuffer[i*breakmax], breakmax, 0);
                        if (subres == breakmax) {
                                res += subres;
                                currentSentBufferSize = res;
                        }
                        else {
                        //      printf("*** Only partial socket sent - %d out of %d ***\n", res, length);
                                currentUnsentBufferSize = 0;
                                currentSentBufferSize = 0;
                                connected = false;
                                return -1;
                        }

                        // t1 = JTime();
                        waitForWriteability(1000);
                        // t2 = JTime();
                        // printf("waitForWriteability 2: %.3fms\n", (double)t2.microDifference(t1)/1000.0);
                }
                // wait(10);
                n = n * breakmax;
                //printf("                           last writing %d bytes to socket...\n", l-n);
                subres = send(mySocket, &lpbuffer[n], l-n, 0);
                if (subres == l-n) {
                        res += subres;
                        currentSentBufferSize = res;
                }
                else {
                        // printf("*** Only partial socket sent - %d out of %d ***\n", res, length);
                        currentUnsentBufferSize = 0;
                        currentSentBufferSize = 0;
                        connected = false;
                        return -1;
                }
                // t1 = JTime();
                waitForWriteability(1000);
                // t2 = JTime();
                // printf("waitForWriteability 3: %.3fms\n", (double)t2.microDifference(t1)/1000.0);
        }

        setNonBlockingMode();




        /*
        if (length <= breakmax) {
//              printf("                           writing %d bytes to socket...\n", length);
                res = send(mySocket, buf, length, 0);
                waitForWriteability(1000);
                // waitForReadability(1000);
        }
        
        else {
          // setBlockingMode();
          res = send(mySocket, buf, length, 0);
          waitForWriteability(1000);
          // setNonBlockingMode();
        }
        */
        /*
        else {
                char* lpbuffer = buf;
                int l = length;
                int n = l / breakmax;
                for (int i=0; i < n; i++) {
                  //printf("                           %d writing %d bytes to socket...\n", i, breakmax);
                        res = send(mySocket, &lpbuffer[i*breakmax], breakmax, 0);
                        waitForWriteability(1000);
                        #ifdef Darwin
                                wait(5);
                        #endif
                                // waitForReadability(1000);
                }
                wait(10);
                n = n * breakmax;
                //printf("                           last writing %d bytes to socket...\n", l-n);
                res = send(mySocket, &lpbuffer[n], l-n, 0);
                waitForWriteability(1000);
                // waitForReadability(1000);
        }*/
        

        if (res == length) {
                currentSentBufferSize = length;
                ioCounts[1] += length;
                return length;
        }
        else if (res > 0) {
                printf("*** Only partial socket send - %d out of %d ***\n", res, length);
                currentUnsentBufferSize = 0;
                currentSentBufferSize = 0;
                connected = false;
                return -1;
        }
        
        if (res == 0) {
                currentUnsentBufferSize = 0;
                currentSentBufferSize = 0;
                connected = false;
                return -1;
        }

        else {
                wsaError = getLastOSErrorNumber();
                if (wsaError == 0) {
                        // No error, just unable to send...
                        if (DEBUGLEVEL(DETAILEDSTATUS))
                                printf("*** No error, just unable to send... ***\n");
                        currentUnsentBufferSize = 0;
                        currentSentBufferSize = 0;
                        return -1;
                }
                else if ((wsaError == WSAEWOULDBLOCK) || (wsaError == EINPROGRESS)) {
                        // Wait for the socket to become writable again...
                        if (!isConnected(1000)) {
                                if (DEBUGLEVEL(DETAILEDSTATUS))
                                        printf("*** Not connected error, unable to send... ***\n");
                                currentUnsentBufferSize = 0;
                                currentSentBufferSize = 0;
                                return -1;
                        }
                        // wait(20);
                        // we are OK, nothing ready to read yet...
                        currentSentBufferSize = length;
                        ioCounts[1] += length;
                        return length;
                }
                else if (wsaError == WSAEMSGSIZE) {
                        // buffer full, but more to read
                        if (DEBUGLEVEL(DETAILEDSTATUS))
                                printf("*** Buffer full error, unable to send... ***\n");
                        currentUnsentBufferSize = 0;
                        currentSentBufferSize = 0;
                        return -2;
                }
                else {
                        dealWithSocketError(wsaError, "Write failed");
                        if (!lastErrorRecoverable) {
                                if (DEBUGLEVEL(DETAILEDSTATUS)) {
                                //      printf("\n######## SOCKET ERROR! #########\n");
                                        printf("*** Socket error, unable to send... ***\n");
                                }
                                disconnectNow();
                                currentUnsentBufferSize = 0;
                                currentSentBufferSize = 0;
                                return -1;
                        }
                        currentUnsentBufferSize = 0;
                        currentSentBufferSize = 0;
                        return -1;
                }
        }
}


bool JSocket::isConnected(int timeout) {

/*      if ((isTerminating) ||
                (!mutex.EnterMutex(0)) ||
                (isTerminating)) {
                return true;
        }*/

        // First use the socket a bit
        int peek = peekIntoStream();

        if (peek < 0) {
                peek = peek + 1 - 1;
        }

//      return isConnected(timeout);
        int maxfd = 0;

//      if ((!connected) || (!isSocketValid())) return false;
        if (!isSocketValid()) {
                if (DEBUGLEVEL(DETAILEDSTATUS)) {
                /*      printf("Socket is not valid [%d]\n", (int) this);
                        if (DEBUGLEVEL(HEARTBEAT)) {
                                Collection trace = JThread::getProgramTrace();
                                printf("Trace:\n- %s\n", (char*) trace.printListLine("\n- "));
                        }*/
        
                        // wait(5);
                }
                // mutex.LeaveMutex();
                return false;
        }

        struct timeval tv;
        tv.tv_sec = 0;
        tv.tv_usec = 10;

        fd_set wfds;
//      fd_set erds;
        // create a list of sockets to check for activity
        FD_ZERO(&wfds);
        // specify mySocket
        FD_SET(mySocket, &wfds);

        #ifdef WIN32
                int len;
        #else
                #ifdef Darwin
                        #if GCC_VERSION < 40000
                                int len;
                                maxfd = mySocket + 1;
                        #else
                                socklen_t len;
                                maxfd = mySocket + 1;
                        #endif // GCC_VERSION < 40000
                #else
                        socklen_t len;
                        maxfd = mySocket + 1;
                #endif
        #endif

        if (timeout > 0) {
                ldiv_t d = ldiv(timeout*1000, 1000000);
                tv.tv_sec = d.quot;
                tv.tv_usec = d.rem;
        }

        // Check for writability
        int res = select(maxfd, NULL, &wfds, NULL, &tv);

        if (res <= 0) {
                if (DEBUGLEVEL(DETAILEDSTATUS)) {
                //      printf("Socket is not connected\n");    
                }
                // mutex.LeaveMutex();
                return false;
        }

        int error;
        len = sizeof(error);

        if (FD_ISSET(mySocket, &wfds) != 0) {
                if (getsockopt(mySocket, SOL_SOCKET, SO_ERROR, (char*)&error, &len) != 0) {

                        int wsaError = getLastOSErrorNumber();
                        if (wsaError == 0) {
                                // No error, just unable to send...
                                // mutex.LeaveMutex();
                                return true;
                        }
                        #ifdef WIN32
                                else if (wsaError == WSAENETDOWN ) {
                                        // mutex.LeaveMutex();
                                        return false;
                                }
                                else if (wsaError == WSAEFAULT  ) {
                                        // mutex.LeaveMutex();
                                        return false;
                                }
                                else if (wsaError == WSAEINPROGRESS  ) {
                                        // mutex.LeaveMutex();
                                        return false;
                                }
                                else if (wsaError == WSAEINVAL  ) {
                                        // mutex.LeaveMutex();
                                        return false;
                                }
                                else if (wsaError == WSAENOPROTOOPT  ) {
                                        if (error == 0) {
                                                // mutex.LeaveMutex();
                                                return true;
                                        }
                                }
                                else if (wsaError == WSAENOTSOCK  ) {
                                        // mutex.LeaveMutex();
                                        return false;
                                }
                        #endif                  
                        printf("**********************  getsockopt failed  *************************");
                        // mutex.LeaveMutex();
                        return false;
                }
                if (error == 0) {
                        // We are good
//                      printf("*"); fflush(stdout);
                        // mutex.LeaveMutex();
                        return true;
                }
        }

        if (DEBUGLEVEL(DETAILEDSTATUS)) {
        //printf("Socket is not connected 2\n");
        }
        // mutex.LeaveMutex();
        return false;
}

bool JSocket::waitForReadability(int timeout) {

        int maxfd = 0;

        // If socket is not valid return true so the next read will report the error
        if (!isSocketValid()) return true;

        struct timeval tv;
        tv.tv_sec = 0;
        tv.tv_usec = 0;

        fd_set rdds;
        // create a list of sockets to check for activity
        FD_ZERO(&rdds);
        // specify mySocket
        FD_SET(mySocket, &rdds);

        #ifdef WIN32
        #else
                #ifdef Darwin
                        maxfd = mySocket + 1;
                #else
                        maxfd = mySocket + 1;
                #endif
        #endif

        if (timeout > 0) {
                ldiv_t d = ldiv(timeout*1000, 1000000);
                tv.tv_sec = d.quot;
                tv.tv_usec = d.rem;
        }

        // Check for readability
//      JTime t1;
        int ret = select(maxfd, &rdds, NULL, NULL, &tv);
//      JTime t2;
//      printf("[waitForReadability] waited: %d max: %d  ret: %d\n", t2-t1, timeout, ret);
//      if (ret != 0)
//              ret = ret;
        return(ret > 0);
}

bool JSocket::waitForWriteability(int timeout) {

        int maxfd = 0;

        // If socket is not valid return true so the next read will report the error
        if (!isSocketValid()) return true;

        struct timeval tv;
        tv.tv_sec = 0;
        tv.tv_usec = 0;

        fd_set wds;
        // create a list of sockets to check for activity
        FD_ZERO(&wds);
        // specify mySocket
        FD_SET(mySocket, &wds);

        #ifdef WIN32
        #else
                #ifdef Darwin
                        maxfd = mySocket + 1;
                #else
                        maxfd = mySocket + 1;
                #endif
        #endif

        if (timeout > 0) {
                ldiv_t d = ldiv(timeout*1000, 1000000);
                tv.tv_sec = d.quot;
                tv.tv_usec = d.rem;
        }

        // Check for readability
        return( select(maxfd, NULL, &wds, NULL, &tv) > 0);
}

bool JSocket::didConnectionGoThrough(int timeout) {
        return isConnected(timeout);
}

bool JSocket::isIPAddressPrivate(JString ipaddr) {

        bool res = false; 

        if (ipaddr.equals("127.0.0.1"))
                res = true;
        else if (ipaddr.startsWith("10."))
                res = true;
        else if (ipaddr.startsWith("192.168."))
                res = true;
        else if (ipaddr.startsWith("0."))
                res = true;

        return res;
}



double JSocket::getReceiveProgress() {
        if (currentUnreceivedBufferSize == 0)
                return 1;
        else if (currentUnreceivedBufferSize == currentReceivedBufferSize)
                return 1;
        else if (currentUnreceivedBufferSize > currentReceivedBufferSize)
                return ((double)currentReceivedBufferSize)/((double)currentUnreceivedBufferSize);
        else
                return 1;
}

double JSocket::getSendProgress() {
        if (currentUnsentBufferSize == 0)
                return 1;
        else if (currentUnsentBufferSize == currentSentBufferSize)
                return 1;
        else if (currentUnsentBufferSize > currentSentBufferSize)
                return ((double)currentSentBufferSize)/((double)currentUnsentBufferSize);
        else
                return 1;
}



double* JSocket::getIOCounts() {
        if (ioCounts[0] < 0) ioCounts[0] = 0;
        if (ioCounts[1] < 0) ioCounts[1] = 0;
        return ioCounts;
}

bool JSocket::resetIOCounts() {
        ioCounts[0] = ioCounts[1] = 0;
        return true;
}







/*
bool JSocket::isConnected(int timeout) {

        int maxfd = 0;

//      if ((!connected) || (!isSocketValid())) return false;
        if (!isSocketValid()) return false;

        struct timeval tv;
        tv.tv_sec = 0;
        tv.tv_usec = 1000;

        fd_set fds;
        // create a list of sockets to check for activity
        FD_ZERO(&fds);
        // specify mySocket
        FD_SET(mySocket, &fds);

        #ifndef WIN32
                maxfd = mySocket + 1;
        #endif

        if (timeout > 0) {
                ldiv_t d = ldiv(timeout*1000, 1000000);
                tv.tv_sec = d.quot;
                tv.tv_usec = d.rem;
        }

        // Check for writability
        int res = select(maxfd, NULL, &fds, NULL, &tv);

        if (res > 0) {
                return true;
        }
        else {
                return false;
        }
}*/













// *****************************************************************
// SocketTester Class
// *****************************************************************

SocketTester::SocketTester(int port) : JThread() {
        portnum = port;
        server = NULL;
}

SocketTester::~SocketTester() {
        shouldContinue = false;
//      wait(500);
//      delete(server);
        int count = 0;
        while (server != NULL) {
                wait(50);
                if (count++ > 20)
                        break;
        }
}

void SocketTester::run() {

        char* buf;

        printf("Starting server\n");
        this->addUnitTestLog("Socket Server starting...");


        JSocket* c = NULL;
        server = new JSocket("", portnum, "");

        if (!server->setUpListening()) {
                printf("\nPort %d not available.\n", portnum);
                this->addUnitTestLog("Socket Server port not available...");
                return;
        }
//      else
//              printf("\nPort %d listening...\n", portnum);

        JString str;
        
        shouldContinue = true;

        int count = 0;
        JTime t;
//      printf("Server socket created\n");
        while (shouldContinue) {
//              printf("%s Server waiting for connection...\n", (char*) t.printStamp());
                // this->addUnitTestLog(JString::format("Server waiting...\n"));
                t = JTime();
                // this->addUnitTestLog(JString::format("Server start wait: %s", (char*) t.printTime()));
                c = server->waitForConnection(50);
                t = JTime();
                // this->addUnitTestLog(JString::format("Server done wait: %s %d\n%s", (char*) t.printTime(), (int) c));
                server->getUnitTestLog();

                t = JTime();
                if (c != NULL) {
                        // this->addUnitTestLog("Socket Server got new connection...");
//                      printf("%s Server got new connection...\n", (char*) t.printStamp());
                        // this->addUnitTestLog(JString::format("%s Server got new connection...\n", (char*) t.printStamp()));

//                      c->writeln("Welcome...");
                        while (c->isConnected()) {
                                // printf("Server reading line...\n");
                                str = c->readln(500);
                                if (str.length() > 0) {

                                  // this->addUnitTestLog(JString::format("Socket Server read line [%d]...", str.length()));
                                  if (str.length() < 9) {
                                    int len = str.toInt();
                                    if (len > 0) {
                                      buf = new char[len+1];
                                      if (c->read(buf, len, MSGTIMEOUT) < len) {
                                                printf("Server Read Error\n");
                                      }
                                      else {
                                                buf[len] = 0;
                                                // printf("Server: %6d [%4d]\n", len, count++);
                                                JString str3 = JString((int)len) + JString("\n") + JString(buf);
                                                if (c->writeString(str3) <= 0) {
                                                        printf("!"); fflush(stdout);
                                                //c->writeln(JString((int)len));
                                                //wait(0);
                                                //c->writeString(JString(buf));
                                                }
                                                else {
                                                        // printf("."); fflush(stdout);
                                                }
                                      }
                                      delete [] buf;
                                      buf=NULL;
                                    }
                                  }
                                  else {


                                          // this->addUnitTestLog(JString::format("Server read %d chars [%d], responding..", str.length(), c->charBufferCount));

//                                      printf("Server read %d chars [%d], responding...\n", str.length(), c->charBufferCount);
                                        c->writeln(str);
                                  }
                                }
                        }
//                      printf("Server closing socket\n");
                        delete(c);
                        c = NULL;
                        t = JTime();
//                      printf("%s Server socket terminated !!!!!!!!!!\n", (char*) t.printStamp());
                }
        }

        delete(server);
        server = NULL;
}

#define TESTMAX 10
bool SocketTester::unitTest() {

        this->addUnitTestLog("Socket test starting...");

//      wait(1000000);
        wait(100);

        printf(".\b"); fflush(stdout);
        JSocket* con;

//      con = new JSocket("localhost", 3552, "");

        // Connect to port 3001 which does not exist
        con = new JSocket("localhost", portnum + 1065, "");

        Collection addresses = con->getLocalIPAddresses();
        printf("Found %d local IP addresses:\n\t%s\n\n", addresses.getCount(), (char*) addresses.printListLine("\n\t"));

        Dictionary interfaces = con->getLocalInterfaceAddresses();
        printf("Found %d local interfaces:\n\t%s\n\n", interfaces.getCount(), (char*) interfaces.printListLine("\n\t"));

        printf("This computer is '%s' with primary IP address %s\n\n", (char*) con->getLocalHostname(), (char*) con->getLocalIPAddress());
        
        //IPNumber ipnum = con->getIPNumberFromName("cmlabs.com");
        //printf("cmlabs: %d.%d.%d.%d\n", ipnum.a, ipnum.b, ipnum.c, ipnum.d);

        //      printf("\nTesting a wrong connection\n");

        if (con->isConnected()) {
                this->addUnitTestLog("Socket should not be connected at this time...");
                return false;
        }

//      printf("Connecting to a wrong connection...\n");
        if (con->connectNow()) {
                this->addUnitTestLog("Socket should not be connected at this time...");
                return false;
        }


//      printf("Testing if the wrong connection is connected...\n");
        if (con->isConnected()) {
                this->addUnitTestLog("Socket should not be connected at this time...");
                return false;
        }

        this->addUnitTestLog("Wrong connection test is complete");

        JString localip = con->getLocalIPAddress();

        delete(con);




//      localip = "localhost";

        // Now tester is ready on port 3000
        con = new JSocket(localip, portnum, "");
//      con = new JSocket("list.dk", 80, "");


//      printf("Connecting to the right connection...\n");
        if (con->isConnected()) {
                this->addUnitTestLog("Socket should not be connected at this time...");
                return false;
        }

        if (!con->connectNow()) {
                this->addUnitTestLog("Not Connecting to the right connection...");
                return false;
        }

        if (!con->isConnected()) {
                this->addUnitTestLog("Not Connected to the right connection...");
                return false;
        }
        
        printf("o\b"); fflush(stdout);

        JString str, str2;
        int n, h[TESTMAX], hh[TESTMAX];
        for (n = 0; n < TESTMAX; n++) {
                h[n] = 0;
                hh[n] = 0;
        }
        
        // Create str
        str = "";

        Collection ips = con->getLocalIPAddresses();
        this->addUnitTestLog(JString::format("IPs:\n - %s", (char*) ips.printListLine("\n - ")));
        Dictionary adaptors = con->getLocalInterfaceAddresses();
        this->addUnitTestLog(JString::format("IPs:\n - %s", (char*) adaptors.printListLine("\n - ")));


        JTime now;
        this->addUnitTestLog(JString::format("Socket connected: %s", (char*) now.printTime()));
        printf("Performance testing sockets...\n");

        JTime t;
        char* buf;
        int len2;

        int maxcount = 20;

        #if defined(_WIN32_WCE)
                maxcount = 1;
        #endif

        wait(1000);

        for (int kk=0; kk<maxcount; kk++) {
                printf("Pre\b\b\b");
                for (int kkk=0; kkk<1000; kkk++)
                  str += "0123456789";
                t = JTime();
                printf("Go\b\b");
                for (n = 0; n < 20; n++) {

                        if (!con->isConnected()) {
                                printf("************  No longer connected!!!  ************\n");
                                this->addUnitTestLog(JString::format("No longer connected %d", n));
                                return false;
                        }
                        /*
                        if (con->writeln(JString((int)str.length())) <= 0) {
                                con->disconnectNow();
                                delete(con);
                        //      wait(1000);
                                return false;
                        }
                        */
                        JString str3 = JString((int)str.length()) + JString("\n") + str;
                        //JString str3 = str;
                        if (con->writeString(str3) <= 0) {
                                printf("************  Unable to write!!!  ************\n");
                                this->addUnitTestLog(JString::format("Unable to write %d", n));
                                con->disconnectNow();
                                delete(con);
                        //      wait(1000);
                                return false;
                        }
                        
        //              wait(1000000);

        //              printf("w1\b\b"); fflush(stdout);
                        str2 = con->readln(5000);
                        //printf("w2\b\b"); fflush(stdout);
                        int len=str2.toInt();
                        if (len <= 0) {
                          printf("ERROR1[%d]: %d %d '%s'\n", n, len, (int)str2.length(), (char*) str2);
                        this->addUnitTestLog(JString::format("ERROR 1 [%d] read %d chars = %d", n, (int)str2.length(), len));
                          return false;
                        }
                        buf = new char[len+1];
                        if ( (len2 = con->read(buf, len, 10000)) < len) {
                        this->addUnitTestLog(JString::format("ERROR 2 [%d] read %d != %d ", n, len2, len));
                          printf("ERROR2");
                          return false;
                        } 
                        buf[len] = 0;
                        str2 = JString(buf);
                        delete [] buf;
                        buf=NULL;


                        if (!str.equals(str2)) {
                                printf("************  %d != %d  [%d]  Count: %d  ************\n", str.length(), str2.length(), con->charBufferCount, n);
                                this->addUnitTestLog(JString::format("Not equal", n));
                        //      wait(1000);
                                con->disconnectNow();
                                delete(con);
                                return false;
                        }
                        //        printf("!"); fflush(stdout);

                        //              printf("w3\b\b"); fflush(stdout);
                        // printf("Client: %6d [%4d]\n", len, (kk*50)+n);

                }

                now = JTime();
                printf(" Round trip for %d chars: %.3f ms\n", str.length(), ((double)(now-t)/n));
        }

        #if defined(_WIN32_WCE)
                maxcount = 1;
        #endif


        delete(con);
        con = new JSocket("localhost", portnum, "");
        if (!con->connectNow()) {
                this->addUnitTestLog("Socket could not connect 2...");
                return false;
        }

        printf("O\b"); fflush(stdout);


//      try {
                str += "0123456789";
                t = JTime();
                for (n = 0; n < maxcount; n++) {

                        printf("O.\b\b"); fflush(stdout);
        //              printf("Running %d\n", n);
                        
                        if (!con->isConnected()) {
                                printf("************  No longer connected!!!  ************\n");
                                this->addUnitTestLog(JString::format("No longer 2 %d", n));
                                return false;
                        }
                        
                        if (con->writeln(str) <= 0) {
                                printf("************  Unable to write!!!  ************\n");
                                this->addUnitTestLog(JString::format("unable to write 2 %d", n));
                                con->disconnectNow();
                                delete(con);
                        //      wait(1000);
                                return false;
                        }

        //              wait(1000000);

                        printf("Ox\b\b"); fflush(stdout);
                        str2 = con->readln(5000);
                        printf("Oo\b\b"); fflush(stdout);

                        if (!str.equals(str2)) {
                                printf("************  %d != %d  [%d]  Count: %d  ************\n", str.length(), str2.length(), con->charBufferCount, n);
                                this->addUnitTestLog(JString::format("not equal 2 %d", n));
                        //      wait(1000);
                                con->disconnectNow();
                                delete(con);
                                return false;
                        }

        //              con->disconnectNow();
                        delete(con);


        //              wait(100);
                        con = new JSocket("localhost", portnum, "");
                        if (!con->connectNow()) {
                                this->addUnitTestLog("Socket could not connect 3...");
                                return false;
                        }
                        printf("OO\b\b"); fflush(stdout);
                }
//      } catch(...) {
//              this->addUnitTestLog(JString::format("Exception during 2 %d", n));
//              return false;
//      }

        
        for (n = 0; n < 5; n++) {

//              printf("Running %d - length: %d\n", n, str.length());

                printf("OO.\b\b\b"); fflush(stdout);
                t = JTime();
                if (!con->isConnected()) {
                        printf("************  No longer connected!!!  ************\n");
                        this->addUnitTestLog(JString::format("No longer 3 %d", n));
                        return false;
                }
                
                if (con->writeln(str) <= 0) {
                        printf("************  Unable to write!!!  ************\n");
                        this->addUnitTestLog(JString::format("unable to write 3 %d", n));
                        con->disconnectNow();
                        delete(con);
                        wait(1000);
                        return false;
                }
                hh[n] = JTime() - t;

                wait(100);

                t = JTime();
                printf("OOo\b\b\b"); fflush(stdout);
                str2 = con->readln(10000);
                h[n] = JTime() - t;

                if (!str.equals(str2)) {
//              if (str.length() != str2.length()) {
                        printf("************  %d != %d  [%d]  JTime: %d  ************\n", str.length(), str2.length(), con->charBufferCount, n);
                        this->addUnitTestLog(JString::format("not equal 3 %d", n));
                        wait(1000);
                        con->disconnectNow();
                        delete(con);
                        return false;
                }
//              printf("%d:   Length: %d   JTime  write: %d   read: %d\n", n, str.length(), hh[n], h[n]);
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
/*              str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
                str += "012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789";
*/
        }
        printf("OOO\b\b\b"); fflush(stdout);

        con->disconnectNow();
        delete(con);

        int tt = 0;
        for (n = 0; n < TESTMAX; n++) tt += h[n];
        


        shouldContinue = false;

        wait(100);

        return true;
}









ConnectionProfile::ConnectionProfile(JString profilename) {
        name = profilename;
        speedUploadBps = 0;
        speedDownloadBps = 0;
        avgUploadBps = 0;
        avgDownloadBps = 0;
        maxAvgUploadBps = 0;
        maxAvgDownloadBps = 0;
        totalUpload = 0;
        totalDownload = 0;
        totalUploadCount = 0;
        totalDownloadCount = 0;
        maxConnectionHistory = 10;
        isDirectlyConnected = false;
}

ConnectionProfile::ConnectionProfile(const ConnectionProfile& profile) {
        this->name = profile.name;
        this->speedUploadBps = profile.speedUploadBps;
        this->speedDownloadBps = profile.speedDownloadBps;
        this->avgUploadBps = profile.avgUploadBps;
        this->avgDownloadBps = profile.avgDownloadBps;
        this->maxAvgUploadBps = profile.maxAvgUploadBps;
        this->maxAvgDownloadBps = profile.maxAvgDownloadBps;
        this->totalUpload = profile.totalUpload;
        this->totalDownload = profile.totalDownload;
        this->totalUploadCount = profile.totalUploadCount;
        this->totalDownloadCount = profile.totalDownloadCount;
        this->uploadHistory = profile.uploadHistory;
        this->downloadHistory = profile.downloadHistory;
}

const ConnectionProfile& ConnectionProfile::operator = (const ConnectionProfile& profile) {
        this->name = profile.name;
        this->speedUploadBps = profile.speedUploadBps;
        this->speedDownloadBps = profile.speedDownloadBps;
        this->avgUploadBps = profile.avgUploadBps;
        this->avgDownloadBps = profile.avgDownloadBps;
        this->maxAvgUploadBps = profile.maxAvgUploadBps;
        this->maxAvgDownloadBps = profile.maxAvgDownloadBps;
        this->totalUpload = profile.totalUpload;
        this->totalDownload = profile.totalDownload;
        this->totalUploadCount = profile.totalUploadCount;
        this->totalDownloadCount = profile.totalDownloadCount;
        this->uploadHistory = profile.uploadHistory;
        this->downloadHistory = profile.downloadHistory;
        return *this;
}


ConnectionProfile::ConnectionProfile(XMLNode* node) {
        speedUploadBps = 0;
        speedDownloadBps = 0;
        avgUploadBps = 0;
        avgDownloadBps = 0;
        maxAvgUploadBps = 0;
        maxAvgDownloadBps = 0;
        totalUpload = 0;
        totalDownload = 0;
        totalUploadCount = 0;
        totalDownloadCount = 0;
        maxConnectionHistory = 10;
        isDirectlyConnected = false;
        if (!fromXML(node)) {}
}

Object* ConnectionProfile::clone() const {
        ConnectionProfile* profile = new ConnectionProfile();
//      *profile = *this;
        profile->name = this->name;
        profile->speedUploadBps = this->speedUploadBps;
        profile->speedDownloadBps = this->speedDownloadBps;
        profile->avgUploadBps = this->avgUploadBps;
        profile->avgDownloadBps = this->avgDownloadBps;
        profile->maxAvgUploadBps = this->maxAvgUploadBps;
        profile->maxAvgDownloadBps = this->maxAvgDownloadBps;
        profile->totalUpload = this->totalUpload;
        profile->totalDownload = this->totalDownload;
        profile->totalUploadCount = this->totalUploadCount;
        profile->totalDownloadCount = this->totalDownloadCount;
//      profile->uploadHistory = this->uploadHistory;
//      profile->downloadHistory = this->downloadHistory;
        return profile;
}

bool ConnectionProfile::equals(const Object* obj) const {
        return (this->name.equalsIgnoreCase(((ConnectionProfile*)obj)->name));
}

bool ConnectionProfile::fromXML(XMLNode* node) {
        if (node == NULL)
                return false;

        if (!node->getTag().equalsIgnoreCase("connectionprofile"))
                return false;

        name = node->getAttribute("name");
        speedUploadBps = node->getAttribute("speeduploadbps").toLong();
        speedDownloadBps = node->getAttribute("speeddownloadbps").toLong();
        avgUploadBps = node->getAttribute("avguploadbps").toLong();
        avgDownloadBps = node->getAttribute("avgdownloadbps").toLong();
        maxAvgUploadBps = node->getAttribute("maxavguploadbps").toLong();
        maxAvgDownloadBps = node->getAttribute("maxavgdownloadbps").toLong();
        totalUpload = node->getAttribute("totalupload").toDouble();
        totalDownload = node->getAttribute("totaldownload").toDouble();
        totalUploadCount = node->getAttribute("totaluploadcount").toLong();
        totalDownloadCount = node->getAttribute("totaldownloadcount").toLong();

        return true;
}

JString ConnectionProfile::toXML() {
        JString up = JString(totalUpload);
        JString down = JString(totalDownload);
        if (isDirectlyConnected)
                return JString::format("<connectionprofile name=\"%s\" speeduploadbps=\"%ld\" speeddownloadbps=\"%ld\" avguploadbps=\"%ld\" avgdownloadbps=\"%ld\" maxavguploadbps=\"%ld\" maxavgdownloadbps=\"%ld\"  totalupload=\"%s\" totaldownload=\"%s\"  totaluploadcount=\"%ld\" totaldownloadcount=\"%ld\" maxhistory=\"%d\" direct=\"yes\" />",
                        (char*) name.xmlStringEncode(), speedUploadBps, speedDownloadBps, avgUploadBps, avgDownloadBps, maxAvgUploadBps, maxAvgDownloadBps, (char*) up, (char*) down, totalUploadCount, totalDownloadCount, maxConnectionHistory);
        else
                return JString::format("<connectionprofile name=\"%s\" speeduploadbps=\"%ld\" speeddownloadbps=\"%ld\" avguploadbps=\"%ld\" avgdownloadbps=\"%ld\" maxavguploadbps=\"%ld\" maxavgdownloadbps=\"%ld\"  totalupload=\"%s\" totaldownload=\"%s\" totaluploadcount=\"%ld\" totaldownloadcount=\"%ld\" maxhistory=\"%d\" direct=\"no\" />",
                        (char*) name.xmlStringEncode(), speedUploadBps, speedDownloadBps, avgUploadBps, avgDownloadBps, maxAvgUploadBps, maxAvgDownloadBps, (char*) up, (char*) down, totalUploadCount, totalDownloadCount, maxConnectionHistory);
}


bool ConnectionProfile::setSpeed(long upbps, long downbps) {
        speedUploadBps = upbps;
        speedDownloadBps = downbps;
        return true;
}

bool ConnectionProfile::addDataStat(long upbytes, long downbytes, const JTime& time) {
        if (upbytes > 0) {
                totalUploadCount++;
                totalUpload += upbytes;
                uploadHistory.put(time, new JString(upbytes));
                while (uploadHistory.getCount() > maxConnectionHistory) {
                        // printf("@@@ %s\n", (char*) uploadHistory.print()); fflush(stdout);
                        uploadHistory.removeOldest();
                }
        }
        if (downbytes > 0) {
                totalDownloadCount++;
                totalDownload += downbytes;
                downloadHistory.put(time, new JString(downbytes));
                while (downloadHistory.getCount() > maxConnectionHistory) {
                        // printf("### %s\n", (char*) downloadHistory.print()); fflush(stdout);
                        downloadHistory.removeOldest();
                }
        }
        return true;
}

JTime ConnectionProfile::getLastActivity() {
        JTime up = uploadHistory.getLastTime();
        JTime down = downloadHistory.getLastTime();
        if ( (!up.isValid()) && (!down.isValid()) ) {
                JTime res;
                res.setInvalid();
                return res;
        }
        else if (!up.isValid())
                return down;
        else if (!down.isValid())
                return up;
        else {
                if (up - down > 0)
                        return up;
                else
                        return down;
        }
}

long ConnectionProfile::getSpeedUpload() {
        recalc();
        return speedUploadBps;
}

long ConnectionProfile::getSpeedDownload() {
        recalc();
        return speedDownloadBps;
}


long ConnectionProfile::getAvgUpload() {
        recalc();
        return avgUploadBps;
}

long ConnectionProfile::getAvgDownload() {
        recalc();
        return avgDownloadBps;
}


long ConnectionProfile::getMaxAvgUpload() {
        recalc();
        return maxAvgUploadBps;
}

long ConnectionProfile::getMaxAvgDownload() {
        recalc();
        return maxAvgDownloadBps;
}

double ConnectionProfile::getTotalUpload() {
        recalc();
        return totalUpload;
}

double ConnectionProfile::getTotalDownload() {
        recalc();
        return totalDownload;
}

long ConnectionProfile::getTotalUploadCount() {
        return totalUploadCount;
}

long ConnectionProfile::getTotalDownloadCount() {
        return totalDownloadCount;
}

bool ConnectionProfile::recalc() {

        JTime now;
        JTime t;
        int n;
        double totalup = 0;
        double totaldown = 0;

        if (uploadHistory.getCount() > 0) {
                t = uploadHistory.getFirstTime();
                double upduration = now.microDifference(t) / 1000000.0;
                if (upduration > 0) {
                        for (n=0; n<uploadHistory.getCount(); n++)
                                totalup += ((JString*)uploadHistory.get(n))->toLong();
                        avgUploadBps = (long) (totalup / upduration);
                        if (avgUploadBps > maxAvgUploadBps)
                                maxAvgUploadBps = avgUploadBps;
                }
        }
        if (downloadHistory.getCount() > 0) {
                t = downloadHistory.getFirstTime();
                double downduration = now.microDifference(t) / 1000000.0;
                if (downduration > 0) {
                        for (n=0; n<downloadHistory.getCount(); n++)
                                totaldown += ((JString*)downloadHistory.get(n))->toLong();
                        avgDownloadBps = (long) (totaldown / downduration);
                        if (avgDownloadBps > maxAvgDownloadBps)
                                maxAvgDownloadBps = avgDownloadBps;
                }
        }
        return true;
}


JString ConnectionProfile::getSpeedString() {
        return JString::bytifyRates(speedUploadBps, speedDownloadBps);
}

JString ConnectionProfile::getRateString() {
        recalc();
        return JString::bytifyRates(avgUploadBps, avgDownloadBps);
}

JString ConnectionProfile::getMaxRateString() {
        recalc();
        return JString::bytifyRates(maxAvgUploadBps, maxAvgDownloadBps);
}

JString ConnectionProfile::getTotalString() {
        return JString::bytifySizes(totalUpload, totalDownload);
}


JString ConnectionProfile::print() {
        JTime lastAct = getLastActivity();
        
        if (!isDirectlyConnected) {
                return JString::format("Connection Profile: %s\n  Speed:   %s\n  Rate:    %s\n  MaxRate: %s\n  Total:   %s\n",
                        (char*) name,
                        (char*) getSpeedString(),
                        (char*) getRateString(),
                        (char*) getMaxRateString(),
                        (char*) getTotalString());
        }
        else {
                return JString::format("Direct Connection Profile: %s\n  Rate:    %s\n  MaxRate: %s\n  Total:   %s\n",
                        (char*) name,
                        (char*) getRateString(),
                        (char*) getMaxRateString(),
                        (char*) getTotalString());
        }

}

JString ConnectionProfile::toHTML() {
        JTime lastAct = getLastActivity();
        
        if (!isDirectlyConnected) {
                return JString::format("Connection Profile: %s\n<br>&nbsp;&nbsp;Speed:   %s\n<br>&nbsp;&nbsp;Rate:    %s\n<br>&nbsp;&nbsp;MaxRate: %s\n<br>&nbsp;&nbsp;Total:   %s\n<br>",
                        (char*) name,
                        (char*) getSpeedString(),
                        (char*) getRateString(),
                        (char*) getMaxRateString(),
                        (char*) getTotalString());
        }
        else {
                return JString::format("Direct Connection Profile: %s\n<br>&nbsp;&nbsp;Rate:    %s\n<br>&nbsp;&nbsp;MaxRate: %s\n<br>&nbsp;&nbsp;Total:   %s\n<br>",
                        (char*) name,
                        (char*) getRateString(),
                        (char*) getMaxRateString(),
                        (char*) getTotalString());
        }
}







} // namespace cmlabs

---