Mercurial > dropbear

comparison common-channel.c @ 1859:1d86a58fb52d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Leave non-interactive at default QoS class Lower class levels are less well defined, and non-interactive SSH can carry various different types of applications. This change also sets lowdelay class (AF21) earlier in an an outbound dbclient session
author Matt Johnston <matt@ucc.asn.au>
date Thu, 27 Jan 2022 14:34:10 +0800
parents 90ac15aeac43
children
comparison
equal deleted inserted replaced
1857:6022df862942 1859:1d86a58fb52d
160 160
161 newchan->extrabuf = NULL; /* The user code can set it up */ 161 newchan->extrabuf = NULL; /* The user code can set it up */
162 newchan->recvdonelen = 0; 162 newchan->recvdonelen = 0;
163 newchan->recvmaxpacket = RECV_MAX_CHANNEL_DATA_LEN; 163 newchan->recvmaxpacket = RECV_MAX_CHANNEL_DATA_LEN;
164 164
165 newchan->prio = DROPBEAR_CHANNEL_PRIO_EARLY; /* inithandler sets it */ 165 newchan->prio = DROPBEAR_PRIO_NORMAL;
166 166
167 ses.channels[i] = newchan; 167 ses.channels[i] = newchan;
168 ses.chancount++; 168 ses.chancount++;
169 169
170 TRACE(("leave newchannel")) 170 TRACE(("leave newchannel"))
953 TRACE(("inithandler returned failure %d", ret)) 953 TRACE(("inithandler returned failure %d", ret))
954 goto failure; 954 goto failure;
955 } 955 }
956 } 956 }
957 957
958 if (channel->prio == DROPBEAR_CHANNEL_PRIO_EARLY) { 958 update_channel_prio();
959 channel->prio = DROPBEAR_CHANNEL_PRIO_BULK;
960 }
961 959
962 /* success */ 960 /* success */
963 send_msg_channel_open_confirmation(channel, channel->recvwindow, 961 send_msg_channel_open_confirmation(channel, channel->recvwindow,
964 channel->recvmaxpacket); 962 channel->recvmaxpacket);
965 goto cleanup; 963 goto cleanup;
968 TRACE(("recv_msg_channel_open failure")) 966 TRACE(("recv_msg_channel_open failure"))
969 send_msg_channel_open_failure(remotechan, errtype, "", ""); 967 send_msg_channel_open_failure(remotechan, errtype, "", "");
970 968
971 cleanup: 969 cleanup:
972 m_free(type); 970 m_free(type);
973
974 update_channel_prio();
975 971
976 TRACE(("leave recv_msg_channel_open")) 972 TRACE(("leave recv_msg_channel_open"))
977 } 973 }
978 974
979 /* Send a failure message */ 975 /* Send a failure message */
1164 TRACE(("inithandler returned failure %d", ret)) 1160 TRACE(("inithandler returned failure %d", ret))
1165 return; 1161 return;
1166 } 1162 }
1167 } 1163 }
1168 1164
1169 if (channel->prio == DROPBEAR_CHANNEL_PRIO_EARLY) {
1170 channel->prio = DROPBEAR_CHANNEL_PRIO_BULK;
1171 }
1172 update_channel_prio(); 1165 update_channel_prio();
1173 1166
1174 TRACE(("leave recv_msg_channel_open_confirmation")) 1167 TRACE(("leave recv_msg_channel_open_confirmation"))
1175 } 1168 }
1176 1169
1177 /* Notification that our channel open request failed */ 1170 /* Notification that our channel open request failed */
1178 void recv_msg_channel_open_failure() { 1171 void recv_msg_channel_open_failure() {