anchor.diff:  	    {error, timeout}
       end.
   
  +update_inet_buffers(Socket) ->
  +    {ok, BufSzs0} = inet:getopts(Socket, [sndbuf,recbuf]),
  +    MinVal = 655360,
  +    case
  +	[{Tag,MinVal} || {Tag,Val} <- BufSzs0,
  +			 Val < MinVal]
  +    of
  +	[] -> ok;
  +	NewOpts -> inet:setopts(Socket, NewOpts)
  +    end.
  
positive.code:     handle_connection_msg(Msg, StateName, D);
  
  handle_event(internal, Msg=#ssh_msg_channel_success{},           StateName, D) ->
      handle_connection_msg(Msg, StateName, D);
  
  handle_event(internal, Msg=#ssh_msg_channel_failure{},           StateName, D) ->
  
negative.code: 		Repls).
  
  get_repl({connection_reply,Msg}, {CallRepls,S}) ->
      if is_record(Msg, ssh_msg_channel_success) ->
  	    update_inet_buffers(S#data.socket);
         true ->
  	    ok
      end,
      {CallRepls, send_msg(Msg,S)};
  get_repl({channel_data,undefined,_Data}, Acc) ->
      Acc;
  