GOSTSec/ccminer
1
0
Fork 0
mirror of https://github.com/GOSTSec/ccminer synced 2025-01-28 15:34:22 +00:00
Code Issues Releases Wiki Activity

api: better compat with telnet + help command

Browse Source 
handle "\r\n" and terminate connection if command is not known
This commit is contained in:
Tanguy Pruvot 2014-11-14 01:24:10 +01:00
parent 63eb163e32
commit e139736a2f
1 changed files with 33 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
api.cpp
View File

@ -58,7 +58,7 @@
# define INVSOCK INVALID_SOCKET # define INVSOCK INVALID_SOCKET
# define INVINETADDR INADDR_NONE # define INVINETADDR INADDR_NONE
# define CLOSESOCKET closesocket # define CLOSESOCKET closesocket
#define in_addr_t uint32_t # define in_addr_t uint32_t
#endif #endif
#define GROUP(g) (toupper(g)) #define GROUP(g) (toupper(g))
@ -88,6 +88,8 @@ static struct IP4ACCESS *ipaccess = NULL;
// Current code assumes it can socket send this size also // Current code assumes it can socket send this size also
#define MYBUFSIZ 16384 #define MYBUFSIZ 16384
#define SOCK_REC_BUFSZ 256
// Socket is on 127.0.0.1 // Socket is on 127.0.0.1
#define QUEUE 10 #define QUEUE 10
@ -184,27 +186,37 @@ static char *getstats(char *params)
return buffer; return buffer;
} }
static char *gethelp(char *params);
struct CMDS { struct CMDS {
const char *name; const char *name;
char *(*func)(char *); char *(*func)(char *);
} cmds[] = { } cmds[] = {
{ "summary", getsummary }, { "summary", getsummary },
{ "stats", getstats }, { "stats", getstats },
/* keep it the last */
{ "help", gethelp },
}; };
#define CMDMAX ARRAY_SIZE(cmds)
static char *gethelp(char *params)
{
*buffer = '\0';
char * p = buffer;
for (int i = 0; i < CMDMAX-1; i++)
p += sprintf(p, "%s\n", cmds[i].name);
return buffer;
}
#define CMDMAX 2
static int send_result(SOCKETTYPE c, char *result) static int send_result(SOCKETTYPE c, char *result)
{ {
int n; int n;
if (!result) { if (!result) {
n = send(c, "", 1, 0); n = send(c, "", 1, 0);
} else { } else {
// ignore failure - it's closed immediately anyway // ignore failure - it's closed immediately anyway
n = send(c, result, strlen(result) + 1, 0); n = send(c, result, strlen(result) + 1, 0);
} }
return n; return n;
} }
@ -440,15 +452,27 @@ static void api()
} }
addrok = check_connect(&cli, &connectaddr, &group); addrok = check_connect(&cli, &connectaddr, &group);
if (opt_protocol) if (opt_debug && opt_protocol)
applog(LOG_DEBUG, "API: connection from %s - %s", applog(LOG_DEBUG, "API: connection from %s - %s",
connectaddr, addrok ? "Accepted" : "Ignored"); connectaddr, addrok ? "Accepted" : "Ignored");
if (addrok) { if (addrok) {
n = recv(c, &buf[0], MYBUFSIZ - 1, 0); n = recv(c, &buf[0], SOCK_REC_BUFSZ, 0);
// applog(LOG_DEBUG, "API: recv command: (%d) '%s'", n, buf);
if (SOCKETFAIL(n))
buf[0] = '\0';
else if (n > 0 && buf[n-1] == '\n') {
/* telnet compat \r\n */
buf[n-1] = '\0'; n--;
if (n > 0 && buf[n-1] == '\r')
buf[n-1] = '\0';
}
buf[n] = '\0';
if (opt_debug && opt_protocol)
applog(LOG_DEBUG, "API: recv command: (%d) '%s'+char(%x)", n, buf, buf[n-1]);
if (!SOCKETFAIL(n)) { if (!SOCKETFAIL(n)) {
buf[n] = '\0';
params = strchr(buf, '|'); params = strchr(buf, '|');
if (params != NULL) if (params != NULL)
*(params++) = '\0'; *(params++) = '\0';
@ -457,10 +481,10 @@ static void api()
if (strcmp(buf, cmds[i].name) == 0) { if (strcmp(buf, cmds[i].name) == 0) {
result = (cmds[i].func)(params); result = (cmds[i].func)(params);
send_result(c, result); send_result(c, result);
CLOSESOCKET(c);
break; break;
} }
} }
CLOSESOCKET(c);
} }
} }
} }