CoreMain.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

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


// CoreTest.cpp : Defines the entry point for the console application.
//

#include "CoreTest.h"
#include "JTime.h"
#include "DynamicLoader.h"

#include "thirdparty/CVML.h"

#include "Bitmap.h"

// bool runMyTest();

using namespace cmlabs;

void printbits( unsigned int size, unsigned char * bits, int type)
{
        int k=0,i,j;
        for(i=size-1;i>=0;i--) {
                for(j=7;j>=0;j--) 
                        printf("%c",(bits[i] & (1<<j)) ? '1' : '0');
                printf(" ");
        };
        printf("\n");
}

/*
#define TGET_DRGB_FROM_2RGBS(a,b) (((unsigned int)GET_R_FROM_RGBA(a)>>3)<<27) + (((unsigned int)GET_G_FROM_RGBA(a)>>2)<<21) + (((unsigned int)GET_B_FROM_RGBA(a)>>3)<<16) + (((unsigned int)GET_R_FROM_RGBA(b)>>3)<<11) + (((unsigned int)GET_G_FROM_RGBA(b)>>2)<<5) + (((unsigned int)GET_B_FROM_RGBA(b)>>3)<<0)
#define TGET_FIRSTRGB_FROM_DRGB(a) ((unsigned int)((unsigned short)((a>>16)&0xF800)>>8)) + ((unsigned int)((unsigned short)((a>>16)&0xE000)>>13)) + ((unsigned int)((unsigned short)((a>>16)&0x07E0)<<6)) + ((unsigned int)((unsigned short)((a>>16)&0x0700))) + ((unsigned int)((unsigned short)(a>>16)&0x001F)<<19) + (((unsigned int)(unsigned short)(a>>16)&0x001C)<<14)
#define TGET_SECONDRGB_FROM_DRGB(a) ((unsigned int)((unsigned short)(a&0xF800)>>8)) + ((unsigned int)((unsigned short)(a&0xE000)>>13)) + ((unsigned int)((unsigned short)(a&0x07E0)<<6)) + ((unsigned int)((unsigned short)(a&0x0700))) + ((unsigned int)((unsigned short)a&0x001F)<<19) + (((unsigned int)(unsigned short)a&0x001C)<<14)
#define TGET_DRGB_FROM_2RGBS(a,b) (((unsigned int)GET_R_FROM_RGBA(a)>>3)<<27) + (((unsigned int)GET_G_FROM_RGBA(a)>>2)<<21) + (((unsigned int)GET_B_FROM_RGBA(a)>>3)<<16) + (((unsigned int)GET_R_FROM_RGBA(b)>>3)<<11) + (((unsigned int)GET_G_FROM_RGBA(b)>>2)<<5) + (((unsigned int)GET_B_FROM_RGBA(b)>>3)<<0)
#define TGET_FIRSTRGB_FROM_DRGB(a) ((unsigned int)((unsigned short)((a>>16)&0xF800)>>8)) | ((unsigned int)((unsigned short)((a>>16)&0xE000)>>13)) | ((unsigned int)((unsigned short)((a>>16)&0x07E0)<<5)) | ((unsigned int)((unsigned short)((a>>16)&0x0600))>>1) | ((unsigned int)((unsigned short)(a>>16)&0x001F)<<19) | (((unsigned int)(unsigned short)(a>>16)&0x001C)<<14)
#define TGET_SECONDRGB_FROM_DRGB(a) ((unsigned int)((unsigned short)(a&0xF800)>>8)) | ((unsigned int)((unsigned short)(a&0xE000)>>13)) | ((unsigned int)((unsigned short)(a&0x07E0)<<5)) | ((unsigned int)((unsigned short)(a&0x0600))>>1) | ((unsigned int)((unsigned short)a&0x001F)<<19) | (((unsigned int)(unsigned short)a&0x001C)<<14)
#define XGET_FIRSTRGB_FROM_DRGB(a) ((unsigned int)((unsigned short)((a>>16)&0xF800)>>8)) + ((unsigned int)((unsigned short)((a>>16)&0x07E0)<<6)) + ((unsigned int)((unsigned short)(a>>16)&0x001F)<<19)
#define XGET_SECONDRGB_FROM_DRGB(a) ((unsigned int)((unsigned short)(a&0xF800)>>8)) + ((unsigned int)((unsigned short)(a&0x07E0)<<6)) + ((unsigned int)((unsigned short)a&0x001F)<<19)
*/

#ifdef WIN32
        #if !defined(_WIN32_WCE)
        #ifdef _DEBUG
                #define _CRTDBG_MAP_ALLOC
                #define MY_NEW new( _NORMAL_BLOCK, __FILE__, __LINE__) 
                #define new MY_NEW 
        #endif
        #endif
#endif

int main(int argc, char* argv[])
{
#ifdef WIN32
//      _CrtSetDbgFlag( _CRTDBG_ALLOC_MEM_DF | _CRTDBG_LEAK_CHECK_DF );
#endif

/*      DataSample* sample = NULL;
        JString curSource = "../../Video/Frame000.bmp";

        if (!JFile::doesAFileExist(curSource)) {
                printf("File does not exist!\n");
                exit(0);
        }
        sample = new Bitmap(curSource);
        if (sample->getDataSize() > 0) {
                printf("File read OK!\n");
                exit(0);
        }
        else {
                printf("File could not be read!\n");
                exit(0);
        }
*/
/*
        JString sss = "company=nova system=Viamão date=2006-07-03";
        Dictionary dict = sss.splitCommandLine();
        printf("%s\n", (char*) dict.printListLine("\n"));

        Collection coll = sss.splitOnWhiteSpaces();
        printf("%s\n", (char*) coll.printListLine("\n"));

        dict = sss.split(" ","=");
        printf("%s\n", (char*) dict.printListLine("\n"));
*/
/*
        RetrieveSpec* spec = new RetrieveSpec();
        spec->content = "*id=\"4\"*";
        JString x = spec->toXML();

        RetrieveSpec* spec2 = new RetrieveSpec();
        spec2->fromXML(x);
*/
        int eee = 0;

/*      JTime t1;
        JTime t2;

        JString s1;
        int kkk = 0;
        
        while (true) {
                t1 = JTime();
                s1 = JString::format("Time: %s\nGMT:  %s\n%d %d %d %d", (char*) t1.print(), (char*) t1.toHTTP(), t1.timebuffer.time, t1.timebuffer.millitm, (int)t1.timebuffer.timezone, (int)t1.timebuffer.dstflag);
                printf("%s\n", (char*) s1);
                getchar();
        }
*/
/*
        unsigned int a = 0x00998844;
        unsigned int b = 0x00448899;

        unsigned int c = TGET_DRGB_FROM_2RGBS(a, b);

        unsigned int aa = TGET_FIRSTRGB_FROM_DRGB(c);
        unsigned int bb = TGET_SECONDRGB_FROM_DRGB(c);

        unsigned int aaa = XGET_FIRSTRGB_FROM_DRGB(c);
        unsigned int bbb = XGET_SECONDRGB_FROM_DRGB(c);

        printf("%X\t", a);
        printbits(4, (unsigned char*) &a, 0);
        printf("%X\t", aa);
        printbits(4, (unsigned char*) &aa, 0);
        printf("%X\t", aaa);
        printbits(4, (unsigned char*) &aaa, 0);
        printf("%X\t", b);
        printbits(4, (unsigned char*) &b, 0);
        printf("%X\t", bb);
        printbits(4, (unsigned char*) &bb, 0);
        printf("%X\t", bbb);
        printbits(4, (unsigned char*) &bbb, 0);

        printf("\n%X\t", c);
        printbits(4, (unsigned char*) &c, 0);
*/
//      StopWatch watch;
//      watch.start();
//      Bitmap* bm = new Bitmap("t:\\map.bmp");
//      watch.setMark("Loaded bitmap");
//      Bitmap* bm2 = bm->getResizedCopy(2);
//      watch.setMark("Resized bitmap");
//      Bitmap* bm2 = new Bitmap(u);
//      bm2->saveToFile("t:\\testout.bmp");
//      delete(bm);
//      delete(bm2);
//      watch.stop();
//      delete(u);
//      printf("%s\n", (char*) watch.printDetails());
//      exit(0);

        JString arg1, arg2;
        if (argc > 1)
                arg1 = JString(argv[1]);
        if (argc > 2)
                arg2 = JString(argv[2]);

        MediaTestServer* mediaTestServer;
        int mediaTestServerPort = 8765;

        if (arg1.equalsIgnoreCase("sysinfo")) {
                SysInfo sysInfo = Object::getSystemInfo();
                printf("\n\n%s\n\n", (char*) sysInfo.print());
                exit(0);
        }
        else if (arg1.equalsIgnoreCase("netinfo")) {
                JSocket* con = new JSocket("localhost", 25471, "");
                Collection addresses = con->getLocalIPAddresses();
                printf("NetInfo:\n\nFound %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());
                exit(0);
        }
        else if (arg1.equalsIgnoreCase("net")) {
                testSockets(new SocketTester(10500));
                testNetwork(new Network(), 10500+100);
                testMediaServer(new MediaServer("Test Media Server"), 10500+200);
                exit(0);
        }
        else if (arg1.equalsIgnoreCase("media")) {
                testMediaServer(new MediaServer("Test Media Server"), 10500+200);
                exit(0);
        }
        else if (arg1.equalsIgnoreCase("thread")) {
                JThread* myThread = new JThread(false);
                myThread->priorityTest();
                delete(myThread);
                exit(0);
        }
        else if (arg1.equalsIgnoreCase("mediaserver")) {
                // If this is a test over time
                if (arg2.equalsIgnoreCase("time")) {
                        mediaTestServer = createMediaTestServer(mediaTestServerPort, "", 1, true);
                }
                else {
                        // arg2 contains number of connections to expect before starting
                        int count = arg2.toInt();
                        if (count <= 0) count = 1;
                        mediaTestServer = createMediaTestServer(mediaTestServerPort, "", count, false);
                }
                if (mediaTestServer == NULL) {
                        printf("Could not initiate MediaTestServer...\n");
                        exit(0);
                }
                mediaTestServer->start();
                while (!mediaTestServer->isTestComplete())
                        Object::wait(1000);
                exit(0);
        }
        else if (arg1.equalsIgnoreCase("mediaclient")) {
                // Now start the local test client...
                runMediaTestClient("", arg2, mediaTestServerPort);
                exit(0);
        }
        else if (arg1.equalsIgnoreCase("medialocal")) {
                // If this is a test over time
                if (arg2.equalsIgnoreCase("time")) {
                        mediaTestServer = createMediaTestServer(mediaTestServerPort, "", 1, true);
                }
                else {
                        // arg2 contains number of connections to expect before starting
                        int count = arg2.toInt();
                        if (count <= 0) count = 1;
                        mediaTestServer = createMediaTestServer(mediaTestServerPort, "", count, false);
                }
                if (mediaTestServer == NULL) {
                        printf("Could not initiate MediaTestServer...\n");
                        exit(0);
                }
                mediaTestServer->start();

                // Now start the local test client...
                runMediaTestClient("", mediaTestServer->getLocation());
                exit(0);
        }

        int systemTestPort = 10500;
        JString str;

        int count = 1;
        if (argc > 1) {
                str = JString(argv[1]);
                count = str.toInt();
        }

        JString testlib;
        if (argc > 2) {
                testlib = JString(argv[2]);
        }

        printf("\nRunning tests %d times\n\n", count);
        
        for (int n=1; n<=count; n++) {
                runTests(systemTestPort+(n*10), testlib);
        }

//      printf("\n\nPress any key to exit...");
//      getchar();
        printf("\n\n");
        return 0;
}









/*

class MyRec : public TCPReceiver {
public: 
        MyRec() {}
        void tcpInput(JString str, NetworkConnection* con) {}

        Message* netObjectReceive(Message* msg, NetworkConnection* con) {
                Message* hmsg = (Message*) msg->clone();
                delete(msg);
                return hmsg;
        }

        JString getName() {return "Test";}
};



bool runMyTest() {

        bool shouldContinue = true;
        MyRec* rec = new MyRec();
        NetworkConnection* con = new NetworkConnection("localhost", 10000, new NetMessageProtocol(), NULL);

        if (con->isConnected()) {
                printf("Connected and ready\n"); fflush(stdout);
        }
        else {
                printf("Never connected...\n"); fflush(stdout);
                shouldContinue = false;
        }

        while (shouldContinue) {
                shouldContinue = con->isConnected();
                con->wait(500);
                printf("."); fflush(stdout);
        }

        printf("Not connected anymore\n"); fflush(stdout);
        con->wait(10000);
        return true;
}
*/

---