Merge branch 'pubsub_serializer_refactoring' into develop
Project: http://git-wip-us.apache.org/repos/asf/celix/repo Commit: http://git-wip-us.apache.org/repos/asf/celix/commit/42545f1a Tree: http://git-wip-us.apache.org/repos/asf/celix/tree/42545f1a Diff: http://git-wip-us.apache.org/repos/asf/celix/diff/42545f1a Branch: refs/heads/develop Commit: 42545f1a9c6d42a152c779ace3107e39baa7b95c Parents: 83018f0 a89ca58 Author: gricciardi <[email protected]> Authored: Fri Sep 29 15:32:18 2017 +0200 Committer: gricciardi <[email protected]> Committed: Fri Sep 29 15:32:18 2017 +0200 ---------------------------------------------------------------------- .travis.yml | 6 +- pubsub/api/pubsub/publisher.h | 2 +- pubsub/api/pubsub/subscriber.h | 2 +- .../examples/mp_pubsub/publisher/CMakeLists.txt | 2 +- .../mp_pubsub/subscriber/CMakeLists.txt | 8 +- pubsub/examples/pubsub/publisher/CMakeLists.txt | 2 +- .../publisher/private/src/pubsub_publisher.c | 7 +- .../examples/pubsub/publisher2/CMakeLists.txt | 2 +- .../examples/pubsub/subscriber/CMakeLists.txt | 2 +- pubsub/pubsub_admin_udp_mc/CMakeLists.txt | 4 +- .../private/include/pubsub_admin_impl.h | 36 +- .../include/pubsub_publish_service_private.h | 59 -- .../private/include/topic_publication.h | 57 ++ .../private/include/topic_subscription.h | 9 +- .../private/src/psa_activator.c | 38 +- .../private/src/pubsub_admin_impl.c | 741 ++++++++++++------- .../private/src/topic_publication.c | 302 +++----- .../private/src/topic_subscription.c | 473 ++++++------ pubsub/pubsub_admin_zmq/CMakeLists.txt | 3 +- .../private/include/pubsub_admin_impl.h | 38 +- .../include/pubsub_publish_service_private.h | 51 -- .../private/include/topic_publication.h | 49 ++ .../private/include/topic_subscription.h | 7 +- .../private/src/psa_activator.c | 36 +- .../private/src/pubsub_admin_impl.c | 708 ++++++++++++------ .../private/src/topic_publication.c | 269 +++---- .../private/src/topic_subscription.c | 502 ++++++------- .../pubsub_common/public/include/pubsub_admin.h | 22 +- .../public/include/pubsub_admin_match.h | 27 + .../public/include/pubsub_common.h | 8 +- .../public/include/pubsub_endpoint.h | 12 +- .../public/include/pubsub_serializer.h | 27 +- pubsub/pubsub_common/public/src/log_helper.c | 48 +- .../public/src/pubsub_admin_match.c | 303 ++++++++ .../pubsub_common/public/src/pubsub_endpoint.c | 184 +++-- pubsub/pubsub_discovery/CMakeLists.txt | 1 + .../private/include/pubsub_discovery_impl.h | 1 - .../pubsub_discovery/private/src/etcd_common.c | 1 + .../pubsub_discovery/private/src/etcd_watcher.c | 216 +++--- .../pubsub_discovery/private/src/etcd_writer.c | 160 ++-- .../private/src/psd_activator.c | 2 +- .../private/src/pubsub_discovery_impl.c | 13 +- .../private/include/pubsub_serializer_impl.h | 23 +- .../private/src/ps_activator.c | 6 +- .../private/src/pubsub_serializer_impl.c | 339 +++++---- .../private/include/pubsub_topology_manager.h | 11 - .../private/src/pstm_activator.c | 64 +- .../private/src/pubsub_topology_manager.c | 526 ++++--------- 48 files changed, 2907 insertions(+), 2502 deletions(-) ----------------------------------------------------------------------
