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