Lines Matching refs:user_data

730 			struct client_data *user_data)  in create_uri()  argument
736 data[user_data->index].buf); in create_uri()
739 print_data(uri, data[user_data->index].len); in create_uri()
744 static coap_pdu_t *create_pdu(struct client_data *user_data) in create_pdu() argument
754 uri = create_uri(uri_buf, MAX_URI, target, user_data); in create_pdu()
762 if (data[user_data->index].data) { in create_pdu()
763 send_data = data[user_data->index].data; in create_pdu()
764 send_data_len = data[user_data->index].data_len; in create_pdu()
768 pdu = coap_new_request(user_data->coap_ctx, in create_pdu()
769 data[user_data->index].coap_method, in create_pdu()
772 data[user_data->index].message_type); in create_pdu()
774 if (data[user_data->index].check_mid) in create_pdu()
775 data[user_data->index].expected_mid = ntohs(pdu->hdr->id); in create_pdu()
782 static void send_packets(struct client_data *user_data) in send_packets() argument
789 data[user_data->index].description, in send_packets()
790 user_data->index, data[user_data->index].len); in send_packets()
792 test_context = user_data; in send_packets()
794 pdu = create_pdu(user_data); in send_packets()
798 user_data->fail = true; in send_packets()
803 method = data[user_data->index].coap_method; in send_packets()
811 tid = coap_send_confirmed(user_data->coap_ctx, in send_packets()
812 user_data->coap_ctx->endpoint, in send_packets()
813 &user_data->coap_dst, in send_packets()
816 tid = coap_send(user_data->coap_ctx, in send_packets()
817 user_data->coap_ctx->endpoint, in send_packets()
818 &user_data->coap_dst, in send_packets()
832 struct client_data *user_data = in try_send() local
839 data[user_data->index].description, in try_send()
840 user_data->index, data[user_data->index].len); in try_send()
842 test_context = user_data; in try_send()
844 pdu = create_pdu(user_data); in try_send()
848 user_data->fail = true; in try_send()
853 method = data[user_data->index].coap_method; in try_send()
861 tid = coap_send_confirmed(user_data->coap_ctx, in try_send()
862 user_data->coap_ctx->endpoint, in try_send()
863 &user_data->coap_dst, in try_send()
866 tid = coap_send(user_data->coap_ctx, in try_send()
867 user_data->coap_ctx->endpoint, in try_send()
868 &user_data->coap_dst, in try_send()
940 struct client_data *user_data = in read_from_peer() local
945 data[user_data->index].description, user_data->index, read_len); in read_from_peer()
951 if (dispatch_data(read_data, read_len, user_data->coap_ctx, in read_from_peer()
955 user_data->fail = true; in read_from_peer()
962 if (!data[user_data->index + 1].buf) { in read_from_peer()
968 if (user_data->index == renegotiate) { in read_from_peer()
993 struct client_data *user_data = in send_to_peer() local
1003 return sendto(user_data->fd, data, len, 0, in send_to_peer()
1009 struct client_data *user_data; in dtls_handle_read() local
1011 user_data = (struct client_data *)dtls_get_app_data(ctx); in dtls_handle_read()
1013 if (!user_data || !user_data->fd) in dtls_handle_read()
1018 user_data->len = recvfrom(user_data->fd, user_data->buf, MAX_READ_BUF, in dtls_handle_read()
1020 if (user_data->len < 0) { in dtls_handle_read()
1025 dtls_debug_dump("bytes from peer", user_data->buf, in dtls_handle_read()
1026 user_data->len); in dtls_handle_read()
1029 return dtls_handle_message(ctx, &session, user_data->buf, in dtls_handle_read()
1030 user_data->len); in dtls_handle_read()
1036 struct client_data *user_data; in handle_event() local
1038 user_data = (struct client_data *)dtls_get_app_data(ctx); in handle_event()
1046 user_data->fail = true; in handle_event()
1071 static int read_data_from_net(struct client_data *user_data) in read_data_from_net() argument
1076 if (!user_data || !user_data->fd) in read_data_from_net()
1079 return coap_read(user_data->coap_ctx); in read_data_from_net()
1579 struct client_data user_data = {}; local
1741 user_data.fd = fd;
1742 user_data.index = 0;
1743 user_data.ifindex = ifindex;
1745 user_data.coap_ctx = coap_ctx;
1748 coap_address_init(&user_data.coap_dst);
1749 memcpy(&user_data.coap_dst.addr, addr_send, addr_len);
1750 user_data.coap_dst.size = addr_len;
1783 dtls_context = dtls_new_context(&user_data);
1806 send_packets(&user_data);
1808 if (quit || user_data.fail)
1849 if (user_data.index >
1853 if (!data[user_data.index].expecting_reply) {
1855 user_data.index++;
1856 if (!data[user_data.index].buf) {
1857 user_data.fail = true;
1864 user_data.index, data[user_data.index].len);
1865 ret = user_data.index + 1;
1866 user_data.fail = true;
1870 ret = user_data.index + 1;
1871 user_data.fail = true;
1878 ret = user_data.index + 1;
1879 user_data.fail = true;
1883 user_data.fd = fd;
1884 if (read_data_from_net(&user_data) < 0) {
1886 ret = user_data.index + 1;
1887 user_data.fail = true;
1903 if (!user_data.fail) {