anchor.diff:              Msg
       end.
   
  +% Send a send-message-event to meeqo_pipe.
   send(Addr, Msg, SysTbl) ->
       [PipeRack] = meeqo:info(SysTbl, [meeqo_piperack]),
       Pipe = case ets:lookup(PipeRack, Addr) of
           [] ->
  -            meeqo_pipe:start_link([SysTbl, Addr]);
  +            Pid = meeqo_pipe:start_link([SysTbl, Addr]),
  +            ets:insert(PipeRack, {Addr, Pid}),
  +            Pid;
           [{Addr, Pid}] ->
               case is_process_alive(Pid) of
                   true -> Pid;
                   false ->
  -                    ets:delete(PipeRack, Addr),
  -                    meeqo_pipe:start_link([SysTbl, Addr])
  +                    Pid = meeqo_pipe:start_link([SysTbl, Addr]),
  +                    ets:insert(PipeRack, {Addr, Pid}),
  +                    Pid
               end
       end,
  -    ets:insert(PipeRack, {Addr, Pipe}),
       gen_fsm:send_event(Pipe, {send, Msg}).
   
   % Decode single read/send request into Elang data type.
  
positive.code:                     MsgRef = make_ref(),
                      ets:insert(meeqo_locker, {MsgRef, Msg}),
                      send(Addr, MsgRef, SysTbl),
                      gen_tcp:send(Sock, <<"ok">>)
              end,
              inet:setopts(Sock, [{active, once}]),
  
negative.code:                         send(Addr, MsgRef, SysTbl)
                      end,
                      lists:map(Fun, Msgs),
                      % The incomplete tweet at the end will be attached to the 
                      % next tweet-datagram.
                      tweet_loop(Sock, Rest, SysTbl)
              end;
          {tcp_closed, Sock} -> ok
  