1
2/*--------------------------------------------------------------------*/
3/*--- The thread state.                            m_threadstate.c ---*/
4/*--------------------------------------------------------------------*/
5
6/*
7   This file is part of Valgrind, a dynamic binary instrumentation
8   framework.
9
10   Copyright (C) 2000-2010 Julian Seward
11      jseward@acm.org
12
13   This program is free software; you can redistribute it and/or
14   modify it under the terms of the GNU General Public License as
15   published by the Free Software Foundation; either version 2 of the
16   License, or (at your option) any later version.
17
18   This program is distributed in the hope that it will be useful, but
19   WITHOUT ANY WARRANTY; without even the implied warranty of
20   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
21   General Public License for more details.
22
23   You should have received a copy of the GNU General Public License
24   along with this program; if not, write to the Free Software
25   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
26   02111-1307, USA.
27
28   The GNU General Public License is contained in the file COPYING.
29*/
30
31#include "pub_core_basics.h"
32#include "pub_core_vki.h"
33#include "pub_core_threadstate.h"
34#include "pub_core_libcassert.h"
35
36/*------------------------------------------------------------*/
37/*--- Data structures.                                     ---*/
38/*------------------------------------------------------------*/
39
40ThreadId VG_(running_tid) = VG_INVALID_THREADID;
41
42ThreadState VG_(threads)[VG_N_THREADS];
43
44/*------------------------------------------------------------*/
45/*--- Operations.                                          ---*/
46/*------------------------------------------------------------*/
47
48const HChar* VG_(name_of_ThreadStatus) ( ThreadStatus status )
49{
50   switch (status) {
51   case VgTs_Empty:     return "VgTs_Empty";
52   case VgTs_Init:      return "VgTs_Init";
53   case VgTs_Runnable:  return "VgTs_Runnable";
54   case VgTs_WaitSys:   return "VgTs_WaitSys";
55   case VgTs_Yielding:  return "VgTs_Yielding";
56   case VgTs_Zombie:    return "VgTs_Zombie";
57   default:             return "VgTs_???";
58  }
59}
60
61ThreadState *VG_(get_ThreadState)(ThreadId tid)
62{
63   vg_assert(tid >= 0 && tid < VG_N_THREADS);
64   vg_assert(VG_(threads)[tid].tid == tid);
65   return &VG_(threads)[tid];
66}
67
68Bool VG_(is_valid_tid) ( ThreadId tid )
69{
70   /* tid is unsigned, hence no < 0 test. */
71   if (tid == 0) return False;
72   if (tid >= VG_N_THREADS) return False;
73   if (VG_(threads)[tid].status == VgTs_Empty) return False;
74   return True;
75}
76
77// This function is for tools to call.
78ThreadId VG_(get_running_tid)(void)
79{
80   return VG_(running_tid);
81}
82
83Bool VG_(is_running_thread)(ThreadId tid)
84{
85   ThreadState *tst = VG_(get_ThreadState)(tid);
86
87   return
88//      tst->os_state.lwpid == VG_(gettid)() &&	// check we're this tid
89      VG_(running_tid) == tid	           &&	// and that we've got the lock
90      tst->status == VgTs_Runnable;		// and we're runnable
91}
92
93/* Return true if the thread is still alive but in the process of exiting. */
94inline Bool VG_(is_exiting)(ThreadId tid)
95{
96   vg_assert(VG_(is_valid_tid)(tid));
97   return VG_(threads)[tid].exitreason != VgSrc_None;
98}
99
100/* Return the number of non-dead Threads */
101Int VG_(count_living_threads)(void)
102{
103   Int count = 0;
104   ThreadId tid;
105
106   for(tid = 1; tid < VG_N_THREADS; tid++)
107      if (VG_(threads)[tid].status != VgTs_Empty &&
108	  VG_(threads)[tid].status != VgTs_Zombie)
109	 count++;
110
111   return count;
112}
113
114/* Return the number of threads in VgTs_Runnable state */
115Int VG_(count_runnable_threads)(void)
116{
117   Int count = 0;
118   ThreadId tid;
119
120   for(tid = 1; tid < VG_N_THREADS; tid++)
121      if (VG_(threads)[tid].status == VgTs_Runnable)
122	 count++;
123
124   return count;
125}
126
127/* Given an LWP id (ie, real kernel thread id), find the corresponding
128   ThreadId */
129ThreadId VG_(lwpid_to_vgtid)(Int lwp)
130{
131   ThreadId tid;
132
133   for(tid = 1; tid < VG_N_THREADS; tid++)
134      if (VG_(threads)[tid].status != VgTs_Empty
135          && VG_(threads)[tid].os_state.lwpid == lwp)
136	 return tid;
137
138   return VG_INVALID_THREADID;
139}
140
141/*--------------------------------------------------------------------*/
142/*--- end                                                          ---*/
143/*--------------------------------------------------------------------*/
144