From: Inga Stotland <inga.stotland@xxxxxxxxx>
The Config Server model is an internal service that allows
priviledged remote Config Client nodes to manipulate and
configure local keys, subscription lists, and publications of
models on specific local nodes. It has been rewritten to allow
control of multiple nodes on the local device.
---
mesh/cfgmod-server.c | 179 ++++++++++++++++++++++++++-------------------------
mesh/cfgmod.h | 3 +-
2 files changed, 93 insertions(+), 89 deletions(-)
diff --git a/mesh/cfgmod-server.c b/mesh/cfgmod-server.c
index 2c4a02912..062bdaaf2 100644
--- a/mesh/cfgmod-server.c
+++ b/mesh/cfgmod-server.c
@@ -15,7 +15,6 @@
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
- *
*/
#ifdef HAVE_CONFIG_H
@@ -24,11 +23,14 @@
#include <unistd.h>
#include <stdio.h>
+#include <stdint.h>
#include <sys/time.h>
#include <ell/ell.h>
+#include <ell/ell.h>
-#include "mesh/mesh-defs.h"
+#include "json-c/json.h"
+#include "mesh/mesh-defs.h"
#include "mesh/mesh.h"
#include "mesh/node.h"
#include "mesh/net.h"
@@ -40,7 +42,7 @@
#define CFG_MAX_MSG_LEN 380
-static void send_pub_status(struct mesh_net *net, uint16_t src, uint16_t dst,
+static void send_pub_status(struct mesh_node *node, uint16_t src, uint16_t dst,
uint8_t status, uint16_t ele_addr, uint16_t pub_addr,
uint32_t mod_id, uint16_t idx, bool cred_flag,
uint8_t ttl, uint8_t period, uint8_t retransmit)
@@ -60,7 +62,7 @@ static void send_pub_status(struct mesh_net *net, uint16_t src, uint16_t dst,
msg[n++] = ttl;
msg[n++] = period;
msg[n++] = retransmit;
- if (mod_id < 0x10000) {
+ if (mod_id < 0x10000 || mod_id > VENDOR_ID_MASK) {
l_put_le16(mod_id, msg + n);
n += 2;
} else {
@@ -70,12 +72,11 @@ static void send_pub_status(struct mesh_net *net, uint16_t src, uint16_t dst,
n += 2;
}
- mesh_model_send(net, CONFIG_SRV_MODEL,
- dst, src,
+ mesh_model_send(node, dst, src,
APP_IDX_DEV, DEFAULT_TTL, msg, n);
}
-static bool config_pub_get(struct mesh_net *net, uint16_t src, uint16_t dst,
+static bool config_pub_get(struct mesh_node *node, uint16_t src, uint16_t dst,
const uint8_t *pkt, uint16_t size)
{
uint32_t mod_id;
@@ -84,33 +85,34 @@ static bool config_pub_get(struct mesh_net *net, uint16_t src, uint16_t dst,
struct mesh_model_pub *pub = NULL;
int status;
- if (size == 4)
+ if (size == 4) {
mod_id = l_get_le16(pkt + 2);
- else if (size == 6) {
+ mod_id |= VENDOR_ID_MASK;
+ } else if (size == 6) {
mod_id = l_get_le16(pkt + 2) << 16;
mod_id |= l_get_le16(pkt + 4);
} else
return false;
ele_addr = l_get_le16(pkt);
- ele_idx = node_get_element_idx(mesh_net_local_node_get(net), ele_addr);
+ ele_idx = node_get_element_idx(node, ele_addr);
if (ele_idx >= 0)
- pub = mesh_model_pub_get(net, ele_idx, mod_id, &status);
+ pub = mesh_model_pub_get(node, ele_idx, mod_id, &status);
else
status = MESH_STATUS_INVALID_ADDRESS;
if (pub && status == MESH_STATUS_SUCCESS)
- send_pub_status(net, src, dst, status, ele_addr, pub->addr,
+ send_pub_status(node, src, dst, status, ele_addr, pub->addr,
mod_id, pub->idx, pub->credential, pub->ttl,
pub->period, pub->retransmit);
else
- send_pub_status(net, src, dst, status, ele_addr, 0, mod_id,
+ send_pub_status(node, src, dst, status, ele_addr, 0, mod_id,
0, 0, 0, 0, 0);
return true;
}
-static bool config_pub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
+static bool config_pub_set(struct mesh_node *node, uint16_t src, uint16_t dst,
const uint8_t *pkt, uint16_t size,
bool unreliable)
{
@@ -133,6 +135,7 @@ static bool config_pub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
period = pkt[7];
retransmit = pkt[8];
mod_id = l_get_le16(pkt + 9);
+ mod_id |= VENDOR_ID_MASK;
break;
case 13:
@@ -151,6 +154,7 @@ static bool config_pub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
period = pkt[21];
retransmit = pkt[22];
mod_id = l_get_le16(pkt + 23);
+ mod_id |= VENDOR_ID_MASK;
break;
case 27:
@@ -181,24 +185,24 @@ static bool config_pub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
if (!b_virt && test_addr > 0x7fff && test_addr < 0xc000)
return false;
- status = mesh_model_pub_set(net, ele_addr, mod_id, pub_addr, idx,
+ status = mesh_model_pub_set(node, ele_addr, mod_id, pub_addr, idx,
cred_flag, ttl, period, retransmit,
b_virt, &ota);
- l_info("pub_set: status %d, ea %4.4x, ota: %4.4x, mod: %x, idx: %3.3x",
+ l_debug("pub_set: status %d, ea %4.4x, ota: %4.4x, mod: %x, idx: %3.3x",
status, ele_addr, ota, mod_id, idx);
if (IS_UNASSIGNED(ota) && !b_virt)
ttl = period = idx = 0;
if (status >= 0 && !unreliable)
- send_pub_status(net, src, dst, status, ele_addr, ota,
+ send_pub_status(node, src, dst, status, ele_addr, ota,
mod_id, idx, cred_flag, ttl, period,
retransmit);
return true;
}
-static void send_sub_status(struct mesh_net *net, uint16_t src, uint16_t dst,
+static void send_sub_status(struct mesh_node *node, uint16_t src, uint16_t dst,
uint8_t status, uint16_t ele_addr,
uint16_t addr, uint32_t mod)
{
@@ -210,7 +214,7 @@ static void send_sub_status(struct mesh_net *net, uint16_t src, uint16_t dst,
n += 2;
l_put_le16(addr, msg + n);
n += 2;
- if (mod >= 0x10000) {
+ if (mod >= 0x10000 && mod < VENDOR_ID_MASK) {
l_put_le16(mod >> 16, msg + n);
l_put_le16(mod, msg + n + 2);
n += 4;
@@ -219,11 +223,10 @@ static void send_sub_status(struct mesh_net *net, uint16_t src, uint16_t dst,
n += 2;
}
- mesh_model_send(net, CONFIG_SRV_MODEL, dst, src, APP_IDX_DEV,
- DEFAULT_TTL, msg, n);
+ mesh_model_send(node, dst, src, APP_IDX_DEV, DEFAULT_TTL, msg, n);
}
-static bool config_sub_get(struct mesh_net *net, uint16_t src, uint16_t dst,
+static bool config_sub_get(struct mesh_node *node, uint16_t src, uint16_t dst,
const uint8_t *pkt, uint16_t size)
{
uint16_t ele_addr;
@@ -251,6 +254,7 @@ static bool config_sub_get(struct mesh_net *net, uint16_t src, uint16_t dst,
n += 2;
l_put_le16(mod_id, msg + n);
n += 2;
+ mod_id |= VENDOR_ID_MASK;
break;
case 6:
@@ -269,7 +273,7 @@ static bool config_sub_get(struct mesh_net *net, uint16_t src, uint16_t dst,
}
buf_size = sizeof(uint16_t) * MAX_GRP_PER_MOD;
- ret = mesh_model_sub_get(net, ele_addr, mod_id, msg + n, buf_size,
+ ret = mesh_model_sub_get(node, ele_addr, mod_id, msg + n, buf_size,
&size);
if (!ret)
@@ -277,13 +281,11 @@ static bool config_sub_get(struct mesh_net *net, uint16_t src, uint16_t dst,
else if (ret > 0)
*status = ret;
- mesh_model_send(net, CONFIG_SRV_MODEL,
- dst, src, APP_IDX_DEV,
- DEFAULT_TTL, msg, n);
+ mesh_model_send(node, dst, src, APP_IDX_DEV, DEFAULT_TTL, msg, n);
return true;
}
-static void config_sub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
+static void config_sub_set(struct mesh_node *node, uint16_t src, uint16_t dst,
const uint8_t *pkt, uint16_t size,
bool virt, uint32_t opcode)
{
@@ -301,13 +303,15 @@ static void config_sub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
if (opcode != OP_CONFIG_MODEL_SUB_DELETE_ALL)
return;
mod_id = l_get_le16(pkt + 2);
+ mod_id |= VENDOR_ID_MASK;
break;
case 6:
if (virt)
return;
- if (opcode != OP_CONFIG_MODEL_SUB_DELETE_ALL)
+ if (opcode != OP_CONFIG_MODEL_SUB_DELETE_ALL) {
mod_id = l_get_le16(pkt + 4);
- else {
+ mod_id |= VENDOR_ID_MASK;
+ } else {
mod_id = l_get_le16(pkt + 2) << 16;
mod_id |= l_get_le16(pkt + 4);
}
@@ -322,6 +326,7 @@ static void config_sub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
if (!virt)
return;
mod_id = l_get_le16(pkt + 18);
+ mod_id |= VENDOR_ID_MASK;
break;
case 22:
if (!virt)
@@ -341,42 +346,42 @@ static void config_sub_set(struct mesh_net *net, uint16_t src, uint16_t dst,
func = opcode & ~OP_UNRELIABLE;
switch (func) {
default:
- l_info("Bad opcode: %x", func);
+ l_debug("Bad opcode: %x", func);
return;
case OP_CONFIG_MODEL_SUB_DELETE_ALL:
- status = mesh_model_sub_del_all(net, ele_addr, mod_id);
+ status = mesh_model_sub_del_all(node, ele_addr, mod_id);
break;
case OP_CONFIG_MODEL_SUB_VIRT_OVERWRITE:
grp = UNASSIGNED_ADDRESS;
/* Fall Through */
case OP_CONFIG_MODEL_SUB_OVERWRITE:
- status = mesh_model_sub_ovr(net, ele_addr, mod_id,
+ status = mesh_model_sub_ovr(node, ele_addr, mod_id,
addr, virt, &grp);
break;
case OP_CONFIG_MODEL_SUB_VIRT_ADD:
grp = UNASSIGNED_ADDRESS;
/* Fall Through */
case OP_CONFIG_MODEL_SUB_ADD:
- status = mesh_model_sub_add(net, ele_addr, mod_id,
+ status = mesh_model_sub_add(node, ele_addr, mod_id,
addr, virt, &grp);
break;
case OP_CONFIG_MODEL_SUB_VIRT_DELETE:
grp = UNASSIGNED_ADDRESS;
/* Fall Through */
case OP_CONFIG_MODEL_SUB_DELETE:
- status = mesh_model_sub_del(net, ele_addr, mod_id,
+ status = mesh_model_sub_del(node, ele_addr, mod_id,
addr, virt, &grp);
break;
}
if (!unreliable && status >= 0)
- send_sub_status(net, src, dst, status, ele_addr, grp, mod_id);
+ send_sub_status(node, src, dst, status, ele_addr, grp, mod_id);
}
-static void send_model_app_status(struct mesh_net *net, uint16_t src,
+static void send_model_app_status(struct mesh_node *node, uint16_t src,
uint16_t dst, uint8_t status,
uint16_t addr, uint32_t id,
uint16_t idx)
@@ -389,18 +394,17 @@ static void send_model_app_status(struct mesh_net *net, uint16_t src,
n += 2;
l_put_le16(idx, msg + n);
n += 2;
- if (id > 0xffff) {
+ if (id >= 0x10000 && id < VENDOR_ID_MASK) {
l_put_le16(id >> 16, msg + n);
n += 2;
}
l_put_le16(id, msg + n);
n += 2;
- mesh_model_send(net, CONFIG_SRV_MODEL, dst, src, APP_IDX_DEV,
- DEFAULT_TTL, msg, n);
+ mesh_model_send(node, dst, src, APP_IDX_DEV, DEFAULT_TTL, msg, n);
}
-static void model_app_list(struct mesh_net *net, uint16_t src, uint16_t dst,
+static void model_app_list(struct mesh_node *node, uint16_t src, uint16_t dst,
const uint8_t *pkt, uint16_t size)
{
uint16_t ele_addr;
@@ -427,6 +431,7 @@ static void model_app_list(struct mesh_net *net, uint16_t src, uint16_t dst,
mod_id = l_get_le16(pkt + 2);
l_put_le16(ele_addr, msg + 1 + n);
l_put_le16(mod_id, msg + 3 + n);
+ mod_id |= VENDOR_ID_MASK;
n += 5;
break;
case 6:
@@ -443,20 +448,20 @@ static void model_app_list(struct mesh_net *net, uint16_t src, uint16_t dst,
}
- result = mesh_model_get_bindings(net, ele_addr, mod_id, msg + n,
+ result = mesh_model_get_bindings(node, ele_addr, mod_id, msg + n,
buf_size, &size);
n += size;
if (result >= 0) {
*status = result;
- mesh_model_send(net, CONFIG_SRV_MODEL, dst, src, APP_IDX_DEV,
- DEFAULT_TTL, msg, n);
+ mesh_model_send(node, dst, src, APP_IDX_DEV, DEFAULT_TTL,
+ msg, n);
}
l_free(msg);
}
-static bool model_app_bind(struct mesh_net *net, uint16_t src, uint16_t dst,
+static bool model_app_bind(struct mesh_node *node, uint16_t src, uint16_t dst,
const uint8_t *pkt, uint16_t size,
bool unbind)
{
@@ -471,6 +476,7 @@ static bool model_app_bind(struct mesh_net *net, uint16_t src, uint16_t dst,
case 6:
mod_id = l_get_le16(pkt + 4);
+ mod_id |= VENDOR_ID_MASK;
break;
case 8:
mod_id = l_get_le16(pkt + 4) << 16;
@@ -485,11 +491,11 @@ static bool model_app_bind(struct mesh_net *net, uint16_t src, uint16_t dst,
return false;
if (unbind)
- result = mesh_model_binding_del(net, ele_addr, mod_id, idx);
+ result = mesh_model_binding_del(node, ele_addr, mod_id, idx);
else
- result = mesh_model_binding_add(net, ele_addr, mod_id, idx);
+ result = mesh_model_binding_add(node, ele_addr, mod_id, idx);
- send_model_app_status(net, src, dst, result, ele_addr, mod_id, idx);
+ send_model_app_status(node, src, dst, result, ele_addr, mod_id, idx);
return true;
}
@@ -533,7 +539,7 @@ static void hb_sub_timeout_func(struct l_timeout *timeout, void *user_data)
struct mesh_net *net = user_data;
struct mesh_net_heartbeat *hb = mesh_net_heartbeat_get(net);
- l_info("HB Subscription Ended");
+ l_debug("HB Subscription Ended");
l_timeout_remove(hb->sub_timer);
hb->sub_timer = NULL;
hb->sub_enabled = false;
@@ -639,7 +645,7 @@ static int hb_subscription_set(struct mesh_net *net, uint16_t src,
static void node_reset(struct l_timeout *timeout, void *user_data)
{
- l_info("Node Reset");
+ l_debug("Node Reset");
l_timeout_remove(timeout);
l_main_quit();
}
@@ -649,7 +655,8 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
const uint8_t *data, uint16_t size,
uint8_t ttl, const void *user_data)
{
- struct mesh_net *net = (struct mesh_net *) user_data;
+ struct mesh_node *node = (struct mesh_node *) user_data;
+ struct mesh_net *net = node_get_net(node);
const uint8_t *pkt = data;
struct timeval time_now;
uint32_t opcode, tmp32;
@@ -663,7 +670,6 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
bool virt = false;
uint8_t count;
uint16_t interval;
- struct mesh_node *node;
uint16_t n;
if (idx != APP_IDX_DEV)
@@ -675,10 +681,10 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
} else
return false;
+ net = node_get_net(node);
hb = mesh_net_heartbeat_get(net);
l_debug("CONFIG-SRV-opcode 0x%x size %u idx %3.3x", opcode, size, idx);
- node = mesh_net_local_node_get(net);
n = 0;
switch (opcode) {
@@ -691,8 +697,8 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
/* Only page 0 is currently supported */
if (pkt[0] != 0) {
- l_info("Unsupported page number %d", pkt[0]);
- l_info("Returning page number 0");
+ l_debug("Unsupported page number %d", pkt[0]);
+ l_debug("Returning page number 0");
}
long_msg = l_malloc(CFG_MAX_MSG_LEN);
n = mesh_model_opcode_set(OP_DEV_COMP_STATUS, long_msg);
@@ -711,7 +717,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
/* Fall Through */
case OP_CONFIG_DEFAULT_TTL_GET:
- l_info("Get/Set Default TTL");
+ l_debug("Get/Set Default TTL");
n = mesh_model_opcode_set(OP_CONFIG_DEFAULT_TTL_STATUS, msg);
msg[n++] = node_default_ttl_get(node);
@@ -721,7 +727,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
if (size != 25 && size != 27)
return true;
- config_pub_set(net, src, unicast, pkt, size,
+ config_pub_set(node, src, unicast, pkt, size,
!!(opcode & OP_UNRELIABLE));
break;
@@ -729,24 +735,24 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
if (size != 11 && size != 13)
return true;
- config_pub_set(net, src, unicast, pkt, size,
+ config_pub_set(node, src, unicast, pkt, size,
!!(opcode & OP_UNRELIABLE));
break;
case OP_CONFIG_MODEL_PUB_GET:
- config_pub_get(net, src, unicast, pkt, size);
+ config_pub_get(node, src, unicast, pkt, size);
break;
case OP_CONFIG_VEND_MODEL_SUB_GET:
if (size != 6)
return true;
- config_sub_get(net, src, unicast, pkt, size);
+ config_sub_get(node, src, unicast, pkt, size);
break;
case OP_CONFIG_MODEL_SUB_GET:
if (size != 4)
return true;
- config_sub_get(net, src, unicast, pkt, size);
+ config_sub_get(node, src, unicast, pkt, size);
break;
case OP_CONFIG_MODEL_SUB_VIRT_OVERWRITE:
@@ -758,7 +764,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
case OP_CONFIG_MODEL_SUB_DELETE:
case OP_CONFIG_MODEL_SUB_ADD:
case OP_CONFIG_MODEL_SUB_DELETE_ALL:
- config_sub_set(net, src, unicast, pkt, size, virt, opcode);
+ config_sub_set(node, src, unicast, pkt, size, virt, opcode);
break;
case OP_CONFIG_RELAY_SET:
@@ -777,7 +783,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
msg[n++] = node_relay_mode_get(node, &count, &interval);
msg[n++] = ((count - 1) << 5) + ((interval/10 - 1) & 0x1f);
- l_info("Get/Set Relay Config (%d)", msg[n-1]);
+ l_debug("Get/Set Relay Config (%d)", msg[n-1]);
break;
case OP_CONFIG_NETWORK_TRANSMIT_SET:
@@ -786,7 +792,8 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
count = (pkt[0] >> 5) + 1;
interval = ((pkt[0] & 0x1f) + 1) * 10;
- if (storage_local_set_transmit_params(net, count, interval))
+ if (storage_set_transmit_params(node_jconfig_get(node), count,
+ interval))
mesh_net_transmit_params_set(net, count, interval);
/* Fall Through */
@@ -796,7 +803,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
mesh_net_transmit_params_get(net, &count, &interval);
msg[n++] = ((count - 1) << 5) + ((interval/10 - 1) & 0x1f);
- l_info("Get/Set Network Transmit Config");
+ l_debug("Get/Set Network Transmit Config");
break;
case OP_CONFIG_PROXY_SET:
@@ -810,7 +817,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
n = mesh_model_opcode_set(OP_CONFIG_PROXY_STATUS, msg);
msg[n++] = node_proxy_mode_get(node);
- l_info("Get/Set Config Proxy (%d)", msg[n-1]);
+ l_debug("Get/Set Config Proxy (%d)", msg[n-1]);
break;
case OP_NODE_IDENTITY_SET:
@@ -845,7 +852,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
n += 2;
msg[n++] = state;
- l_info("Get/Set Config Identity (%d)", state);
+ l_debug("Get/Set Config Identity (%d)", state);
break;
case OP_CONFIG_BEACON_SET:
@@ -859,7 +866,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
n = mesh_model_opcode_set(OP_CONFIG_BEACON_STATUS, msg);
msg[n++] = node_beacon_mode_get(node);
- l_info("Get/Set Config Beacon (%d)", msg[n-1]);
+ l_debug("Get/Set Config Beacon (%d)", msg[n-1]);
break;
case OP_CONFIG_FRIEND_SET:
@@ -874,7 +881,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
n = mesh_model_opcode_set(OP_CONFIG_FRIEND_STATUS, msg);
msg[n++] = node_friend_mode_get(node);
- l_info("Get/Set Friend (%d)", msg[n-1]);
+ l_debug("Get/Set Friend (%d)", msg[n-1]);
break;
case OP_CONFIG_KEY_REFRESH_PHASE_SET:
@@ -908,7 +915,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
n += 2;
msg[n++] = phase;
- l_info("Get/Set Key Refresh State (%d)", msg[n-1]);
+ l_debug("Get/Set Key Refresh State (%d)", msg[n-1]);
break;
case OP_APPKEY_ADD:
@@ -921,7 +928,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
b_res = appkey_key_add(net, net_idx, app_idx, pkt + 3,
opcode == OP_APPKEY_UPDATE);
- l_info("Add/Update AppKey %s: Net_Idx %3.3x, App_Idx %3.3x",
+ l_debug("Add/Update AppKey %s: Net_Idx %3.3x, App_Idx %3.3x",
(b_res == MESH_STATUS_SUCCESS) ? "success" : "fail",
net_idx, app_idx);
@@ -942,9 +949,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
net_idx = l_get_le16(pkt) & 0xfff;
app_idx = l_get_le16(pkt + 1) >> 4;
b_res = appkey_key_delete(net, net_idx, app_idx);
- if (b_res == MESH_STATUS_SUCCESS)
- node_app_key_delete(net, dst, net_idx, app_idx);
- l_info("Delete AppKey %s Net_Idx %3.3x to App_Idx %3.3x",
+ l_debug("Delete AppKey %s Net_Idx %3.3x to App_Idx %3.3x",
(b_res == MESH_STATUS_SUCCESS) ? "success" : "fail",
net_idx, app_idx);
@@ -979,7 +984,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
b_res = mesh_net_add_key(net, opcode == OP_NETKEY_UPDATE,
l_get_le16(pkt), pkt + 2);
- l_info("NetKey Add/Update %s",
+ l_debug("NetKey Add/Update %s",
(b_res == MESH_STATUS_SUCCESS) ? "success" : "fail");
n = mesh_model_opcode_set(OP_NETKEY_STATUS, msg);
@@ -994,7 +999,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
b_res = mesh_net_del_key(net, l_get_le16(pkt));
- l_info("NetKey delete %s",
+ l_debug("NetKey delete %s",
(b_res == MESH_STATUS_SUCCESS) ? "success" : "fail");
n = mesh_model_opcode_set(OP_NETKEY_STATUS, msg);
@@ -1016,26 +1021,26 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
case OP_MODEL_APP_BIND:
case OP_MODEL_APP_UNBIND:
- model_app_bind(net, src, unicast, pkt, size,
+ model_app_bind(node, src, unicast, pkt, size,
opcode != OP_MODEL_APP_BIND);
break;
case OP_VEND_MODEL_APP_GET:
if (size != 6)
return true;
- model_app_list(net, src, unicast, pkt, size);
+ model_app_list(node, src, unicast, pkt, size);
break;
case OP_MODEL_APP_GET:
if (size != 4)
return true;
- model_app_list(net, src, unicast, pkt, size);
+ model_app_list(node, src, unicast, pkt, size);
break;
case OP_CONFIG_HEARTBEAT_PUB_SET:
- l_info("OP_CONFIG_HEARTBEAT_PUB_SET");
+ l_debug("OP_CONFIG_HEARTBEAT_PUB_SET");
if (size != 9) {
- l_info("bad size %d", size);
+ l_debug("bad size %d", size);
return true;
}
if (pkt[2] > 0x11 || pkt[3] > 0x10 || pkt[4] > 0x7f)
@@ -1101,7 +1106,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
if (size != 5)
return true;
- l_info("Set Sub Period (Log %2.2x) %d sec",
+ l_debug("Set Sub Period (Log %2.2x) %d sec",
pkt[4], log_to_uint32(pkt[4], 1));
b_res = hb_subscription_set(net, l_get_le16(pkt),
@@ -1121,7 +1126,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
else
time_now.tv_sec = hb->sub_period - time_now.tv_sec;
- l_info("Sub Period (Log %2.2x) %d sec",
+ l_debug("Sub Period (Log %2.2x) %d sec",
uint32_to_log(time_now.tv_sec),
(int) time_now.tv_sec);
@@ -1159,8 +1164,7 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
if (n) {
/* print_packet("App Tx", long_msg ? long_msg : msg, n); */
- mesh_model_send(net, CONFIG_SRV_MODEL,
- unicast, src,
+ mesh_model_send(node, unicast, src,
APP_IDX_DEV, DEFAULT_TTL,
long_msg ? long_msg : msg, n);
}
@@ -1171,7 +1175,8 @@ static bool cfg_srv_pkt(uint16_t src, uint32_t dst,
static void cfgmod_srv_unregister(void *user_data)
{
- struct mesh_net *net = user_data;
+ struct mesh_node *node = user_data;
+ struct mesh_net *net = node_get_net(node);
struct mesh_net_heartbeat *hb = mesh_net_heartbeat_get(net);
l_timeout_remove(hb->pub_timer);
@@ -1187,8 +1192,8 @@ static const struct mesh_model_ops ops = {
.pub = NULL
};
-void mesh_config_srv_init(struct mesh_net *net, uint8_t ele_idx)
+void mesh_config_srv_init(struct mesh_node *node, uint8_t ele_idx)
{
l_debug("%2.2x", ele_idx);
- mesh_model_register(net, ele_idx, CONFIG_SRV_MODEL, &ops, net);
+ mesh_model_register(node, ele_idx, CONFIG_SRV_MODEL, &ops, node);
}
diff --git a/mesh/cfgmod.h b/mesh/cfgmod.h
index bedb0c6f6..84fa184e5 100644
--- a/mesh/cfgmod.h
+++ b/mesh/cfgmod.h
@@ -15,7 +15,6 @@
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
- *
*/
#define CONFIG_SRV_MODEL (VENDOR_ID_MASK | 0x0000)
@@ -95,4 +94,4 @@
#define OP_VEND_MODEL_APP_GET 0x804C
#define OP_VEND_MODEL_APP_LIST 0x804E
-void mesh_config_srv_init(struct mesh_net *net, uint8_t ele_idx);
+void mesh_config_srv_init(struct mesh_node *node, uint8_t ele_idx);
--
2.14.5
