anchor.diff:    double precision :: time0, time
   
     allocate(pt2_detail(N_states, N_det_generators), comb(100000), computed(N_det_generators), tbc(0:N_det_generators))
  +  sumabove = 0d0
  +  sum2above = 0d0
  +  Nabove = 0d0
  +
     provide nproc
   
     !call random_seed()
  
positive.code:   time0 = omp_get_wtime()
    print *, "grep - time - avg - err - n_combs"
    do while(.true.)
    
    call new_parallel_job(zmq_to_qp_run_socket,"pt2")
    call zmq_put_psi(zmq_to_qp_run_socket,1,ci_electronic_energy,size(ci_electronic_energy))
    call zmq_set_running(zmq_to_qp_run_socket)
    call create_selection_buffer(1, 1*2, b)
     
  
  
  
  
  
    call get_carlo_workbatch(1d-3, computed, comb, Ncomb, tbc)
    generator_per_task = 1 ! tbc(0)/300 + 1
    print *, 'TASKS REVERSED'
    !do i=1,tbc(0),generator_per_task
    do i=1,tbc(0) ! generator_per_task
      i_generator_end = min(i+generator_per_task-1, tbc(0))
      !print *, "TASK", (i_generator_end-i+1), tbc(i:i_generator_end)
      if(i > 10) then
        integer :: zero
        zero = 0
        write(task,*) (i_generator_end-i+1), zero, tbc(i:i_generator_end)
        call add_task_to_taskserver(zmq_to_qp_run_socket,task)
      else
        do j=1,8
          write(task,*) (i_generator_end-i+1), j, tbc(i:i_generator_end)
          call add_task_to_taskserver(zmq_to_qp_run_socket,task)
        end do
      end if
    end do
  
    print *, "tasked" 
    !$OMP PARALLEL DEFAULT(shared)  SHARED(b, pt2)  PRIVATE(i) NUM_THREADS(nproc+1)
      i = omp_get_thread_num()
      if (i==0) then
        call pt2_collector(b, pt2_detail)
      else
        call pt2_slave_inproc(i)
      endif
    !$OMP END PARALLEL
    call end_parallel_job(zmq_to_qp_run_socket, 'pt2')
    double precision :: E0, avg, eqt
    call do_carlo(tbc, Ncomb, comb, pt2_detail, sumabove, sum2above, Nabove)
    !END LOOP?
    integer :: tooth
    call get_first_tooth(computed, tooth)
    !print *, "TOOTH ", tooth 
    
    !!! ASSERT
    !do i=1,first_det_of_teeth(tooth)
    !  if(not(computed(i))) stop "deter non calc"
    !end do
    !logical :: ok
    !ok = .false.
    !do i=first_det_of_teeth(tooth), first_det_of_teeth(tooth+1)
    !  if(not(computed(i))) ok = .true.
    !end do
    !if(not(ok)) stop "not OK..."
    !!!!!
    double precision :: prop
    if(Nabove(tooth) >= 30) then
      E0 = sum(pt2_detail(1,:first_det_of_teeth(tooth)-1))
      prop = ((1d0 - dfloat(comb_teeth - tooth + 1) * comb_step) - cweight(first_det_of_teeth(tooth)-1))
      prop = prop / weight(first_det_of_teeth(tooth))
      E0 += pt2_detail(1,first_det_of_teeth(tooth)) * prop
      avg = E0 + (sumabove(tooth) / Nabove(tooth))
      eqt = sqrt(1d0 / (Nabove(tooth)-1) * abs(sum2above(tooth) / Nabove(tooth) - (sumabove(tooth)/Nabove(tooth))**2))
      time = omp_get_wtime()
      print "(A, 5(E15.7))", "PT2stoch ", time - time0, avg, eqt, Nabove(tooth)
    else
      print *, Nabove(tooth), "< 30 combs"
    end if
    tbc(0) = 0
    end do
  
    pt2 = 0d0
  end subroutine
  
  
  subroutine do_carlo(tbc, Ncomb, comb, pt2_detail, sumabove, sum2above, Nabove)
    integer, intent(in) :: tbc(0:N_det_generators), Ncomb
    double precision, intent(in) :: comb(Ncomb), pt2_detail(N_states, N_det_generators)
    double precision, intent(inout) :: sumabove(comb_teeth), sum2above(comb_teeth), Nabove(comb_teeth)
    integer :: i, dets(comb_teeth)
    double precision :: myVal, myVal2
  
  
    do i=1,Ncomb
      call get_comb(comb(i), dets)
      myVal = 0d0
      myVal2 = 0d0
      do j=comb_teeth,1,-1
  
negative.code:   call run_pt2_slave(1,i,ci_electronic_energy)
  end
  
  subroutine pt2_collector(b, tbc, comb, Ncomb, computed, pt2_detail, sumabove, sum2above, Nabove)
    use f77_zmq
    use selection_types
    use bitmasks
    implicit none
  
    
    integer, intent(in) :: Ncomb
    double precision, intent(inout) :: pt2_detail(N_states, N_det_generators)
    double precision, intent(in) :: comb(Ncomb)
    logical, intent(inout) :: computed(N_det_generators)
    integer, intent(in) :: tbc(0:N_det_generators)
    double precision, intent(inout) :: sumabove(comb_teeth), sum2above(comb_teeth), Nabove(comb_teeth)
  
  
    type(selection_buffer), intent(inout) :: b
    double precision                   :: pt2_mwen(N_states, N_det)
    integer(ZMQ_PTR),external      :: new_zmq_to_qp_run_socket
    integer(ZMQ_PTR)               :: zmq_to_qp_run_socket
  