X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Fold%2Ftestmpi.cc;fp=src%2Fceph%2Fsrc%2Ftest%2Fold%2Ftestmpi.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=68969b5b08881640279bf4df16ea836b7dc81535;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/test/old/testmpi.cc b/src/ceph/src/test/old/testmpi.cc deleted file mode 100644 index 68969b5..0000000 --- a/src/ceph/src/test/old/testmpi.cc +++ /dev/null @@ -1,53 +0,0 @@ -#include -#include -#include -using namespace std; - -#include "common/config.h" -#include "messages/MPing.h" -#include "common/Mutex.h" - -#include "msg/MPIMessenger.h" - -class Pinger : public Dispatcher { -public: - Messenger *messenger; - explicit Pinger(Messenger *m) : messenger(m) { - m->set_dispatcher(this); - } - void dispatch(Message *m) { - //dout(1) << "got incoming " << m << endl; - delete m; - - } -}; - -int main(int argc, char **argv) { - int num = 1000; - - int myrank = mpimessenger_init(argc, argv); - int world = mpimessenger_world(); - - Pinger *p = new Pinger( new MPIMessenger(myrank) ); - - mpimessenger_start(); - - //while (1) { - for (int i=0; i<10000; i++) { - - // ping random nodes - int d = rand() % world; - if (d != myrank) { - //cout << "sending " << i << " to " << d << endl; - p->messenger->send_message(new MPing(), d); - } - - } - - - //cout << "shutting down" << endl; - //p->messenger->shutdown(); - - mpimessenger_wait(); - mpimessenger_shutdown(); // shutdown MPI -}