this is the function that performs the insert and delete operations
spontaneously and every second it will put a console message about the
amount of operations in that second ........

if run as stand alone(10.0.2.55 application node) with only one node up i
get about 70,000 operations per second, mean while it is running if start
another node in just ignite with the configurations (10.0.2.56) then the
transactions rate will drop to max of 7000(at the starting it will be very
less, i understand that is because of data balancing between the nodes.),

void put(Cache<double , double>& cache, int lTime, vector<double>  &Stat,
key_t mQueId)
{

        double counter = 0;
        double lTotalInsertionsCount = 0;
        double lStartime = time(NULL);

        while(lStartime == time(NULL));
        double lEndTime = time(NULL) + lTime;
        double lCurrentSec = time(NULL);
        double looptime;
        double lDeleteCounter = 0;
        double lDeleteStartCounter = 0;

        if (lEvenFlag  != 1)
        {
                lTotalInsertionsCount = 1;
                lDeleteStartCounter = 1;
        }

        while(lEndTime > time(NULL))
        {
                if((lCurrentSec + 1) == (looptime = time(NULL)))
                {
                        lCurrentSec = time(NULL);
                        //                      Stat.push_back(counter);
                        //                      cout << "Time : " <<
time(NULL) << ", Cache size : " << cache.LocalSize() << ", Contents Wrote :
" << counter << endl;
                        cout << "Time : "<< looptime << "No Of Records " <<
counter << endl;
                        counter = 0;
                }

                cache.Put(lTotalInsertionsCount,counter++);

                if ( 0 != msgsnd (mQueId, &lTotalInsertionsCount,
sizeof(lTotalInsertionsCount), IPC_NOWAIT))
                {
                        cout << "Que write FAILED!!!! for : " <<
lTotalInsertionsCount << endl;
                }

                lTotalInsertionsCount+=2;
                lDeleteCounter++;
                if (lDeleteCounter > 50000)
                {
                        cache.Remove(lDeleteStartCounter);
                        lDeleteStartCounter+=2;
                        counter++;
                }
        }
        cout << endl;
        cout << "**************************************" << endl;
        //       cout << "-> No of records : " << counter << " for given "
<< lTime << " seconds inserted." << endl;
        cout << "-> Total No of insertions : " << lTotalInsertionsCount/2 <<
endl;
        cout << "**************************************" << endl;
        cout << endl;
}




--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/How-to-compile-C-code-tp13989p14115.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

Reply via email to