nhyatt/putty-source
1
0
Fork 0
mirror of https://git.tartarus.org/simon/putty.git synced 2025-05-30 16:30:29 -05:00
Code Issues Projects Releases Wiki Activity

Install a notification procedure (ASR) on each TCP connection that wakes

Browse Source 
PuTTY up when something happens.  This should allow it to receive data without
having to poll for it continuously.

[originally from svn r2519]
This commit is contained in:
Ben Harris 2003-01-09 19:26:39 +00:00
parent 1604a192fe
commit f11987f988
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
mac/mtcpnet.c
View File

@ -187,10 +187,13 @@ static struct {
Handle dnr_handle; Handle dnr_handle;
int initialised; int initialised;
short refnum; short refnum;
ProcessSerialNumber self;
Actual_Socket socklist; Actual_Socket socklist;
} mactcp; } mactcp;
static pascal void mactcp_lookupdone(struct hostInfo *hi, char *cookie); static pascal void mactcp_lookupdone(struct hostInfo *hi, char *cookie);
static pascal void mactcp_asr(StreamPtr, unsigned short, Ptr, unsigned short,
struct ICMPReport *);
static Plug mactcp_plug(Socket, Plug); static Plug mactcp_plug(Socket, Plug);
static void mactcp_flush(Socket); static void mactcp_flush(Socket);
static void mactcp_close(Socket); static void mactcp_close(Socket);
@ -365,6 +368,8 @@ Socket sk_register(void *sock, Plug plug)
fatalbox("sk_register"); fatalbox("sk_register");
} }
static TCPNotifyUPP mactcp_asr_upp;
Socket sk_new(SockAddr addr, int port, int privport, int oobinline, Socket sk_new(SockAddr addr, int port, int privport, int oobinline,
int nodelay, Plug plug) int nodelay, Plug plug)
{ {
@ -424,11 +429,14 @@ Socket sk_new(SockAddr addr, int port, int privport, int oobinline,
buflen = upb.csParam.mtu.mtuSize * 4 + 1024; buflen = upb.csParam.mtu.mtuSize * 4 + 1024;
if (buflen < 4096) buflen = 4096; if (buflen < 4096) buflen = 4096;
if (mactcp_asr_upp == NULL)
mactcp_asr_upp = NewTCPNotifyUPP(&mactcp_asr);
GetCurrentProcess(&mactcp.self);
pb.ioCRefNum = mactcp.refnum; pb.ioCRefNum = mactcp.refnum;
pb.csCode = TCPCreate; pb.csCode = TCPCreate;
pb.csParam.create.rcvBuff = smalloc(buflen); pb.csParam.create.rcvBuff = smalloc(buflen);
pb.csParam.create.rcvBuffLen = buflen; pb.csParam.create.rcvBuffLen = buflen;
pb.csParam.create.notifyProc = NULL; pb.csParam.create.notifyProc = mactcp_asr_upp;
pb.csParam.create.userDataPtr = (Ptr)ret; pb.csParam.create.userDataPtr = (Ptr)ret;
ret->err = PBControlSync((ParmBlkPtr)&pb); ret->err = PBControlSync((ParmBlkPtr)&pb);
if (ret->err != noErr) return (Socket)ret; if (ret->err != noErr) return (Socket)ret;
@ -548,6 +556,14 @@ static int mactcp_write_oob(Socket sock, char *buf, int len)
fatalbox("mactcp_write_oob"); fatalbox("mactcp_write_oob");
} }
static pascal void mactcp_asr(StreamPtr str, unsigned short event, Ptr cookie,
unsigned short termin_reason,
struct ICMPReport *icmp)
{
WakeUpProcess(&mactcp.self);
}
/* /*
* Called from our event loop if there's work to do. * Called from our event loop if there's work to do.
*/ */