]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/lib/dlist.c
kes Fix memory leak with storage ids in cats/sql_get.c
[bacula/bacula] / bacula / src / lib / dlist.c
index 9fff70c1730f3fefbb5de7da5ff6e846cb24289b..1e0034604712bcf202e0b1552cabc78de72a02a8 100644 (file)
@@ -1,28 +1,41 @@
+/*
+   Bacula® - The Network Backup Solution
+
+   Copyright (C) 2003-2007 Free Software Foundation Europe e.V.
+
+   The main author of Bacula is Kern Sibbald, with contributions from
+   many others, a complete list can be found in the file AUTHORS.
+   This program is Free Software; you can redistribute it and/or
+   modify it under the terms of version two of the GNU General Public
+   License as published by the Free Software Foundation plus additions
+   that are listed in the file LICENSE.
+
+   This program is distributed in the hope that it will be useful, but
+   WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+   General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
+   02110-1301, USA.
+
+   Bacula® is a registered trademark of John Walker.
+   The licensor of Bacula is the Free Software Foundation Europe
+   (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
+   Switzerland, email:ftf@fsfeurope.org.
+*/
 /*
  *  Bacula doubly linked list routines.
  *
  *    dlist is a doubly linked list with the links being in the
- *      list data item.
+ *       list data item.
  *
  *   Kern Sibbald, July MMIII
  *
  *   Version $Id$
  *
  */
-/*
-   Copyright (C) 2003-2005 Kern Sibbald
-
-   This program is free software; you can redistribute it and/or
-   modify it under the terms of the GNU General Public License
-   version 2 as amended with additional clauses defined in the
-   file LICENSE in the main source directory.
-
-   This program is distributed in the hope that it will be useful,
-   but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 
-   the file LICENSE for additional details.
-
- */
 
 #include "bacula.h"
 
  */
 void dlist::append(void *item)
 {
-   ((dlink *)(((char *)item)+loffset))->next = NULL;
-   ((dlink *)(((char *)item)+loffset))->prev = tail;
+   set_next(item, NULL);
+   set_prev(item, tail);
    if (tail) {
-      ((dlink *)(((char *)tail)+loffset))->next = item;
+      set_next(tail, item);
    }
    tail = item;
-   if (head == NULL) {               /* if empty list, */
-      head = item;                   /* item is head as well */
+   if (head == NULL) {                /* if empty list, */
+      head = item;                    /* item is head as well */
    }
    num_items++;
 }
@@ -52,14 +65,14 @@ void dlist::append(void *item)
  */
 void dlist::prepend(void *item)
 {
-   ((dlink *)(((char *)item)+loffset))->next = head;
-   ((dlink *)(((char *)item)+loffset))->prev = NULL;
+   set_next(item, head);
+   set_prev(item, NULL);
    if (head) {
-      ((dlink *)(((char *)head)+loffset))->prev = item;
+      set_prev(head, item);
    }
    head = item;
-   if (tail == NULL) {               /* if empty list, */
-      tail = item;                   /* item is tail too */
+   if (tail == NULL) {                /* if empty list, */
+      tail = item;                    /* item is tail too */
    }
    num_items++;
 }
@@ -68,11 +81,11 @@ void dlist::insert_before(void *item, void *where)
 {
    dlink *where_link = (dlink *)((char *)where+loffset);
 
-   ((dlink *)(((char *)item)+loffset))->next = where;
-   ((dlink *)(((char *)item)+loffset))->prev = where_link->prev;
+   set_next(item, where);
+   set_prev(item, where_link->prev);
 
    if (where_link->prev) {
-      ((dlink *)(((char *)(where_link->prev))+loffset))->next = item;
+      set_next(where_link->prev, item);
    }
    where_link->prev = item;
    if (head == where) {
@@ -85,11 +98,11 @@ void dlist::insert_after(void *item, void *where)
 {
    dlink *where_link = (dlink *)((char *)where+loffset);
 
-   ((dlink *)(((char *)item)+loffset))->next = where_link->next;
-   ((dlink *)(((char *)item)+loffset))->prev = where;
+   set_next(item, where_link->next);
+   set_prev(item, where);
 
    if (where_link->next) {
-      ((dlink *)(((char *)(where_link->next))+loffset))->prev = item;
+      set_prev(where_link->next, item);
    }
    where_link->next = item;
    if (tail == where) {
@@ -102,8 +115,8 @@ void dlist::insert_after(void *item, void *where)
  *  Insert an item in the list, but only if it is unique
  *  otherwise, the item is returned non inserted
  *
- * Returns: item        if item inserted
- *         other_item   if same value already exists (item not inserted)
+ * Returns: item         if item inserted
+ *          other_item   if same value already exists (item not inserted)
  */
 void *dlist::binary_insert(void *item, int compare(void *item1, void *item2))
 {
@@ -119,16 +132,16 @@ void *dlist::binary_insert(void *item, int compare(void *item1, void *item2))
    if (num_items == 1) {
       comp = compare(item, first());
       if (comp < 0) {
-        prepend(item);
+         prepend(item);
        //Dmsg0(000, "Insert before first.\n");
-        return item;
+         return item;
       } else if (comp > 0) {
-        insert_after(item, first());
+         insert_after(item, first());
        //Dmsg0(000, "Insert after first.\n");
-        return item;
+         return item;
       } else {
        //Dmsg0(000, "Same as first.\n");
-        return first();
+         return first();
       }
    }
    /* Check against last item */
@@ -164,25 +177,25 @@ void *dlist::binary_insert(void *item, int compare(void *item1, void *item2))
       int nxt;
       nxt = (low + high) / 2;
       while (nxt > cur) {
-        cur_item = next(cur_item);
-        cur++;
+         cur_item = next(cur_item);
+         cur++;
       }
       while (nxt < cur) {
-        cur_item = prev(cur_item);
-        cur--;
+         cur_item = prev(cur_item);
+         cur--;
       }
     //Dmsg1(000, "Compare item to %d\n", cur);
       comp = compare(item, cur_item);
     //Dmsg2(000, "Compare item to %d = %d\n", cur, comp);
       if (comp < 0) {
-        high = cur;
+         high = cur;
        //Dmsg2(000, "set high; low=%d high=%d\n", low, high);
       } else if (comp > 0) {
-        low = cur + 1;
+         low = cur + 1;
        //Dmsg2(000, "set low; low=%d high=%d\n", low, high);
       } else {
        //Dmsg1(000, "Same as item %d\n", cur);
-        return cur_item;
+         return cur_item;
       }
    }
    if (high == cur) {
@@ -225,9 +238,9 @@ void *dlist::binary_search(void *item, int compare(void *item1, void *item2))
    if (num_items == 1) {
       comp = compare(item, cur_item);
       if (comp == 0) {
-        return cur_item;
+         return cur_item;
       } else {
-        return NULL;
+         return NULL;
       }
    }
    low = 1;
@@ -239,35 +252,35 @@ void *dlist::binary_search(void *item, int compare(void *item1, void *item2))
       nxt = (low + high) / 2;
       /* Now get cur pointing to nxt */
       while (nxt > cur) {
-        cur_item = next(cur_item);
-        cur++;
+         cur_item = next(cur_item);
+         cur++;
       }
       while (nxt < cur) {
-        cur_item = prev(cur_item);
-        cur--;
+         cur_item = prev(cur_item);
+         cur--;
       }
       comp = compare(item, cur_item);
       //Dmsg2(000, "Compare item to %d = %d\n", cur, comp);
       if (comp < 0) {
-        high = cur;
+         high = cur;
          //Dmsg2(000, "set high; low=%d high=%d\n", low, high);
       } else if (comp > 0) {
-        low = cur + 1;
+         low = cur + 1;
          //Dmsg2(000, "set low; low=%d high=%d\n", low, high);
       } else {
-        return cur_item;
+         return cur_item;
       }
    }
    /*
     * low == high can only happen if low just 
-    *  got incremented from cur, and we have
-    *  not yet tested cur+1
+    *   got incremented from cur, and we have
+    *   not yet tested cur+1
     */
    if (low == high) {
       cur_item = next(cur_item);
       comp = compare(item, cur_item);
       if (comp == 0) {
-        return cur_item;
+         return cur_item;
       }
    }
    return NULL;
@@ -281,21 +294,21 @@ void dlist::remove(void *item)
    if (item == head) {
       head = ilink->next;
       if (head) {
-        ((dlink *)(((char *)head)+loffset))->prev = NULL;
+         set_prev(head, NULL);
       }
       if (item == tail) {
-        tail = ilink->prev;
+         tail = ilink->prev;
       }
    } else if (item == tail) {
       tail = ilink->prev;
       if (tail) {
-        ((dlink *)(((char *)tail)+loffset))->next = NULL;
+         set_next(tail, NULL);
       }
    } else {
       xitem = ilink->next;
-      ((dlink *)(((char *)xitem)+loffset))->prev = ilink->prev;
+      set_prev(xitem, ilink->prev);
       xitem = ilink->prev;
-      ((dlink *)(((char *)xitem)+loffset))->next = ilink->next;
+      set_next(xitem, ilink->next);
    }
    num_items--;
    if (num_items == 0) {
@@ -332,7 +345,20 @@ void dlist::destroy()
    head = tail = NULL;
 }
 
+/* String helpers for dlist usage */
 
+dlistString *new_dlistString(const char *str)
+{
+   return new_dlistString(str, strlen(str));
+}
+
+dlistString *new_dlistString(const char *str, int len)
+{
+   dlistString *node;
+   node = (dlistString *)malloc(sizeof(dlistString) + len);
+   bstrncpy(node->c_str(), str, len);
+   return node;
+}
 
 #ifdef TEST_PROGRAM
 
@@ -360,6 +386,7 @@ int main()
    MYJCR *jcr1;
    MYJCR *save_jcr = NULL;
    MYJCR *next_jcr;
+   int count;
 
    jcr_chain = (dlist *)malloc(sizeof(dlist));
    jcr_chain->init(jcr, &jcr->link);
@@ -371,7 +398,7 @@ int main()
       jcr->buf = bstrdup(buf);
       jcr_chain->prepend(jcr);
       if (i == 10) {
-        save_jcr = jcr;
+         save_jcr = jcr;
       }
    }
 
@@ -393,6 +420,10 @@ int main()
    jcr_chain->destroy();
    free(jcr_chain);
 
+   /* The following may seem a bit odd, but we create a chaing
+    *  of jcr objects.  Within a jcr object, there is a buf
+    *  that points to a malloced string containing data   
+    */
    jcr_chain = New(dlist(jcr, &jcr->link));
    printf("append 20 items 0-19\n");
    for (int i=0; i<20; i++) {
@@ -401,7 +432,7 @@ int main()
       jcr->buf = bstrdup(buf);
       jcr_chain->append(jcr);
       if (i == 10) {
-        save_jcr = jcr;
+         save_jcr = jcr;
       }
    }
 
@@ -429,24 +460,24 @@ int main()
 #define CNT 26
    printf("append %d items\n", CNT*CNT*CNT);
    strcpy(buf, "ZZZ");
-   int count = 0;
+   count = 0;
    for (int i=0; i<CNT; i++) {
       for (int j=0; j<CNT; j++) {
-        for (int k=0; k<CNT; k++) {
-           count++;
-           if ((count & 0x3FF) == 0) {
+         for (int k=0; k<CNT; k++) {
+            count++;
+            if ((count & 0x3FF) == 0) {
                Dmsg1(000, "At %d\n", count);
-           }
-           jcr = (MYJCR *)malloc(sizeof(MYJCR));
-           jcr->buf = bstrdup(buf);
-           jcr1 = (MYJCR *)jcr_chain->binary_insert(jcr, my_compare);
-           if (jcr != jcr1) {
+            }
+            jcr = (MYJCR *)malloc(sizeof(MYJCR));
+            jcr->buf = bstrdup(buf);
+            jcr1 = (MYJCR *)jcr_chain->binary_insert(jcr, my_compare);
+            if (jcr != jcr1) {
                Dmsg2(000, "Insert of %s vs %s failed.\n", jcr->buf, jcr1->buf);
-           }
-           buf[1]--;
-        }
+            }
+            buf[1]--;
+         }
          buf[1] = 'Z';
-        buf[2]--;
+         buf[2]--;
       }
       buf[2] = 'Z';
       buf[0]--;
@@ -485,6 +516,39 @@ int main()
    }
    delete jcr_chain;
 
+   /* Finally, do a test using the dlistString string helper, which
+    *  allocates a dlist node and stores the string directly in
+    *  it.
+    */
+   dlist chain;
+   dlistString *node;
+#define CNT 26
+   printf("append %d dlistString items\n", CNT*CNT*CNT);
+   strcpy(buf, "ZZZ");
+   count = 0;
+   for (int i=0; i<CNT; i++) {
+      for (int j=0; j<CNT; j++) {
+         for (int k=0; k<CNT; k++) {
+            count++;
+            if ((count & 0x3FF) == 0) {
+               Dmsg1(000, "At %d\n", count);
+            }
+            node = new_dlistString(buf);
+            chain.append(node);
+            buf[1]--;
+         }
+         buf[1] = 'Z';
+         buf[2]--;
+      }
+      buf[2] = 'Z';
+      buf[0]--;
+   }
+   printf("dlistString items appended, walking chain\n");
+   foreach_dlist(node, &chain) {
+      printf("%s\n", node->c_str());
+   }
+   printf("destroy dlistString chain\n");
+   chain.destroy();
 
    sm_dump(false);