LCPQ/quantum_package
10
0
Fork 0
mirror of https://github.com/LCPQ/quantum_package synced 2024-12-25 22:03:51 +01:00
Code Issues Releases Wiki Activity

debug in abort

Browse Source
This commit is contained in:
Anthony Scemama 2018-03-20 08:52:46 +01:00
parent 205d786c3a
commit b3bade7c9f
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -761,6 +761,7 @@ integer function add_task_to_taskserver(zmq_to_qp_run_socket,task)
rc = f77_zmq_recv(zmq_to_qp_run_socket, message, sze-1, 0) rc = f77_zmq_recv(zmq_to_qp_run_socket, message, sze-1, 0)
if (message(1:rc) /= 'ok') then if (message(1:rc) /= 'ok') then
print *, 'add_task_to_taskserver: '//trim(message(1:rc))
add_task_to_taskserver = -1 add_task_to_taskserver = -1
return return
endif endif
@ -790,6 +791,7 @@ integer function zmq_abort(zmq_to_qp_run_socket)
rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 510, 0) rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 510, 0)
if (trim(message(1:rc)) /= 'ok') then if (trim(message(1:rc)) /= 'ok') then
print *, 'zmq_abort: '//trim(message(1:rc))
zmq_abort = -1 zmq_abort = -1
return return
endif endif
@ -821,6 +823,7 @@ integer function task_done_to_taskserver(zmq_to_qp_run_socket, worker_id, task_i
rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 510, 0) rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 510, 0)
if (trim(message(1:rc)) /= 'ok') then if (trim(message(1:rc)) /= 'ok') then
print *, 'task_done_to_taskserver: '//trim(message(1:rc))
task_done_to_taskserver = -1 task_done_to_taskserver = -1
return return
endif endif
@ -862,6 +865,7 @@ integer function tasks_done_to_taskserver(zmq_to_qp_run_socket, worker_id, task_
rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 64, 0) rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 64, 0)
if (trim(message(1:rc)) /= 'ok') then if (trim(message(1:rc)) /= 'ok') then
print *, 'tasks_done_to_taskserver: '//trim(message(1:rc))
tasks_done_to_taskserver = -1 tasks_done_to_taskserver = -1
endif endif
deallocate(message) deallocate(message)