FS-10167: Fixing linux build for blade.broadcast related stuff

diff --git a/libs/libblade/Makefile.am b/libs/libblade/Makefile.am
index 45378d1b9f01f2c5a62a4b4c305f46d529f010b8..bd51abd604b8b64ab61ed7da1587a3b0f0010e5e 100644 (file)
--- a/libs/libblade/Makefile.am
+++ b/libs/libblade/Makefile.am
@@ -13,7 +13,7 @@ libunqlite_la_LIBADD    = -lpthread
 lib_LTLIBRARIES                = libblade.la
 libblade_la_SOURCES     = src/blade.c src/blade_stack.c
 libblade_la_SOURCES    += src/blade_identity.c src/blade_rpc.c src/blade_connection.c src/blade_session.c
-libblade_la_SOURCES    += src/blade_protocol.c
+libblade_la_SOURCES    += src/blade_protocol.c src/blade_subscription.c
 libblade_la_SOURCES    += src/blade_transport.c src/blade_transport_wss.c
 
 libblade_la_CFLAGS     = $(AM_CFLAGS) $(AM_CPPFLAGS)
@@ -23,7 +23,7 @@ libblade_la_LIBADD      = libunqlite.la
 library_includedir     = $(prefix)/include
 library_include_HEADERS = src/include/blade.h src/include/blade_types.h src/include/blade_stack.h
 library_include_HEADERS += src/include/blade_identity.h src/include/blade_rpc.h src/include/blade_connection.h src/include/blade_session.h
-library_include_HEADERS += src/include/blade_protocol.h
+library_include_HEADERS += src/include/blade_protocol.h src/include/blade_subscription.h
 library_include_HEADERS += src/include/blade_transport.h src/include/blade_transport_wss.h
 library_include_HEADERS += src/include/unqlite.h test/tap.h
 

diff --git a/libs/libblade/src/blade_stack.c b/libs/libblade/src/blade_stack.c
index 278a16e5b46aa218c39b85a3ba5f74a5cab37ea3..38c20290458133a979d6be02c12cee0342c3948d 100644 (file)
--- a/libs/libblade/src/blade_stack.c
+++ b/libs/libblade/src/blade_stack.c
@@ -1990,7 +1990,7 @@ KS_DECLARE(ks_status_t) blade_protocol_subscribe(blade_handle_t *bh, const char
                ret = KS_STATUS_DISCONNECTED;
                goto done;
        }
-       
+
        if (remove) {
                propagate = blade_handle_subscriber_remove(bh, &bsub, event, protocol, realm, bh->local_nodeid);
        } else {
@@ -2193,7 +2193,7 @@ KS_DECLARE(ks_status_t) blade_protocol_broadcast_raw(blade_handle_t *bh, const c
                        cJSON *req = NULL;
                        cJSON *req_params = NULL;
 
-                       ks_hash_this(it, &key, NULL, &value);
+                       ks_hash_this(it, (const void **)&key, NULL, &value);
 
                        if (excluded_nodeid && !ks_safe_strcasecmp(excluded_nodeid, (const char *)key)) continue;
 
@@ -2311,7 +2311,7 @@ ks_bool_t blade_protocol_broadcast_request_handler(blade_rpc_request_t *brpcreq,
                goto done;
        }
 
-       req_params_params = cJSON_GetObjectCstr(req_params, "params");
+       req_params_params = cJSON_GetObjectItem(req_params, "params");
 
 
        blade_protocol_broadcast_raw(bh, blade_session_id_get(bs), req_params_event, req_params_protocol, req_params_realm, req_params_params, NULL, NULL);
@@ -2324,7 +2324,7 @@ ks_bool_t blade_protocol_broadcast_request_handler(blade_rpc_request_t *brpcreq,
        bsub = (blade_subscription_t *)ks_hash_search(bh->subscriptions, (void *)bsub_key, KS_UNLOCKED);
        if (bsub) {
                ks_rwl_read_lock(bh->local_nodeid_rwl);
-               if (ks_hash_search(blade_subscription_subscribers_get(bsub), bh->local_nodeid, KS_UNLOCKED)) {
+               if (ks_hash_search(blade_subscription_subscribers_get(bsub), (void *)bh->local_nodeid, KS_UNLOCKED)) {
                        callback = blade_subscription_callback_get(bsub);
                        if (callback) ret = callback(brpcreq, blade_subscription_callback_data_get(bsub));
                }