Lines Matching defs:wsi
27 struct lws *wsi;
129 i.pwsi = &item->wsi;
196 callback_mqtt(struct lws *wsi, enum lws_callback_reasons reason,
199 struct test_item *item = (struct test_item *)lws_get_opaque_user_data(wsi);
214 lwsl_user("%s: item %d: CLIENT_CLOSED %p\n", __func__, (int)(item - &items[0]), wsi);
221 lwsl_user("%s: MQTT_CLIENT_ESTABLISHED: %p\n", __func__, wsi);
222 lws_callback_on_writable(wsi);
232 lws_callback_on_writable(wsi);
237 __func__, (int)(item - &item[0]), wsi);
258 lwsl_user("%s: item %d: WRITEABLE: %p: Subscribing\n", __func__, (int)(item - &items[0]), wsi);
260 if (lws_mqtt_client_send_subcribe(wsi, &sub_param)) {
271 lwsl_user("%s: item %d: WRITEABLE: %p: Publish\n", __func__, (int)(item - &items[0]), wsi);
290 if (lws_mqtt_client_send_publish(wsi, &pss->pub_param,
308 __func__, (int)(item - &item[0]), wsi);
310 if (lws_mqtt_client_send_unsubcribe(wsi, &sub_param)) {
326 * For our test, that's the indication we can close the wsi.
331 lws_callback_on_writable(wsi);
369 lws_cancel_service(lws_get_context(wsi));