Subversion Repositories planix.SVN

#include <u.h>

#include <libc.h>

#include <venti.h>

#include "queue.h"

int chattyventi;

VtConn*

vtconn(int infd, int outfd)

{

	VtConn *z;

	NetConnInfo *nci;

	z = vtmallocz(sizeof(VtConn));

	z->tagrend.l = &z->lk;

	z->rpcfork.l = &z->lk;

	z->infd = infd;

	z->outfd = outfd;

	z->part = packetalloc();

	nci = getnetconninfo(nil, infd);

	if(nci == nil)

		snprint(z->addr, sizeof z->addr, "/dev/fd/%d", infd);

	else{

		strecpy(z->addr, z->addr+sizeof z->addr, nci->raddr);

		freenetconninfo(nci);

	}

	return z;

}

void

vtfreeconn(VtConn *z)

{

	vthangup(z);

	qlock(&z->lk);

	/*

	 * Wait for send and recv procs to notice

	 * the hangup and clear out the queues.

	 */

	while(z->readq || z->writeq){

		if(z->readq)

			_vtqhangup(z->readq);

		if(z->writeq)

			_vtqhangup(z->writeq);

		rsleep(&z->rpcfork);

	}

	packetfree(z->part);

	vtfree(z->version);

	vtfree(z->sid);

	qunlock(&z->lk);

	vtfree(z);

}