kernel/posix/xsi_semaphore.cpp

44 	sem_undo(XsiSemaphoreSet *semaphoreSet, Team *team, int16 *undoValues)
47 		team(team),
54 	Team								*team;
69 		mutex_init(&lock, "Private team undo_list lock");
232 		Team *team = thread_get_current_thread()->team;
236 			if (current->team == team) {
239 					fID, semaphoreNumber, (int)team->id));
240 				MutexLocker _(team->xsi_sem_context->lock);
250 		// of the calling team. This happens only on semctl SETALL.
251 		Team *team = thread_get_current_thread()->team;
255 			if (current->team == team) {
257 					"semaphoreSetID = %d\n", (int)team->id, fID));
258 				MutexLocker _(team->xsi_sem_context->lock);
338 	// the team undo_list. The only limit here is the memory needed
342 		// Look if there is already a record from the team caller
345 		Team *team = thread_get_current_thread()->team;
349 			if (current->team == team) {
351 				MutexLocker _(team->xsi_sem_context->lock);
362 					(int)team->id, fID, semaphoreNumber,
369 			// First sem_undo request from this team for this
376 				= new(std::nothrow) sem_undo(this, team, undoValues);
384 			// Check if it's the very first sem_undo request for this team
385 			xsi_sem_context *context = atomic_pointer_get(&team->xsi_sem_context);
398 				if (atomic_pointer_test_and_set(&team->xsi_sem_context, context,
403 			// Add the request to both XsiSemaphoreSet and team list
405 			MutexLocker _(team->xsi_sem_context->lock);
406 			team->xsi_sem_context->undo_list.Add(request);
409 				(int)team->id, fID, semaphoreNumber, value));
417 		Team *team = thread_get_current_thread()->team;
421 			if (current->team == team) {
422 				MutexLocker _(team->xsi_sem_context->lock);
631 /*!	Function called on team exit to process any sem_undo requests */
633 xsi_sem_undo(Team *team)
635 	if (team->xsi_sem_context == NULL)
643 	// Process all sem_undo request in the team sem undo list
646 		= team->xsi_sem_context->undo_list.GetIterator();
653 		MutexLocker _(team->xsi_sem_context->lock);
658 					"SemaphoreNumber = %d, undo value = %d\n", (int)team->id,
668 	delete team->xsi_sem_context;
669 	team->xsi_sem_context = NULL;
1001 				MutexLocker _(entry->team->xsi_sem_context->lock);
1002 				entry->team->xsi_sem_context->undo_list.Remove(entry);