Changeset fed9152 for lib/data-struct/object_cache.c

Timestamp:

01/20/15 10:52:15 (8 years ago)

Author:

Richard Sanger <rsangerarj@…>

Branches:

4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes

Children:

1b59edf, cb39d35

Parents:

18bf317 (diff), 04bf7c5 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'tidy_parallel_libtrace' into develop

File:

• lib/data-struct/object_cache.c (modified) (3 diffs)

lib/data-struct/object_cache.c

@@ -175 +175 @@
   *             reads will block (free never should).Otherwise packets can be freely
   *     allocated upon requested and are free'd if there is not enough space for them.
-  * @return Returns The number of packets outstanding, or extra object recevied
-  *             Ideally this should be zero (0) otherwise some form of memory leak
-  *             is likely present.
+  * @return If successful returns 0 otherwise -1.
   */
-DLLEXPORT void libtrace_ocache_init(libtrace_ocache_t *oc, void *(*alloc)(void), void (*free)(void *),
-                                                                          size_t thread_cache_size, size_t buffer_size, bool limit_size) {
+DLLEXPORT int libtrace_ocache_init(libtrace_ocache_t *oc, void *(*alloc)(void),
+                                    void (*free)(void *),
+                                    size_t thread_cache_size,
+                                    size_t buffer_size, bool limit_size) {
 
         assert(buffer_size);
         assert(alloc);
         assert(free);
-        libtrace_ringbuffer_init(&oc->rb, buffer_size, LIBTRACE_RINGBUFFER_BLOCKING);
+        if (libtrace_ringbuffer_init(&oc->rb, buffer_size, LIBTRACE_RINGBUFFER_BLOCKING) != 0) {
+                return -1;
+        }
         oc->alloc = alloc;
         oc->free = free;
@@ -193 +195 @@
         oc->max_nb_thread_list = 0x10;
         oc->thread_list = calloc(0x10, sizeof(void*));
+        if (oc->thread_list == NULL) {
+                libtrace_ringbuffer_destroy(&oc->rb);
+                return -1;
+        }
         pthread_spin_init(&oc->spin, 0);
         if (limit_size)
@@ -198 +204 @@
         else
                 oc->max_allocations = 0;
+        return 0;
 }