LCPQ/quantum_package
10
0
Fork 0
mirror of https://github.com/LCPQ/quantum_package synced 2024-11-19 04:22:36 +01:00
Code Issues Releases Wiki Activity

Removed IPC

Browse Source
This commit is contained in:
Anthony Scemama 2017-05-04 15:51:33 +02:00
parent b82bbdab73
commit e0812d4b41
2 changed files with 3 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ocaml/TaskServer.ml
View File

@ -70,16 +70,7 @@ let bind_socket ~socket_type ~socket ~port =
with with
| Unix.Unix_error _ -> (Time.pause @@ Time.Span.of_float 1. ; loop (i-1) ) | Unix.Unix_error _ -> (Time.pause @@ Time.Span.of_float 1. ; loop (i-1) )
| other_exception -> raise other_exception | other_exception -> raise other_exception
in loop 60; in loop 60
let filename =
Printf.sprintf "/tmp/qp_run:%d" port
in
begin
match Sys.file_exists filename with
| `Yes -> Sys.remove filename
| _ -> ()
end;
ZMQ.Socket.bind socket ("ipc://"^filename)
let hostname = lazy ( let hostname = lazy (
@ -133,7 +124,7 @@ let stop ~port =
let req_socket = let req_socket =
ZMQ.Socket.create zmq_context ZMQ.Socket.req ZMQ.Socket.create zmq_context ZMQ.Socket.req
and address = and address =
Printf.sprintf "ipc:///tmp/qp_run:%d" port Printf.sprintf "tcp://localhost:%d" port
in in
ZMQ.Socket.set_linger_period req_socket 1_000_000; ZMQ.Socket.set_linger_period req_socket 1_000_000;
ZMQ.Socket.connect req_socket address; ZMQ.Socket.connect req_socket address;

2
plugins/Full_CI_ZMQ/fci_zmq.irp.f
View File

@ -147,7 +147,7 @@ program fci_zmq
print *, 'E+PT2 = ', E_CI_before(k)+pt2(k) print *, 'E+PT2 = ', E_CI_before(k)+pt2(k)
print *, '-----' print *, '-----'
enddo enddo
call ezfio_set_full_ci_zmq_energy(CI_energy(1)) call ezfio_set_full_ci_zmq_energy(E_CI_before(1))
call ezfio_set_full_ci_zmq_energy_pt2(E_CI_before(1)+pt2(1)) call ezfio_set_full_ci_zmq_energy_pt2(E_CI_before(1)+pt2(1))
endif endif