static int gen_level_set()

in apps/blemesh_models_example_2/src/device_composition.c [480:554]

• 62 lines of code
• 12 McCabe index (conditional complexity)

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

	level = (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))) {
		gen_level_get(model, ctx, buf);
		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->target_level = level;

	if (state->target_level != state->level) {
		level_tt_values(state, tt, delay);
	} else {
		gen_level_get(model, ctx, buf);
		gen_level_publish(model);
		return 0;
	}

	/* For Instantaneous Transition */
	if (state->transition->counter == 0) {
		state->level = state->target_level;
	}

	state->transition->just_started = true;
	gen_level_get(model, ctx, buf);
	gen_level_publish(model);

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