Various improvements. Close-on-exec and close on failure on either
[egate.git] / util / iso2709.c
index 1bd46e3..d79e422 100644 (file)
@@ -1,12 +1,45 @@
 /*
-   Iso2709 record management
-
-   Europagate, 1994-1995.
-
-   $Log: iso2709.c,v $
-   Revision 1.4  1995/02/15 17:45:44  adam
-   Bug fix in iso2709 module.
-
+ * Iso2709 record management
+ *
+ * Europagate, 1994-1995.
+ *
+ * $Log: iso2709.c,v $
+ * Revision 1.15  1995/03/31 10:42:41  adam
+ * Bug fix.
+ *
+ * Revision 1.14  1995/03/30  14:22:18  adam
+ * More work on new MARC anchor functions.
+ *
+ * Revision 1.13  1995/03/30  07:33:32  adam
+ * New 2709 function: iso2709_mk.
+ * First implementation of iso2709_a_insert.
+ *
+ * Revision 1.12  1995/03/29  16:08:56  adam
+ * Better error recovery when using bad records.
+ *
+ * Revision 1.11  1995/03/28  16:07:07  adam
+ * New function: iso2709_out. This function is the reverse of iso2709_cvt.
+ *
+ * Revision 1.10  1995/03/10  09:10:56  adam
+ * Removed dbc2709_cvt function. Makes heuristic guess for DBC2709 records.
+ *
+ * Revision 1.9  1995/03/08  12:36:39  adam
+ * New function: dbc2709_cvt.
+ *
+ * Revision 1.8  1995/03/08  12:03:15  adam
+ * Hack: When tags 00? are used, every separator (DC[1-3]) marks
+ * the end of the data field.
+ *
+ * Revision 1.7  1995/02/22  21:28:03  adam
+ * Changed header.
+ *
+ * Revision 1.5  1995/02/22  15:24:14  adam
+ * Function iso2709_cvt makes a litte check for the format. It returns
+ * NULL if the buffer parameter can never be a MARC record.
+ *
+ * Revision 1.4  1995/02/15  17:45:44  adam
+ * Bug fix in iso2709 module.
+ *
  * Revision 1.3  1995/02/10  17:05:18  adam
  * New function iso2709_display to display MARC records in a
  * line-by-line format. The iso2709_cvt function no longer
@@ -53,10 +86,6 @@ static void strncpyx (char *d, const char *s, int n)
             s++;
         }
     *d = '\0';
-#if 0
-    strncpy (d, s, n);
-    d[n] = '\0';
-#endif
 }
 
 char *iso2709_read (FILE *inf)
@@ -82,6 +111,29 @@ char *iso2709_read (FILE *inf)
     return buf;
 }
 
+Iso2709Rec iso2709_mk (void)
+{
+    Iso2709Rec p;
+
+    if (!(p = malloc (sizeof(*p))))
+        return NULL;
+
+    p->record_length = 0;
+    strncpyx (p->record_status, " ", 1);
+    strncpyx (p->implementation_codes, "    ", 4);
+    p->indicator_length = 2;
+    p->identifier_length = 2;
+    p->base_address = 0;
+    strncpyx (p->user_systems, "   ", 3);
+    p->length_data_entry = 4;
+    p->length_starting = 5;
+    p->length_implementation = 0;
+    strncpyx (p->future_use, " ", 1);
+
+    p->directory = NULL;
+    return p;
+}
+
 Iso2709Rec iso2709_cvt (const char *buf)
 {
     struct iso2709_dir **dpp, *dp;
@@ -100,6 +152,11 @@ Iso2709Rec iso2709_cvt (const char *buf)
     p->base_address = atoin (buf+12, 4);
     strncpyx (p->user_systems, buf+17, 3);
 
+    if (p->record_length < 26)
+    {
+        free (p);
+        return NULL;
+    }
     p->length_data_entry = atoin (buf+20, 1);
     p->length_starting = atoin (buf+21, 1);
     p->length_implementation = atoin (buf+22, 1);
@@ -110,8 +167,14 @@ Iso2709Rec iso2709_cvt (const char *buf)
     *dpp = NULL;
     while (buf[pos] != ISO2709_FS)
     {
-        *dpp = malloc (sizeof(**dpp));
+        if (!(*dpp = malloc (sizeof(**dpp))))
+        {
+            iso2709_rm (p);
+            return NULL;
+        }
         (*dpp)->next = NULL;
+        (*dpp)->fields = NULL;
+        (*dpp)->indicator = NULL;
         strncpyx ((*dpp)->tag, buf+pos, 3);
         pos += 3;
         (*dpp)->length = atoin (buf+pos, p->length_data_entry);
@@ -120,59 +183,107 @@ Iso2709Rec iso2709_cvt (const char *buf)
         pos += p->length_starting + p->length_implementation;
 
         dpp = &(*dpp)->next;
+        if (pos > p->record_length)
+        {
+            iso2709_rm (p);
+            return NULL;
+        }
     }
     pos++;
     /* deal with datafields */
     for (dp = p->directory; dp; dp = dp->next)
     {
-        int tag00;
+        int identifier_flag;
         struct iso2709_field **fpp;
         int dpos = pos+dp->offset;
+        int epos = pos+dp->offset+dp->length-1;
 
+        if (epos <= dpos)
+        {
+            iso2709_rm (p);
+            return NULL;
+        }
         fpp = &dp->fields;
 
-        *fpp = malloc (sizeof(**fpp));
+        if (!(*fpp = malloc (sizeof(**fpp))))
+        {
+            iso2709_rm (p);
+            return NULL;
+        }
         (*fpp)->next = NULL;
-        if (p->indicator_length && memcmp (dp->tag, "00", 2))
+
+        identifier_flag = 1;
+        if (p->indicator_length)
         {
-            dp->indicator = malloc (p->indicator_length+1);
+#if STUPID_ISO_DBC
+            if (buf[dpos+p->indicator_length] != ISO2709_IDFS)
+                identifier_flag = 0;
+#else
+            if (!memcmp (dp->tag, "00", 2))
+                identifier_flag = 0;
+#endif
+        }
+        else if (!memcmp (dp->tag, "00", 2))
+                identifier_flag = 0;
+        if (identifier_flag && p->indicator_length)
+        {
+            if (!(dp->indicator = malloc (p->indicator_length+1)))
+            {
+                iso2709_rm (p);
+                return NULL;
+            }
             strncpyx (dp->indicator, buf+dpos, p->indicator_length);
             dpos += p->indicator_length;
         }
         else
             dp->indicator = NULL;
-
-        if (memcmp (dp->tag, "00", 2))
-            tag00 = 0;
-        else
-            tag00 = 1;
         while (1)
         {
             int dpos_n;
-            if (p->identifier_length && !tag00)
+            if (p->identifier_length && identifier_flag)
             {
-                (*fpp)->identifier = malloc (p->identifier_length+1);
                 strncpyx ((*fpp)->identifier, buf+dpos+1,
                           p->identifier_length-1);
-                dpos += p->identifier_length;
+                dpos_n = dpos += p->identifier_length;
+                while (buf[dpos_n] != ISO2709_FS && buf[dpos_n] != ISO2709_RS
+                       && buf[dpos_n] != ISO2709_IDFS && dpos_n < epos)
+                    dpos_n++;
             }
             else
-                (*fpp)->identifier = NULL;
-
-            dpos_n = dpos;
-            while (buf[dpos_n] != ISO2709_FS && buf[dpos_n] != ISO2709_IDFS &&
-                   buf[dpos_n] != ISO2709_RS)
-                dpos_n++;
-
-            (*fpp)->data = malloc (dpos_n - dpos + 1);
+            {
+                *(*fpp)->identifier = '\0';
+                dpos_n = dpos;
+                while (buf[dpos_n] != ISO2709_FS && buf[dpos_n] != ISO2709_RS
+                       && dpos_n < epos)
+                    dpos_n++;
+            }
+            if (!((*fpp)->data = malloc (dpos_n - dpos + 1)))
+            {
+                iso2709_rm (p);
+                return NULL;
+            }
             strncpyx ((*fpp)->data, buf+dpos, dpos_n - dpos);
             dpos = dpos_n;
             
+            if (dpos >= epos)
+            {
+                if (buf[dpos] != ISO2709_FS && buf[dpos] != ISO2709_RS)
+                    fprintf (stderr, "Missing separator at end of field "
+                             "in %s %s\n", dp->tag, (*fpp)->identifier);
+                break;
+            }
             if (buf[dpos] == ISO2709_FS || buf[dpos] == ISO2709_RS)
+            {
+                fprintf (stderr, "Unexpected separator inside field %s %s\n",
+                         dp->tag, (*fpp)->identifier);
                 break;
-            
+            }
             fpp = &(*fpp)->next;
-            *fpp = malloc (sizeof(**fpp));
+            if (!(*fpp = malloc (sizeof(**fpp))))
+            {
+                iso2709_rm (p);
+                return NULL;
+            }
             (*fpp)->next = NULL;
         }
     }
@@ -189,7 +300,6 @@ void iso2709_rm (Iso2709Rec rec)
 
         for (field = dir->fields; field; field = field1)
         {
-            free (field->identifier);
             free (field->data);
             field1 = field->next;
             free (field);
@@ -199,3 +309,4 @@ void iso2709_rm (Iso2709Rec rec)
         free (dir);
     }
 }
+