Apple-2gs-SW/marignotti
1
0
Fork 0
mirror of https://github.com/ksherlock/marignotti.git synced 2025-03-11 21:39:34 +00:00
Code Issues Projects Releases Wiki Activity

select

Browse Source
This commit is contained in:
Kelvin Sherlock 2012-05-07 22:41:13 -04:00
parent fb960b0f9e
commit 38080d632d
1 changed files with 122 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

122
mselect.c Normal file
View File

@ -0,0 +1,122 @@
#include "marignotti.h"
#include <gno/kerntool.h>
#include <errno.h>
#pragma noroot
#pragma optimize 79
/*
* return value is ignored.
*
*/
static boolean readable(Entry *e)
{
if (e->_SHUT_RD)
return false;
if (e->sr.srState > TCPSESTABLISHED && e->sr.srRcvQueued)
return true;
if (e->sr.srRcvQueued >= e->_RCVLOWAT)
return true;
return false;
}
static boolean writable(Entry *e)
{
if (e->_SHUT_WR)
return false;
if (e->sr.srState != TCPSESTABLISHED)
return false;
if (e->sr.srRcvQueued <= e->_SNDLOWAT)
return true;
return false;
}
static boolean exceptable(Entry *e)
{
switch (e->terr)
{
case tcperrOK:
break;
case tcperrConClosing:
case tcperrClosing:
case tcperrConReset:
if (!e->sr.srRcvQueued)
return true;
break;
}
if (e->sr.srRcvQueued)
return false;
if (e->sr.srNetworkError)
return true;
if (e->sr.srState > TCPSESTABLISHED)
return true;
return false;
}
int mselect(Entry *e, void *p1, void *p2, void *p3, void *p4, void *p5)
{
Word t;
Word terr;
int pid = *(int *)p2;
int flag = *(int *)p3;
*(int *)p3 = 0;
IncBusy();
terr = TCPIPStatusTCP(e->ipid, &e->sr);
t = _toolErr;
if (t) terr = t;
e->terr = terr;
DecBusy();
if (e->sr.srState == TCPSLISTEN)
{
// for a listen socket, "read" means "accept".
switch (flag)
{
case 0:
if (e->sr.srAcceptCount)
*(int *)p3 = 1;
break;
}
}
else
{
switch (flag)
{
case 0:
// readable.
*(int *)p3 = readable(e);
break;
case 1:
// writable.
*(int *)p3 = writable(e);
break;
case 2:
// exception.
*(int *)p3 = exceptable(e);
break;
}
}
return 0;
}