Function ds_check_timer

modules/dispatcher/dispatch.c:2695–2854

* Timer for checking inactive destinations * * This timer is regularly fired. */

 * This timer is regularly fired.
 */
void ds_check_timer(unsigned int ticks, void* param)
{
	struct gw_prob_pack {
		/* IMPORTANT, this member must be the first, as we use its pointer
		 * to free the whole structure here */
		ds_options_callback_param_t params;

		const struct socket_info *sock;
		struct usr_avp *avps;

		struct gw_prob_pack *next;
	};
	ds_partition_t *partition;
	struct gw_prob_pack *pack, *pack_last, *pack_head;
	dlg_t *dlg;
	ds_set_p list;
	int_str val;
	int j;
	int nodes_no, node_idx=-1;
	unsigned int h;

	if ( !( ds_cluster_id<=0
	|| (ds_cluster_prob_mode == DS_CLUSTER_PROB_MODE_ALL)
	|| (ds_cluster_prob_mode == DS_CLUSTER_PROB_MODE_DISTRIBUTED &&
		(node_idx=ds_cluster_get_my_index(&nodes_no))>=0 )
	|| (ds_cluster_prob_mode == DS_CLUSTER_PROB_MODE_SHTAG &&
		ds_cluster_shtag_is_active())
	) )
		return;

	for (partition = partitions; partition; partition = partition->next){
		/* Check for the list. */
		if ( (*partition->data)->sets==NULL )
			continue;

		pack_last = pack_head = NULL;

		/* access ds data under reader's lock */
		lock_start_read( partition->lock );

		/* Iterate over the groups and the entries of each group: */
		for( list=(*partition->data)->sets ; list!= NULL ; list= list->next)
		{
			for(j=0; j<list->nr; j++)
			{
				/* If list is probed by this proxy and the Flag of
				 * the entry has "Probing" set, send a probe: */
				if ( (!ds_probing_list || in_int_list(ds_probing_list, list->id)==0) &&
				((list->dlist[j].flags&DS_INACTIVE_DST)==0) &&
				(ds_probing_mode==1 || (list->dlist[j].flags&(DS_PROBING_DST|DS_PROBING_PERM_DST))!=0
				))
				{
					/* stage 2 of checking, clustering level */
					if (node_idx>=0) {
						h=core_hash( &list->dlist[j].uri, NULL, 0);
						if ( (h % nodes_no) != node_idx)
							continue;
					}