---

threads.h File Reference

#include "global.h"
#include "types.h"

Include dependency graph for threads.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Compounds
class	ClassInfo
class	MethodInfo
class	ThreadInfo
Functions
void	ThreadDump (const string &info, ThreadID caller)
Variables
bool	HotSpot
	provides workaround for threading issue. More...

---

Function Documentation

void ThreadDump ( const string & info, ThreadID caller )

Definition at line 205 of file threads.cpp. Referenced by BackgroundThread(). { ostringstream output; Lock(threads_lock); Lock(methods_lock); Lock(output_lock); if (ShutdownRequested) { unsafe_debug("shutdown in ", "ThreadDump"); Unlock(output_lock); Unlock(methods_lock); Unlock(threads_lock); return; } //if(false) CALL(DisableGC()); ThreadMap::iterator t; set<ThreadID> SuspendedThreads; const char Endl = '\n'; // suspend all threads for (t = Threads.begin(); t != Threads.end(); ++t) { ThreadID tid = t->first; jlong status = CALL(GetThreadStatus)(tid); if ((tid != caller) && ( ((status & (~JVMPI_THREAD_INTERRUPTED)) == JVMPI_THREAD_RUNNABLE) || HotSpot ) ) { CALL(SuspendThread)(tid); SuspendedThreads.insert(tid); unsafe_debug("Suspended ", tid); } else { unsafe_debug(tid, (long)status); } } unsafe_debug("#threads ", Threads.size()); output << "// start_message; num threads: " << Threads.size() << Endl; output << Threads.size() << Endl; const int number_of_frames = 100; MethodSet methods_to_send; JVMPI_CallTrace trace; JVMPI_CallFrame tframes[number_of_frames]; const JVMPI_CallFrame* f; for (t = Threads.begin(); t != Threads.end(); ++t) { const ThreadInfo& ti = t->second; output << "// start_thread " << t->first << Endl; output << t->first << Endl; // threadid jint thread_status = CALL(GetThreadStatus)(t->first); output << ti.getShortInfo(); output << ti.getStarted() << Endl; output << thread_status << Endl; // thread status // unsafe_debug(t->first, ti.getThreadName(), thread_status); trace.frames = tframes; trace.env_id = t->first; //assert(false); CALL(GetCallTrace)(&trace, number_of_frames); unsafe_debug("num frames: ", trace.num_frames); output << "// num frames = " << trace.num_frames << Endl; output << trace.num_frames << Endl; // send each frame for (int i = 0; i < trace.num_frames; i++) { //output << "// start frame " << i << Endl; f = &trace.frames[i]; output << f->method_id << ' ' << f->lineno << Endl; // send method_id lineno methods_to_send.insert(f->method_id); } } output << "// sending methods now, count=" << methods_to_send.size() << Endl; output << methods_to_send.size() << Endl; ClassSet classes_to_send; const MethodInfo * the_method; //const MethodMap::iterator MethodMap::iterator m; const MethodMap::iterator m_end = Methods.end(); MethodMap::iterator mc_end = MethodCache.end(); // look in the cache const MethodSet::iterator mse = methods_to_send.end(); for(MethodSet::iterator mi = methods_to_send.begin(); mi != mse; ++mi) { m = MethodCache.find(*mi); if (m == mc_end) { // couldn't find, so load it and cache it m = Methods.find(*mi); //assert(m != Methods.end()); if (m == m_end ) { jclassID cid = CALL(GetMethodClass(*mi)); unsafe_debug("Couldn't find ", *mi, cid); unsafe_debug("perf Methods = ", Methods.size()); output << ends; // unsafe_debug("output:: ", output.str()); assert(m != Methods.end()); CALL(EnableGC()); Unlock(output_lock); Unlock(methods_lock); Unlock(threads_lock); return; } MethodCache.insert(make_pair(*mi, m->second)); mc_end = MethodCache.end(); } //m = Methods.find(*mi); //TODO: caching? assert(m != Methods.end()); the_method = m->second; //classid methodid methodname methodsig output << the_method->getShortInfo() << Endl; unsafe_debug(the_method->getClassID(), the_method->getShortInfo()); classes_to_send.insert(the_method->getClassID()); } output << "// sending classes now, count=" << classes_to_send.size() << Endl; output << classes_to_send.size() << Endl; const ClassInfoMap::iterator end = ClassCache.end(); ClassInfoMap::iterator c; const ClassSet::iterator cse = classes_to_send.end(); for (ClassSet::iterator ci = classes_to_send.begin(); ci != cse; ++ci) { c = ClassCache.find(*ci); if (c == end) { c = Classes.find(*ci); ClassCache.insert(make_pair(*ci, c->second)); } //c = Classes.find(*ci); //TODO: caching? assert(c != Classes.end()); // class_id class_name source_name //unsafe_debug("ci1", c->second.getShortInfo() ); output << c->second.getShortInfo() << Endl; } output << "// end_message" << Endl; output << ends; // Restart all suspended threads; in reverse order. set<ThreadID>::reverse_iterator susIter; const set<ThreadID>::reverse_iterator stre = SuspendedThreads.rend(); for (susIter = SuspendedThreads.rbegin(); susIter != stre; ++susIter) { CALL(ResumeThread(*susIter)); unsafe_debug("Resumed", *susIter); } //if(false) CALL(EnableGC()); Unlock(output_lock); Unlock(methods_lock); Unlock(threads_lock); //return; Lock(output_lock); const int chunk = 1024; const string s = output.str(); const char* cp = s.c_str(); // send in tiny chunks RecordPacket(info.size() + s.size()); Send(info); for (string::size_type p = 0; p < (s.size()/chunk); p++) { Send(cp, chunk); cp += chunk; } Send(cp, strlen(cp)); Unlock(output_lock); LeaveRelease; unsafe_debug("perf ", ""); unsafe_debug("perf classes to send count", classes_to_send.size()); unsafe_debug("perf Classes", Classes.size()); unsafe_debug("perf ClassesCache", ClassCache.size()); unsafe_debug("perf methods to send count", methods_to_send.size()); unsafe_debug("perf MethodsCache = ", MethodCache.size()); unsafe_debug("perf Methods = ", Methods.size()); ofstream outtrace("network.txt"); outtrace << info << s << endl; debug("message", s.size()); debug(s); }

---

Variable Documentation

bool HotSpot

provides workaround for threading issue. Definition at line 43 of file threads.h.

---