[BACK]Return to channels.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / ssh

Diff for /src/usr.bin/ssh/channels.c between version 1.372 and 1.373

version 1.372, 2017/09/21 19:16:53 version 1.373, 2017/09/23 22:04:07
Line 2419 
Line 2419 
 static void  static void
 channel_output_poll_input_open(struct ssh *ssh, Channel *c)  channel_output_poll_input_open(struct ssh *ssh, Channel *c)
 {  {
         size_t len, dlen;          size_t len, plen;
           const u_char *pkt;
         int r;          int r;
   
         if ((len = sshbuf_len(c->input)) == 0) {          if ((len = sshbuf_len(c->input)) == 0) {
Line 2446 
Line 2447 
   
         if (c->datagram) {          if (c->datagram) {
                 /* Check datagram will fit; drop if not */                  /* Check datagram will fit; drop if not */
                 if ((r = sshbuf_peek_string_direct(c->input, NULL, &dlen)) != 0)                  if ((r = sshbuf_get_string_direct(c->input, &pkt, &plen)) != 0)
                         fatal("%s: channel %d: peek datagram: %s", __func__,                          fatal("%s: channel %d: get datagram: %s", __func__,
                             c->self, ssh_err(r));                              c->self, ssh_err(r));
                 /*                  /*
                  * XXX this does tail-drop on the datagram queue which is                   * XXX this does tail-drop on the datagram queue which is
                  * usually suboptimal compared to head-drop. Better to have                   * usually suboptimal compared to head-drop. Better to have
                  * backpressure at read time? (i.e. read + discard)                   * backpressure at read time? (i.e. read + discard)
                  */                   */
                 if (dlen > c->remote_window || dlen > c->remote_maxpacket) {                  if (plen > c->remote_window || plen > c->remote_maxpacket) {
                         debug("channel %d: datagram too big", c->self);                          debug("channel %d: datagram too big", c->self);
                         return;                          return;
                 }                  }
                 /* Enqueue it */                  /* Enqueue it */
                 if ((r = sshpkt_start(ssh, SSH2_MSG_CHANNEL_DATA)) != 0 ||                  if ((r = sshpkt_start(ssh, SSH2_MSG_CHANNEL_DATA)) != 0 ||
                     (r = sshpkt_put_u32(ssh, c->remote_id)) != 0 ||                      (r = sshpkt_put_u32(ssh, c->remote_id)) != 0 ||
                     (r = sshpkt_put_stringb(ssh, c->input)) != 0 ||                      (r = sshpkt_put_string(ssh, pkt, plen)) != 0 ||
                     (r = sshpkt_send(ssh)) != 0) {                      (r = sshpkt_send(ssh)) != 0) {
                         fatal("%s: channel %i: datagram: %s", __func__,                          fatal("%s: channel %i: datagram: %s", __func__,
                             c->self, ssh_err(r));                              c->self, ssh_err(r));
                 }                  }
                 c->remote_window -= dlen;                  c->remote_window -= plen;
                 return;                  return;
         }          }
   
Legend:
Removed from v.1.372  
changed lines
  Added in v.1.373