anchor.diff:    end.
   
   process_now(Request, Asset) ->
  +  try unsafe_process_now(Request, Asset) of
  +    _AnyResponse -> ok
  +  catch
  +    _AnyError -> ok
  +  after
  +    asset_pool:return(Asset),
  +    ernie_server:asset_freed(),
  +    gen_tcp:close(Request#request.sock)
  +  end.
  +
  +unsafe_process_now(Request, Asset) ->
     BinaryTerm = Request#request.action,
     Term = binary_to_term(BinaryTerm),
     case Term of
  
positive.code:       gen_tcp:send(Sock, term_to_binary({noreply})),
        ok = gen_tcp:close(Sock),
        logger:debug("Closing cast.~n", []);
      Any ->
        ok
    end,
    case queue:is_empty(State#state.pending) of
  
negative.code:       {asset, Port, Token} = Asset,
        logger:debug("Asset: ~p ~p~n", [Port, Token]),
        {ok, Data} = port_wrapper:rpc(Port, BinaryTerm),
        gen_tcp:send(Sock, Data),
        ok = gen_tcp:close(Sock);
      {cast, Mod, Fun, Args} ->
        logger:debug("Casting ~p:~p(~p)~n", [Mod, Fun, Args]),
        {asset, Port, Token} = Asset,
        logger:debug("Asset: ~p ~p~n", [Port, Token]),
        {ok, _Data} = port_wrapper:rpc(Port, BinaryTerm)
    end.