LCPQ/quantum_package
10
0
Fork 0
mirror of https://github.com/LCPQ/quantum_package synced 2024-12-24 13:23:41 +01:00
Code Issues Releases Wiki Activity

timestamp of first pull

Browse Source
This commit is contained in:
Yann Garniron 2018-09-04 14:35:04 +02:00
parent 34d9fa0165
commit 0d91b9310a
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
plugins/dress_zmq/dress_stoch_routines.irp.f
View File

@ -428,7 +428,8 @@ subroutine dress_collector(zmq_socket_pull, E, relative_error, delta, delta_s2,
c = 0 c = 0
S(:) = 0d0 S(:) = 0d0
S2(:) = 0d0 S2(:) = 0d0
time0 = omp_get_wtime() time = omp_get_wtime()
time0 = -1d0 ! omp_get_wtime()
more = 1 more = 1
do while (.not. found) do while (.not. found)
@ -464,6 +465,10 @@ subroutine dress_collector(zmq_socket_pull, E, relative_error, delta, delta_s2,
else else
do do
call pull_dress_results(zmq_socket_pull, m_task, f, edI_task, edI_index, breve_delta_m, task_id, n_tasks) call pull_dress_results(zmq_socket_pull, m_task, f, edI_task, edI_index, breve_delta_m, task_id, n_tasks)
if(time0 == -1d0) then
print *, "first pull", omp_get_wtime()-time
time0 = omp_get_wtime()
end if
if(m_task == 0) then if(m_task == 0) then
if (zmq_delete_tasks(zmq_to_qp_run_socket,zmq_socket_pull,task_id,n_tasks,more) == -1) then if (zmq_delete_tasks(zmq_to_qp_run_socket,zmq_socket_pull,task_id,n_tasks,more) == -1) then
stop 'Unable to delete tasks' stop 'Unable to delete tasks'

6
plugins/dress_zmq/run_dress_slave.irp.f
View File

@ -87,9 +87,13 @@ double precision :: time, time0
stop "WORKER -1" stop "WORKER -1"
end if end if
iproc = omp_get_thread_num()+1 iproc = omp_get_thread_num()+1
allocate(breve_delta_m(N_states,N_det,2)) allocate(breve_delta_m(N_states,N_det,2))
allocate(task_buf(pt2_n_tasks_max)) allocate(task_buf(pt2_n_tasks_max))
ntask_buf = 0 ntask_buf = 0
if(iproc==1) then
call push_dress_results(zmq_socket_push, 0, 0, edI_task, edI_index, breve_delta_m, task_buf, ntask_buf)
end if
do while(cp_done > cp_sent .or. m /= dress_N_cp+1) do while(cp_done > cp_sent .or. m /= dress_N_cp+1)
call omp_set_lock(getting_task) call omp_set_lock(getting_task)