linse/sics
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SICS-595: Added "busy" checks to the callbacks used by asynnet.c:anetRead()

Browse Source
This commit is contained in:
Ferdi Franceschini
2013-04-27 18:00:36 +10:00
parent c6f1dd6591
commit 44579ee8aa
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
nread.c
View File

@ -1075,8 +1075,10 @@ static int CommandDataCB(int handle, void *userData)
if (pPtr[i] == '\r' || pPtr[i] == '\n') { if (pPtr[i] == '\r' || pPtr[i] == '\n') {
self->state = SKIPTERM; self->state = SKIPTERM;
if (!testAndInvokeInterrupt(self, handle)) { if (!testAndInvokeInterrupt(self, handle)) {
status = if (self->pCon->iProtocolID == 0 && CostaLocked(self->pCon->pStack))
CostaTop(self->pCon->pStack, GetCharArray(self->command)); status = 0;
else
status = CostaTop(self->pCon->pStack, GetCharArray(self->command));
if (!status) { if (!status) {
SCWrite(self->pCon, "ERROR: Busy", eError); SCWrite(self->pCon, "ERROR: Busy", eError);
} }
@ -1174,8 +1176,10 @@ static int ANETTelnetProcess(int handle, void *usData)
case '\r': case '\r':
case '\n': case '\n':
if (!testAndInvokeInterrupt(self, handle)) { if (!testAndInvokeInterrupt(self, handle)) {
status = if (self->pCon->iProtocolID == 0 && CostaLocked(self->pCon->pStack))
CostaTop(self->pCon->pStack, GetCharArray(self->command)); status = 0;
else
status = CostaTop(self->pCon->pStack, GetCharArray(self->command));
if (!status) { if (!status) {
SCWrite(self->pCon, "ERROR: Busy", eError); SCWrite(self->pCon, "ERROR: Busy", eError);
} }