X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Flib%2Fgscprts%2Frts_main.c;h=e41b748c9a4fc4c283ccdce590a352bcf5ce3e48;hb=HEAD;hp=5cbd092cb93d5f0f5cd0a45e0421c3e8f91d3fc9;hpb=834803ff24ff04d1f952ef2783838e964d961b87;p=com%2Fgs-lite.git

diff --git a/src/lib/gscprts/rts_main.c b/src/lib/gscprts/rts_main.c
index 5cbd092..e41b748 100644
--- a/src/lib/gscprts/rts_main.c
+++ b/src/lib/gscprts/rts_main.c
@@ -33,9 +33,9 @@
 #include <sys/socket.h>
 
 gs_retval_t main_csv(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);
-gs_retval_t main_csv2(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);
 gs_retval_t main_gdat(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);
 gs_retval_t main_dproto(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);
+gs_retval_t main_kafka(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);
 
 int main (int argc, char* argv[]) {
     gs_int32_t pid;
@@ -51,6 +51,7 @@ int main (int argc, char* argv[]) {
     gs_int32_t tip1,tip2,tip3,tip4;
     endpoint gshub;
     gs_sp_t instance_name;
+    gs_csp_t kafka;
     
     
 	gsopenlog(argv[0]);
@@ -134,7 +135,7 @@ int main (int argc, char* argv[]) {
         }
         
         if (pid==0) {
-            gs_sp_t interfacetype;
+            gs_csp_t interfacetype;
             /* wait for clearinghouse to finish startup */
             sleep(2);
             for(y=0;y<mapcnt;y++) {
@@ -153,22 +154,20 @@ int main (int argc, char* argv[]) {
                 exit(1);
             }
             
-            if (strcmp(interfacetype,"CSV")==0) {
-                main_csv(x,device[x],lmapcnt,lmap);        
+            if ((kafka = get_iface_properties(device[x],(gs_sp_t)"kafka")) && !strcmp(kafka,"TRUE")) {
+                main_kafka(x,device[x],lmapcnt,lmap);
+            } else if (strcmp(interfacetype,"CSV")==0) {
+                main_csv(x,device[x],lmapcnt,lmap);             
+            } else if (strncmp(interfacetype,"GDAT",4)==0) {
+                main_gdat(x,device[x],lmapcnt,lmap);
+			} else if (strncmp(interfacetype,"PROTO",5)==0) {
+                main_dproto(x,device[x],lmapcnt,lmap);
             } else {
-           		if (strncmp(interfacetype,"GDAT",4)==0) {
-                    main_gdat(x,device[x],lmapcnt,lmap);
-				}else{
-	           		if (strncmp(interfacetype,"PROTO",5)==0) {
-                    	main_dproto(x,device[x],lmapcnt,lmap);
-                	} else {
-						fprintf(stderr,"interface type %s not recognized\n",interfacetype);
-                    	gslog(LOG_ERR,"UNKNOWN InterfaceType\n");
-                    	exit(0);
-                	}
-				}
+    		    fprintf(stderr,"interface type %s not recognized\n",interfacetype);
+           	    gslog(LOG_ERR,"UNKNOWN InterfaceType\n");
+           	    exit(0);
             }
-            
+			
             /* should never return */
             gslog(LOG_EMERG,"lfta init returned");
             exit(1);