)]}'
{"/COMMIT_MSG":[{"author":{"_account_id":6598,"name":"Berezovsky Irena","email":"irenab.dev@gmail.com","username":"irenab"},"change_message_id":"9d758b91ecf49a73e7a2fcb8334733309d927f7e","unresolved":false,"context_lines":[{"line_number":5,"context_line":"CommitDate: 2017-09-25 12:34:22 +0300"},{"line_number":6,"context_line":""},{"line_number":7,"context_line":"Spec: Make multiproc publishers into brokers"},{"line_number":8,"context_line":""},{"line_number":9,"context_line":"Change-Id: Id27e2eb4ca3577cf86aebc22464a73d917847d02"}],"source_content_type":"text/x-gerrit-commit-message","patch_set":1,"id":"5f4e5783_4591ef4d","line":8,"updated":"2017-10-15 06:23:32.000000000","message":"please add launchpad bug/bp to link to","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":20229,"name":"Omer Anson","email":"omer.anson@toganetworks.com","username":"oanson"},"change_message_id":"91a043a2c8b860ccc90074164f06e42640c3ed9b","unresolved":false,"context_lines":[{"line_number":5,"context_line":"CommitDate: 2017-09-25 12:34:22 +0300"},{"line_number":6,"context_line":""},{"line_number":7,"context_line":"Spec: Make multiproc publishers into brokers"},{"line_number":8,"context_line":""},{"line_number":9,"context_line":"Change-Id: Id27e2eb4ca3577cf86aebc22464a73d917847d02"}],"source_content_type":"text/x-gerrit-commit-message","patch_set":1,"id":"5f4e5783_fb24fcb0","line":8,"in_reply_to":"5f4e5783_4591ef4d","updated":"2017-10-15 11:40:40.000000000","message":"Done","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"}],"doc/source/specs/zmq_broker.rst":[{"author":{"_account_id":6598,"name":"Berezovsky Irena","email":"irenab.dev@gmail.com","username":"irenab"},"change_message_id":"9d758b91ecf49a73e7a2fcb8334733309d927f7e","unresolved":false,"context_lines":[{"line_number":5,"context_line":" http://creativecommons.org/licenses/by/3.0/legalcode"},{"line_number":6,"context_line":""},{"line_number":7,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":8,"context_line":"Example Spec - The title of your RFE"},{"line_number":9,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":10,"context_line":""},{"line_number":11,"context_line":"Work will be tracked under the following bug:"}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_25827301","line":8,"range":{"start_line":8,"start_character":0,"end_line":8,"end_character":36},"updated":"2017-10-15 06:23:32.000000000","message":"missing title","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":20229,"name":"Omer Anson","email":"omer.anson@toganetworks.com","username":"oanson"},"change_message_id":"91a043a2c8b860ccc90074164f06e42640c3ed9b","unresolved":false,"context_lines":[{"line_number":5,"context_line":" http://creativecommons.org/licenses/by/3.0/legalcode"},{"line_number":6,"context_line":""},{"line_number":7,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":8,"context_line":"Example Spec - The title of your RFE"},{"line_number":9,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":10,"context_line":""},{"line_number":11,"context_line":"Work will be tracked under the following bug:"}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_bb3a04c9","line":8,"range":{"start_line":8,"start_character":0,"end_line":8,"end_character":36},"in_reply_to":"5f4e5783_25827301","updated":"2017-10-15 11:40:40.000000000","message":"Done","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":6598,"name":"Berezovsky Irena","email":"irenab.dev@gmail.com","username":"irenab"},"change_message_id":"9d758b91ecf49a73e7a2fcb8334733309d927f7e","unresolved":false,"context_lines":[{"line_number":13,"context_line":"https://bugs.launchpad.net/dragonflow/+bug/1716933"},{"line_number":14,"context_line":""},{"line_number":15,"context_line":"This feature discusses the removal of _multiproc_ publishers, and allow only"},{"line_number":16,"context_line":"_broker_ publishers, i.e. publisher\u0027s which have a broker service (e.g. redis)."},{"line_number":17,"context_line":""},{"line_number":18,"context_line":"In order to support full pluggability, it is also proposed to add a ZMQ-based"},{"line_number":19,"context_line":"broker implementation."}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_05877711","line":16,"range":{"start_line":16,"start_character":35,"end_line":16,"end_character":37},"updated":"2017-10-15 06:23:32.000000000","message":"remove","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":20229,"name":"Omer Anson","email":"omer.anson@toganetworks.com","username":"oanson"},"change_message_id":"91a043a2c8b860ccc90074164f06e42640c3ed9b","unresolved":false,"context_lines":[{"line_number":13,"context_line":"https://bugs.launchpad.net/dragonflow/+bug/1716933"},{"line_number":14,"context_line":""},{"line_number":15,"context_line":"This feature discusses the removal of _multiproc_ publishers, and allow only"},{"line_number":16,"context_line":"_broker_ publishers, i.e. publisher\u0027s which have a broker service (e.g. redis)."},{"line_number":17,"context_line":""},{"line_number":18,"context_line":"In order to support full pluggability, it is also proposed to add a ZMQ-based"},{"line_number":19,"context_line":"broker implementation."}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_5b4f906a","line":16,"range":{"start_line":16,"start_character":35,"end_line":16,"end_character":37},"in_reply_to":"5f4e5783_05877711","updated":"2017-10-15 11:40:40.000000000","message":"Done","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":6598,"name":"Berezovsky Irena","email":"irenab.dev@gmail.com","username":"irenab"},"change_message_id":"9d758b91ecf49a73e7a2fcb8334733309d927f7e","unresolved":false,"context_lines":[{"line_number":24,"context_line":""},{"line_number":25,"context_line":"Our _multiproc_ pub/sub mechanism is proving to not work as well as it should."},{"line_number":26,"context_line":""},{"line_number":27,"context_line":"_multipoc_ means that we run a process per controller node (which"},{"line_number":28,"context_line":"contains the neutron server), which binds the network socket and sends"},{"line_number":29,"context_line":"the events. The neutron servers (forked one per cpu) connect to that"},{"line_number":30,"context_line":"service via IPC (read unix socket) and send the events to it.  In essence,"}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_85724748","line":27,"range":{"start_line":27,"start_character":43,"end_line":27,"end_character":53},"updated":"2017-10-15 06:23:32.000000000","message":"OpenStack controller?","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":20229,"name":"Omer Anson","email":"omer.anson@toganetworks.com","username":"oanson"},"change_message_id":"91a043a2c8b860ccc90074164f06e42640c3ed9b","unresolved":false,"context_lines":[{"line_number":24,"context_line":""},{"line_number":25,"context_line":"Our _multiproc_ pub/sub mechanism is proving to not work as well as it should."},{"line_number":26,"context_line":""},{"line_number":27,"context_line":"_multipoc_ means that we run a process per controller node (which"},{"line_number":28,"context_line":"contains the neutron server), which binds the network socket and sends"},{"line_number":29,"context_line":"the events. The neutron servers (forked one per cpu) connect to that"},{"line_number":30,"context_line":"service via IPC (read unix socket) and send the events to it.  In essence,"}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_1b5598fa","line":27,"range":{"start_line":27,"start_character":43,"end_line":27,"end_character":53},"in_reply_to":"5f4e5783_85724748","updated":"2017-10-15 11:40:40.000000000","message":"Yes. Added.","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":26131,"name":"Eyal Leshem","email":"eyal.leshem@toganetworks.com","username":"leyal"},"change_message_id":"8849c14ade8b9eb8c30a038916eccec193dc06b3","unresolved":false,"context_lines":[{"line_number":62,"context_line":"a ZMQ-based pub/sub broker. Neutron server (the \u0027publishers\u0027) connect"},{"line_number":63,"context_line":"with a PULL/PUSH socket - that\u0027s the pattern for many publishers, few"},{"line_number":64,"context_line":"subscribers. The subscribers connect with a PUB/SUB socket - that\u0027s the"},{"line_number":65,"context_line":"pattern for many subscribers, few publishers."},{"line_number":66,"context_line":""},{"line_number":67,"context_line":"There are many interesting ideas in this regard in [1]_."},{"line_number":68,"context_line":""}],"source_content_type":"text/x-rst","patch_set":1,"id":"7f515b1d_040b558e","line":65,"updated":"2017-09-25 12:07:10.000000000","message":"In ZMQ the subscriber need to connect to the publisher. \nI think that in our case the biggest challenge is how to pass to the compute-nodes(the subscribers) the number of publishers(neutron-servers) and how to connect to each of them (e.g port-numbers..). \nIn ZMQ  tutorial it\u0027s suggests for such cases  a method that really close to our df_publisher_service.(http://zguide.zeromq.org/page:all#The-Dynamic-Discovery-Problem)","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":20229,"name":"Omer Anson","email":"omer.anson@toganetworks.com","username":"oanson"},"change_message_id":"91a043a2c8b860ccc90074164f06e42640c3ed9b","unresolved":false,"context_lines":[{"line_number":62,"context_line":"a ZMQ-based pub/sub broker. Neutron server (the \u0027publishers\u0027) connect"},{"line_number":63,"context_line":"with a PULL/PUSH socket - that\u0027s the pattern for many publishers, few"},{"line_number":64,"context_line":"subscribers. The subscribers connect with a PUB/SUB socket - that\u0027s the"},{"line_number":65,"context_line":"pattern for many subscribers, few publishers."},{"line_number":66,"context_line":""},{"line_number":67,"context_line":"There are many interesting ideas in this regard in [1]_."},{"line_number":68,"context_line":""}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_5b78b08e","line":65,"in_reply_to":"7f515b1d_040b558e","updated":"2017-10-15 11:40:40.000000000","message":"Thanks for pointing this out. This is one of the open questions this spec should answer.","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":6598,"name":"Berezovsky Irena","email":"irenab.dev@gmail.com","username":"irenab"},"change_message_id":"9d758b91ecf49a73e7a2fcb8334733309d927f7e","unresolved":false,"context_lines":[{"line_number":63,"context_line":"with a PULL/PUSH socket - that\u0027s the pattern for many publishers, few"},{"line_number":64,"context_line":"subscribers. The subscribers connect with a PUB/SUB socket - that\u0027s the"},{"line_number":65,"context_line":"pattern for many subscribers, few publishers."},{"line_number":66,"context_line":""},{"line_number":67,"context_line":"There are many interesting ideas in this regard in [1]_."},{"line_number":68,"context_line":""},{"line_number":69,"context_line":"TBD"}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_c5ca7f4c","line":66,"updated":"2017-10-15 06:23:32.000000000","message":"So your suggestion to have ZMQ publisher proxy? What about Redis?","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"},{"author":{"_account_id":20229,"name":"Omer Anson","email":"omer.anson@toganetworks.com","username":"oanson"},"change_message_id":"91a043a2c8b860ccc90074164f06e42640c3ed9b","unresolved":false,"context_lines":[{"line_number":63,"context_line":"with a PULL/PUSH socket - that\u0027s the pattern for many publishers, few"},{"line_number":64,"context_line":"subscribers. The subscribers connect with a PUB/SUB socket - that\u0027s the"},{"line_number":65,"context_line":"pattern for many subscribers, few publishers."},{"line_number":66,"context_line":""},{"line_number":67,"context_line":"There are many interesting ideas in this regard in [1]_."},{"line_number":68,"context_line":""},{"line_number":69,"context_line":"TBD"}],"source_content_type":"text/x-rst","patch_set":1,"id":"5f4e5783_9b48685c","line":66,"in_reply_to":"5f4e5783_c5ca7f4c","updated":"2017-10-15 11:40:40.000000000","message":"Yes. Redis pub/sub is unaffected. Added.","commit_id":"4b55eb4e5aba39c782a1e94d5589135fc4986b66"}]}