debuganalyzer/model_loader/ModelLoader.cpp

213 	void AddEvent(system_profiler_event_header* event)
215 		fEvents[fEventIndex++] = event;
431 	// create a debug event array
471 		// get next event
472 		uint32 event;
476 		ssize_t bufferSize = input.ReadNextEvent(&event, &cpu, &buffer,
483 		// process the event
484 		status_t error = _ProcessEvent(event, cpu, buffer, bufferSize);
611 		// get next event
612 		uint32 event;
615 		ssize_t bufferSize = input.ReadNextEvent(&event, &cpu, &buffer, NULL);
639 		// get next event
640 		uint32 event;
644 		input.ReadNextEvent(&event, &cpu, &buffer, &offset);
659 ModelLoader::_ProcessEvent(uint32 event, uint32 cpu, const void* buffer,
662 	switch (event) {
725 			printf("unsupported event type %" B_PRIu32 ", size: %" B_PRIuSIZE
726 				"\n", event, size);
745 	// fill the threads' event arrays
752 		switch (header->event) {
755 				system_profiler_thread_added* event
757 				fState->LookupThread(event->thread)->AddEvent(header);
763 				system_profiler_thread_removed* event
765 				fState->LookupThread(event->thread)->AddEvent(header);
771 				system_profiler_thread_scheduled* event
773 				fState->LookupThread(event->thread)->AddEvent(header);
775 				if (event->thread != event->previous_thread) {
776 					fState->LookupThread(event->previous_thread)
784 				thread_enqueued_in_run_queue* event
786 				fState->LookupThread(event->thread)->AddEvent(header);
792 				thread_removed_from_run_queue* event
794 				fState->LookupThread(event->thread)->AddEvent(header);
881 ModelLoader::_HandleTeamAdded(system_profiler_team_added* event)
883 	if (fModel->AddTeam(event, fState->LastEventTime()) == NULL)
889 ModelLoader::_HandleTeamRemoved(system_profiler_team_removed* event)
891 	if (Model::Team* team = fModel->TeamByID(event->team))
894 		printf("Warning: Removed event for unknown team: %" B_PRId32 "\n",
895 			event->team);
901 ModelLoader::_HandleTeamExec(system_profiler_team_exec* event)
908 ModelLoader::_HandleThreadAdded(system_profiler_thread_added* event)
910 	_AddThread(event)->IncrementEventCount();
915 ModelLoader::_HandleThreadRemoved(system_profiler_thread_removed* event)
917 	ExtendedThreadSchedulingState* thread = fState->LookupThread(event->thread);
919 		printf("Warning: Removed event for unknown thread: %" B_PRId32 "\n",
920 			event->thread);
921 		thread = _AddUnknownThread(event->thread);
931 	system_profiler_thread_scheduled* event)
933 	_UpdateLastEventTime(event->time);
935 	ExtendedThreadSchedulingState* thread = fState->LookupThread(event->thread);
937 		printf("Warning: Schedule event for unknown thread: %" B_PRId32 "\n",
938 			event->thread);
939 		thread = _AddUnknownThread(event->thread);
967 	if (event->thread == event->previous_thread)
970 	thread = fState->LookupThread(event->previous_thread);
972 		printf("Warning: Schedule event for unknown previous thread: %" B_PRId32
973 			"\n", event->previous_thread);
974 		thread = _AddUnknownThread(event->previous_thread);
995 		if (event->previous_thread_state == B_THREAD_WAITING) {
996 			addr_t waitObject = event->previous_thread_wait_object;
997 			switch (event->previous_thread_wait_object_type) {
1013 				event->previous_thread_wait_object_type, waitObject);
1019 		uint32 threadState = event->previous_thread_state;
1036 	thread_enqueued_in_run_queue* event)
1038 	_UpdateLastEventTime(event->time);
1040 	ExtendedThreadSchedulingState* thread = fState->LookupThread(event->thread);
1042 		printf("Warning: Enqueued in run queue event for unknown thread: %"
1043 			B_PRId32 "\n", event->thread);
1044 		thread = _AddUnknownThread(event->thread);
1065 	thread->priority = event->priority;
1073 	thread_removed_from_run_queue* event)
1075 	_UpdateLastEventTime(event->time);
1077 	ExtendedThreadSchedulingState* thread = fState->LookupThread(event->thread);
1079 		printf("Warning: Removed from run queue event for unknown thread: "
1080 			"%" B_PRId32 "\n", event->thread);
1081 		thread = _AddUnknownThread(event->thread);
1107 ModelLoader::_HandleWaitObjectInfo(system_profiler_wait_object_info* event)
1109 	if (fModel->AddWaitObject(event, NULL) == NULL)
1115 ModelLoader::_HandleIOSchedulerAdded(system_profiler_io_scheduler_added* event)
1117 	Model::IOScheduler* scheduler = fModel->IOSchedulerByID(event->scheduler);
1119 		printf("Warning: Duplicate added event for I/O scheduler %" B_PRId32
1120 			"\n", event->scheduler);
1124 	if (fModel->AddIOScheduler(event) == NULL)
1130 ModelLoader::_HandleIORequestScheduled(io_request_scheduled* event)
1132 	IORequest* request = fIORequests->Lookup(event->request);
1134 		printf("Warning: Duplicate schedule event for I/O request %p\n",
1135 			event->request);
1139 	ExtendedThreadSchedulingState* thread = fState->LookupThread(event->thread);
1142 			event->thread);
1143 		thread = _AddUnknownThread(event->thread);
1146 	if (fModel->IOSchedulerByID(event->scheduler) == NULL) {
1148 			event->scheduler);
1153 	request = new(std::nothrow) IORequest(event);
1163 ModelLoader::_HandleIORequestFinished(io_request_finished* event)
1165 	IORequest* request = fIORequests->Lookup(event->request);
1169 	request->finishedEvent = event;
1178 ModelLoader::_HandleIOOperationStarted(io_operation_started* event)
1180 	IORequest* request = fIORequests->Lookup(event->request);
1183 			event->operation);
1187 	IOOperation* operation = new(std::nothrow) IOOperation(event);
1196 ModelLoader::_HandleIOOperationFinished(io_operation_finished* event)
1198 	IORequest* request = fIORequests->Lookup(event->request);
1201 			event->operation);
1205 	IOOperation* operation = request->FindOperation(event->operation);
1207 		printf("Warning: operation %p not found\n", event->operation);
1211 	operation->finishedEvent = event;
1216 ModelLoader::_AddThread(system_profiler_thread_added* event)
1219 	ExtendedThreadSchedulingState* info = fState->LookupThread(event->thread);
1221 		printf("Warning: Duplicate thread added event for thread %" B_PRId32
1222 			"\n", event->thread);
1227 	Model::Thread* thread = fModel->AddThread(event, fState->LastEventTime());
1238 	if (strncmp(event->name, "idle thread", strlen("idle thread")) == 0)
1252 	// create a dummy "add thread" event
1253 	system_profiler_thread_added* event = (system_profiler_thread_added*)
1255 	if (event == NULL)
1258 	if (!fModel->AddAssociatedData(event)) {
1259 		free(event);
1264 		event->team = _AddUnknownTeam()->ID();
1265 		event->thread = threadID;
1266 		snprintf(event->name, sizeof(event->name), "unknown thread %" B_PRId32,
1270 		ExtendedThreadSchedulingState* state = _AddThread(event);
1285 	// create a dummy "add team" event
1289 	system_profiler_team_added* event = (system_profiler_team_added*)
1291 	if (event == NULL)
1294 	event->team = teamID;
1295 	event->args_offset = nameLength;
1296 	strlcpy(event->name, kUnknownThreadsTeamName, nameLength + 1);
1299 	team = fModel->AddTeam(event, fState->LastEventTime());