X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=Bouncer%2Fsrc%2Fxapp-mgmt%2Fsubs_mgmt.hpp;h=28cf2930d9b6c0033ab3734a8b4dbfbe26b65748;hb=beb35192344dcb74d0cf98ecc22645827d74871f;hp=c50082780cf3d81caf37aec227afbc8a6bb02aa2;hpb=ff20129c8f517cca6e0b4de6544ff64aebe7c171;p=ric-app%2Fbouncer.git diff --git a/Bouncer/src/xapp-mgmt/subs_mgmt.hpp b/Bouncer/src/xapp-mgmt/subs_mgmt.hpp index c500827..28cf293 100644 --- a/Bouncer/src/xapp-mgmt/subs_mgmt.hpp +++ b/Bouncer/src/xapp-mgmt/subs_mgmt.hpp @@ -141,7 +141,9 @@ private: template bool SubscriptionHandler::add_transmitter_entry(transaction_identifier id, AppTransmitter &&trans){ - mdclog_write(MDCLOG_INFO,"Entry added for Transaction ID: %s",id.c_str()); + + mdclog_write(MDCLOG_INFO,"Entry added for Transaction ID: %s", id.c_str()); + // add entry in hash table if it does not exist auto search = trans_table.find(id); @@ -166,7 +168,9 @@ int SubscriptionHandler::manage_subscription_request(transaction_identifier rmr_ res = add_request_entry(rmr_trans_id, request_pending); if(! res){ - mdclog_write(MDCLOG_ERR, "%s, %d : Error adding new subscription request %s to queue because request with identical key already present", __FILE__, __LINE__, rmr_trans_id); + + mdclog_write(MDCLOG_ERR, "%s : Error adding new subscription request %s to queue because request with identical key already present", __FILE__, __LINE__); + return SUBSCR_ERR_DUPLICATE; } } @@ -181,10 +185,10 @@ int SubscriptionHandler::manage_subscription_request(transaction_identifier rmr_ if (!flg){ // clear state delete_request_entry(rmr_trans_id); - mdclog_write(MDCLOG_ERR, "%s, %d :: Error transmitting subscription request %s", __FILE__, __LINE__, rmr_trans_id.c_str() ); + mdclog_write(MDCLOG_ERR, "%s, %d :: Error transmitting subscription request %s", __FILE__, __LINE__, rmr_trans_id.c_str()); return SUBSCR_ERR_TX; } else { - mdclog_write(MDCLOG_INFO, "%s, %d :: Transmitted subscription request for trans_id %s", __FILE__, __LINE__, rmr_trans_id.c_str() ); + mdclog_write(MDCLOG_INFO, "%s, %d :: Transmitted subscription request for trans_id %s", __FILE__, __LINE__, rmr_trans_id.c_str()); add_transmitter_entry(rmr_trans_id, tx); }