usr.bin/csup/mux.c

646 	struct mux_header mh;
649 	mh.type = MUX_STARTUPREQ;
650 	mh.mh_startup.version = htons(MUX_PROTOVER);
651 	error = sock_write(m->socket, &mh, MUX_STARTUPHDRSZ);
654 	error = sock_readwait(m->socket, &mh, MUX_STARTUPHDRSZ);
657 	if (mh.type != MUX_STARTUPREP ||
658 	    ntohs(mh.mh_startup.version) != MUX_PROTOVER)
779 	struct mux_header mh;
795 		mh.type = MUX_CONNECT;
796 		mh.mh_connect.id = id;
797 		mh.mh_connect.mss = htons(chan->recvmss);
798 		mh.mh_connect.window = htonl(chan->recvseq +
803 		mh.type = MUX_ACCEPT;
804 		mh.mh_accept.id = id;
805 		mh.mh_accept.mss = htons(chan->recvmss);
806 		mh.mh_accept.window = htonl(chan->recvseq +
811 		mh.type = MUX_RESET;
812 		mh.mh_reset.id = id;
816 		mh.type = MUX_WINDOW;
817 		mh.mh_window.id = id;
818 		mh.mh_window.window = htonl(chan->recvseq +
823 		mh.type = MUX_DATA;
824 		mh.mh_data.id = id;
829 		mh.mh_data.len = htons(size);
833 		mh.type = MUX_CLOSE;
834 		mh.mh_close.id = id;
839 		assert(mh.type == MUX_DATA);
845 		iov[0].iov_base = (char *)&mh;
879 		error = sock_write(m->socket, &mh, hdrsize);
970 #define	SOCK_READREST(s, mh, hsize)	\
971     sock_readwait(s, (char *)&mh + sizeof(mh.type), (hsize) - sizeof(mh.type))
976 	struct mux_header mh;
984 	while ((error = sock_readwait(m->socket, &mh.type,
985 	    sizeof(mh.type))) == 0) {
986 		switch (mh.type) {
988 			error = SOCK_READREST(m->socket, mh, MUX_CONNECTHDRSZ);
991 			chan = chan_get(m, mh.mh_connect.id);
994 				chan->sendmss = ntohs(mh.mh_connect.mss);
995 				chan->sendwin = ntohl(mh.mh_connect.window);
1004 			error = SOCK_READREST(m->socket, mh, MUX_ACCEPTHDRSZ);
1007 			chan = chan_get(m, mh.mh_accept.id);
1009 				chan->sendmss = ntohs(mh.mh_accept.mss);
1010 				chan->sendwin = ntohl(mh.mh_accept.window);
1021 			error = SOCK_READREST(m->socket, mh, MUX_RESETHDRSZ);
1026 			error = SOCK_READREST(m->socket, mh, MUX_WINDOWHDRSZ);
1029 			chan = chan_get(m, mh.mh_window.id);
1032 				chan->sendwin = ntohl(mh.mh_window.window);
1040 			error = SOCK_READREST(m->socket, mh, MUX_DATAHDRSZ);
1043 			chan = chan_get(m, mh.mh_data.id);
1044 			len = ntohs(mh.mh_data.len);
1079 			error = SOCK_READREST(m->socket, mh, MUX_CLOSEHDRSZ);
1082 			chan = chan_get(m, mh.mh_close.id);