mirror of
https://github.com/LCPQ/quantum_package
synced 2024-12-25 13:53:49 +01:00
bug with zmq_state
This commit is contained in:
parent
80005aa36e
commit
045109056f
@ -31,8 +31,8 @@ OPENMP : 1 ; Append OpenMP flags
|
|||||||
# -ftz : Flushes denormal results to zero
|
# -ftz : Flushes denormal results to zero
|
||||||
#
|
#
|
||||||
[OPT]
|
[OPT]
|
||||||
FCFLAGS : -xAVX -O2 -ip -ftz -g -traceback
|
FCFLAGS : -xSSE4.2 -O2 -ip -ftz -g -traceback
|
||||||
|
# !xAVX
|
||||||
# Profiling flags
|
# Profiling flags
|
||||||
#################
|
#################
|
||||||
#
|
#
|
||||||
|
@ -38,19 +38,16 @@ subroutine run_wf
|
|||||||
zmq_to_qp_run_socket = new_zmq_to_qp_run_socket()
|
zmq_to_qp_run_socket = new_zmq_to_qp_run_socket()
|
||||||
|
|
||||||
do
|
do
|
||||||
|
|
||||||
call wait_for_states(states,zmq_state,1)
|
call wait_for_states(states,zmq_state,1)
|
||||||
|
if(zmq_state(1:7) == 'Stopped') then
|
||||||
if(trim(zmq_state) == 'Stopped') then
|
|
||||||
|
|
||||||
exit
|
exit
|
||||||
|
|
||||||
else if (trim(zmq_state) == 'mrcc') then
|
else if (zmq_state(1:4) == 'mrcc') then
|
||||||
|
|
||||||
! Selection
|
! Selection
|
||||||
! ---------
|
! ---------
|
||||||
|
|
||||||
print *, 'mrcc'
|
|
||||||
!call wall_time(t0)
|
!call wall_time(t0)
|
||||||
if (zmq_get_psi(zmq_to_qp_run_socket,1) == -1) cycle
|
if (zmq_get_psi(zmq_to_qp_run_socket,1) == -1) cycle
|
||||||
if (zmq_get_N_det_generators (zmq_to_qp_run_socket, 1) == -1) cycle
|
if (zmq_get_N_det_generators (zmq_to_qp_run_socket, 1) == -1) cycle
|
||||||
|
@ -209,7 +209,6 @@ subroutine mrcc_collector(zmq_socket_pull, E, relative_error, delta, delta_s2, m
|
|||||||
old_cur_cp = 0
|
old_cur_cp = 0
|
||||||
pullLoop : do while (more == 1)
|
pullLoop : do while (more == 1)
|
||||||
call pull_mrcc_results(zmq_socket_pull, Nindex, ind, mrcc_mwen, delta_loc, task_id, ntask)
|
call pull_mrcc_results(zmq_socket_pull, Nindex, ind, mrcc_mwen, delta_loc, task_id, ntask)
|
||||||
|
|
||||||
if(Nindex /= 1) stop "tried pull multiple Nindex"
|
if(Nindex /= 1) stop "tried pull multiple Nindex"
|
||||||
|
|
||||||
do i=1,Nindex
|
do i=1,Nindex
|
||||||
|
@ -41,7 +41,6 @@ subroutine run_mrcc_slave(thread,iproc,energy)
|
|||||||
integer :: h,p,n
|
integer :: h,p,n
|
||||||
logical :: ok
|
logical :: ok
|
||||||
double precision :: contrib(N_states)
|
double precision :: contrib(N_states)
|
||||||
|
|
||||||
allocate(delta_ij_loc(N_states,N_det_non_ref,2) &
|
allocate(delta_ij_loc(N_states,N_det_non_ref,2) &
|
||||||
,delta_ii_loc(N_states,2))! &
|
,delta_ii_loc(N_states,2))! &
|
||||||
!,delta_ij_s2_loc(N_states,N_det_non_ref,N_det_ref) &
|
!,delta_ij_s2_loc(N_states,N_det_non_ref,N_det_ref) &
|
||||||
@ -73,7 +72,7 @@ subroutine run_mrcc_slave(thread,iproc,energy)
|
|||||||
else
|
else
|
||||||
integer :: i_generator, i_i_generator, subset
|
integer :: i_generator, i_i_generator, subset
|
||||||
read (task,*) subset, ind
|
read (task,*) subset, ind
|
||||||
|
print *, "SLAVE RECEIVED", ind
|
||||||
! if(buf%N == 0) then
|
! if(buf%N == 0) then
|
||||||
! ! Only first time
|
! ! Only first time
|
||||||
! call create_selection_buffer(1, 2, buf)
|
! call create_selection_buffer(1, 2, buf)
|
||||||
|
Loading…
Reference in New Issue
Block a user