Lines Matching refs:client
21 int mqtt_client_tcp_connect(struct mqtt_client *client) in mqtt_client_tcp_connect() argument
23 const struct sockaddr *broker = client->broker; in mqtt_client_tcp_connect()
26 client->transport.tcp.sock = zsock_socket(broker->sa_family, SOCK_STREAM, in mqtt_client_tcp_connect()
28 if (client->transport.tcp.sock < 0) { in mqtt_client_tcp_connect()
32 NET_DBG("Created socket %d", client->transport.tcp.sock); in mqtt_client_tcp_connect()
34 if (client->transport.if_name != NULL) { in mqtt_client_tcp_connect()
37 strncpy(ifname.ifr_name, client->transport.if_name, in mqtt_client_tcp_connect()
40 ret = zsock_setsockopt(client->transport.tcp.sock, SOL_SOCKET, in mqtt_client_tcp_connect()
53 if (client->transport.proxy.addrlen != 0) { in mqtt_client_tcp_connect()
54 ret = setsockopt(client->transport.tcp.sock, in mqtt_client_tcp_connect()
56 &client->transport.proxy.addr, in mqtt_client_tcp_connect()
57 client->transport.proxy.addrlen); in mqtt_client_tcp_connect()
70 ret = zsock_connect(client->transport.tcp.sock, client->broker, in mqtt_client_tcp_connect()
80 (void)zsock_close(client->transport.tcp.sock); in mqtt_client_tcp_connect()
84 int mqtt_client_tcp_write(struct mqtt_client *client, const uint8_t *data, in mqtt_client_tcp_write() argument
91 ret = zsock_send(client->transport.tcp.sock, data + offset, in mqtt_client_tcp_write()
103 int mqtt_client_tcp_write_msg(struct mqtt_client *client, in mqtt_client_tcp_write_msg() argument
116 ret = zsock_sendmsg(client->transport.tcp.sock, message, 0); in mqtt_client_tcp_write_msg()
143 int mqtt_client_tcp_read(struct mqtt_client *client, uint8_t *data, uint32_t buflen, in mqtt_client_tcp_read() argument
153 ret = zsock_recv(client->transport.tcp.sock, data, buflen, flags); in mqtt_client_tcp_read()
161 int mqtt_client_tcp_disconnect(struct mqtt_client *client) in mqtt_client_tcp_disconnect() argument
165 NET_INFO("Closing socket %d", client->transport.tcp.sock); in mqtt_client_tcp_disconnect()
167 ret = zsock_close(client->transport.tcp.sock); in mqtt_client_tcp_disconnect()