Fix idle and pending counts for bs_serial

Author: jaynel

src/elysium_bs_serial.erl

@@ -51,8 +51,8 @@
 
 -spec idle_connection_count(connection_queue_name()) -> max_connections().
 %% @doc Get the current number of Cassandra Connections in the elysium_serial_queue.
-idle_connection_count(Connection_Queue) ->
-    elysium_serial_queue:num_entries(Connection_Queue).
+idle_connection_count(_Connection_Queue) ->
+    elysium_serial_queue:num_entries(elysium_serial_sessions).
 
 -spec checkin_connection(connection_queue_name(), cassandra_connection()) -> max_connections().
 %% @doc Add free connection to the end of serial queue.
@@ -77,8 +77,8 @@ checkout_connection_error(_Config, ?MODULE, Connection_Queue, Error) ->
 
 -spec pending_request_count(requests_queue_name()) -> pending_count().
 %% @doc Get the current number of Pending Requests in the elysium_serial_queue.
-pending_request_count(Pending_Queue) ->
-    elysium_serial_queue:num_entries(Pending_Queue).
+pending_request_count(_Pending_Queue) ->
+    elysium_serial_queue:num_entries(elysium_serial_pendings).
 
 -spec checkin_pending_request(requests_queue_name(), reference(), erlang:timestamp()) -> pending_count().
 %% @doc Put the Pending Request at the end of the elysium_serial_queue and return the new size.

src/elysium_buffering_strategy.erl

@@ -402,14 +402,14 @@ idle_connections(Config) ->
     Connection_Queue = elysium_config:session_queue_name             (Config),
     Max_Connections  = elysium_config:session_max_count              (Config),
     {_BS, BS_Module} = elysium_connection:get_buffer_strategy_module (Config),
-    Idle_Count       = BS_Module:idle_connection_count               (Config),
+    Idle_Count       = BS_Module:idle_connection_count        (Connection_Queue),
     {idle_connections, report_available_resources(Connection_Queue, Idle_Count, Max_Connections)}.
 
 pending_requests(Config) ->
     Pending_Queue    = elysium_config:requests_queue_name            (Config),
     Reply_Timeout    = elysium_config:request_reply_timeout          (Config),
     {_BS, BS_Module} = elysium_connection:get_buffer_strategy_module (Config),
-    Pending_Count    = BS_Module:pending_request_count               (Config),
+    Pending_Count    = BS_Module:pending_request_count           (Pending_Queue),
     {pending_requests, report_available_resources(Pending_Queue, Pending_Count, Reply_Timeout)}.
 
 %% Worker_Pid is passed to allow tracing