Lines Matching refs:context

45 } context;  variable
68 lwm2m_engine_stop(&context.firmware_ctx); in pull_service()
106 msg = lwm2m_get_message(&context.firmware_ctx); in transfer_request()
128 if (strncmp(context.uri, "http", 4) == 0) { in transfer_request()
130 } else if (strncmp(context.uri, "coap", 4) == 0) { in transfer_request()
145 ret = http_parser_parse_url(context.uri, strlen(context.uri), 0, &parser); in transfer_request()
147 LOG_ERR("Invalid firmware url: %s", context.uri); in transfer_request()
155 cursor = context.uri + off; in transfer_request()
190 ret = coap_packet_append_option(&msg->cpkt, COAP_OPTION_PROXY_URI, context.uri, in transfer_request()
191 strlen(context.uri)); in transfer_request()
193 LOG_ERR("Error adding PROXY_URI '%s'", context.uri); in transfer_request()
242 ret = lwm2m_send_empty_ack(&context.firmware_ctx, in do_firmware_transfer_reply_cb()
260 memcpy(&received_block_ctx, &context.block_ctx, sizeof(context.block_ctx)); in do_firmware_transfer_reply_cb()
262 ret = coap_update_from_block(check_response, &context.block_ctx); in do_firmware_transfer_reply_cb()
270 if (context.block_ctx.current < received_block_ctx.current) { in do_firmware_transfer_reply_cb()
274 memcpy(&context.block_ctx, &received_block_ctx, sizeof(context.block_ctx)); in do_firmware_transfer_reply_cb()
282 last_block = !coap_next_block(check_response, &context.block_ctx); in do_firmware_transfer_reply_cb()
288 LOG_DBG("total: %zd, current: %zd", context.block_ctx.total_size, in do_firmware_transfer_reply_cb()
289 context.block_ctx.current); in do_firmware_transfer_reply_cb()
313 if (context.write_cb) { in do_firmware_transfer_reply_cb()
314 size_t offset = context.block_ctx.current; in do_firmware_transfer_reply_cb()
328 ret = context.write_cb(context.obj_inst_id, 0, 0, write_buf, len, in do_firmware_transfer_reply_cb()
330 context.block_ctx.total_size, offset); in do_firmware_transfer_reply_cb()
341 ret = transfer_request(&context.block_ctx, token, tkl, in do_firmware_transfer_reply_cb()
348 context.result_cb(context.obj_inst_id, 0); in do_firmware_transfer_reply_cb()
355 context.result_cb(context.obj_inst_id, ret); in do_firmware_transfer_reply_cb()
364 context.result_cb(context.obj_inst_id, -ENOMSG); in do_transmit_timeout_cb()
387 server_addr = context.uri; in firmware_transfer()
390 ret = lwm2m_parse_peerinfo(server_addr, &context.firmware_ctx, context.is_firmware_uri); in firmware_transfer()
396 lwm2m_engine_context_init(&context.firmware_ctx); in firmware_transfer()
397 ret = lwm2m_socket_start(&context.firmware_ctx); in firmware_transfer()
403 LOG_INF("Connecting to server %s", context.uri); in firmware_transfer()
406 coap_block_transfer_init(&context.block_ctx, lwm2m_default_block_size(), 0); in firmware_transfer()
407 ret = transfer_request(&context.block_ctx, coap_next_token(), 8, in firmware_transfer()
416 context.result_cb(context.obj_inst_id, ret); in firmware_transfer()
438 context.result_cb(req.obj_inst_id, -EALREADY); in lwm2m_pull_context_start_transfer()
443 context.obj_inst_id = req.obj_inst_id; in lwm2m_pull_context_start_transfer()
444 memcpy(context.uri, uri, LWM2M_PACKAGE_URI_LEN); in lwm2m_pull_context_start_transfer()
445 context.is_firmware_uri = req.is_firmware_uri; in lwm2m_pull_context_start_transfer()
446 context.result_cb = req.result_cb; in lwm2m_pull_context_start_transfer()
447 context.write_cb = req.write_cb; in lwm2m_pull_context_start_transfer()
449 (void)memset(&context.block_ctx, 0, sizeof(struct coap_block_context)); in lwm2m_pull_context_start_transfer()
450 context.firmware_ctx.sock_fd = -1; in lwm2m_pull_context_start_transfer()
459 context.firmware_ctx.set_socketoptions = set_sockopt_cb; in lwm2m_pull_context_set_sockopt_callback()