hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix avrorouter client counts

Browse Source 
The avro client numbers were decremented twice for each client.
This commit is contained in:
Markus Mäkelä
2017-06-02 10:54:27 +03:00
parent 919d08af1e
commit 4b6c5caa47
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
server/modules/routing/avro/avro.c
View File

@ -654,11 +654,9 @@ static void freeSession(ROUTER* router_instance, void* router_client_ses)
{ {
AVRO_INSTANCE *router = (AVRO_INSTANCE *) router_instance; AVRO_INSTANCE *router = (AVRO_INSTANCE *) router_instance;
AVRO_CLIENT *client = (AVRO_CLIENT *) router_client_ses; AVRO_CLIENT *client = (AVRO_CLIENT *) router_client_ses;
int prev_val;
prev_val = atomic_add(&router->stats.n_clients, -1); ss_debug(int prev_val = )atomic_add(&router->stats.n_clients, -1);
ss_dassert(prev_val > 0); ss_dassert(prev_val > 0);
(void) prev_val;
free(client->uuid); free(client->uuid);
maxavro_file_close(client->file_handle); maxavro_file_close(client->file_handle);
@ -713,9 +711,6 @@ static void closeSession(ROUTER *instance, void *router_session)
spinlock_release(&client->file_lock); spinlock_release(&client->file_lock);
spinlock_release(&client->catch_lock); spinlock_release(&client->catch_lock);
/* decrease server registered slaves counter */
atomic_add(&router->stats.n_clients, -1);
} }
/** /**