mirror of
https://github.com/eclipse/paho.mqtt-sn.embedded-c.git
synced 2025-12-15 16:36:52 +01:00
Add Invalid TopicId check.
Signed-off-by: tomoaki <tomoaki@tomy-tech.com>
This commit is contained in:
@@ -416,10 +416,16 @@ Client* ClientList::createClient(SensorNetAddress* addr, MQTTSNString* clientId,
|
|||||||
|
|
||||||
Client* ClientList::createPredefinedTopic( MQTTSNString* clientId, string topicName, uint16_t topicId, bool aggregate)
|
Client* ClientList::createPredefinedTopic( MQTTSNString* clientId, string topicName, uint16_t topicId, bool aggregate)
|
||||||
{
|
{
|
||||||
|
if ( topicId == 0 )
|
||||||
|
{
|
||||||
|
WRITELOG("Invalid TopicId. Predefined Topic %s, TopicId is 0. \n", topicName.c_str());
|
||||||
|
return nullptr;
|
||||||
|
}
|
||||||
|
|
||||||
if ( strcmp(clientId->cstring, common_topic) == 0 )
|
if ( strcmp(clientId->cstring, common_topic) == 0 )
|
||||||
{
|
{
|
||||||
theGateway->getTopics()->add((const char*)topicName.c_str(), topicId);
|
theGateway->getTopics()->add((const char*)topicName.c_str(), topicId);
|
||||||
return 0;
|
return nullptr;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -427,7 +433,7 @@ Client* ClientList::createPredefinedTopic( MQTTSNString* clientId, string topicN
|
|||||||
|
|
||||||
if ( _authorize && client == nullptr )
|
if ( _authorize && client == nullptr )
|
||||||
{
|
{
|
||||||
return 0;
|
return nullptr;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* anonimous clients */
|
/* anonimous clients */
|
||||||
|
|||||||
Reference in New Issue
Block a user