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:             exit({?MODULE, run_listen_server, tcp_port, TcpPort, Else})
      end.
  
  run_append_server(FluPid, AckPid, #state{flu_name=Name,
                                           wedged=Wedged_p,epoch_id=EpochId}=S) ->
      %% Reminder: Name is the "main" name of the FLU, i.e., no suffix
      register(Name, self()),
      TID = ets:new(ets_table_name(Name),
                    [set, protected, named_table, {read_concurrency, true}]),
      ets:insert(TID, {epoch, {Wedged_p, EpochId}}),
      AckPid ! append_server_ack,
      append_server_loop(FluPid, S#state{etstab=TID}).
  
  listen_server_loop(LSock, S) ->
  
negative.code:     put(flu_append_pid, S1#state.append_pid),
      put(flu_projection_pid, ProjectionPid),
      put(flu_listen_pid, ListenPid),
      proc_lib:init_ack({ok, self()}),
  
      receive killme -> ok end,
      (catch exit(S1#state.append_pid, kill)),
      (catch exit(ProjectionPid, kill)),
  