---

prof_thread.cpp

/*
 *                         Sun Public License Notice
 *
 * The contents of this file are subject to the Sun Public License
 * Version 1.0 (the "License"); you may not use this file except
 * in compliance with the License. A copy of the License is available
 * at http://www.sun.com/
 *
 * The Original Code is the Java Profiler module.  The Initial Developers
 * of the Original Code are Jan Stola, Pavel Vacha, Michal Pise, Petr Luner,
 * Lukas Petru and Marek Przeczek.
 *
 * Portions created by Jan Stola are Copyright (C) 2000-2001.
 * All Rights Reserved.
 *
 * Portions created by Pavel Vacha are Copyright (C) 2000-2001.
 * All Rights Reserved.
 *
 * Portions created by Michal Pise are Copyright (C) 2000-2001.
 * All Rights Reserved.
 *
 * Portions created by Petr Luner are Copyright (C) 2000-2001.
 * All Rights Reserved.
 *
 * Portions created by Lukas Petru are Copyright (C) 2000-2001.
 * All Rights Reserved.
 *
 * Portions created by Marek Przeczek are Copyright (C) 2000-2001.
 * All Rights Reserved.
 *
 * Contributors: Jan Stola, Pavel Vacha, Michal Pise, Petr Luner,
 *               Lukas Petru and Marek Przeczek.
 */

#include "../prof/prof.h"
#include "../shared/groupThread.h"
#include "../prof/synchronized.h"

int Prof::findParent( Thread* t, void** inout) {

        if( t->active && t->threadName == reinterpret_cast<const char*>( *inout)) {
        
                *inout = t;
                return 1;
        }

        return 0;
}

int Prof::findGroup( GroupThread* g, void** inout) {
        
        if( g->groupName == reinterpret_cast<const char*> ( *inout)) {
        
                *inout = g;
                return 1;
        }

        return 0;
}

void Prof::event_threadStart( JVMPI_Event* event) {

        Synchronized sync( dataLock, 0);
        if( !(event->event_type & JVMPI_REQUESTED_EVENT)) sync.enter();

        JNIEnv* envId = event->u.thread_start.thread_env_id;
        char* name = event->u.thread_start.thread_name;

        if (!envId) return;
        if (strcmp(name, COMMUN_THREAD) == 0) return;
        if (strcmp(name, SAMPLING_THREAD) == 0) return;

        static int firstTime = 1;
        if( firstTime) {
        
                jvmpiInterface->EnableEvent( JVMPI_EVENT_THREAD_END, NULL);
                firstTime = 0;
        }

        Thread* t = new Thread;

        t->threadName  = event->u.thread_start.thread_name;
        t->threadId    = event->u.thread_start.thread_id;
        t->threadEnvId    = envId;

        threads.add(t);
        activeThreads.add(t);
        sampledThreads.add(t);

        void* inout = event->u.thread_start.group_name;
        if( !groupsOfThreads.forEach( findGroup, &inout)) {
        
                GroupThread* g = new GroupThread;

                g->groupName = event->u.thread_start.group_name;
                g->threads.add( t);

                t->group = g;

                groupsOfThreads.add( g);
        }
        else {
                
                t->group = reinterpret_cast<GroupThread*> ( inout);
                t->group->threads.add( t);
        }

        inout = event->u.thread_start.parent_name;
        if( !threads.forEach( findParent, &inout)) t->parent = NULL;
        else t->parent = reinterpret_cast<Thread*> ( inout);

        if( t->parent) t->parent->children.add( t);
}

void Prof::event_threadEnd( JVMPI_Event* event) {

        Synchronized sync( dataLock);

        Thread* t = getThread(event->env_id, 0);
        if (t) t->deactivate();
}

---