LCPQ/quantum_package
10
0
Fork 0
mirror of https://github.com/LCPQ/quantum_package synced 2025-01-10 21:18:29 +01:00
Code Issues Releases Wiki Activity

Terminating ZMQ context when parallel calculation is finished

Browse Source
This commit is contained in:
Anthony Scemama 2016-02-22 19:41:41 +01:00
parent f71fa7ff6b
commit d49dcb7d8f
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/ZMQ/utils.irp.f
View File

@ -12,7 +12,7 @@ BEGIN_PROVIDER [ integer(ZMQ_PTR), zmq_context ]
! Context for the ZeroMQ library ! Context for the ZeroMQ library
END_DOC END_DOC
call omp_init_lock(zmq_lock) call omp_init_lock(zmq_lock)
zmq_context = f77_zmq_ctx_new () zmq_context = 0_ZMQ_PTR
END_PROVIDER END_PROVIDER
@ -421,7 +421,8 @@ subroutine new_parallel_job(zmq_to_qp_run_socket,name_in)
integer :: rc, sze integer :: rc, sze
integer(ZMQ_PTR),external :: new_zmq_to_qp_run_socket integer(ZMQ_PTR),external :: new_zmq_to_qp_run_socket
integer(ZMQ_PTR), intent(out) :: zmq_to_qp_run_socket integer(ZMQ_PTR), intent(out) :: zmq_to_qp_run_socket
zmq_context = f77_zmq_ctx_new ()
zmq_to_qp_run_socket = new_zmq_to_qp_run_socket() zmq_to_qp_run_socket = new_zmq_to_qp_run_socket()
name = name_in name = name_in
sze = len(trim(name)) sze = len(trim(name))
@ -474,6 +475,11 @@ subroutine end_parallel_job(zmq_to_qp_run_socket,name_in)
zmq_state = 'No_state' zmq_state = 'No_state'
call end_zmq_to_qp_run_socket(zmq_to_qp_run_socket) call end_zmq_to_qp_run_socket(zmq_to_qp_run_socket)
rc = f77_zmq_ctx_term(zmq_context)
if (rc /= 0) then
print *, 'Unable to terminate ZMQ context'
stop 'error'
endif
end end
subroutine connect_to_taskserver(zmq_to_qp_run_socket,worker_id,thread) subroutine connect_to_taskserver(zmq_to_qp_run_socket,worker_id,thread)