blob: 365baf1daca301f70c08aa0e82741d56d5b3fa60 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
#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);
}
|