Symaptic: os/ossrv/glib/tests/slice-test.c@260cb5ec6c19

     1 /* GLIB sliced memory - fast threaded memory chunk allocator

     2  * Copyright (C) 2005 Tim Janik

     3  * Portion Copyright © 2008-09 Nokia Corporation and/or its subsidiary(-ies). All rights reserved.

     4  * This library is free software; you can redistribute it and/or

     5  * modify it under the terms of the GNU Lesser General Public

     6  * License as published by the Free Software Foundation; either

     7  * version 2 of the License, or (at your option) any later version.

     8  *

     9  * This library is distributed in the hope that it will be useful,

    10  * but WITHOUT ANY WARRANTY; without even the implied warranty of

    11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

    12  * Lesser General Public License for more details.

    13  *

    14  * You should have received a copy of the GNU Lesser General Public

    15  * License along with this library; if not, write to the

    16  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,

    17  * Boston, MA 02111-1307, USA.

    18  */

    19 #include <glib.h>

    21 #include <stdio.h>

    22 #include <string.h>

    23 #ifdef __SYMBIAN32__

    24 #include "mrt2_glib2_test.h"

    25 #endif /*__SYMBIAN32__*/

    26 #define quick_rand32()  (rand_accu = 1664525 * rand_accu + 1013904223, rand_accu)

    27 static guint    prime_size = 1021; // 769; // 509

    28 static gboolean clean_memchunks = FALSE;

    29 static guint    number_of_blocks = 100;          /* total number of blocks allocated */

    30 static guint    number_of_repetitions = 100;     /* number of alloc+free repetitions */

    31 static gboolean want_corruption = FALSE;

    33 /* --- old memchunk prototypes (memchunks.c) --- */

    34 void            old_mem_chunks_init     (void);

    35 GMemChunk*      old_mem_chunk_new       (const gchar  *name,

    36                                          gint          atom_size,

    37                                          gulong        area_size,

    38                                          gint          type);

    39 void            old_mem_chunk_destroy   (GMemChunk *mem_chunk);

    40 gpointer        old_mem_chunk_alloc     (GMemChunk *mem_chunk);

    41 gpointer        old_mem_chunk_alloc0    (GMemChunk *mem_chunk);

    42 void            old_mem_chunk_free      (GMemChunk *mem_chunk,

    43                                          gpointer   mem);

    44 void            old_mem_chunk_clean     (GMemChunk *mem_chunk);

    45 void            old_mem_chunk_reset     (GMemChunk *mem_chunk);

    46 void            old_mem_chunk_print     (GMemChunk *mem_chunk);

    47 void            old_mem_chunk_info      (void);

    48 #ifndef G_ALLOC_AND_FREE

    49 #define G_ALLOC_AND_FREE  2

    50 #endif

    52 /* --- functions --- */

    53 static inline int

    54 corruption (void)

    55 {

    56   if (G_UNLIKELY (want_corruption))

    57     {

    58       /* corruption per call likelyness is about 1:4000000 */

    59       guint32 r = g_random_int() % 8000009;

    60       return r == 277 ? +1 : r == 281 ? -1 : 0;

    61     }

    62   return 0;

    63 }

    65 static inline gpointer

    66 memchunk_alloc (GMemChunk **memchunkp,

    67                 guint       size)

    68 {

    69   size = MAX (size, 1);

    70   if (G_UNLIKELY (!*memchunkp))

    71     *memchunkp = old_mem_chunk_new ("", size, 4096, G_ALLOC_AND_FREE);

    72   return old_mem_chunk_alloc (*memchunkp);

    73 }

    75 static inline void

    76 memchunk_free (GMemChunk *memchunk,

    77                gpointer   chunk)

    78 {

    79   old_mem_chunk_free (memchunk, chunk);

    80   if (clean_memchunks)

    81     old_mem_chunk_clean (memchunk);

    82 }

    84 static gpointer

    85 test_memchunk_thread (gpointer data)

    86 {

    87   GMemChunk **memchunks;

    88   guint i, j;

    89   guint8 **ps;

    90   guint   *ss;

    91   guint32 rand_accu = 2147483563;

    92   /* initialize random numbers */

    93   if (data)

    94     rand_accu = *(guint32*) data;

    95   else

    96     {

    97       GTimeVal rand_tv;

    98       g_get_current_time (&rand_tv);

    99       rand_accu = rand_tv.tv_usec + (rand_tv.tv_sec << 16);

   100     }

   102   /* prepare for memchunk creation */

   103   memchunks = (GMemChunk **)g_alloca (sizeof (memchunks[0]) * prime_size);

   104   memset (memchunks, 0, sizeof (memchunks[0]) * prime_size);

   106   ps = g_new (guint8*, number_of_blocks);

   107   ss = g_new (guint, number_of_blocks);

   108   /* create number_of_blocks random sizes */

   109   for (i = 0; i < number_of_blocks; i++)

   110     ss[i] = quick_rand32() % prime_size;

   111   /* allocate number_of_blocks blocks */

   112   for (i = 0; i < number_of_blocks; i++)

   113     ps[i] = memchunk_alloc (&memchunks[ss[i]], ss[i]);

   114   for (j = 0; j < number_of_repetitions; j++)

   115     {

   116       /* free number_of_blocks/2 blocks */

   117       for (i = 0; i < number_of_blocks; i += 2)

   118         memchunk_free (memchunks[ss[i]], ps[i]);

   119       /* allocate number_of_blocks/2 blocks with new sizes */

   120       for (i = 0; i < number_of_blocks; i += 2)

   121         {

   122           ss[i] = quick_rand32() % prime_size;

   123           ps[i] = memchunk_alloc (&memchunks[ss[i]], ss[i]);

   124         }

   125     }

   126   /* free number_of_blocks blocks */

   127   for (i = 0; i < number_of_blocks; i++)

   128     memchunk_free (memchunks[ss[i]], ps[i]);

   129   /* alloc and free many equally sized chunks in a row */

   130   for (i = 0; i < number_of_repetitions; i++)

   131     {

   132       guint sz = quick_rand32() % prime_size;

   133       guint k = number_of_blocks / 100;

   134       for (j = 0; j < k; j++)

   135         ps[j] = memchunk_alloc (&memchunks[sz], sz);

   136       for (j = 0; j < k; j++)

   137         memchunk_free (memchunks[sz], ps[j]);

   138     }

   139   /* cleanout memchunks */

   140   for (i = 0; i < prime_size; i++)

   141     if (memchunks[i])

   142       old_mem_chunk_destroy (memchunks[i]);

   143   g_free (ps);

   144   g_free (ss);

   146   return NULL;

   147 }

   149 static gpointer

   150 test_sliced_mem_thread (gpointer data)

   151 {

   152   guint32 rand_accu = 2147483563;

   153   guint i, j;

   154   guint8 **ps;

   155   guint   *ss;

   157   /* initialize random numbers */

   158   if (data)

   159     rand_accu = *(guint32*) data;

   160   else

   161     {

   162       GTimeVal rand_tv;

   163       g_get_current_time (&rand_tv);

   164       rand_accu = rand_tv.tv_usec + (rand_tv.tv_sec << 16);

   165     }

   167   ps = g_new (guint8*, number_of_blocks);

   168   ss = g_new (guint, number_of_blocks);

   169   /* create number_of_blocks random sizes */

   170   for (i = 0; i < number_of_blocks; i++)

   171     ss[i] = quick_rand32() % prime_size;

   172   /* allocate number_of_blocks blocks */

   173   for (i = 0; i < number_of_blocks; i++)

   174     ps[i] = g_slice_alloc (ss[i] + corruption());

   175   for (j = 0; j < number_of_repetitions; j++)

   176     {

   177       /* free number_of_blocks/2 blocks */

   178       for (i = 0; i < number_of_blocks; i += 2)

   179         g_slice_free1 (ss[i] + corruption(), ps[i] + corruption());

   180       /* allocate number_of_blocks/2 blocks with new sizes */

   181       for (i = 0; i < number_of_blocks; i += 2)

   182         {

   183           ss[i] = quick_rand32() % prime_size;

   184           ps[i] = g_slice_alloc (ss[i] + corruption());

   185         }

   186     }

   187   /* free number_of_blocks blocks */

   188   for (i = 0; i < number_of_blocks; i++)

   189     g_slice_free1 (ss[i] + corruption(), ps[i] + corruption());

   190   /* alloc and free many equally sized chunks in a row */

   191   for (i = 0; i < number_of_repetitions; i++)

   192     {

   193       guint sz = quick_rand32() % prime_size;

   194       guint k = number_of_blocks / 100;

   195       for (j = 0; j < k; j++)

   196         ps[j] = g_slice_alloc (sz + corruption());

   197       for (j = 0; j < k; j++)

   198         g_slice_free1 (sz + corruption(), ps[j] + corruption());

   199     }

   200   g_free (ps);

   201   g_free (ss);

   203   return NULL;

   204 }

   206 static void

   207 usage (void)

   208 {

   209   g_print ("Usage: slice-test [n_threads] [G|S|M|O][f][c][~] [maxblocksize] [seed]\n");

   210 }

   212 int

   213 main (int   argc,

   214       char *argv[])

   215 {

   216   guint seed32, *seedp = NULL;

   217   gboolean ccounters = FALSE, use_memchunks = FALSE;

   218   guint n_threads = 1;

   219   const gchar *mode = "slab allocator + magazine cache", *emode = " ";

   220 #ifdef __SYMBIAN32__

   221   g_log_set_handler (NULL,  G_LOG_FLAG_FATAL| G_LOG_FLAG_RECURSION | G_LOG_LEVEL_CRITICAL | G_LOG_LEVEL_WARNING | G_LOG_LEVEL_MESSAGE | G_LOG_LEVEL_INFO | G_LOG_LEVEL_DEBUG, &mrtLogHandler, NULL);

   222   g_set_print_handler(mrtPrintHandler);

   223   #endif /*__SYMBIAN32__*/

   224   if (argc > 1)

   225     n_threads = g_ascii_strtoull (argv[1], NULL, 10);

   226   if (argc > 2)

   227     {

   228       guint i, l = strlen (argv[2]);

   229       for (i = 0; i < l; i++)

   230         switch (argv[2][i])

   231           {

   232           case 'G': /* GLib mode */

   233             g_slice_set_config (G_SLICE_CONFIG_ALWAYS_MALLOC, FALSE);

   234             g_slice_set_config (G_SLICE_CONFIG_BYPASS_MAGAZINES, FALSE);

   235             mode = "slab allocator + magazine cache";

   236             break;

   237           case 'S': /* slab mode */

   238             g_slice_set_config (G_SLICE_CONFIG_ALWAYS_MALLOC, FALSE);

   239             g_slice_set_config (G_SLICE_CONFIG_BYPASS_MAGAZINES, TRUE);

   240             mode = "slab allocator";

   241             break;

   242           case 'M': /* malloc mode */

   243             g_slice_set_config (G_SLICE_CONFIG_ALWAYS_MALLOC, TRUE);

   244             mode = "system malloc";

   245             break;

   246           case 'O': /* old memchunks */

   247             use_memchunks = TRUE;

   248             mode = "old memchunks";

   249             break;

   250           case 'f': /* eager freeing */

   251             g_slice_set_config (G_SLICE_CONFIG_WORKING_SET_MSECS, 0);

   252             clean_memchunks = TRUE;

   253             emode = " with eager freeing";

   254             break;

   255           case 'c': /* print contention counters */

   256             ccounters = TRUE;

   257             break;

   258           case '~':

   259             want_corruption = TRUE; /* force occasional corruption */

   260             break;

   261           default:

   262             usage();

   263             return 1;

   264           }

   265     }

   266   if (argc > 3)

   267     prime_size = g_ascii_strtoull (argv[3], NULL, 10);

   268   if (argc > 4)

   269     {

   270       seed32 = g_ascii_strtoull (argv[4], NULL, 10);

   271       seedp = &seed32;

   272     }

   274   g_thread_init (NULL);

   276   if (argc <= 1)

   277     usage();

   279   {

   280     gchar strseed[64] = "<random>";

   281     GThread **threads;

   282     guint i;

   284     if (seedp)

   285       g_snprintf (strseed, 64, "%u", *seedp);

   286     g_print ("Starting %d threads allocating random blocks <= %u bytes with seed=%s using %s%s\n", n_threads, prime_size, strseed, mode, emode);

   287     threads = (GThread **)g_alloca (sizeof(GThread*) * n_threads);

   288     if (!use_memchunks)

   289       for (i = 0; i < n_threads; i++)

   290         threads[i] = g_thread_create_full (test_sliced_mem_thread, seedp, 0, TRUE, FALSE, 0, NULL);

   291     else

   292       {

   293         old_mem_chunks_init();

   294         for (i = 0; i < n_threads; i++)

   295           threads[i] = g_thread_create_full (test_memchunk_thread, seedp, 0, TRUE, FALSE, 0, NULL);

   296       }

   297     for (i = 0; i < n_threads; i++)

   298       g_thread_join (threads[i]);

   300     if (ccounters)

   301       {

   302         guint n, n_chunks = g_slice_get_config (G_SLICE_CONFIG_CHUNK_SIZES);

   303         g_print ("    ChunkSize | MagazineSize | Contention\n");

   304         for (i = 0; i < n_chunks; i++)

   305           {

   306             gint64 *vals = g_slice_get_config_state (G_SLICE_CONFIG_CONTENTION_COUNTER, i, &n);

   307             g_print ("  %9llu   |  %9llu   |  %9llu\n", vals[0], vals[2], vals[1]);

   308             g_free (vals);

   309           }

   310       }

   311     else

   312       g_print ("Done.\n");

   313 #ifdef __SYMBIAN32__

   314   testResultXml("slice-test");

   315   #endif /* EMULATOR */

   316     return 0;

   317   }

   318 }

author	sl
	Tue, 10 Jun 2014 14:32:02 +0200
changeset 1	260cb5ec6c19
permissions	-rw-r--r--