openstack
/
dragonflow
Code Issues Proposed changes

Merge "Fix pubsub topic encoding"

This commit is contained in:
Zuul 2019-08-13 06:22:01 +00:00 committed by Gerrit Code Review
parent 5682d39ade fc38995de3
commit 88977704d6
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
dragonflow/db/pubsub_drivers/etcd_pubsub_driver.py
View File

@ -23,11 +23,11 @@ from dragonflow.db import pub_sub_api
LOG = logging.getLogger(__name__)
PUBSUB_DB_PREFIX = "pubsub"
PUBSUB_DB_PREFIX = b"/pubsub"
def _get_topic_watch_prefix(topic):
topic_prefix = "/{}/{}".format(PUBSUB_DB_PREFIX, topic)
topic_prefix = b'/'.join((PUBSUB_DB_PREFIX, topic))
return topic_prefix
@ -123,7 +123,8 @@ class EtcdSubscriberAgent(pub_sub_api.SubscriberApi):
def register_topic(self, topic):
LOG.info('Register topic %s', topic)
if topic not in self.topic_dict:
topic_thread = self._create_topic_thread(topic)
topic_thread = self._create_topic_thread(topic.encode('utf-8',
'ignore'))
self.topic_dict[topic] = topic_thread
if self.running:
topic_thread.start()