Commit bbb092e0daf19cba598583ee4bab43aaced53a89
2012-10-02T09:08:47
Make the stratum recv buffer larger than the recvsize.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40
diff --git a/util.c b/util.c
index 89d7a0f..0afd6fb 100644
--- a/util.c
+++ b/util.c
@@ -887,7 +887,7 @@ out_unlock:
return ret;;
}
-#define RECVSIZE 8192
+#define RECVSIZE 8191
static void clear_sock(SOCKETTYPE sock)
{
@@ -921,7 +921,7 @@ char *recv_line(SOCKETTYPE sock)
char *sret = NULL, *s, c;
ssize_t offset = 0;
- s = alloca(RECVSIZE);
+ s = alloca(RECVSIZE + 1);
if (SOCKETFAIL(recv(sock, s, RECVSIZE, MSG_PEEK))) {
applog(LOG_DEBUG, "Failed to recv sock in recv_line");
goto out;
@@ -1136,7 +1136,7 @@ bool auth_stratum(struct pool *pool)
json_error_t err;
bool ret = false;
- s = alloca(RECVSIZE);
+ s = alloca(RECVSIZE + 1);
sprintf(s, "{\"id\": %d, \"method\": \"mining.authorize\", \"params\": [\"%s\", \"%s\"]}",
swork_id++, pool->rpc_user, pool->rpc_pass);
@@ -1196,7 +1196,7 @@ bool initiate_stratum(struct pool *pool)
if (pool->stratum_active)
return true;
- s = alloca(RECVSIZE);
+ s = alloca(RECVSIZE + 1);
sprintf(s, "{\"id\": %d, \"method\": \"mining.subscribe\", \"params\": []}", swork_id++);
pool->sock = socket(AF_INET, SOCK_STREAM, 0);