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

Add asyncqueue 'transact' command and list the protocol

Browse Source
This commit is contained in:
Douglas Clowes
2014-08-26 13:30:39 +10:00
parent 3ff6377f85
commit ee40adceb2
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
asyncqueue.c
View File

@ -892,7 +892,7 @@ int AsyncQueueAction(SConnection * pCon, SicsInterp * pSics,
char line[132]; char line[132];
pAsyncQueue self = (pAsyncQueue) pData; pAsyncQueue self = (pAsyncQueue) pData;
if (argc > 1) { if (argc > 1) {
if (strcasecmp("send", argv[1]) == 0) { if (strcasecmp("send", argv[1]) == 0 || strcasecmp("transact", argv[1]) == 0) {
AsyncUnit myUnit; AsyncUnit myUnit;
char cmd[10240]; char cmd[10240];
char rsp[10240]; char rsp[10240];
@ -1117,6 +1117,8 @@ int AsyncQueueAction(SConnection * pCon, SicsInterp * pSics,
SCPrintf(pCon, eValue, "%s.trace = %d", argv[0], self->trace); SCPrintf(pCon, eValue, "%s.trace = %d", argv[0], self->trace);
if (self->noreply_text) if (self->noreply_text)
SCPrintf(pCon, eValue, "%s.noreply = %s", argv[0], self->noreply_text); SCPrintf(pCon, eValue, "%s.noreply = %s", argv[0], self->noreply_text);
if (self->protocol && self->protocol->protocolName)
SCPrintf(pCon, eValue, "%s.protocol = %s", argv[0], self->protocol->protocolName);
return OKOK; return OKOK;
} }
} }