| 1 | /* |
| 2 | * libwebsockets - small server side websockets and web server implementation |
| 3 | * |
| 4 | * Copyright (C) 2010 - 2019 Andy Green <andy@warmcat.com> |
| 5 | * |
| 6 | * Permission is hereby granted, free of charge, to any person obtaining a copy |
| 7 | * of this software and associated documentation files (the "Software"), to |
| 8 | * deal in the Software without restriction, including without limitation the |
| 9 | * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or |
| 10 | * sell copies of the Software, and to permit persons to whom the Software is |
| 11 | * furnished to do so, subject to the following conditions: |
| 12 | * |
| 13 | * The above copyright notice and this permission notice shall be included in |
| 14 | * all copies or substantial portions of the Software. |
| 15 | * |
| 16 | * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
| 17 | * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, |
| 18 | * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE |
| 19 | * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER |
| 20 | * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING |
| 21 | * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS |
| 22 | * IN THE SOFTWARE. |
| 23 | */ |
| 24 | |
| 25 | typedef struct lws_retry_bo { |
| 26 | const uint32_t *retry_ms_table; /* base delay in ms */ |
| 27 | uint16_t retry_ms_table_count; /* entries in table */ |
| 28 | uint16_t conceal_count; /* max retries to conceal */ |
| 29 | uint16_t secs_since_valid_ping; /* idle before PING issued */ |
| 30 | uint16_t secs_since_valid_hangup; /* idle before hangup conn */ |
| 31 | uint8_t jitter_percent; /* % additional random jitter */ |
| 32 | } lws_retry_bo_t; |
| 33 | |
| 34 | #define LWS_RETRY_CONCEAL_ALWAYS (0xffff) |
| 35 | |
| 36 | /** |
| 37 | * lws_retry_get_delay_ms() - get next delay from backoff table |
| 38 | * |
| 39 | * \param lws_context: the lws context (used for getting random) |
| 40 | * \param retry: the retry backoff table we are using, or NULL for default |
| 41 | * \param ctry: pointer to the try counter |
| 42 | * \param conceal: pointer to flag set to nonzero if the try should be concealed |
| 43 | * in terms of creating an error |
| 44 | * |
| 45 | * Increments *\p try and retruns the number of ms that should elapse before the |
| 46 | * next connection retry, according to the backoff table \p retry. *\p conceal is |
| 47 | * set if the number of tries is less than the backoff table conceal_count, or |
| 48 | * is zero if it exceeded it. This lets you conceal a certain number of retries |
| 49 | * before alerting the caller there is a problem. |
| 50 | * |
| 51 | * If \p retry is NULL, a default of 3s + (0..300ms jitter) is used. If it's |
| 52 | * non-NULL but jitter_percent is 0, the default of 30% jitter is retained. |
| 53 | */ |
| 54 | |
| 55 | LWS_VISIBLE LWS_EXTERN unsigned int |
| 56 | lws_retry_get_delay_ms(struct lws_context *context, const lws_retry_bo_t *retry, |
| 57 | uint16_t *ctry, char *conceal); |
| 58 | |
| 59 | /** |
| 60 | * lws_retry_sul_schedule() - schedule a sul according to the backoff table |
| 61 | * |
| 62 | * \param lws_context: the lws context (used for getting random) |
| 63 | * \param sul: pointer to the sul to schedule |
| 64 | * \param retry: the retry backoff table we are using, or NULL for default |
| 65 | * \param cb: the callback for when the sul schedule time arrives |
| 66 | * \param ctry: pointer to the try counter |
| 67 | * |
| 68 | * Helper that combines interpreting the retry table with scheduling a sul to |
| 69 | * the computed delay. If conceal is not set, it will not schedule the sul |
| 70 | * and just return 1. Otherwise the sul is scheduled and it returns 0. |
| 71 | */ |
| 72 | LWS_VISIBLE LWS_EXTERN int |
| 73 | lws_retry_sul_schedule(struct lws_context *context, int tid, |
| 74 | lws_sorted_usec_list_t *sul, const lws_retry_bo_t *retry, |
| 75 | sul_cb_t cb, uint16_t *ctry); |
| 76 | |
| 77 | /** |
| 78 | * lws_retry_sul_schedule_retry_wsi() - retry sul schedule helper using wsi |
| 79 | * |
| 80 | * \param wsi: the wsi to set the hrtimer sul on to the next retry interval |
| 81 | * \param sul: pointer to the sul to schedule |
| 82 | * \param cb: the callback for when the sul schedule time arrives |
| 83 | * \param ctry: pointer to the try counter |
| 84 | * |
| 85 | * Helper that uses context, tid and retry policy from a wsi to call |
| 86 | * lws_retry_sul_schedule. |
| 87 | * |
| 88 | * Since a udp connection can have many writes in flight, the retry count and |
| 89 | * the sul used to track each thing that wants to be written have to be handled |
| 90 | * individually, not the wsi. But the retry policy and the other things can |
| 91 | * be filled in from the wsi conveniently. |
| 92 | */ |
| 93 | LWS_VISIBLE LWS_EXTERN int |
| 94 | lws_retry_sul_schedule_retry_wsi(struct lws *wsi, lws_sorted_usec_list_t *sul, |
| 95 | sul_cb_t cb, uint16_t *ctry); |
| 96 | |