diff --git a/src/user.c b/src/user.c index d4e1a05..cbc990f 100644 --- a/src/user.c +++ b/src/user.c @@ -333,7 +333,9 @@ int user_is_registered(struct user* user) void user_net_io_want_write(struct user* user) { +#ifdef DEBUG_SENDQ hub_log(log_trace, "user_net_io_want_write: %s", user_log_str(user)); +#endif if (user && user->net.ev_write) { event_add(user->net.ev_write, 0); @@ -342,8 +344,9 @@ void user_net_io_want_write(struct user* user) void user_net_io_want_read(struct user* user, int timeout_s) { +#ifdef DEBUG_SENDQ hub_log(log_trace, "user_net_io_want_read: %s", user_log_str(user)); - +#endif struct timeval timeout = { timeout_s, 0 }; if (user && user->net.ev_read) { @@ -351,4 +354,14 @@ void user_net_io_want_read(struct user* user, int timeout_s) } } +void user_reset_last_write(struct user* user) +{ + user->net.tm_last_write = time(NULL); +} + +void user_reset_last_read(struct user* user) +{ + user->net.tm_last_read = time(NULL); +} + diff --git a/src/user.h b/src/user.h index e58f3c0..a15ab53 100644 --- a/src/user.h +++ b/src/user.h @@ -283,7 +283,15 @@ extern void user_net_io_want_write(struct user* user); */ extern void user_net_io_want_read(struct user* user, int timeout_s); +/** + * Reset the last-write timer. + */ +extern void user_reset_last_write(struct user* user); +/** + * Reset the last-write timer. + */ +extern void user_reset_last_read(struct user* user); #endif /* HAVE_UHUB_USER_H */