|
|
@ -1085,10 +1085,10 @@ char *recv_line(struct pool *pool) |
|
|
|
{ |
|
|
|
{ |
|
|
|
ssize_t len, buflen; |
|
|
|
ssize_t len, buflen; |
|
|
|
char *tok, *sret = NULL; |
|
|
|
char *tok, *sret = NULL; |
|
|
|
|
|
|
|
struct timeval rstart, now; |
|
|
|
|
|
|
|
|
|
|
|
if (!strstr(pool->sockbuf, "\n")) { |
|
|
|
if (!strstr(pool->sockbuf, "\n")) { |
|
|
|
enum recv_ret ret = RECV_OK; |
|
|
|
enum recv_ret ret = RECV_OK; |
|
|
|
struct timeval rstart, now; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cgtime(&rstart); |
|
|
|
cgtime(&rstart); |
|
|
|
if (!socket_full(pool, true)) { |
|
|
|
if (!socket_full(pool, true)) { |
|
|
@ -1138,6 +1138,9 @@ char *recv_line(struct pool *pool) |
|
|
|
tok = strtok(pool->sockbuf, "\n"); |
|
|
|
tok = strtok(pool->sockbuf, "\n"); |
|
|
|
if (!tok) { |
|
|
|
if (!tok) { |
|
|
|
applog(LOG_DEBUG, "Failed to parse a \\n terminated string in recv_line"); |
|
|
|
applog(LOG_DEBUG, "Failed to parse a \\n terminated string in recv_line"); |
|
|
|
|
|
|
|
applog(LOG_DEBUG, "sockbuf: %s", pool->sockbuf); |
|
|
|
|
|
|
|
applog(LOG_DEBUG, "Receive start time %d end time %d", |
|
|
|
|
|
|
|
rstart.tv_sec, now.tv_sec); |
|
|
|
goto out; |
|
|
|
goto out; |
|
|
|
} |
|
|
|
} |
|
|
|
sret = strdup(tok); |
|
|
|
sret = strdup(tok); |
|
|
|