anchor.diff:                  etstab=ets_table_name(FluName),
                   epoch_id=EpochId,
                   props=Props},
  -    AppendPid = start_append_server(S0, self()),
  -    receive
  -        append_server_ack -> ok
  -    end,
  +    {ok, AppendPid} = start_append_server(S0, self()),
       if SendAppendPidToProj_p ->
               machi_projection_store:set_wedge_notify_pid(ProjectionPid,
                                                           AppendPid);
  
positive.code:     put(flu_append_pid, S1#state.append_pid),
      put(flu_projection_pid, ProjectionPid),
      put(flu_listen_pid, ListenPid),
      receive killme -> ok end,
      (catch exit(S1#state.append_pid, kill)),
      (catch exit(ProjectionPid, kill)),
  
negative.code:     ok.
  
  start_listen_server(S) ->
      proc_lib:start_link(?MODULE, run_listen_server, [S], ?INIT_TIMEOUT).
  
  start_append_server(S, AckPid) ->
      proc_lib:start_link(?MODULE, run_append_server, [AckPid, S], ?INIT_TIMEOUT).
  
  run_listen_server(#state{flu_name=FluName, tcp_port=TcpPort}=S) ->
      register(make_listener_regname(FluName), self()),
  