X-Git-Url: https://git.street.me.uk/andy/viking.git/blobdiff_plain/e044ae9e96b95fc6e58b4f05f759e5fc59bb79ab..b870a51291519a44976d85d47471abaf791028ec:/src/mapcache.c?ds=inline diff --git a/src/mapcache.c b/src/mapcache.c index f697252d..5485f178 100644 --- a/src/mapcache.c +++ b/src/mapcache.c @@ -18,10 +18,16 @@ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * */ +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif #include +#include #include +#include "globals.h" #include "mapcache.h" +#include "preferences.h" #include "config.h" @@ -35,20 +41,56 @@ typedef struct _List { static List *queue_tail = NULL; static int queue_count = 0; -#define VIK_CONFIG_MAPCACHE_MAX_SIZE 50331648 /* 48 meggerbytes */ static guint32 queue_size = 0; +static guint32 max_queue_size = VIK_CONFIG_MAPCACHE_SIZE; static GHashTable *cache = NULL; +static GMutex *mc_mutex = NULL; + #define HASHKEY_FORMAT_STRING "%d-%d-%d-%d-%d-%d-%.3f-%.3f" #define HASHKEY_FORMAT_STRING_NOSHRINK_NOR_ALPHA "%d-%d-%d-%d-%d-" +static VikLayerParamScale params_scales[] = { + /* min, max, step, digits (decimal places) */ + { 1, 300, 1, 0 }, +}; + +static VikLayerParam prefs[] = { + { VIKING_PREFERENCES_NAMESPACE "mapcache_size", VIK_LAYER_PARAM_UINT, VIK_LAYER_GROUP_NONE, N_("Mapcache memory size (MB):"), VIK_LAYER_WIDGET_HSCALE, params_scales, NULL }, +}; + void a_mapcache_init () { + VikLayerParamData tmp; + tmp.u = VIK_CONFIG_MAPCACHE_SIZE / 1024 / 1024; + a_preferences_register(prefs, tmp, VIKING_PREFERENCES_GROUP_KEY); + + mc_mutex = g_mutex_new(); cache = g_hash_table_new_full ( g_str_hash, g_str_equal, g_free, g_object_unref ); } +static void cache_add(gchar *key, GdkPixbuf *pixbuf) +{ + /* TODO: Check if already exists */ + g_hash_table_insert ( cache, key, pixbuf ); + queue_size += gdk_pixbuf_get_rowstride(pixbuf) * gdk_pixbuf_get_height(pixbuf); + queue_size += 100; + queue_count++; +} + +static void cache_remove(const gchar *key) +{ + GdkPixbuf *buf = g_hash_table_lookup ( cache, key ); + if (buf) { + queue_size -= gdk_pixbuf_get_rowstride(buf) * gdk_pixbuf_get_height(buf); + queue_size -= 100; + queue_count --; + g_hash_table_remove ( cache, key ); + } +} + /* returns key from head, adds on newtailkey to tail. */ static gchar *list_shift_add_entry ( gchar *newtailkey ) { @@ -87,33 +129,20 @@ void a_mapcache_add ( GdkPixbuf *pixbuf, gint x, gint y, gint z, guint8 type, gu gchar *key = g_strdup_printf ( HASHKEY_FORMAT_STRING, x, y, z, type, zoom, alpha, xshrinkfactor, yshrinkfactor ); static int tmp = 0; - /* FIXME: what if already exists? problem! */ - g_hash_table_insert ( cache, key, pixbuf ); + g_mutex_lock(mc_mutex); + cache_add(key, pixbuf); - queue_size += gdk_pixbuf_get_rowstride(pixbuf) * gdk_pixbuf_get_height(pixbuf); - queue_size += 100; - queue_count++; + // TODO: that should be done on preference change only... + max_queue_size = a_preferences_get(VIKING_PREFERENCES_NAMESPACE "mapcache_size")->u * 1024 * 1024; - if ( queue_size > VIK_CONFIG_MAPCACHE_SIZE ) { + if ( queue_size > max_queue_size ) { gchar *oldkey = list_shift_add_entry ( key ); - GdkPixbuf *oldbuf = g_hash_table_lookup ( cache, oldkey ); - queue_size -= gdk_pixbuf_get_rowstride(oldbuf) * gdk_pixbuf_get_height(oldbuf); - queue_size -= 100; - queue_count --; - g_hash_table_remove ( cache, oldkey ); - - /* should delete BEFORE adding -- not really possible because don't know size, - * but you could guess size (only applic if add big file to full cache) */ - + cache_remove(oldkey); - while ( queue_size > VIK_CONFIG_MAPCACHE_SIZE && + while ( queue_size > max_queue_size && (queue_tail->next != queue_tail) ) { /* make sure there's more than one thing to delete */ oldkey = list_shift (); - oldbuf = g_hash_table_lookup ( cache, oldkey ); - queue_size -= gdk_pixbuf_get_rowstride(oldbuf) * gdk_pixbuf_get_height(oldbuf); - queue_size -= 100; - queue_count --; - g_hash_table_remove ( cache, oldkey ); + cache_remove(oldkey); } /* chop off 'start' etc */ @@ -121,8 +150,9 @@ void a_mapcache_add ( GdkPixbuf *pixbuf, gint x, gint y, gint z, guint8 type, gu list_add_entry ( key ); /* business as usual */ } + g_mutex_unlock(mc_mutex); - if ( (++tmp == 100 )) { g_print("DEBUG: queue count=%d %ld\n", queue_count, queue_size ); tmp=0; } + if ( (++tmp == 100 )) { g_print("DEBUG: queue count=%d size=%u\n", queue_count, queue_size ); tmp=0; } } GdkPixbuf *a_mapcache_get ( gint x, gint y, gint z, guint8 type, guint zoom, guint8 alpha, gdouble xshrinkfactor, gdouble yshrinkfactor ) @@ -145,12 +175,13 @@ void a_mapcache_remove_all_shrinkfactors ( gint x, gint y, gint z, guint8 type, g_snprintf ( key, sizeof(key), HASHKEY_FORMAT_STRING_NOSHRINK_NOR_ALPHA, x, y, z, type, zoom ); len = strlen(key); + g_mutex_lock(mc_mutex); /* TODO: check logic here */ do { tmp = loop->next; if ( strncmp(tmp->key, key, len) == 0 ) { - g_hash_table_remove ( cache, tmp->key ); + cache_remove(tmp->key); if ( tmp == loop ) /* we deleted the last thing in the queue! */ loop = queue_tail = NULL; else { @@ -167,8 +198,31 @@ void a_mapcache_remove_all_shrinkfactors ( gint x, gint y, gint z, guint8 type, } while ( loop && (loop != queue_tail || tmp == NULL) ); /* loop thru list, looking for the one, compare first whatever chars */ + cache_remove(key); + g_mutex_unlock(mc_mutex); +} + +void a_mapcache_flush () +{ + List *loop = queue_tail; + List *tmp; + + if ( queue_tail == NULL ) + return; + + g_mutex_lock(mc_mutex); + do { + tmp = loop->next; + cache_remove(tmp->key); + if ( tmp == queue_tail ) /* we deleted the last thing in the queue */ + loop = queue_tail = NULL; + else + loop->next = tmp->next; + g_free ( tmp ); + tmp = NULL; + } while ( loop ); - g_hash_table_remove ( cache, key ); + g_mutex_unlock(mc_mutex); } void a_mapcache_uninit ()