45 static buffer* buf_decompress(buffer* buf, unsigned int len);
46 static void buf_compress(buffer * dest, buffer * src, unsigned int len);
52 	int len, written;  in write_packet()  local
61 	len = writebuf->len - writebuf->pos;  in write_packet()
62 	dropbear_assert(len > 0);  in write_packet()
64 	written = write(ses.sock, buf_getptr(writebuf, len), len);  in write_packet()
79 	if (written == len) {  in write_packet()
97 	int len;  in read_packet()  local
104 	if (ses.readbuf == NULL || ses.readbuf->len < blocksize) {  in read_packet()
113 		if (ses.decryptreadbuf->len == 0) {  in read_packet()
122 	maxlen = ses.readbuf->len - ses.readbuf->pos;  in read_packet()
123 	len = read(ses.sock, buf_getptr(ses.readbuf, maxlen), maxlen);  in read_packet()
125 	if (len == 0) {  in read_packet()
129 	if (len < 0) {  in read_packet()
138 	buf_incrpos(ses.readbuf, len);  in read_packet()
140 	if ((unsigned int)len == maxlen) {  in read_packet()
154 	int len;  in read_packet_init()  local
172 	len = read(ses.sock, buf_getwriteptr(ses.readbuf, maxlen),  in read_packet_init()
174 	if (len == 0) {  in read_packet_init()
177 	if (len < 0) {  in read_packet_init()
185 	buf_incrwritepos(ses.readbuf, len);  in read_packet_init()
187 	if ((unsigned int)len != maxlen) {  in read_packet_init()
210 	len = buf_getint(ses.decryptreadbuf) + 4 + macsize;  in read_packet_init()
215 	if ((len > MAX_PACKET_LEN) ||  in read_packet_init()
216 		(len < MIN_PACKET_LEN + macsize) ||  in read_packet_init()
217 		((len - macsize) % blocksize != 0)) {  in read_packet_init()
218 		dropbear_exit("bad packet size %d", len);  in read_packet_init()
221 	buf_resize(ses.readbuf, len);  in read_packet_init()
222 	buf_setlen(ses.readbuf, len);  in read_packet_init()
232 	unsigned int len;  in decrypt_packet()  local
238 	ses.kexstate.datarecv += ses.readbuf->len;  in decrypt_packet()
243 	buf_resize(ses.decryptreadbuf, ses.readbuf->len - macsize);  in decrypt_packet()
250 		len = ses.readbuf->len - macsize - blocksize;  in decrypt_packet()
251 		memcpy(buf_getwriteptr(ses.decryptreadbuf, len),  in decrypt_packet()
252 				buf_getptr(ses.readbuf, len), len);  in decrypt_packet()
255 		while (ses.readbuf->pos < ses.readbuf->len - macsize) {  in decrypt_packet()
268 	buf_setpos(ses.readbuf, ses.readbuf->len - macsize);  in decrypt_packet()
283 	len = ses.decryptreadbuf->len - padlen - 4 - 1;  in decrypt_packet()
284 	if ((len > MAX_PAYLOAD_LEN) || (len < 1)) {  in decrypt_packet()
293 		ses.payload = buf_decompress(ses.decryptreadbuf, len);  in decrypt_packet()
299 		ses.payload = buf_new(len);  in decrypt_packet()
300 		memcpy(ses.payload->data, buf_getptr(ses.decryptreadbuf, len), len);  in decrypt_packet()
301 		buf_incrlen(ses.payload, len);  in decrypt_packet()
321 	unsigned int len;  in checkmac()  local
344 	len = sourcebuf->len;  in checkmac()
345 	if (hmac_process(&hmac, buf_getptr(sourcebuf, len), len) != CRYPT_OK) {  in checkmac()
364 static buffer* buf_decompress(buffer* buf, unsigned int len) {  in buf_decompress()  argument
371 	ret = buf_new(len);  in buf_decompress()
373 	zstream->avail_in = len;  in buf_decompress()
374 	zstream->next_in = buf_getptr(buf, len);  in buf_decompress()
385 		buf_setpos(ret, ret->len);  in buf_decompress()
425 	clearwritebuf = buf_new((ses.writepayload->len+4+1) + MIN_PACKET_LEN + 3  in encrypt_packet()
438 		buf_compress(clearwritebuf, ses.writepayload, ses.writepayload->len);  in encrypt_packet()
442 		memcpy(buf_getwriteptr(clearwritebuf, ses.writepayload->len),  in encrypt_packet()
443 				buf_getptr(ses.writepayload, ses.writepayload->len),  in encrypt_packet()
444 				ses.writepayload->len);  in encrypt_packet()
445 		buf_incrwritepos(clearwritebuf, ses.writepayload->len);  in encrypt_packet()
454 	padlen = blocksize - (clearwritebuf->len) % blocksize;  in encrypt_packet()
459 	if (clearwritebuf->len + padlen < MIN_PACKET_LEN) {  in encrypt_packet()
465 	buf_putint(clearwritebuf, clearwritebuf->len + padlen - 4);  in encrypt_packet()
470 	buf_setpos(clearwritebuf, clearwritebuf->len);  in encrypt_packet()
478 	writebuf = buf_new(clearwritebuf->len + macsize);  in encrypt_packet()
482 		memcpy(buf_getwriteptr(writebuf, clearwritebuf->len),  in encrypt_packet()
483 				buf_getptr(clearwritebuf, clearwritebuf->len),  in encrypt_packet()
484 				clearwritebuf->len);  in encrypt_packet()
485 		buf_incrwritepos(writebuf, clearwritebuf->len);  in encrypt_packet()
488 		while (clearwritebuf->pos < clearwritebuf->len) {  in encrypt_packet()
512 	ses.kexstate.datatrans += writebuf->len;  in encrypt_packet()
550 						clearwritebuf->len),  in writemac()
551 					clearwritebuf->len) != CRYPT_OK) {  in writemac()
568 static void buf_compress(buffer * dest, buffer * src, unsigned int len) {  in buf_compress()  argument
570 	unsigned int endpos = src->pos + len;  in buf_compress()
589 		buf_setpos(dest, dest->len);  in buf_compress()