cur_buffers--;
GNUNET_MQ_discard (env);
lower_rung (dir);
+ GNUNET_STATISTICS_set (stats,
+ "# buffer use",
+ cur_buffers,
+ GNUNET_NO);
}
&dir->env_tail,
env);
cur_buffers++;
+ GNUNET_STATISTICS_set (stats,
+ "# buffer use",
+ cur_buffers,
+ GNUNET_NO);
/* Clean up 'rung' if now empty (and not head) */
if ( (NULL == rung->rd_head) &&
(rung != rung_head) )
GNUNET_CONTAINER_multishortmap_remove (routes,
&route->cid.connection_of_tunnel,
route));
+ GNUNET_STATISTICS_set (stats,
+ "# routes",
+ GNUNET_CONTAINER_multishortmap_size (routes),
+ GNUNET_NO);
destroy_direction (&route->prev);
destroy_direction (&route->next);
GNUNET_free (route);
&dir->env_tail,
env);
cur_buffers--;
+ GNUNET_STATISTICS_set (stats,
+ "# buffer use",
+ cur_buffers,
+ GNUNET_NO);
lower_rung (dir);
dir->is_ready = GNUNET_NO;
GCP_send (dir->mqm,
&route->cid.connection_of_tunnel,
route,
GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
+ GNUNET_STATISTICS_set (stats,
+ "# routes",
+ GNUNET_CONTAINER_multishortmap_size (routes),
+ GNUNET_NO);
route->hn = GNUNET_CONTAINER_heap_insert (route_heap,
route,
route->last_use.abs_value_us);