system/kernel/UserTimer.cpp

17 #include <team.h>
42 	Team*	team;
47 		team(NULL),
57 	void Lock(Team* team, Thread* thread)
59 		this->team = team;
60 		team->Lock();
69 		// We don't check thread->team != team here, since this method can be
70 		// called for new threads not added to the team yet.
76 		team = thread_get_current_thread()->team;
77 		team->Lock();
83 			if (thread->team != team)
88 			? thread->UserTimerFor(timerID) : team->UserTimerFor(timerID);
102 		if (team != NULL) {
103 			team->Unlock();
104 			team = NULL;
544 	// Get the team. If it doesn't exist anymore, just don't schedule the
617 	Called whenever threads of the team whose CPU time is referred to by the
618 	timer are scheduled or unscheduled (or leave the team), or when the timer
633 	// determine how many of the team's threads are currently running
638 		if (thread != unscheduledThread && thread->team == fTeam)
646 /*!	Called when the team's CPU time clock which this timer refers to has been
787 	// Get the team. If it doesn't exist anymore, just don't schedule the
1074 /*!	Called when the team's CPU time clock which this timer refers to has been
1231 create_timer(clockid_t clockID, int32 timerID, Team* team, Thread* thread,
1252 			if (team == NULL)
1254 			timer = new(std::nothrow) TeamTimeUserTimer(team->id);
1258 			if (team == NULL)
1260 			timer = new(std::nothrow) TeamUserTimeUserTimer(team->id);
1265 			// The clock ID is a ID of the team whose CPU time the clock refers
1266 			// to. Check whether the team exists and we have permission to
1312 					event.sigev_signo, SI_TIMER, 0, team->id);
1314 				// The signal shall be sent to the team.
1315 				signalEvent = TeamSignalEvent::Create(team, event.sigev_signo,
1344 	// add it to the team/thread
1346 	timerLocker.Lock(team, thread);
1349 		? thread->AddUserTimer(timer) : team->AddUserTimer(timer);
1386 /*!	Called when the CPU time clock of the given team has been set.
1390 	\param team The team whose CPU time clock has been set.
1395 team_clock_changed(Team* team, bigtime_t changedBy)
1398 				= team->CPUTimeUserTimerIterator();
1409 	The thread may not have been added to its team yet, hence the team must be
1412 	\param team The thread's (future) team.
1417 user_timer_create_thread_timers(Team* team, Thread* thread)
1425 		team, thread, USER_TIMER_SIGNAL_THREAD, event, NULL, true);
1433 /*!	Creates the pre-defined user timers for the given team.
1435 	\param team The team whose pre-defined timers shall be created.
1439 user_timer_create_team_timers(Team* team)
1447 		team, NULL, 0, event, NULL, true);
1456 		USER_TIMER_TEAM_TOTAL_TIME_ID, team, NULL, 0, event, NULL, true);
1465 		USER_TIMER_TEAM_USER_TIME_ID, team, NULL, 0, event, NULL, true);
1495 			Team* team = thread_get_current_thread()->team;
1496 			InterruptsSpinLocker timeLocker(team->time_lock);
1497 			_time = team->UserCPUTime();
1504 			// get the ID of the target team (or the respective placeholder)
1517 			// get the team
1518 			Team* team = Team::Get(teamID);
1519 			if (team == NULL)
1521 			BReference<Team> teamReference(team, true);
1524 			InterruptsSpinLocker timeLocker(team->time_lock);
1525 			_time = team->CPUTime(false);
1558 	// update team timers
1559 	if (nextThread == NULL || nextThread->team != thread->team) {
1561 					= thread->team->CPUTimeUserTimerIterator();
1572 	// update team timers
1573 	if (previousThread == NULL || previousThread->team != thread->team) {
1575 					= thread->team->CPUTimeUserTimerIterator();
1591 user_timer_check_team_user_timers(Team* team)
1594 				= team->UserTimeUserTimerIterator();
1656 			// get the ID of the target team (or the respective placeholder)
1669 			// get the team
1670 			Team* team = Team::Get(teamID);
1671 			if (team == NULL)
1673 			BReference<Team> teamReference(team, true);
1676 			InterruptsSpinLocker timeLocker(team->time_lock);
1677 			bigtime_t diff = time - team->CPUTime(false);
1678 			team->cpu_clock_offset += diff;
1680 			team_clock_changed(team, diff);
1717 	// get team and thread
1718 	Team* team = thread_get_current_thread()->team;
1730 	return create_timer(clockID, -1, team, thread, flags, event,
1756 		timerLocker.team->RemoveUserTimer(timer);