static int gen_move_set_unack()

in apps/blemesh_models_example_2/src/device_composition.c [797:878]

• 68 lines of code
• 14 McCabe index (conditional complexity)

static int gen_move_set_unack(struct bt_mesh_model *model,
			       struct bt_mesh_msg_ctx *ctx,
			       struct os_mbuf *buf)
{
	uint8_t tid, tt, delay;
	int16_t delta;
	int32_t tmp32;
	int64_t now;
	struct generic_level_state *state = model->user_data;
	int rc;

	delta = (int16_t) net_buf_simple_pull_le16(buf);
	tid = net_buf_simple_pull_u8(buf);

	now = k_uptime_get();
	if (state->last_tid == tid &&
	    state->last_src_addr == ctx->addr &&
	    state->last_dst_addr == ctx->recv_dst &&
	    (now - state->last_msg_timestamp <= K_SECONDS(6))) {
		return 0;
	}

	switch (buf->om_len) {
	case 0x00:	/* No optional fields are available */
		tt = default_tt;
		delay = 0;
		break;
	case 0x02:	/* Optional fields are available */
		tt = net_buf_simple_pull_u8(buf);
		if ((tt & 0x3F) == 0x3F) {
			return 0;
		}

		delay = net_buf_simple_pull_u8(buf);
		break;
	default:
		return 0;
	}

	*ptr_counter = 0;
	os_callout_stop(ptr_timer);

	state->last_tid = tid;
	state->last_src_addr = ctx->addr;
	state->last_dst_addr = ctx->recv_dst;
	state->last_msg_timestamp = now;
	state->last_delta = delta;

	tmp32 = state->level + delta;
	if (tmp32 < INT16_MIN) {
		tmp32 = INT16_MIN;
	} else if (tmp32 > INT16_MAX) {
		tmp32 = INT16_MAX;
	}

	state->target_level = tmp32;

	if (state->target_level != state->level) {
		level_tt_values(state, tt, delay);
	} else {
		rc = gen_level_move_publish(model);
		return rc;
	}

	if (state->transition->counter == 0) {
		return 0;
	}

	state->transition->just_started = true;
	rc = gen_level_move_publish(model);

	if (bt_mesh_model_elem(model)->addr == elements[0].addr) {
		/* Root element */
		transition_type = LEVEL_TT_MOVE;
		level_lightness_handler(state);
	} else if (bt_mesh_model_elem(model)->addr == elements[1].addr) {
		/* Secondary element */
		transition_type = LEVEL_TEMP_TT_MOVE;
		level_temp_handler(state);
	}
    return rc;
}