Lines Matching full:client

24 int mqtt_client_websocket_connect(struct mqtt_client *client)  in mqtt_client_websocket_connect()  argument
33 if (client->transport.type == MQTT_TRANSPORT_NON_SECURE_WEBSOCKET) { in mqtt_client_websocket_connect()
34 ret = mqtt_client_tcp_connect(client); in mqtt_client_websocket_connect()
39 transport_sock = client->transport.tcp.sock; in mqtt_client_websocket_connect()
42 else if (client->transport.type == MQTT_TRANSPORT_SECURE_WEBSOCKET) { in mqtt_client_websocket_connect()
43 ret = mqtt_client_tls_connect(client); in mqtt_client_websocket_connect()
48 transport_sock = client->transport.tls.sock; in mqtt_client_websocket_connect()
55 if (client->transport.websocket.config.url == NULL) { in mqtt_client_websocket_connect()
56 client->transport.websocket.config.url = "/mqtt"; in mqtt_client_websocket_connect()
59 if (client->transport.websocket.config.host == NULL) { in mqtt_client_websocket_connect()
60 client->transport.websocket.config.host = "localhost"; in mqtt_client_websocket_connect()
69 client->transport.websocket.config.optional_headers = extra_headers; in mqtt_client_websocket_connect()
71 client->transport.websocket.sock = websocket_connect( in mqtt_client_websocket_connect()
73 &client->transport.websocket.config, in mqtt_client_websocket_connect()
74 client->transport.websocket.timeout, in mqtt_client_websocket_connect()
76 if (client->transport.websocket.sock < 0) { in mqtt_client_websocket_connect()
78 client->transport.websocket.sock); in mqtt_client_websocket_connect()
81 return client->transport.websocket.sock; in mqtt_client_websocket_connect()
89 int mqtt_client_websocket_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_websocket_write() argument
96 ret = websocket_send_msg(client->transport.websocket.sock, in mqtt_client_websocket_write()
110 int mqtt_client_websocket_write_msg(struct mqtt_client *client, in mqtt_client_websocket_write_msg() argument
125 ret = websocket_send_msg(client->transport.websocket.sock, in mqtt_client_websocket_write_msg()
140 int mqtt_client_websocket_read(struct mqtt_client *client, uint8_t *data, in mqtt_client_websocket_read() argument
151 ret = websocket_recv_msg(client->transport.websocket.sock, in mqtt_client_websocket_read()
169 int mqtt_client_websocket_disconnect(struct mqtt_client *client) in mqtt_client_websocket_disconnect() argument
173 NET_INFO("Closing socket %d", client->transport.websocket.sock); in mqtt_client_websocket_disconnect()
175 ret = websocket_disconnect(client->transport.websocket.sock); in mqtt_client_websocket_disconnect()
180 if (client->transport.type == MQTT_TRANSPORT_NON_SECURE_WEBSOCKET) { in mqtt_client_websocket_disconnect()
181 ret = mqtt_client_tcp_disconnect(client); in mqtt_client_websocket_disconnect()
184 else if (client->transport.type == MQTT_TRANSPORT_SECURE_WEBSOCKET) { in mqtt_client_websocket_disconnect()
185 ret = mqtt_client_tls_disconnect(client); in mqtt_client_websocket_disconnect()