Subversion Repositories planix.SVN

#include <u.h>
#ifdef PLAN9PORT
#include <sys/socket.h>
#endif
#include <libc.h>
#include <venti.h>
#include "queue.h"

void
vthangup(VtConn *z)
{
        qlock(&z->lk);
        z->state = VtStateClosed;
#ifdef PLAN9PORT
        /* try to make the read in vtrecvproc fail */
        shutdown(SHUT_WR, z->infd);
        shutdown(SHUT_WR, z->outfd);
#endif
        if(z->infd >= 0)
                close(z->infd);
        if(z->outfd >= 0 && z->outfd != z->infd)
                close(z->outfd);
        z->infd = -1;
        z->outfd = -1;
        if(z->writeq)
                _vtqhangup(z->writeq);
        if(z->readq)
                _vtqhangup(z->readq);
        qunlock(&z->lk);
}