lws-timeout-timer.h

/*
 * libwebsockets - small server side websockets and web server implementation
 *
 * Copyright (C) 2010-2018 Andy Green <andy@warmcat.com>
 *
 *  This library is free software; you can redistribute it and/or
 *  modify it under the terms of the GNU Lesser General Public
 *  License as published by the Free Software Foundation:
 *  version 2.1 of the License.
 *
 *  This library is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 *  Lesser General Public License for more details.
 *
 *  You should have received a copy of the GNU Lesser General Public
 *  License along with this library; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
 *  MA  02110-1301  USA
 *
 * included from libwebsockets.h
 */
 
 
/*
 * NOTE: These public enums are part of the abi.  If you want to add one,
 * add it at where specified so existing users are unaffected.
 */
enum pending_timeout {
        NO_PENDING_TIMEOUT                                      =  0,
        PENDING_TIMEOUT_AWAITING_PROXY_RESPONSE                 =  1,
        PENDING_TIMEOUT_AWAITING_CONNECT_RESPONSE               =  2,
        PENDING_TIMEOUT_ESTABLISH_WITH_SERVER                   =  3,
        PENDING_TIMEOUT_AWAITING_SERVER_RESPONSE                =  4,
        PENDING_TIMEOUT_AWAITING_PING                           =  5,
        PENDING_TIMEOUT_CLOSE_ACK                               =  6,
        PENDING_TIMEOUT_UNUSED1                                 =  7,
        PENDING_TIMEOUT_SENT_CLIENT_HANDSHAKE                   =  8,
        PENDING_TIMEOUT_SSL_ACCEPT                              =  9,
        PENDING_TIMEOUT_HTTP_CONTENT                            = 10,
        PENDING_TIMEOUT_AWAITING_CLIENT_HS_SEND                 = 11,
        PENDING_FLUSH_STORED_SEND_BEFORE_CLOSE                  = 12,
        PENDING_TIMEOUT_SHUTDOWN_FLUSH                          = 13,
        PENDING_TIMEOUT_CGI                                     = 14,
        PENDING_TIMEOUT_HTTP_KEEPALIVE_IDLE                     = 15,
        PENDING_TIMEOUT_WS_PONG_CHECK_SEND_PING                 = 16,
        PENDING_TIMEOUT_WS_PONG_CHECK_GET_PONG                  = 17,
        PENDING_TIMEOUT_CLIENT_ISSUE_PAYLOAD                    = 18,
        PENDING_TIMEOUT_AWAITING_SOCKS_GREETING_REPLY           = 19,
        PENDING_TIMEOUT_AWAITING_SOCKS_CONNECT_REPLY            = 20,
        PENDING_TIMEOUT_AWAITING_SOCKS_AUTH_REPLY               = 21,
        PENDING_TIMEOUT_KILLED_BY_SSL_INFO                      = 22,
        PENDING_TIMEOUT_KILLED_BY_PARENT                        = 23,
        PENDING_TIMEOUT_CLOSE_SEND                              = 24,
        PENDING_TIMEOUT_HOLDING_AH                              = 25,
        PENDING_TIMEOUT_UDP_IDLE                                = 26,
        PENDING_TIMEOUT_CLIENT_CONN_IDLE                        = 27,
        PENDING_TIMEOUT_LAGGING                                 = 28,
        PENDING_TIMEOUT_THREADPOOL                              = 29,
        PENDING_TIMEOUT_THREADPOOL_TASK                         = 30,
        PENDING_TIMEOUT_KILLED_BY_PROXY_CLIENT_CLOSE            = 31,
        PENDING_TIMEOUT_USER_OK                                 = 32,
 
        /****** add new things just above ---^ ******/
 
        PENDING_TIMEOUT_USER_REASON_BASE                        = 1000
};
 
#define lws_time_in_microseconds lws_now_usecs
 
#define LWS_TO_KILL_ASYNC -1
#define LWS_TO_KILL_SYNC -2
LWS_VISIBLE LWS_EXTERN void
lws_set_timeout(struct lws *wsi, enum pending_timeout reason, int secs);
 
void
lws_set_timeout_us(struct lws *wsi, enum pending_timeout reason, lws_usec_t us);
 
#define LWS_SET_TIMER_USEC_CANCEL ((lws_usec_t)-1ll)
#define LWS_USEC_PER_SEC ((lws_usec_t)1000000)
 
LWS_VISIBLE LWS_EXTERN void
lws_set_timer_usecs(struct lws *wsi, lws_usec_t usecs);
 
/*
 * lws_timed_callback_vh_protocol() - calls back a protocol on a vhost after
 *                                      the specified delay in seconds
 *
 * \param vh:    the vhost to call back
 * \param protocol: the protocol to call back
 * \param reason: callback reason
 * \param secs: how many seconds in the future to do the callback.
 *
 * Callback the specified protocol with a fake wsi pointing to the specified
 * vhost and protocol, with the specified reason, at the specified time in the
 * future.
 *
 * Returns 0 if OK or 1 on OOM.
 *
 * In the multithreaded service case, the callback will occur in the same
 * service thread context as the call to this api that requested it.  If it is
 * called from a non-service thread, tsi 0 will handle it.
 */
LWS_VISIBLE LWS_EXTERN int
lws_timed_callback_vh_protocol(struct lws_vhost *vh,
                               const struct lws_protocols *prot,
                               int reason, int secs);
 
/*
 * lws_timed_callback_vh_protocol_us() - calls back a protocol on a vhost after
 *                                       the specified delay in us
 *
 * \param vh:    the vhost to call back
 * \param protocol: the protocol to call back
 * \param reason: callback reason
 * \param us:   how many us in the future to do the callback.
 *
 * Callback the specified protocol with a fake wsi pointing to the specified
 * vhost and protocol, with the specified reason, at the specified time in the
 * future.
 *
 * Returns 0 if OK or 1 on OOM.
 *
 * In the multithreaded service case, the callback will occur in the same
 * service thread context as the call to this api that requested it.  If it is
 * called from a non-service thread, tsi 0 will handle it.
 */
LWS_VISIBLE LWS_EXTERN int
lws_timed_callback_vh_protocol_us(struct lws_vhost *vh,
                                  const struct lws_protocols *prot, int reason,
                                  lws_usec_t us);
 
 
typedef void (*sul_cb_t)(lws_sorted_usec_list_t *sul);
 
struct lws_sorted_usec_list {
        struct lws_dll2 list;   /* simplify the code by keeping this at start */
        sul_cb_t        cb;
        lws_usec_t      us;
};
 
 
/*
 * lws_sul_schedule() - schedule a callback
 *
 * \param context: the lws_context
 * \param tsi: the thread service index (usually 0)
 * \param sul: pointer to the sul element
 * \param cb: the scheduled callback
 * \param us: the delay before the callback arrives, or
 *              LWS_SET_TIMER_USEC_CANCEL to cancel it.
 *
 * Generic callback-at-a-later time function.  The callback happens on the
 * event loop thread context.
 *
 * Although the api has us resultion, the actual resolution depends on the
 * platform and is commonly 1ms.
 *
 * This doesn't allocate and doesn't fail.
 *
 * You can call it again with another us value to change the delay.
 */
LWS_VISIBLE LWS_EXTERN void
lws_sul_schedule(struct lws_context *context, int tsi,
                 lws_sorted_usec_list_t *sul, sul_cb_t cb, lws_usec_t us);