mirror of
https://github.com/QuantumPackage/qp2.git
synced 2024-08-29 04:12:00 +02:00
Fixed distributed davidson
This commit is contained in:
parent
3c9944225c
commit
1691c74539
@ -270,10 +270,12 @@ subroutine davidson_push_results_async_recv(zmq_socket_push,sending)
|
|||||||
! Activate is zmq_socket_push is a REQ
|
! Activate is zmq_socket_push is a REQ
|
||||||
IRP_IF ZMQ_PUSH
|
IRP_IF ZMQ_PUSH
|
||||||
IRP_ELSE
|
IRP_ELSE
|
||||||
character*(2) :: ok
|
character*(256) :: ok
|
||||||
rc = f77_zmq_recv( zmq_socket_push, ok, 2, 0)
|
rc = f77_zmq_recv( zmq_socket_push, ok, 2, 0)
|
||||||
if ((rc /= 2).and.(ok(1:2)/='ok')) then
|
if ((rc /= 2).and.(ok(1:2)/='ok')) then
|
||||||
print *, irp_here, ': f77_zmq_recv( zmq_socket_push, ok, 2, 0)'
|
print *, irp_here, ': f77_zmq_recv( zmq_socket_push, ok, 2, 0)'
|
||||||
|
print *, rc
|
||||||
|
print *, ok
|
||||||
stop -1
|
stop -1
|
||||||
endif
|
endif
|
||||||
IRP_ENDIF
|
IRP_ENDIF
|
||||||
|
@ -193,7 +193,7 @@ subroutine davidson_csf_push_results(zmq_socket_push, v_t, imin, imax, task_id)
|
|||||||
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
||||||
if(rc /= 4) stop 'davidson_csf_push_results failed to push imax'
|
if(rc /= 4) stop 'davidson_csf_push_results failed to push imax'
|
||||||
|
|
||||||
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, ZMQ_SNDMORE)
|
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, 0)
|
||||||
if(rc8 /= 8_8*sz) stop 'davidson_csf_push_results failed to push vt'
|
if(rc8 /= 8_8*sz) stop 'davidson_csf_push_results failed to push vt'
|
||||||
|
|
||||||
! Activate is zmq_socket_push is a REQ
|
! Activate is zmq_socket_push is a REQ
|
||||||
@ -240,7 +240,7 @@ subroutine davidson_csf_push_results_async_send(zmq_socket_push, v_t, imin, imax
|
|||||||
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
||||||
if(rc /= 4) stop 'davidson_csf_push_results failed to push imax'
|
if(rc /= 4) stop 'davidson_csf_push_results failed to push imax'
|
||||||
|
|
||||||
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, ZMQ_SNDMORE)
|
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, 0)
|
||||||
if(rc8 /= 8_8*sz) stop 'davidson_csf_push_results failed to push vt'
|
if(rc8 /= 8_8*sz) stop 'davidson_csf_push_results failed to push vt'
|
||||||
|
|
||||||
|
|
||||||
|
@ -193,7 +193,7 @@ subroutine davidson_nos2_push_results(zmq_socket_push, v_t, imin, imax, task_id)
|
|||||||
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
||||||
if(rc /= 4) stop 'davidson_nos2_push_results failed to push imax'
|
if(rc /= 4) stop 'davidson_nos2_push_results failed to push imax'
|
||||||
|
|
||||||
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, ZMQ_SNDMORE)
|
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, 0)
|
||||||
if(rc8 /= 8_8*sz) stop 'davidson_nos2_push_results failed to push vt'
|
if(rc8 /= 8_8*sz) stop 'davidson_nos2_push_results failed to push vt'
|
||||||
|
|
||||||
! Activate is zmq_socket_push is a REQ
|
! Activate is zmq_socket_push is a REQ
|
||||||
@ -240,7 +240,7 @@ subroutine davidson_nos2_push_results_async_send(zmq_socket_push, v_t, imin, ima
|
|||||||
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
rc = f77_zmq_send( zmq_socket_push, imax, 4, ZMQ_SNDMORE)
|
||||||
if(rc /= 4) stop 'davidson_nos2_push_results failed to push imax'
|
if(rc /= 4) stop 'davidson_nos2_push_results failed to push imax'
|
||||||
|
|
||||||
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, ZMQ_SNDMORE)
|
rc8 = f77_zmq_send8( zmq_socket_push, v_t(1,imin), 8_8*sz, 0)
|
||||||
if(rc8 /= 8_8*sz) stop 'davidson_nos2_push_results failed to push vt'
|
if(rc8 /= 8_8*sz) stop 'davidson_nos2_push_results failed to push vt'
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user