mirror of
https://libwebsockets.org/repo/libwebsockets
synced 2024-12-04 22:07:14 +00:00
72 lines
1.6 KiB
C
72 lines
1.6 KiB
C
/*
|
|
* pico-sspc-binance
|
|
*
|
|
* Written in 2010 - 2021 by Andy Green <andy@warmcat.com>
|
|
*
|
|
* This file is made available under the Creative Commons CC0 1.0
|
|
* Universal Public Domain Dedication.
|
|
*
|
|
* The SS user struct for the "GET" stream... it reads from
|
|
* https://libwebsockets.org/index.html every 5s
|
|
*/
|
|
|
|
#include "private.h"
|
|
|
|
LWS_SS_USER_TYPEDEF
|
|
lws_sorted_usec_list_t sul5;
|
|
} get_t;
|
|
|
|
static void
|
|
sul_start_get(lws_sorted_usec_list_t *sul)
|
|
{
|
|
get_t *g = lws_container_of(sul, get_t, sul5);
|
|
|
|
lws_ss_request_tx(lws_ss_from_user(g));
|
|
lws_sul_schedule(lws_ss_cx_from_user(g), 0, sul, sul_start_get,
|
|
5 * LWS_US_PER_SEC);
|
|
}
|
|
|
|
static lws_ss_state_return_t
|
|
get_rx(void *userobj, const uint8_t *in, size_t len, int flags)
|
|
{
|
|
get_t *g = (get_t *)userobj;
|
|
|
|
lwsl_ss_notice(lws_ss_from_user(g), "RX %u, flags 0x%x",
|
|
(unsigned int)len, (unsigned int)flags);
|
|
|
|
if (len) {
|
|
lwsl_hexdump_notice(in, 16);
|
|
if (len >= 16)
|
|
lwsl_hexdump_notice(in + len - 16, 16);
|
|
}
|
|
|
|
return LWSSSSRET_OK;
|
|
}
|
|
|
|
static lws_ss_state_return_t
|
|
get_state(void *userobj, void *h_src, lws_ss_constate_t state,
|
|
lws_ss_tx_ordinal_t ack)
|
|
{
|
|
get_t *g = (get_t *)userobj;
|
|
|
|
lwsl_ss_notice(lws_ss_from_user(g), "%s (%d), ord 0x%x",
|
|
lws_ss_state_name((int)state), state, (unsigned int)ack);
|
|
|
|
switch (state) {
|
|
case LWSSSCS_CREATING:
|
|
lws_sul_schedule(lws_ss_cx_from_user(g), 0, &g->sul5,
|
|
sul_start_get, 5 * LWS_US_PER_SEC);
|
|
break;
|
|
case LWSSSCS_DESTROYING:
|
|
lws_sul_cancel(&g->sul5);
|
|
break;
|
|
}
|
|
|
|
return LWSSSSRET_OK;
|
|
}
|
|
|
|
LWS_SS_INFO("mintest-lws", get_t)
|
|
.rx = get_rx,
|
|
.state = get_state,
|
|
};
|