mirror of
https://github.com/QuantumPackage/qp2.git
synced 2024-12-25 13:03:28 +01:00
Trying to fix segfault
This commit is contained in:
parent
baeb9765d9
commit
b697042b40
@ -913,7 +913,7 @@ integer function get_task_from_taskserver(zmq_to_qp_run_socket,worker_id,task_id
|
|||||||
|
|
||||||
task_id = 0
|
task_id = 0
|
||||||
message = repeat(' ',1024)
|
message = repeat(' ',1024)
|
||||||
rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 1024, 0)
|
rc = f77_zmq_recv(zmq_to_qp_run_socket, message, 1023, 0)
|
||||||
if (rc <= 0) then
|
if (rc <= 0) then
|
||||||
print *, rc
|
print *, rc
|
||||||
stop "rc"
|
stop "rc"
|
||||||
@ -930,7 +930,7 @@ integer function get_task_from_taskserver(zmq_to_qp_run_socket,worker_id,task_id
|
|||||||
rc += 1
|
rc += 1
|
||||||
enddo
|
enddo
|
||||||
rc += 1
|
rc += 1
|
||||||
task = message(rc:)
|
task = trim(message(rc:rc+511))
|
||||||
else if (trim(reply) == 'terminate') then
|
else if (trim(reply) == 'terminate') then
|
||||||
task = 'terminate'
|
task = 'terminate'
|
||||||
else if (trim(message) == 'error No job is running') then
|
else if (trim(message) == 'error No job is running') then
|
||||||
|
Loading…
Reference in New Issue
Block a user