From 54cd1f79a66ec0c378dffa26a8de96c413c7cfc2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Mierzwa?= Date: Mon, 15 Apr 2013 19:15:54 +0200 Subject: [PATCH] add missing locks to legion_cache_fetch plugin --- plugins/legion_cache_fetch/legion_cache_fetch.c | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/plugins/legion_cache_fetch/legion_cache_fetch.c b/plugins/legion_cache_fetch/legion_cache_fetch.c index 6e322e75..3f1c90ae 100644 --- a/plugins/legion_cache_fetch/legion_cache_fetch.c +++ b/plugins/legion_cache_fetch/legion_cache_fetch.c @@ -1,6 +1,9 @@ #include +extern struct uwsgi_server uwsgi; + + static int legion_action_cache_fetch_from_legion(struct uwsgi_legion *ul, char *arg) { uwsgi_log("[legion-cache-fetch] getting cache '%s' dump from legion '%s' nodes\n", arg, ul->legion); @@ -12,6 +15,7 @@ static int legion_action_cache_fetch_from_legion(struct uwsgi_legion *ul, char * struct uwsgi_string_list *dump_from_nodes = NULL; + uwsgi_rlock(ul->lock); struct uwsgi_legion_node *legion_nodes = ul->nodes_head; while (legion_nodes) { char *dump_socket = NULL; @@ -42,7 +46,11 @@ static int legion_action_cache_fetch_from_legion(struct uwsgi_legion *ul, char * free(usl); usl = next; } + uwsgi_rwunlock(ul->lock); + + uwsgi_rlock(uc->lock); uc->sync_nodes = dump_from_nodes; + uwsgi_rwunlock(uc->lock); // call sync uwsgi_cache_sync_from_nodes(uc);