Add threshold to proxy lib to call system allocator

Add threshold to proxy lib to call system allocator
when a size is less than the given threshold.

Signed-off-by: Lukasz Dorau <[email protected]>

Author: ldorau

src/provider/provider_tracking.c

@@ -121,9 +121,7 @@ umf_result_t umfMemoryTrackerGetAllocInfo(const void *ptr,
     int found = critnib_find(TRACKER->map, (uintptr_t)ptr, FIND_LE,
                              (void *)&rkey, (void **)&rvalue);
     if (!found || (uintptr_t)ptr >= rkey + rvalue->size) {
-        LOG_WARN("pointer %p not found in the "
-                 "tracker, TRACKER=%p",
-                 ptr, (void *)TRACKER);
+        // LOG_DEBUG("pointer %p not found in the tracker, TRACKER=%p", ptr, (void *)TRACKER);
         return UMF_RESULT_ERROR_INVALID_ARGUMENT;
     }
 

src/proxy_lib/proxy_lib.c

@@ -27,6 +27,12 @@
  * - _aligned_offset_recalloc()
  */
 
+#ifndef _WIN32
+#define _GNU_SOURCE
+#include <dlfcn.h>
+#undef _GNU_SOURCE
+#endif /* _WIN32 */
+
 #if (defined PROXY_LIB_USES_JEMALLOC_POOL)
 #include <umf/pools/pool_jemalloc.h>
 #define umfPoolManagerOps umfJemallocPoolOps
@@ -103,12 +109,28 @@ static umf_memory_pool_handle_t Proxy_pool = NULL;
 // it protects us from recursion in umfPool*()
 static __TLS int was_called_from_umfPool = 0;
 
+typedef void *(*system_aligned_alloc_t)(size_t alignment, size_t size);
+typedef void *(*system_calloc_t)(size_t nmemb, size_t size);
+typedef void (*system_free_t)(void *ptr);
+typedef void *(*system_malloc_t)(size_t size);
+typedef size_t (*system_malloc_usable_size_t)(void *ptr);
+typedef void *(*system_realloc_t)(void *ptr, size_t size);
+
+static system_aligned_alloc_t system_aligned_alloc;
+static system_calloc_t system_calloc;
+static system_free_t system_free;
+static system_malloc_t system_malloc;
+static system_malloc_usable_size_t system_malloc_usable_size;
+static system_realloc_t system_realloc;
+static size_t threshold_value = 0;
+
 /*****************************************************************************/
 /*** The constructor and destructor of the proxy library *********************/
 /*****************************************************************************/
 
 void proxy_lib_create_common(void) {
     utils_log_init();
+
     umf_os_memory_provider_params_t os_params =
         umfOsMemoryProviderParamsDefault();
     umf_result_t umf_result;
@@ -117,8 +139,8 @@ void proxy_lib_create_common(void) {
     char shm_name[NAME_MAX];
 
     if (utils_env_var_has_str("UMF_PROXY", "page.disposition=shared-fd")) {
-        LOG_DEBUG("proxy_lib: using the MAP_SHARED visibility mode with the "
-                  "file descriptor duplication");
+        LOG_DEBUG("using the MAP_SHARED visibility mode with the file "
+                  "descriptor duplication");
         os_params.visibility = UMF_MEM_MAP_SHARED;
         os_params.shm_name = NULL;
 
@@ -130,8 +152,8 @@ void proxy_lib_create_common(void) {
         sprintf(shm_name, "umf_proxy_lib_shm_pid_%i", utils_getpid());
         os_params.shm_name = shm_name;
 
-        LOG_DEBUG("proxy_lib: using the MAP_SHARED visibility mode with the "
-                  "named shared memory: %s",
+        LOG_DEBUG("using the MAP_SHARED visibility mode with the named shared "
+                  "memory: %s",
                   os_params.shm_name);
     }
 #endif
@@ -149,8 +171,32 @@ void proxy_lib_create_common(void) {
         LOG_ERR("creating UMF pool manager failed");
         exit(-1);
     }
+
+    LOG_DEBUG("proxy pool created");
+
+#ifndef _WIN32
+    *((void **)(&system_aligned_alloc)) = dlsym(RTLD_NEXT, "aligned_alloc");
+    *((void **)(&system_calloc)) = dlsym(RTLD_NEXT, "calloc");
+    *((void **)(&system_free)) = dlsym(RTLD_NEXT, "free");
+    *((void **)(&system_malloc)) = dlsym(RTLD_NEXT, "malloc");
+    *((void **)(&system_malloc_usable_size)) =
+        dlsym(RTLD_NEXT, "malloc_usable_size");
+    *((void **)(&system_realloc)) = dlsym(RTLD_NEXT, "realloc");
+
+    if (system_aligned_alloc && system_calloc && system_free && system_malloc &&
+        system_malloc_usable_size && system_realloc) {
+        // TODO threshold_value will be read from the environment variable
+        threshold_value = 128;
+        LOG_DEBUG("all system hooks initialized, threshold_value = %zu",
+                  threshold_value);
+    } else {
+        LOG_WARN("NOT all system hooks initialized");
+    }
+#endif
+
     // The UMF pool has just been created (Proxy_pool != NULL). Stop using
     // the linear allocator and start using the UMF pool allocator from now on.
+    LOG_DEBUG("proxy library initialized");
 }
 
 void proxy_lib_destroy_common(void) {
@@ -246,6 +292,10 @@ static inline size_t ba_leak_pool_contains_pointer(void *ptr) {
 /*****************************************************************************/
 
 void *malloc(size_t size) {
+    if (size < threshold_value) {
+        return system_malloc(size);
+    }
+
     if (!was_called_from_umfPool && Proxy_pool) {
         was_called_from_umfPool = 1;
         void *ptr = umfPoolMalloc(Proxy_pool, size);
@@ -257,6 +307,10 @@ void *malloc(size_t size) {
 }
 
 void *calloc(size_t nmemb, size_t size) {
+    if ((nmemb * size) < threshold_value) {
+        return system_calloc(nmemb, size);
+    }
+
     if (!was_called_from_umfPool && Proxy_pool) {
         was_called_from_umfPool = 1;
         void *ptr = umfPoolCalloc(Proxy_pool, nmemb, size);
@@ -276,15 +330,17 @@ void free(void *ptr) {
         return;
     }
 
-    if (Proxy_pool) {
+    if (Proxy_pool && (umfPoolByPtr(ptr) == Proxy_pool)) {
         if (umfPoolFree(Proxy_pool, ptr) != UMF_RESULT_SUCCESS) {
             LOG_ERR("umfPoolFree() failed");
-            assert(0);
         }
         return;
     }
 
-    assert(0);
+    if (threshold_value) {
+        system_free(ptr);
+    }
+
     return;
 }
 
@@ -303,18 +359,26 @@ void *realloc(void *ptr, size_t size) {
         return ba_leak_realloc(ptr, size, leak_pool_contains_pointer);
     }
 
-    if (Proxy_pool) {
+    if (!was_called_from_umfPool && Proxy_pool &&
+        (umfPoolByPtr(ptr) == Proxy_pool)) {
         was_called_from_umfPool = 1;
         void *new_ptr = umfPoolRealloc(Proxy_pool, ptr, size);
         was_called_from_umfPool = 0;
         return new_ptr;
     }
 
-    assert(0);
+    if (threshold_value) {
+        return system_realloc(ptr, size);
+    }
+
     return NULL;
 }
 
 void *aligned_alloc(size_t alignment, size_t size) {
+    if (size < threshold_value) {
+        return system_aligned_alloc(alignment, size);
+    }
+
     if (!was_called_from_umfPool && Proxy_pool) {
         was_called_from_umfPool = 1;
         void *ptr = umfPoolAlignedMalloc(Proxy_pool, size, alignment);
@@ -330,19 +394,30 @@ size_t _msize(void *ptr) {
 #else
 size_t malloc_usable_size(void *ptr) {
 #endif
-
+    LOG_DEBUG("malloc_usable_size: %p BEGIN", ptr);
     // a check to verify we are running the proxy library
     if (ptr == (void *)0x01) {
         return 0xDEADBEEF;
     }
 
-    if (!was_called_from_umfPool && Proxy_pool) {
+    LOG_DEBUG("malloc_usable_size: %p ba_leak_pool_contains_pointer", ptr);
+    if (ba_leak_pool_contains_pointer(ptr)) {
+        return 0; // unsupported in this case
+    }
+
+    LOG_DEBUG("malloc_usable_size: %p umfPoolByPtr", ptr);
+    if (!was_called_from_umfPool && Proxy_pool && (umfPoolByPtr(ptr) == Proxy_pool)) {
         was_called_from_umfPool = 1;
         size_t size = umfPoolMallocUsableSize(Proxy_pool, ptr);
         was_called_from_umfPool = 0;
         return size;
     }
 
+    if (threshold_value) {
+        LOG_DEBUG("malloc_usable_size: %p SYSTEM", ptr);
+        return system_malloc_usable_size(ptr);
+    }
+
     return 0; // unsupported in this case
 }