G4DAECHROMA transport testing ================================ Same Node Success ------------------- Client sends workload to broker ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ :: [blyth@belle7 ~]$ czrt-nsend ZMQRoot::ZMQRoot envvar [CHROMA_CLIENT_CONFIG] config [tcp://127.0.0.1:5001] ChromaPhotonList::Print UID [0] [6] ZMQRoot::SendObject sent bytes: 457 ZMQRoot::ReceiveObject received bytes: 457 ZMQRoot::ReceiveObject reading TObject from the TMessage ZMQRoot::ReceiveObject returning TObject ReceiveObject ChromaPhotonList::Print UID [0] [6] ChromaPhotonList::Print UID [0] [6] ChromaPhotonList::Details [6] index 0 pos (1,1,1) mom (2,2,2) pol (3,3,3) _t 0 _wavelength 100 _pmtid 101 index 1 pos (1,1,1) mom (2,2,2) pol (3,3,3) _t 0 _wavelength 100 _pmtid 101 index 2 pos (1,1,1) mom (2,2,2) pol (3,3,3) _t 0 _wavelength 100 _pmtid 101 index 3 pos (1,1,1) mom (2,2,2) pol (3,3,3) _t 0 _wavelength 100 _pmtid 101 index 4 pos (1,1,1) mom (2,2,2) pol (3,3,3) _t 0 _wavelength 100 _pmtid 101 index 5 pos (1,1,1) mom (2,2,2) pol (3,3,3) _t 0 _wavelength 100 _pmtid 101 [blyth@belle7 ~]$ Worker polls the broker for smth to do ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ :: [blyth@belle7 g4daeview]$ g4daechroma.sh ZMQ_BROKER_URL_FRONTEND=tcp://203.64.184.126:5001 ZMQ_BROKER_URL_BACKEND=tcp://203.64.184.126:5002 ZMQROOT_LIB=/data1/env/local/dyb/NuWa-trunk/dybgaudi/InstallArea/i686-slc5-gcc41-dbg/lib/libZMQRoot.so ZMQROOT_LIBRARIES=ZMQRoot ZMQROOT_PREFIX=/data1/env/local/env/zmqroot CHROMAPHOTONLIST_PREFIX=/data1/env/local/env/chroma/ChromaPhotonList CHROMA_GEANT4_SDIR=/src/geant4.9.5.p01 CHROMAPHOTONLIST_LIB=/data1/env/local/dyb/NuWa-trunk/dybgaudi/InstallArea/i686-slc5-gcc41-dbg/lib/libChroma.so Warning in : duplicate entry =vector.dll> for level 0; ignored Warning in : duplicate entry =vector.dll> for level 0; ignored Warning in : duplicate entry =vector.dll> for level 0; ignored main 2014-09-19 13:56:37,296 env.geant4.geometry.collada.g4daeview.g4daechroma:16 polling: DAEDirectResponder connect tcp://203.64.184.126:5002 2014-09-19 13:56:37,297 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 0 2014-09-19 13:56:38,397 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 1 2014-09-19 13:56:39,498 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 2 2014-09-19 13:56:40,599 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 3 2014-09-19 13:56:41,700 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 4 2014-09-19 13:56:42,801 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 5 2014-09-19 13:56:43,902 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 6 2014-09-19 13:56:45,003 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 7 2014-09-19 13:56:46,104 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 8 2014-09-19 13:56:47,205 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 9 2014-09-19 13:56:47,205 env.zmqroot.responder:131 recv_object req of length 457 2014-09-19 13:56:47,391 env.geant4.geometry.collada.g4daeview.daedirectresponder:38 responder reply [6L, 6L, 6L, 6L, 6L, 6L, 6L, 6L, 6L, 6L, 6L, 6L] {'pmtid': 101, 'pz': 2.0, 'px': 2.0, 'py': 2.0, 'polz': 3.0, 'poly': 3.0, 'polx': 3.0, 't': 0.0, 'x': 1.0, 'y': 1.0, 'wavelength': 100.0, 'z': 1.0} {'pmtid': 101, 'pz': 2.0, 'px': 2.0, 'py': 2.0, 'polz': 3.0, 'poly': 3.0, 'polx': 3.0, 't': 0.0, 'x': 1.0, 'y': 1.0, 'wavelength': 100.0, 'z': 1.0} {'pmtid': 101, 'pz': 2.0, 'px': 2.0, 'py': 2.0, 'polz': 3.0, 'poly': 3.0, 'polx': 3.0, 't': 0.0, 'x': 1.0, 'y': 1.0, 'wavelength': 100.0, 'z': 1.0} {'pmtid': 101, 'pz': 2.0, 'px': 2.0, 'py': 2.0, 'polz': 3.0, 'poly': 3.0, 'polx': 3.0, 't': 0.0, 'x': 1.0, 'y': 1.0, 'wavelength': 100.0, 'z': 1.0} {'pmtid': 101, 'pz': 2.0, 'px': 2.0, 'py': 2.0, 'polz': 3.0, 'poly': 3.0, 'polx': 3.0, 't': 0.0, 'x': 1.0, 'y': 1.0, 'wavelength': 100.0, 'z': 1.0} {'pmtid': 101, 'pz': 2.0, 'px': 2.0, 'py': 2.0, 'polz': 3.0, 'poly': 3.0, 'polx': 3.0, 't': 0.0, 'x': 1.0, 'y': 1.0, 'wavelength': 100.0, 'z': 1.0} 2014-09-19 13:56:47,931 env.zmqroot.responder:147 send_object rep of length 457 2014-09-19 13:56:48,931 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 10 2014-09-19 13:56:50,031 env.geant4.geometry.collada.g4daeview.g4daechroma:19 polling 11 Normal Topology Success, via tunneling both client and worker ----------------------------------------------------------------- * broker on N, `czmq_broker` running all the time under supervisord * worker on D, interactively started after which polls every second:: delta:~ blyth$ g4daechroma.sh --zmqtunnelnode=N * client on D or N, interactively sends CPL at each invokation:: delta:~ blyth$ czrt.sh --zmqtunnelnode=N [blyth@belle7 ~]$ czrt-nsend