Can you also share your configuration file?
By the way, using double as a key type seems to be a *really*
bad idea. It should not affect performance, but may cause
a lot of issues.
Best Regards,
Igor
On Tue, Jun 27, 2017 at 4:46 PM, Rahul.S <rahu...@tayana.in> wrote:
> 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.
>
