anchor.diff:              ok = gen_tcp:send(Sock, <<"HTTP/1.0 499 TIMEOUT\r\n\r\n">>)
       end.
   
  -http_server_hack_get(Sock, _G, _FluName, MyURI, S) ->
  -    DataDir = S#state.data_dir,
  -    {Wedged_p, CurrentEpochId} = ets:lookup_element(S#state.etstab, epoch, 2),
  -    EpochID = <<"unused">>,
  -    NoSuchFileFun = fun(Sck) ->
  -                            ok = gen_tcp:send(Sck, "HTTP/1.0 455 NOT-WRITTEN\r\n\r\n")
  -                    end,
  -    BadIoFun = fun(Sck) ->
  -                            ok = gen_tcp:send(Sck, "HTTP/1.0 466 BAD-IO\r\n\r\n")
  -               end,
  -    DoItFun = fun(FH, Offset, Len) ->
  -                      case file:pread(FH, Offset, Len) of
  -                          {ok, Bytes} when byte_size(Bytes) == Len ->
  -                              Hdrs = io_lib:format("HTTP/1.0 200 OK\r\nContent-Length: ~w\r\n\r\n", [Len]),
  -                              gen_tcp:send(Sock, [Hdrs, Bytes]);
  -                          {ok, Bytes} ->
  -                              machi_util:verb("ok read but wanted ~p  got ~p: ~p @ offset ~p\n",
  -                                  [Len, size(Bytes), Bytes, Offset]),
  -                              ok = gen_tcp:send(Sock, "HTTP/1.0 455 PARTIAL-READ\r\n\r\n");
  -                          eof ->
  -                              ok = gen_tcp:send(Sock, "HTTP/1.0 455 NOT-WRITTEN\r\n\r\n");
  -                          _Else2 ->
  -                              machi_util:verb("Else2 ~p ~p ~P\n",
  -                                              [Offset, Len, _Else2, 20]),
  -                              ok = gen_tcp:send(Sock, "HTTP/1.0 466 ERROR BAD-READ\r\n\r\n")
  -                      end
  -              end,
  -    [File, OptsBin] = binary:split(MyURI, <<"?">>),
  -    Opts = split_uri_options(OptsBin),
  -    OffsetHex = machi_util:int_to_hexstr(proplists:get_value(offset, Opts), 64),
  -    LenHex = machi_util:int_to_hexstr(proplists:get_value(size, Opts), 32),
  -    do_net_server_readwrite_common2(Sock, OffsetHex, LenHex, File, DataDir,
  -                                    [read, binary, raw], DoItFun,
  -                                    EpochID, Wedged_p, CurrentEpochId,
  -                                    NoSuchFileFun, BadIoFun).
  +http_server_hack_get(Sock, _G, _FluName, _MyURI, _S) ->
  +    ok = gen_tcp:send(Sock, <<"TODO BROKEN FEATURE see old commits\r\n">>).
   
   http_harvest_headers(Sock) ->
       ok = inet:setopts(Sock, [{packet, httph}]),
  
positive.code:                                 [Prefix, self(), FileNum, Offset]),
              exit(normal)
      end.
  
  do_projection_command(Sock, LenHex, S) ->
      try
          Len = machi_util:hexstr_to_int(LenHex),
          ok = inet:setopts(Sock, [{packet, raw}]),
          {ok, ProjCmdBin} = gen_tcp:recv(Sock, Len),
          ok = inet:setopts(Sock, [{packet, line}]),
          ProjCmdM = machi_pb:decode_mpb_ll_request(ProjCmdBin),
          {ID, ProjCmd} = machi_pb_wrap:unmake_projection_req(ProjCmdM),
          ProjOp = element(1, ProjCmd),
          put(hack, ProjCmd),
          Res = handle_projection_command(ProjCmd, S),
          ResM = machi_pb_wrap:make_projection_resp(ID, ProjOp, Res),
          ResBin = machi_pb:encode_mpb_ll_response(ResM),
          ResLenHex = machi_util:int_to_hexbin(iolist_size(ResBin), 32),
          ok = gen_tcp:send(Sock, [<<"OK ">>, ResLenHex, <<"\n">>, ResBin])
      catch
          What:Why ->
              io:format(user, "OOPS ~p\n", [get(hack)]),
              io:format(user, "OOPS ~p ~p ~p\n", [What, Why, erlang:get_stacktrace()]),
              WHA = list_to_binary(io_lib:format("TODO-YOLO.~w:~w-~w",
                                                 [What, Why, erlang:get_stacktrace()])),
              _ = (catch gen_tcp:send(Sock, [<<"ERROR ">>, WHA, <<"\n">>]))
      end.
  
  handle_projection_command({get_latest_epochid, ProjType},
                            #state{proj_store=ProjStore}) ->
      machi_projection_store:get_latest_epochid(ProjStore, ProjType);
  handle_projection_command({read_latest_projection, ProjType},
                            #state{proj_store=ProjStore}) ->
      machi_projection_store:read_latest_projection(ProjStore, ProjType);
  handle_projection_command({read_projection, ProjType, Epoch},
                            #state{proj_store=ProjStore}) ->
      machi_projection_store:read(ProjStore, ProjType, Epoch);
  handle_projection_command({write_projection, ProjType, Proj},
                            #state{proj_store=ProjStore}) ->
      machi_projection_store:write(ProjStore, ProjType, Proj);
  handle_projection_command({get_all_projections, ProjType},
                            #state{proj_store=ProjStore}) ->
      machi_projection_store:get_all_projections(ProjStore, ProjType);
  handle_projection_command({list_all_projections, ProjType},
                            #state{proj_store=ProjStore}) ->
      machi_projection_store:list_all_projections(ProjStore, ProjType).
  
  make_listener_regname(BaseName) ->
      list_to_atom(atom_to_list(BaseName) ++ "_listener").
  
negative.code:                             error
                      end
              end
      end.
  
  write_server_get_pid(Prefix, DataDir, LinkPid) ->
  