anchor.diff:                      ?log_error("Engine for bucket ~p didn't start in ~p ms. Exit.", [Bucket, Time]),
                       exit(RV);
                   _ ->
  -                    receive
  -                        {'EXIT', Pid, Reason} ->
  -                            ?log_debug("Received exit from ~p with reason ~p", [Pid, Reason]),
  -                            exit(Reason)
  -                    after 500 ->
  -                            ok
  -                    end,
  +                    timer:sleep(500),
   
                       Time1 = Time + 500,
                       ?log_debug("Waiting for engine to start. Bucket: ~p, Wait time: ~p ms.",
  
positive.code:       end).
  
  init({Bucket, Replicator, ReplicationSrvr, UseReplicaIndex, NumVBuckets}) ->
      process_flag(trap_exit, true),
      Self = self(),
  
      ns_couchdb_api:register_doc_manager(Replicator),
  
negative.code:             ok
      end,
      {noreply, State};
  
  handle_info(Info, State) ->
      ?log_info("Ignoring unexpected message: ~p", [Info]),
  