Lines Matching defs:wsi
45 lws_mqtt_generate_id(struct lws* wsi, lws_mqtt_str_t **ms, const char *client_id)
47 struct lws_context *context = wsi->a.context;
91 lws_read_mqtt(struct lws *wsi, unsigned char *buf, lws_filepos_t len)
93 lws_mqttc_t *c = &wsi->mqtt->client;
95 return _lws_mqtt_rx_parser(wsi, &c->par, buf, (size_t)len);
100 struct lws *wsi)
105 /* allocate the ws struct for the wsi */
106 wsi->mqtt = lws_zalloc(sizeof(*wsi->mqtt), "client mqtt struct");
107 if (!wsi->mqtt)
110 wsi->mqtt->wsi = wsi;
111 c = &wsi->mqtt->client;
113 if (lws_mqtt_generate_id(wsi, &c->id, cp->client_id)) {
187 lws_mqtt_client_socket_service(struct lws *wsi, struct lws_pollfd *pollfd,
190 struct lws_context *context = wsi->a.context;
191 struct lws_context_per_thread *pt = &context->pt[(int)wsi->tsi];
201 switch (lwsi_state(wsi)) {
208 switch (lws_socks5c_handle_state(wsi, pollfd, &cce)) {
220 if (!(wsi->tls.use_ssl & LCCSCF_USE_SSL))
223 switch (lws_client_create_tls(wsi, &cce, 0)) {
244 if (!lws_client_connect_2_dnsreq(wsi)) {
260 lws_client_connect_3_connect(wsi, NULL, NULL, 0, NULL);
266 if (wsi->tls.use_ssl & LCCSCF_USE_SSL) {
267 n = lws_ssl_client_connect2(wsi, erbuf, sizeof(erbuf));
275 wsi->tls.ssl = NULL;
283 lwsi_set_state(wsi, LRS_MQTTC_IDLE);
284 lws_set_timeout(wsi, PENDING_TIMEOUT_AWAITING_CLIENT_HS_SEND,
294 __func__, lws_wsi_tag(wsi));
295 if (lws_change_pollfd(wsi, LWS_POLLOUT, 0))
297 if (!lws_mqtt_client_send_connect(wsi)) {
301 if (lws_change_pollfd(wsi, 0, LWS_POLLIN))
304 lwsi_set_state(wsi, LRS_MQTTC_AWAIT_CONNACK);
311 ebuf.len = (int)wsi->a.context->pt_serv_buf_size;
313 if ((unsigned int)ebuf.len > wsi->a.context->pt_serv_buf_size)
314 ebuf.len = (int)wsi->a.context->pt_serv_buf_size;
319 ebuf.len = lws_ssl_capable_read(wsi, ebuf.token,
339 n = lws_read_mqtt(wsi, ebuf.token, (unsigned int)ebuf.len);
346 // lws_buflist_describe(&wsi->buflist, wsi, __func__);
348 if (lws_buflist_aware_finished_consuming(wsi, &ebuf, m,
361 lws_inform_client_conn_fail(wsi, (void *)cce, strlen(cce));
363 lws_close_free_wsi(wsi, LWS_CLOSE_STATUS_NOSTATUS, "cbail3");
372 lws_close_free_wsi(wsi, LWS_CLOSE_STATUS_NOSTATUS, "mqtt svc fail");