ThreadImpl.cs

Go to the documentation of this file.

/*
  Copyright (C) 2011-2014 Jeroen Frijters
 
  This software is provided 'as-is', without any express or implied
  warranty.  In no event will the authors be held liable for any damages
  arising from the use of this software.
 
  Permission is granted to anyone to use this software for any purpose,
  including commercial applications, and to alter it and redistribute it
  freely, subject to the following restrictions:
 
  1. The origin of this software must not be misrepresented; you must not
     claim that you wrote the original software. If you use this software
     in a product, an acknowledgment in the product documentation would be
     appreciated but is not required.
  2. Altered source versions must be plainly marked as such, and must not be
     misrepresented as being the original software.
  3. This notice may not be removed or altered from any source distribution.
 
  Jeroen Frijters
  jeroen@frijters.net
  
*/
 
namespace IKVM.Java.Externs.sun.management
{
 
    static class ThreadImpl
    {
 
        public static object getThreads()
        {
            return IKVM.Java.Externs.java.lang.Thread.getThreads();
        }
 
        private const int JVMTI_THREAD_STATE_ALIVE = 0x0001;
        private const int JVMTI_THREAD_STATE_TERMINATED = 0x0002;
        private const int JVMTI_THREAD_STATE_RUNNABLE = 0x0004;
        private const int JVMTI_THREAD_STATE_BLOCKED_ON_MONITOR_ENTER = 0x0400;
        private const int JVMTI_THREAD_STATE_WAITING_INDEFINITELY = 0x0010;
        private const int JVMTI_THREAD_STATE_WAITING_WITH_TIMEOUT = 0x0020;
        private const int JMM_THREAD_STATE_FLAG_SUSPENDED = 0x00100000;
        private const int JMM_THREAD_STATE_FLAG_NATIVE = 0x00400000;
 
        public static void getThreadInfo1(long[] ids, int maxDepth, object result)
        {
#if !FIRST_PASS
            System.Reflection.ConstructorInfo[] constructors = typeof(global::java.lang.management.ThreadInfo).GetConstructors(System.Reflection.BindingFlags.Instance | System.Reflection.BindingFlags.NonPublic);
            foreach (System.Reflection.ConstructorInfo constructor in constructors)
            {
                if (constructor.GetParameters().Length == 9)
                {
                    global::java.lang.Thread[] threads = (global::java.lang.Thread[])getThreads();
                    global::java.lang.management.ThreadInfo[] threadInfos = (global::java.lang.management.ThreadInfo[])result;
                    for (int i = 0; i < ids.Length; i++)
                    {
                        long id = ids[i];
                        for (int t = 0; t < threads.Length; t++)
                        {
                            if (threads[t].getId() == id)
                            {
                                global::java.lang.Thread thread = threads[t];
 
                                int state;
                                // invers to sun.misc.VM.toThreadState
                                switch (thread.getState().ordinal())
                                {
                                    case (int)global::java.lang.Thread.State.__Enum.RUNNABLE:
                                        state = JVMTI_THREAD_STATE_RUNNABLE;
                                        break;
                                    case (int)global::java.lang.Thread.State.__Enum.BLOCKED:
                                        state = JVMTI_THREAD_STATE_BLOCKED_ON_MONITOR_ENTER;
                                        break;
                                    case (int)global::java.lang.Thread.State.__Enum.WAITING:
                                        state = JVMTI_THREAD_STATE_WAITING_INDEFINITELY;
                                        break;
                                    case (int)global::java.lang.Thread.State.__Enum.TIMED_WAITING:
                                        state = JVMTI_THREAD_STATE_WAITING_WITH_TIMEOUT;
                                        break;
                                    case (int)global::java.lang.Thread.State.__Enum.TERMINATED:
                                        state = JVMTI_THREAD_STATE_TERMINATED;
                                        break;
                                    case (int)global::java.lang.Thread.State.__Enum.NEW:
                                        state = JVMTI_THREAD_STATE_ALIVE;
                                        break;
                                    default:
                                        state = 0;
                                        break;
                                }
                                //TODO set in state JMM_THREAD_STATE_FLAG_SUSPENDED if the thread is suspended
 
                                global::java.lang.StackTraceElement[] stacktrace = thread.getStackTrace();
                                if (maxDepth >= 0 && maxDepth < stacktrace.Length)
                                {
                                    global::java.lang.StackTraceElement[] temp = new global::java.lang.StackTraceElement[maxDepth];
                                    System.Array.Copy(stacktrace, temp, temp.Length);
                                    stacktrace = temp;
                                }
 
                                object[] parameters = new object[9];
                                parameters[0] = thread;                     // thread
                                parameters[1] = state;                      // state
                                                                            // lockObj
                                                                            // lockOwner
                                parameters[4] = 0;                          // blockedCount
                                parameters[5] = 0;                          // blockedTime
                                parameters[6] = -1;                         // waitedCount
                                parameters[7] = 0;                          // waitedTime
                                parameters[8] = stacktrace;                 // stackTrace
                                threadInfos[i] = (global::java.lang.management.ThreadInfo)constructor.Invoke(parameters);
                                break;
                            }
                        }
                    }
                    return;
                }
            }
            throw new global::java.lang.InternalError("Constructor for java.lang.management.ThreadInfo not find.");
#endif
        }
 
        private static int GetCurrentThreadId()
        {
#pragma warning disable 618
            // On the CLR and Mono on Windows this is the (obsolete) equivalent of kernel32!GetCurrentThreadId
            return System.AppDomain.GetCurrentThreadId();
#pragma warning restore 618
        }
 
        public static long getThreadTotalCpuTime0(long id)
        {
            if (id == 0)
            {
                int currentId = GetCurrentThreadId();
                System.Diagnostics.ProcessThreadCollection threads = System.Diagnostics.Process.GetCurrentProcess().Threads;
                foreach (System.Diagnostics.ProcessThread t in threads)
                {
                    if (t.Id == currentId)
                    {
                        return (long)(t.TotalProcessorTime.Ticks * 100);
                    }
                }
                return 0;
            }
            else
            {
                throw new System.NotImplementedException("Only current Thread is supported.");
            }
        }
 
        public static void getThreadTotalCpuTime1(long[] ids, long[] result)
        {
            throw new System.NotImplementedException();
        }
 
        public static long getThreadUserCpuTime0(long id)
        {
            throw new System.NotImplementedException();
        }
 
        public static void getThreadUserCpuTime1(long[] ids, long[] result)
        {
            throw new System.NotImplementedException();
        }
 
        public static void getThreadAllocatedMemory1(long[] ids, long[] result)
        {
            throw new System.NotImplementedException();
        }
 
        public static void setThreadCpuTimeEnabled0(bool enable)
        {
            //ignoring, we need nothing to enable
        }
 
        public static void setThreadAllocatedMemoryEnabled0(bool enable)
        {
            throw new System.NotImplementedException();
        }
 
        public static void setThreadContentionMonitoringEnabled0(bool enable)
        {
            throw new System.NotImplementedException();
        }
 
        public static object findMonitorDeadlockedThreads0()
        {
            throw new System.NotImplementedException();
        }
 
        public static object findDeadlockedThreads0()
        {
            throw new System.NotImplementedException();
        }
 
        public static void resetPeakThreadCount0()
        {
            throw new System.NotImplementedException();
        }
 
        public static object dumpThreads0(long[] ids, bool lockedMonitors, bool lockedSynchronizers)
        {
            throw new System.NotImplementedException();
        }
 
        public static void resetContentionTimes0(long tid)
        {
            throw new System.NotImplementedException();
        }
 
    }
 
}