Archipelago » qemu

/*

 * Copyright (c) 1995 Danny Gasparovski.

 * terms and conditions of the copyright.

 */

/* Done as a macro in socket.h */

/* int

 * {

 *	return SB_DATALEN - sb->sb_cc;

 * }

void

sbdrop(sb, num)

	struct sbuf *sb;

{

	 * We can only drop how much we have

	 */

	if(num > sb->sb_cc)

		num = sb->sb_cc;

	sb->sb_rptr += num;

	if(sb->sb_rptr >= sb->sb_data + sb->sb_datalen)

		sb->sb_rptr -= sb->sb_datalen;

}

void

	struct mbuf *m;

{

	int ret = 0;

	DEBUG_CALL("sbappend");

	DEBUG_ARG("so = %lx", (long)so);

	DEBUG_ARG("m = %lx", (long)m);

	DEBUG_ARG("m->m_len = %d", m->m_len);

	/* Shouldn't happen, but...  e.g. foreign host closes connection */

	if (m->m_len <= 0) {

		m_free(m);

		return;

	}

	/*

	 * If there is urgent data, call sosendoob

	 * if not all was sent, sowrite will take care of the rest

		sosendoob(so);

		return;

	}

	/*

	 * We only write if there's nothing in the buffer,

	 * ottherwise it'll arrive out of order, and hence corrupt

	 */

	if (!so->so_rcv.sb_cc)

	   ret = send(so->s, m->m_data, m->m_len, 0);

	if (ret <= 0) {

		 * Nothing was written

		 * It's possible that the socket has closed, but

		 * we don't need to check because if it has closed,

	 struct mbuf *m;

{

	int len, n,  nn;

	len = m->m_len;

	if (sb->sb_wptr < sb->sb_rptr) {

	char *to;

{

	char *from;

	from = sb->sb_rptr + off;

	if (from >= sb->sb_data + sb->sb_datalen)

		from -= sb->sb_datalen;

		   memcpy(to+off,sb->sb_data,len);

	}

}