GitHub/paho.mqtt-sn.embedded-c
1
0
Fork 0
mirror of https://github.com/eclipse/paho.mqtt-sn.embedded-c.git synced 2025-12-15 16:36:52 +01:00
Code Issues Projects Releases Wiki Activity

update for #188

Browse Source 
Signed-off-by: tomoaki <tomoaki@tomy-tech.com>
This commit is contained in:
tomoaki
2020-04-06 19:02:02 +09:00
parent 61d9a283f5
commit 687a78ee2c
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
MQTTSNGateway/src/MQTTSNGWClientRecvTask.cpp
View File

@@ -178,14 +178,14 @@ void ClientRecvTask::run()
client = clientList->getClient(&data.clientID); client = clientList->getClient(&data.clientID);
if ( fwd ) if ( fwd != nullptr )
{ {
if ( client == nullptr ) if ( client == nullptr )
{ {
/* create a new client */ /* create a new client */
client = clientList->createClient(0, &data.clientID, clientType); client = clientList->createClient(0, &data.clientID, clientType);
} }
/* Add to af forwarded client list of forwarder. */ /* Add to a forwarded client list of forwarder. */
fwd->addClient(client, &nodeId); fwd->addClient(client, &nodeId);
} }
else else

1
MQTTSNGateway/src/MQTTSNGWForwarder.cpp
View File

@@ -143,6 +143,7 @@ void Forwarder::addClient(Client* client, WirelessNodeId* id)
if ( p->_client == client ) if ( p->_client == client )
{ {
client->setForwarder(this); client->setForwarder(this);
p->setWirelessNodeId(id);
return; return;
} }
prev = p; prev = p;