anchor.diff:      FluPid = self(),
       proc_lib:spawn_link(fun() -> run_append_server(FluPid, AckPid, S) end).
   
  -%% start_projection_server(S) ->
  -%%     spawn_link(fun() -> run_projection_server(S) end).
  -
   run_listen_server(#state{flu_name=FluName, tcp_port=TcpPort}=S) ->
       register(make_listener_regname(FluName), self()),
       SockOpts = ?PB_PACKET_OPTS ++
  
positive.code:                                                  DataDir, AppendServerPid) end),
              append_server_loop(FluPid, S);
          {wedge_myself, WedgeEpochId} ->
              if WedgeEpochId == OldEpochId ->
                      true = ets:insert(S#state.etstab,
                                        {epoch, {true, OldEpochId}}),
                      append_server_loop(FluPid, S#state{wedged=true});
                 true ->
                      append_server_loop(FluPid, S)
  
negative.code:     spawn_link(fun() -> net_server_loop(Sock, S) end),
      listen_server_loop(LSock, S).
  
  append_server_loop(FluPid, #state{data_dir=DataDir, wedged=Wedged_p,
                                    epoch_id=OldEpochId, flu_name=FluName}=S) ->
      AppendServerPid = self(),
      receive
          {seq_append, From, _Prefix, _Chunk, _CSum, _Extra, _EpochID}
  