-/* ------------------------------------------------\r
- Copyright 2014 AT&T Intellectual Property\r
- Licensed under the Apache License, Version 2.0 (the "License");\r
- you may not use this file except in compliance with the License.\r
- You may obtain a copy of the License at\r
- \r
- http://www.apache.org/licenses/LICENSE-2.0\r
- \r
- Unless required by applicable law or agreed to in writing, software\r
- distributed under the License is distributed on an "AS IS" BASIS,\r
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- See the License for the specific language governing permissions and\r
- limitations under the License.\r
- ------------------------------------------- */\r
-\r
-#include "gsconfig.h"\r
-#include "gstypes.h"\r
-#include "gshub.h"\r
-\r
-#include "lapp.h"\r
-#include "fta.h"\r
-#include "lfta/rts.h"\r
-\r
-#include "stdio.h"\r
-#include "stdlib.h"\r
-#include <sys/types.h>\r
-#include <unistd.h>\r
-\r
-#include <sys/ipc.h>\r
-#include <sys/shm.h>\r
-#include <fcntl.h>\r
-#include <errno.h>\r
-#include <sys/socket.h>\r
-\r
-gs_retval_t main_csv(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);\r
-gs_retval_t main_csv2(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);\r
-gs_retval_t main_gdat(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);\r
-gs_retval_t main_dproto(gs_int32_t devicenum, gs_sp_t device, gs_int32_t mapcnt, gs_sp_t map[]);\r
-\r
-int main (int argc, char* argv[]) {\r
- gs_int32_t pid;\r
- gs_int32_t x;\r
- gs_int32_t y;\r
- gs_sp_t* device;\r
- gs_int32_t devcnt=0;\r
- gs_sp_t* mappings;\r
- gs_int32_t mapcnt=0;\r
- gs_sp_t* lmap;\r
- gs_int32_t lmapcnt=0;\r
- FILE * cfg_file;\r
- gs_int32_t tip1,tip2,tip3,tip4;\r
- endpoint gshub;\r
- gs_sp_t instance_name;\r
- \r
- \r
- gsopenlog(argv[0]);\r
- \r
- if (setpgid(0,0)<0) {\r
- gslog(LOG_EMERG,"Could not set process group id of rts");\r
- exit(1);\r
- }\r
- \r
- if (argc<4) {\r
- gslog(LOG_EMERG,"Wrong arguments at startup");\r
- exit(1);\r
- }\r
- \r
- /* allocate more than enough for each array */\r
- if ((device=(gs_sp_t*)malloc(sizeof(gs_sp_t*) * argc))==0) {\r
- gslog(LOG_EMERG,"malloc error");\r
- exit(1);\r
- }\r
- if ((mappings=(gs_sp_t*)malloc(sizeof(gs_sp_t*) * argc))==0) {\r
- gslog(LOG_EMERG,"malloc error");\r
- exit(1);\r
- }\r
- if ((lmap=(gs_sp_t*)malloc(sizeof(gs_sp_t*) * argc))==0) {\r
- gslog(LOG_EMERG,"malloc error");\r
- exit(1);\r
- }\r
- \r
- /* parse the arguments */\r
- \r
- if ((sscanf(argv[1],"%u.%u.%u.%u:%hu",&tip1,&tip2,&tip3,&tip4,&(gshub.port))!=5)) {\r
- gslog(LOG_EMERG,"HUB IP NOT DEFINED");\r
- exit(1);\r
- }\r
- gshub.ip=htonl(tip1<<24|tip2<<16|tip3<<8|tip4);\r
- gshub.port=htons(gshub.port);\r
- instance_name=strdup(argv[2]);\r
- if (set_hub(gshub)!=0) {\r
- gslog(LOG_EMERG,"Could not set hub");\r
- exit(1);\r
- }\r
- if (set_instance_name(instance_name)!=0) {\r
- gslog(LOG_EMERG,"Could not set instance name");\r
- exit(1);\r
- }\r
- \r
- for(x=3;x<argc;x++) {\r
- if (strncmp("-D",argv[x],2)==0) {\r
- /* macro definition */\r
- y=2;\r
- while((y<(strlen(argv[x])-1))&&(argv[x][y]!='=')) y++;\r
- \r
- \r
- if (y<(strlen(argv[x])-1)) {\r
- /* if that is not true the define is empty and\r
- we ignore it otherwise we set the = to 0 to\r
- make two strings out of it*/\r
- argv[x][y]=0;\r
- mappings[mapcnt]=&(argv[x][2]);\r
- mapcnt++;\r
- }\r
- } else {\r
- /* device definition */\r
- device[devcnt]=argv[x];\r
- devcnt++;\r
- }\r
- }\r
- \r
- if (devcnt==0) {\r
- gslog(LOG_EMERG,"at least one device has to be specified");\r
- exit(1);\r
- }\r
- \r
- \r
- /* now startup all the device dependend processes. */\r
- \r
- for (x=0;x<devcnt;x++) {\r
- if ((pid=fork())==-1) {\r
- gslog(LOG_EMERG,"fork error");\r
- exit(1);\r
- }\r
- \r
- if (pid==0) {\r
- gs_sp_t interfacetype;\r
- /* wait for clearinghouse to finish startup */\r
- sleep(2);\r
- for(y=0;y<mapcnt;y++) {\r
- if (strcmp(device[x],&mappings[y][strlen(mappings[y])+1])==0) {\r
- /* point to the second string */\r
- lmap[lmapcnt]=mappings[y];\r
- lmapcnt++;\r
- }\r
- }\r
- /* the devicename always matches */\r
- lmap[lmapcnt]=device[x];\r
- lmapcnt++;\r
- \r
- if ((interfacetype=get_iface_properties(device[x],(gs_sp_t)"interfacetype"))==0) {\r
- gslog(LOG_EMERG,"Interface Type not configured but required");\r
- exit(1);\r
- }\r
- \r
- if (strcmp(interfacetype,"CSV")==0) {\r
- main_csv(x,device[x],lmapcnt,lmap); \r
- } else {\r
- if (strncmp(interfacetype,"GDAT",4)==0) {\r
- main_gdat(x,device[x],lmapcnt,lmap);\r
- }else{\r
- if (strncmp(interfacetype,"PROTO",5)==0) {\r
- main_dproto(x,device[x],lmapcnt,lmap);\r
- } else {\r
- fprintf(stderr,"interface type %s not recognized\n",interfacetype);\r
- gslog(LOG_ERR,"UNKNOWN InterfaceType\n");\r
- exit(0);\r
- }\r
- }\r
- }\r
- \r
- /* should never return */\r
- gslog(LOG_EMERG,"lfta init returned");\r
- exit(1); \r
- }\r
- }\r
- \r
- /* initalize host_lib */\r
- \r
- gslog(LOG_INFO,"Init host lib in clearinghouse");\r
- \r
- if (hostlib_init(CLEARINGHOUSE,0,DEFAULTDEV,0,0)<0) {\r
- gslog(LOG_EMERG,"%s::error:could not initiate host lib for clearinghouse\n",\r
- argv[0]);\r
- exit(7);\r
- }\r
- \r
- \r
- \r
- /* start processing messages should never return*/\r
- if (fta_start_service(-1)<0) {\r
- gslog(LOG_EMERG,"error in processing the msg queue");\r
- exit(9);\r
- }\r
- gslog(LOG_EMERG,"%s::error:start service returned");\r
- return 0;\r
-}\r
-\r
+/* ------------------------------------------------
+ Copyright 2014 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
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+ ------------------------------------------- */
+
+#include "gsconfig.h"
+#include "gstypes.h"
+#include "gshub.h"
+
+#include "lapp.h"
+#include "fta.h"
+#include "lfta/rts.h"
+
+#include "stdio.h"
+#include "stdlib.h"
+#include <sys/types.h>
+#include <unistd.h>
+
+#include <sys/ipc.h>
+#include <sys/shm.h>
+#include <fcntl.h>
+#include <errno.h>
+#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[]);
+
+int main (int argc, char* argv[]) {
+ gs_int32_t pid;
+ gs_int32_t x;
+ gs_int32_t y;
+ gs_sp_t* device;
+ gs_int32_t devcnt=0;
+ gs_sp_t* mappings;
+ gs_int32_t mapcnt=0;
+ gs_sp_t* lmap;
+ gs_int32_t lmapcnt=0;
+ FILE * cfg_file;
+ gs_int32_t tip1,tip2,tip3,tip4;
+ endpoint gshub;
+ gs_sp_t instance_name;
+
+
+ gsopenlog(argv[0]);
+
+ if (setpgid(0,0)<0) {
+ gslog(LOG_EMERG,"Could not set process group id of rts");
+ exit(1);
+ }
+
+ if (argc<4) {
+ gslog(LOG_EMERG,"Wrong arguments at startup");
+ exit(1);
+ }
+
+ /* allocate more than enough for each array */
+ if ((device=(gs_sp_t*)malloc(sizeof(gs_sp_t*) * argc))==0) {
+ gslog(LOG_EMERG,"malloc error");
+ exit(1);
+ }
+ if ((mappings=(gs_sp_t*)malloc(sizeof(gs_sp_t*) * argc))==0) {
+ gslog(LOG_EMERG,"malloc error");
+ exit(1);
+ }
+ if ((lmap=(gs_sp_t*)malloc(sizeof(gs_sp_t*) * argc))==0) {
+ gslog(LOG_EMERG,"malloc error");
+ exit(1);
+ }
+
+ /* parse the arguments */
+
+ if ((sscanf(argv[1],"%u.%u.%u.%u:%hu",&tip1,&tip2,&tip3,&tip4,&(gshub.port))!=5)) {
+ gslog(LOG_EMERG,"HUB IP NOT DEFINED");
+ exit(1);
+ }
+ gshub.ip=htonl(tip1<<24|tip2<<16|tip3<<8|tip4);
+ gshub.port=htons(gshub.port);
+ instance_name=strdup(argv[2]);
+ if (set_hub(gshub)!=0) {
+ gslog(LOG_EMERG,"Could not set hub");
+ exit(1);
+ }
+ if (set_instance_name(instance_name)!=0) {
+ gslog(LOG_EMERG,"Could not set instance name");
+ exit(1);
+ }
+
+ for(x=3;x<argc;x++) {
+ if (strncmp("-D",argv[x],2)==0) {
+ /* macro definition */
+ y=2;
+ while((y<(strlen(argv[x])-1))&&(argv[x][y]!='=')) y++;
+
+
+ if (y<(strlen(argv[x])-1)) {
+ /* if that is not true the define is empty and
+ we ignore it otherwise we set the = to 0 to
+ make two strings out of it*/
+ argv[x][y]=0;
+ mappings[mapcnt]=&(argv[x][2]);
+ mapcnt++;
+ }
+ } else {
+ /* device definition */
+ device[devcnt]=argv[x];
+ devcnt++;
+ }
+ }
+
+ if (devcnt==0) {
+ gslog(LOG_EMERG,"at least one device has to be specified");
+ exit(1);
+ }
+
+
+ /* now startup all the device dependend processes. */
+
+ for (x=0;x<devcnt;x++) {
+ if ((pid=fork())==-1) {
+ gslog(LOG_EMERG,"fork error");
+ exit(1);
+ }
+
+ if (pid==0) {
+ gs_sp_t interfacetype;
+ /* wait for clearinghouse to finish startup */
+ sleep(2);
+ for(y=0;y<mapcnt;y++) {
+ if (strcmp(device[x],&mappings[y][strlen(mappings[y])+1])==0) {
+ /* point to the second string */
+ lmap[lmapcnt]=mappings[y];
+ lmapcnt++;
+ }
+ }
+ /* the devicename always matches */
+ lmap[lmapcnt]=device[x];
+ lmapcnt++;
+
+ if ((interfacetype=get_iface_properties(device[x],(gs_sp_t)"interfacetype"))==0) {
+ gslog(LOG_EMERG,"Interface Type not configured but required");
+ exit(1);
+ }
+
+ 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 {
+ 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);
+ }
+ }
+
+ /* initalize host_lib */
+
+ gslog(LOG_INFO,"Init host lib in clearinghouse");
+
+ if (hostlib_init(CLEARINGHOUSE,0,DEFAULTDEV,0,0)<0) {
+ gslog(LOG_EMERG,"%s::error:could not initiate host lib for clearinghouse\n",
+ argv[0]);
+ exit(7);
+ }
+
+
+
+ /* start processing messages should never return*/
+ if (fta_start_service(-1)<0) {
+ gslog(LOG_EMERG,"error in processing the msg queue");
+ exit(9);
+ }
+ gslog(LOG_EMERG,"%s::error:start service returned");
+ return 0;
+}
+
Code Review / com / gs-lite.git / blobdiff