diff options
| -rw-r--r-- | lib/conn.c | 36 | ||||
| -rw-r--r-- | lib/conn.h | 2 | 
2 files changed, 20 insertions, 18 deletions
| @@ -43,6 +43,25 @@ conn_user_dispatch_p (const struct rs_connection *conn)  	  conn->callbacks.sent_cb);  } + +int +conn_activate_timeout (struct rs_connection *conn) +{ +  assert (conn); +  assert (conn->tev); +  assert (conn->evb); +  if (conn->timeout.tv_sec || conn->timeout.tv_usec) +    { +      rs_debug (("%s: activating timer: %d.%d\n", __func__, +		 conn->timeout.tv_sec, conn->timeout.tv_usec)); +      if (evtimer_add (conn->tev, &conn->timeout)) +	return rs_err_conn_push_fl (conn, RSE_EVENT, __FILE__, __LINE__, +				    "evtimer_add: %d", errno); +    } +  return RSE_OK; +} + +/* Public functions. */  int  rs_conn_create (struct rs_context *ctx,  		struct rs_connection **conn, @@ -306,20 +325,3 @@ rs_conn_set_timeout(struct rs_connection *conn, struct timeval *tv)    assert (tv);    conn->timeout = *tv;  } - -int -conn_activate_timeout (struct rs_connection *conn) -{ -  assert (conn); -  assert (conn->tev); -  assert (conn->evb); -  if (conn->timeout.tv_sec || conn->timeout.tv_usec) -    { -      rs_debug (("%s: activating timer: %d.%d\n", __func__, -		 conn->timeout.tv_sec, conn->timeout.tv_usec)); -      if (evtimer_add (conn->tev, &conn->timeout)) -	return rs_err_conn_push_fl (conn, RSE_EVENT, __FILE__, __LINE__, -				    "evtimer_add: %d", errno); -    } -  return RSE_OK; -} @@ -1,6 +1,6 @@  /* Copyright 2011 NORDUnet A/S. All rights reserved.     See LICENSE for licensing information.  */ -int conn_user_dispatch_p (const struct rs_connection *conn);  int conn_close (struct rs_connection **connp); +int conn_user_dispatch_p (const struct rs_connection *conn);  int conn_activate_timeout (struct rs_connection *conn); | 
