Debug for send queue fix.
This commit is contained in:
parent
61d639bfa2
commit
0ec4913e15
@ -36,16 +36,16 @@ void debug_sendq_send(struct user* user, int sent, int total)
|
|||||||
|
|
||||||
void debug_sendq_recv(struct user* user, int received, int max, const char* buffer)
|
void debug_sendq_recv(struct user* user, int received, int max, const char* buffer)
|
||||||
{
|
{
|
||||||
printf("RECV: %d/%d bytes\n", ret, (int) len);
|
printf("RECV: %d/%d bytes\n", received, (int) max);
|
||||||
if (ret == -1)
|
if (received == -1)
|
||||||
{
|
{
|
||||||
int err = net_error();
|
int err = net_error();
|
||||||
printf(" errno: %d - %s\n", err, net_error_string(err));
|
printf(" errno: %d - %s\n", err, net_error_string(err));
|
||||||
}
|
}
|
||||||
else if (ret > 0)
|
else if (received > 0)
|
||||||
{
|
{
|
||||||
char* data = hub_malloc_zero(ret + 1);
|
char* data = hub_malloc_zero(received + 1);
|
||||||
memcpy(data, buf, ret);
|
memcpy(data, buffer, received);
|
||||||
printf("RECV: \"%s\"\n", data);
|
printf("RECV: \"%s\"\n", data);
|
||||||
hub_free(data);
|
hub_free(data);
|
||||||
}
|
}
|
||||||
|
@ -331,7 +331,7 @@ int user_is_registered(struct user* user)
|
|||||||
void user_net_io_want_write(struct user* user)
|
void user_net_io_want_write(struct user* user)
|
||||||
{
|
{
|
||||||
#ifdef DEBUG_SENDQ
|
#ifdef DEBUG_SENDQ
|
||||||
hub_log(log_trace, "user_net_io_want_write: %s", user_log_str(user));
|
hub_log(log_trace, "user_net_io_want_write: %s (pending: %d)", user_log_str(user), event_pending(&user->net.event, EV_READ | EV_WRITE, 0));
|
||||||
#endif
|
#endif
|
||||||
if (user->net.events == (EV_READ | EV_WRITE))
|
if (user->net.events == (EV_READ | EV_WRITE))
|
||||||
return;
|
return;
|
||||||
@ -344,7 +344,7 @@ void user_net_io_want_write(struct user* user)
|
|||||||
void user_net_io_want_read(struct user* user)
|
void user_net_io_want_read(struct user* user)
|
||||||
{
|
{
|
||||||
#ifdef DEBUG_SENDQ
|
#ifdef DEBUG_SENDQ
|
||||||
hub_log(log_trace, "user_net_io_want_read: %s", user_log_str(user));
|
hub_log(log_trace, "user_net_io_want_read: %s (pending: %d)", user_log_str(user), event_pending(&user->net.event, EV_READ | EV_WRITE, 0));
|
||||||
#endif
|
#endif
|
||||||
if (user->net.events == EV_READ)
|
if (user->net.events == EV_READ)
|
||||||
return;
|
return;
|
||||||
|
Loading…
Reference in New Issue
Block a user