Added quantiling UDAFs
[com/gs-lite.git] / src / tools / gdatcat.c
index 83e626c..26d4eb1 100644 (file)
-/* ------------------------------------------------
- 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 <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <time.h>
-#include <unistd.h>
-
-
-
-gs_sp_t me = 0;
-gs_sp_t schematext = 0;
-gs_int32_t schematextlen = 0;
-gs_sp_t schematmp = 0;
-
-static void do_file(gs_sp_t filename, gs_int32_t fnlen);
-
-int main(int argc, char** argv) {
-    gs_int32_t x;
-    gs_int32_t s=1;
-    gs_int32_t debug=0;
-    if (strcmp(argv[s],"-d")==0) {
-        debug=1;
-        s++;
-    }
-    for(x=s;x<argc;x++) {
-        if (debug) {
-            fprintf(stderr,"%s\n",argv[x]);
-        }
-        do_file(argv[x], strlen(argv[x]));
-    }
-    return 0;
-}
-
-
-/*
- * do_file: dump the file out
- */
-
-static void do_file(gs_sp_t filename, gs_int32_t fnlen) {
-    gs_int32_t pipe, parserversion, schemalen;
-    FILE *input;
-    gs_int8_t cmd2[4096 + 128];
-    static gs_int8_t *dbuf;
-    size_t sz;
-    
-    if (fnlen > 3 && filename[fnlen - 3] == '.' &&
-        filename[fnlen - 2] == 'g' &&
-        filename[fnlen - 1] == 'z') {
-        pipe = 1;
-        snprintf(cmd2, sizeof(cmd2), "gzcat %s", filename);
-        input = popen(cmd2, "r");
-    } else {
-        if (fnlen > 3 && filename[fnlen - 3] == 'b' &&
-            filename[fnlen - 2] == 'z' &&
-            filename[fnlen - 1] == '2') {
-            pipe = 1;
-            snprintf(cmd2, sizeof(cmd2), "bzcat %s", filename);
-            input = popen(cmd2, "r");
-        } else {
-            input = fopen(filename, "r");
-        }
-    }
-    
-    if (!input) {
-        perror("stream open");
-        fprintf(stderr, "%s: cannot open %s\n", me, filename);
-        return;
-    }
-    
-    if (fscanf(input, "GDAT\nVERSION:%u\nSCHEMALENGTH:%u\n",
-               &parserversion,&schemalen) != 2) {
-        fprintf(stderr,"%s: cannot parse GDAT file header in '%s'\n",
-                me, filename);
-        exit(1);
-    }
-    
-    /* first time ? */
-    if (schematext == 0) {
-        schematextlen = schemalen;
-        schematext = malloc(schemalen);
-        dbuf = malloc(CATBLOCKSZ);
-        if (!schematext  || !dbuf) {
-            fprintf(stderr,"%s: malloc error reading GDAT file header in '%s'\n",
-                    me, filename);
-            exit(1);
-        }
-        if (fread(schematext, schemalen, 1, input) != 1) {
-            fprintf(stderr,"%s: cannot parse-read GDAT file header in '%s'\n",
-                    me, filename);
-            exit(1);
-        }
-        printf("GDAT\nVERSION:%u\nSCHEMALENGTH:%u\n", parserversion, schemalen);
-        fwrite(schematext, schemalen, 1, stdout);
-    } else {
-        schematmp = malloc(schemalen);
-        if (!schematmp ) {
-            fprintf(stderr,"%s: malloc error reading GDAT file header in '%s'\n",
-                    me, filename);
-            exit(1);
-        }
-        if (fread(schematmp, schemalen, 1, input) != 1) {
-            fprintf(stderr,"%s: cannot parse-read GDAT file header in '%s'\n",
-                    me, filename);
-            exit(1);
-        }
-        free(schematmp);
-        //   if (memcmp(schematext, schematmp, schematextlen)) {
-        //     fprintf(stderr,"%s: GDAT schema mis-match in file '%s'\n",
-        //             me, filename);
-        //     exit(1);
-        //   }
-    }
-    
-    while ((sz = fread(dbuf, 1, CATBLOCKSZ, input)) > 0) {
-        fwrite(dbuf, 1, sz, stdout);
-    }
-    
-    if (pipe) {
-        pclose(input);
-    } else {
-        fclose(input);
-    }
-    
-}
+/* ------------------------------------------------\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
+\r
+#include <stdio.h>\r
+#include <stdlib.h>\r
+#include <string.h>\r
+#include <sys/types.h>\r
+#include <sys/stat.h>\r
+#include <time.h>\r
+#include <unistd.h>\r
+\r
+\r
+\r
+gs_sp_t me = 0;\r
+gs_sp_t schematext = 0;\r
+gs_int32_t schematextlen = 0;\r
+gs_sp_t schematmp = 0;\r
+\r
+static void do_file(gs_sp_t filename, gs_int32_t fnlen);\r
+\r
+int main(int argc, char** argv) {\r
+    gs_int32_t x;\r
+    gs_int32_t s=1;\r
+    gs_int32_t debug=0;\r
+    if (strcmp(argv[s],"-d")==0) {\r
+        debug=1;\r
+        s++;\r
+    }\r
+    for(x=s;x<argc;x++) {\r
+        if (debug) {\r
+            fprintf(stderr,"%s\n",argv[x]);\r
+        }\r
+        do_file(argv[x], strlen(argv[x]));\r
+    }\r
+    return 0;\r
+}\r
+\r
+\r
+/*\r
+ * do_file: dump the file out\r
+ */\r
+\r
+static void do_file(gs_sp_t filename, gs_int32_t fnlen) {\r
+    gs_int32_t pipe, parserversion, schemalen;\r
+    FILE *input;\r
+    gs_int8_t cmd2[4096 + 128];\r
+    static gs_int8_t *dbuf;\r
+    size_t sz;\r
+    \r
+    if (fnlen > 3 && filename[fnlen - 3] == '.' &&\r
+        filename[fnlen - 2] == 'g' &&\r
+        filename[fnlen - 1] == 'z') {\r
+        pipe = 1;\r
+        snprintf(cmd2, sizeof(cmd2), "gzcat %s", filename);\r
+        input = popen(cmd2, "r");\r
+    } else {\r
+        if (fnlen > 3 && filename[fnlen - 3] == 'b' &&\r
+            filename[fnlen - 2] == 'z' &&\r
+            filename[fnlen - 1] == '2') {\r
+            pipe = 1;\r
+            snprintf(cmd2, sizeof(cmd2), "bzcat %s", filename);\r
+            input = popen(cmd2, "r");\r
+        } else {\r
+            input = fopen(filename, "r");\r
+        }\r
+    }\r
+    \r
+    if (!input) {\r
+        perror("stream open");\r
+        fprintf(stderr, "%s: cannot open %s\n", me, filename);\r
+        return;\r
+    }\r
+    \r
+    if (fscanf(input, "GDAT\nVERSION:%u\nSCHEMALENGTH:%u\n",\r
+               &parserversion,&schemalen) != 2) {\r
+        fprintf(stderr,"%s: cannot parse GDAT file header in '%s'\n",\r
+                me, filename);\r
+        exit(1);\r
+    }\r
+    \r
+    /* first time ? */\r
+    if (schematext == 0) {\r
+        schematextlen = schemalen;\r
+        schematext = malloc(schemalen);\r
+        dbuf = malloc(CATBLOCKSZ);\r
+        if (!schematext  || !dbuf) {\r
+            fprintf(stderr,"%s: malloc error reading GDAT file header in '%s'\n",\r
+                    me, filename);\r
+            exit(1);\r
+        }\r
+        if (fread(schematext, schemalen, 1, input) != 1) {\r
+            fprintf(stderr,"%s: cannot parse-read GDAT file header in '%s'\n",\r
+                    me, filename);\r
+            exit(1);\r
+        }\r
+        printf("GDAT\nVERSION:%u\nSCHEMALENGTH:%u\n", parserversion, schemalen);\r
+        fwrite(schematext, schemalen, 1, stdout);\r
+    } else {\r
+        schematmp = malloc(schemalen);\r
+        if (!schematmp ) {\r
+            fprintf(stderr,"%s: malloc error reading GDAT file header in '%s'\n",\r
+                    me, filename);\r
+            exit(1);\r
+        }\r
+        if (fread(schematmp, schemalen, 1, input) != 1) {\r
+            fprintf(stderr,"%s: cannot parse-read GDAT file header in '%s'\n",\r
+                    me, filename);\r
+            exit(1);\r
+        }\r
+        free(schematmp);\r
+        //   if (memcmp(schematext, schematmp, schematextlen)) {\r
+        //     fprintf(stderr,"%s: GDAT schema mis-match in file '%s'\n",\r
+        //             me, filename);\r
+        //     exit(1);\r
+        //   }\r
+    }\r
+    \r
+    while ((sz = fread(dbuf, 1, CATBLOCKSZ, input)) > 0) {\r
+        fwrite(dbuf, 1, sz, stdout);\r
+    }\r
+    \r
+    if (pipe) {\r
+        pclose(input);\r
+    } else {\r
+        fclose(input);\r
+    }\r
+    \r
+}\r