diff --git a/GNUmakefile b/GNUmakefile index 0a254575c..1ed16502e 100644 --- a/GNUmakefile +++ b/GNUmakefile @@ -63,7 +63,7 @@ Z_FEATURE_RAWETH_TRANSPORT?=0 # Buffer sizes FRAG_MAX_SIZE?=300000 BATCH_UNICAST_SIZE?=65535 -BATCH_MULTICAST_SIZE?=8096 +BATCH_MULTICAST_SIZE?=8192 # zenoh-pico/ directory ROOT_DIR:=$(shell dirname $(realpath $(firstword $(MAKEFILE_LIST)))) diff --git a/include/zenoh-pico/config.h b/include/zenoh-pico/config.h index 5b946505f..060afd51b 100644 --- a/include/zenoh-pico/config.h +++ b/include/zenoh-pico/config.h @@ -43,9 +43,9 @@ #define Z_FEATURE_ENCODING_VALUES 1 #define Z_FEATURE_TCP_NODELAY 1 #define Z_FEATURE_LOCAL_SUBSCRIBER 0 -#define Z_FEATURE_PUBLISHER_SESSION_CHECK 1 +#define Z_FEATURE_PUBLISHER_SESSION_CHECK 0 #define Z_FEATURE_BATCHING 1 -#define Z_FEATURE_RX_CACHE 0 +#define Z_FEATURE_RX_CACHE 1 // End of CMake generation /*------------------ Runtime configuration properties ------------------*/ diff --git a/include/zenoh-pico/protocol/codec/transport.h b/include/zenoh-pico/protocol/codec/transport.h index 006a59396..b0bcf2462 100644 --- a/include/zenoh-pico/protocol/codec/transport.h +++ b/include/zenoh-pico/protocol/codec/transport.h @@ -18,8 +18,8 @@ #include "zenoh-pico/protocol/definitions/transport.h" #include "zenoh-pico/protocol/iobuf.h" -extern "C" { #ifdef __cplusplus +extern "C" { #endif z_result_t _z_scouting_message_encode(_z_wbuf_t *buf, const _z_scouting_message_t *msg); diff --git a/include/zenoh-pico/session/queryable.h b/include/zenoh-pico/session/queryable.h index 6e8e8eeed..684880c17 100644 --- a/include/zenoh-pico/session/queryable.h +++ b/include/zenoh-pico/session/queryable.h @@ -24,7 +24,7 @@ typedef struct _z_session_rc_t _z_session_rc_t; // Queryable infos typedef struct { - _z_query_handler_t callback; + _z_closure_query_callback_t callback; void *arg; } _z_queryable_infos_t; diff --git a/include/zenoh-pico/session/session.h b/include/zenoh-pico/session/session.h index e709665e1..e1a39584e 100644 --- a/include/zenoh-pico/session/session.h +++ b/include/zenoh-pico/session/session.h @@ -89,7 +89,7 @@ typedef struct _z_query_t _z_query_t; /** * The callback signature of the functions handling query messages. */ -typedef void (*_z_closure_query_callback_t)(_z_query_rc_t *query, void *arg); +typedef void (*_z_closure_query_callback_t)(_z_query_t *query, void *arg); typedef struct { _z_keyexpr_t _key; diff --git a/include/zenoh-pico/session/subscription.h b/include/zenoh-pico/session/subscription.h index e124ce507..a103b0c21 100644 --- a/include/zenoh-pico/session/subscription.h +++ b/include/zenoh-pico/session/subscription.h @@ -24,7 +24,7 @@ typedef struct _z_session_t _z_session_t; // Subscription infos typedef struct { - _z_sample_handler_t callback; + _z_closure_sample_callback_t callback; void *arg; } _z_subscription_infos_t; diff --git a/include/zenoh-pico/transport/multicast/transport.h b/include/zenoh-pico/transport/multicast/transport.h index 049c64566..3e61f4bc1 100644 --- a/include/zenoh-pico/transport/multicast/transport.h +++ b/include/zenoh-pico/transport/multicast/transport.h @@ -42,4 +42,4 @@ static inline void _z_multicast_peer_mutex_unlock(_z_transport_multicast_t *ztm) #ifdef __cplusplus } #endif -#endif /* ZENOH_PICO_MULTICAST_TRANSPORT_H */ +#endif /* ZENOH_PICO_MULTICAST_TRANSPORT_H */ diff --git a/src/transport/multicast.c b/src/transport/multicast.c index 1573cb64d..eae7f7bc7 100644 --- a/src/transport/multicast.c +++ b/src/transport/multicast.c @@ -27,6 +27,7 @@ #include "zenoh-pico/transport/unicast/rx.h" #include "zenoh-pico/transport/utils.h" #include "zenoh-pico/utils/logging.h" +#include "zenoh-pico/utils/uuid.h" #if Z_FEATURE_MULTICAST_TRANSPORT == 1 void _zp_multicast_fetch_zid(const _z_transport_t *zt, _z_closure_zid_t *callback) { diff --git a/src/transport/unicast.c b/src/transport/unicast.c index bddc96fba..2387565cc 100644 --- a/src/transport/unicast.c +++ b/src/transport/unicast.c @@ -26,6 +26,7 @@ #include "zenoh-pico/transport/unicast/rx.h" #include "zenoh-pico/transport/utils.h" #include "zenoh-pico/utils/logging.h" +#include "zenoh-pico/utils/uuid.h" #if Z_FEATURE_UNICAST_TRANSPORT == 1 void _zp_unicast_fetch_zid(const _z_transport_t *zt, _z_closure_zid_t *callback) { diff --git a/zenohpico.pc b/zenohpico.pc index 1e3b39ae2..0bfb73da3 100644 --- a/zenohpico.pc +++ b/zenohpico.pc @@ -3,6 +3,6 @@ prefix=/usr/local Name: zenohpico Description: URL: -Version: 1.0.20241018dev +Version: 1.0.20241113dev Cflags: -I${prefix}/include Libs: -L${prefix}/lib -lzenohpico