-/* ------------------------------------------------
- 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;
-}
-
+/* ------------------------------------------------\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
Code Review / com / gs-lite.git / blobdiff