rpl/src/interruptions.c - diff

Return to interruptions.c CVS log

Up to [local] / rpl / src

Diff for /rpl/src/interruptions.c between versions 1.96 and 1.97

version 1.96, 2012/05/17 17:06:18	version 1.97, 2012/05/18 09:30:31
Line 99 thread_surveillance_signaux(void *argume	Line 99 thread_surveillance_signaux(void *argume
break;	break;
}	}

	# ifndef SEMAPHORES_NOMMES
	sem_post(&(*s_queue_signaux).signalisation);
	# else
	sem_post(semaphore_signalisation);
	# endif

nombre_signaux_envoyes = 0;	nombre_signaux_envoyes = 0;
	sched_yield();

// Dans un premier temps, on verrouille la queue des signaux	// Dans un premier temps, on verrouille la queue des signaux
// affectée au processus courant pour vérifier s'il y a quelque	// affectée au processus courant pour vérifier s'il y a quelque
Line 310 retrait_thread(struct_processus *s_etat_	Line 317 retrait_thread(struct_processus *s_etat_
return;	return;
}	}

	// Le thread ne peut plus traiter de signaux explicites. Il convient
	// alors de corriger le sémaphore pour annuler les signaux en attente.

	while(((((struct_thread ) (l_element_courant).donnee)).s_etat_processus)
	.pointeur_signal_ecriture != ((((struct_thread *)
	(*l_element_courant).donnee)).s_etat_processus)
	.pointeur_signal_lecture)
	{
	# ifndef SEMAPHORES_NOMMES
	sem_wait(&((*s_queue_signaux).signalisation));
	# else
	sem_wait(semaphore_signalisation);
	# endif

	((((struct_thread ) (l_element_courant).donnee)).s_etat_processus)
	.pointeur_signal_lecture = (((((struct_thread *)
	(*l_element_courant).donnee)).s_etat_processus)
	.pointeur_signal_lecture + 1) % LONGUEUR_QUEUE_SIGNAUX;
	}

free((void ) (l_element_courant).donnee);	free((void ) (l_element_courant).donnee);
free((struct_liste_chainee_volatile *) l_element_courant);	free((struct_liste_chainee_volatile *) l_element_courant);

Line 1674 inline static void	Line 1701 inline static void
signal_term(struct_processus *s_etat_processus, pid_t pid)	signal_term(struct_processus *s_etat_processus, pid_t pid)
{	{
struct_processus *s_thread_principal;	struct_processus *s_thread_principal;
volatile sig_atomic_t exclusion = 0;	pthread_mutex_t exclusion = PTHREAD_MUTEX_INITIALIZER;

verrouillage_gestionnaire_signaux(s_etat_processus);	verrouillage_gestionnaire_signaux(s_etat_processus);

Line 1696 signal_term(struct_processus *s_etat_pro	Line 1723 signal_term(struct_processus *s_etat_pro
{	{
(*s_etat_processus).var_volatile_traitement_sigint = -1;	(*s_etat_processus).var_volatile_traitement_sigint = -1;

while(exclusion == 1);	pthread_mutex_lock(&exclusion);
exclusion = 1;

if ((*s_etat_processus).var_volatile_requete_arret == -1)	if ((*s_etat_processus).var_volatile_requete_arret == -1)
{	{
deverrouillage_gestionnaire_signaux(s_etat_processus);	deverrouillage_gestionnaire_signaux(s_etat_processus);
exclusion = 0;	pthread_mutex_unlock(&exclusion);
return;	return;
}	}

(*s_etat_processus).var_volatile_requete_arret = -1;	(*s_etat_processus).var_volatile_requete_arret = -1;
(*s_etat_processus).var_volatile_alarme = -1;	(*s_etat_processus).var_volatile_alarme = -1;

exclusion = 0;	pthread_mutex_unlock(&exclusion);
}	}
}	}
else	else
Line 2509 envoi_signal_processus(pid_t pid, enum s	Line 2535 envoi_signal_processus(pid_t pid, enum s
# ifndef IPCS_SYSV	# ifndef IPCS_SYSV
# ifdef SEMAPHORES_NOMMES	# ifdef SEMAPHORES_NOMMES
sem_t *semaphore;	sem_t *semaphore;
	sem_t *signalisation;
# endif	# endif
# else	# else
# ifndef OS2	# ifndef OS2
Line 2562 envoi_signal_processus(pid_t pid, enum s	Line 2589 envoi_signal_processus(pid_t pid, enum s
{	{
return(1);	return(1);
}	}

	# ifndef SEMAPHORES_NOMMES
	if (sem_post(&((*s_queue_signaux).signalisation)) != 0)
	# else
	if (sem_post(semaphore_signalisation) != 0)
	# endif
	{
	return(1);
	}
}	}
else	else
{	{
Line 2648 envoi_signal_processus(pid_t pid, enum s	Line 2684 envoi_signal_processus(pid_t pid, enum s
return(1);	return(1);
}	}

	if ((signalisation = sem_open2(pid, SEM_SIGNALISATION))
	== SEM_FAILED)
	{
	return(1);
	}

while(sem_wait(semaphore) != 0)	while(sem_wait(semaphore) != 0)
{	{
if (errno != EINTR)	if (errno != EINTR)
{	{
sem_close(semaphore);	sem_close(semaphore);
	sem_close(signalisation);
return(1);	return(1);
}	}
}	}
Line 2679 envoi_signal_processus(pid_t pid, enum s	Line 2722 envoi_signal_processus(pid_t pid, enum s
{	{
return(1);	return(1);
}	}

	if (sem_post(&((*queue).signalisation)) != 0)
	{
	return(1);
	}
# else	# else
if (sem_post(semaphore) != 0)	if (sem_post(semaphore) != 0)
{	{
sem_close(semaphore);	sem_close(semaphore);
	sem_close(signalisation);
return(1);	return(1);
}	}

Line 2690 envoi_signal_processus(pid_t pid, enum s	Line 2739 envoi_signal_processus(pid_t pid, enum s
{	{
return(1);	return(1);
}	}

	if (sem_post(signalisation) != 0)
	{
	sem_close(signalisation);
	return(1);
	}

	if (sem_close(signalisation) != 0)
	{
	return(1);
	}

# endif	# endif

if (munmap(queue, sizeof(struct_queue_signaux)) != 0)	if (munmap(queue, sizeof(struct_queue_signaux)) != 0)
Line 2703 envoi_signal_processus(pid_t pid, enum s	Line 2764 envoi_signal_processus(pid_t pid, enum s
return(1);	return(1);
}	}

	if (sem_post(&((*queue).signalisation)) != 0)
	{
	return(1);
	}

# ifndef OS2 // SysV	# ifndef OS2 // SysV
if (shmdt(queue) != 0)	if (shmdt(queue) != 0)
{	{
Line 2714 envoi_signal_processus(pid_t pid, enum s	Line 2780 envoi_signal_processus(pid_t pid, enum s
# endif	# endif
}	}

kill(pid, SIGALRM);

return(0);	return(0);
}	}

Line 2779 envoi_signal_thread(pthread_t tid, enum	Line 2843 envoi_signal_thread(pthread_t tid, enum
return(1);	return(1);
}	}

pthread_kill(tid, SIGALRM);	# ifndef SEMAPHORES_NOMMES
	if (sem_post(&((*s_queue_signaux).signalisation)) != 0)
	{
	return(1);
	}
	# else
	if (sem_post(semaphore_signalisation) != 0)
	{
	return(1);
	}
	# endif

return(0);	return(0);
}	}
Line 2797 envoi_signal_contexte(struct_processus *	Line 2871 envoi_signal_contexte(struct_processus *
% LONGUEUR_QUEUE_SIGNAUX;	% LONGUEUR_QUEUE_SIGNAUX;
pthread_mutex_unlock(&mutex_interruptions);	pthread_mutex_unlock(&mutex_interruptions);

pthread_kill((*s_etat_processus_a_signaler).tid, SIGALRM);	# ifndef SEMAPHORES_NOMMES
	if (sem_post(&((*s_queue_signaux).signalisation)) != 0)
	{
	return(1);
	}
	# else
	if (sem_post(semaphore_signalisation) != 0)
	{
	return(1);
	}
	# endif

return(0);	return(0);
}	}

CVSweb interface <joel.bertrand@systella.fr>

Removed from v.1.96
changed lines
	Added in v.1.97