X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fnng%2Finclude%2Frmr_nng_private.h;h=6bca91f83bfcab37670ab9b15abf5c958edfcc62;hb=907fbf43104b1670b7374bf1a4b22096977774bf;hp=a1bba74bad95f54db7620ba7840acf903580efdd;hpb=d710957ed5d73bf2da2ceea3f5a1a3c509275c30;p=ric-plt%2Flib%2Frmr.git

diff --git a/src/nng/include/rmr_nng_private.h b/src/nng/include/rmr_nng_private.h
index a1bba74..6bca91f 100644
--- a/src/nng/include/rmr_nng_private.h
+++ b/src/nng/include/rmr_nng_private.h
@@ -1,14 +1,14 @@
 // : vi ts=4 sw=4 noet :
 /*
 ==================================================================================
-	Copyright (c) 2019 Nokia 
+	Copyright (c) 2019 Nokia
 	Copyright (c) 2018-2019 AT&T Intellectual Property.
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at
 
-       http://www.apache.org/licenses/LICENSE-2.0
+	   http://www.apache.org/licenses/LICENSE-2.0
 
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
@@ -49,14 +49,14 @@ struct endpoint {
 	Epoll information needed for the rmr_torcv_msg() funciton
 */
 typedef struct epoll_stuff {
-    struct epoll_event events[1];				// wait on 10 possible events
-    struct epoll_event epe;						// event definition for event to listen to
+	struct epoll_event events[1];				// wait on 10 possible events
+	struct epoll_event epe;						// event definition for event to listen to
 	int ep_fd;									// file des from nng
 	int nng_fd;									// fd from nng
 } epoll_stuff_t;
 
 /*
-	Context describing our world. Should be returned to user programme on 
+	Context describing our world. Should be returned to user programme on
 	call to initialise, and passed as first parm on all calls to other
 	visible functions.
 
@@ -79,10 +79,10 @@ struct uta_ctx {
 	route_table_t* new_rtable;	// route table under construction
 	if_addrs_t*	ip_list;		// list manager of the IP addresses that are on our known interfaces
 	void*	mring;				// ring where msgs are queued while waiting for a call response msg
-	
+
 	char*	rtg_addr;			// addr/port of the route table generation publisher
 	int		rtg_port;			// the port that the rtg listens on
-	
+
 	wh_mgt_t*	wormholes;		// management of user opened wormholes
 	epoll_stuff_t*	eps;		// epoll information needed for the rcv with timeout call
 
@@ -92,7 +92,7 @@ struct uta_ctx {
 
 
 /*
-	Static prototypes for functions located here. All common protos are in the 
+	Static prototypes for functions located here. All common protos are in the
 	agnostic header file.
 */
 
@@ -104,7 +104,7 @@ static void free_ctx( uta_ctx_t* ctx );
 static int uta_link2( char* target, nng_socket* nn_sock, nng_dialer* dialer );
 static int rt_link2_ep( endpoint_t* ep );
 static int uta_epsock_byname( route_table_t* rt, char* ep_name, nng_socket* nn_sock );
-static int uta_epsock_rr( route_table_t *rt, int mtype, int group, int* more, nng_socket* nn_sock );
+static int uta_epsock_rr( route_table_t *rt, uint64_t key, int group, int* more, nng_socket* nn_sock );
 static inline int xlate_nng_state( int state, int def_state );