Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(59)

Side by Side Diff: runtime/vm/thread_interrupter.h

Issue 128653004: Use list of isolates in profiler (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 6 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 #ifndef VM_THREAD_INTERRUPTER_H_ 5 #ifndef VM_THREAD_INTERRUPTER_H_
6 #define VM_THREAD_INTERRUPTER_H_ 6 #define VM_THREAD_INTERRUPTER_H_
7 7
8 #include "vm/allocation.h" 8 #include "vm/allocation.h"
9 #include "vm/signal_handler.h" 9 #include "vm/signal_handler.h"
10 #include "vm/thread.h" 10 #include "vm/thread.h"
(...skipping 12 matching lines...) Expand all
23 // callback will be invoked at the interrupt period. Each callback is given an 23 // callback will be invoked at the interrupt period. Each callback is given an
24 // InterruptedThreadState and the thread specific data pointer. When inside a 24 // InterruptedThreadState and the thread specific data pointer. When inside a
25 // thread interrupt callback doing any of the following 25 // thread interrupt callback doing any of the following
26 // is forbidden: 26 // is forbidden:
27 // * Accessing TLS. 27 // * Accessing TLS.
28 // * Allocating memory. 28 // * Allocating memory.
29 // * Taking a lock. 29 // * Taking a lock.
30 typedef void (*ThreadInterruptCallback)(const InterruptedThreadState& state, 30 typedef void (*ThreadInterruptCallback)(const InterruptedThreadState& state,
31 void* data); 31 void* data);
32 32
33 // State stored per registered thread.
34 struct InterruptableThreadState {
35 ThreadId id;
36 ThreadInterruptCallback callback;
37 void* data;
38 };
39
33 class ThreadInterrupter : public AllStatic { 40 class ThreadInterrupter : public AllStatic {
34 public: 41 public:
35 static void InitOnce(); 42 static void InitOnce();
43
44 static void Startup();
36 static void Shutdown(); 45 static void Shutdown();
37 46
38 // Delay between interrupts. 47 // Delay between interrupts.
39 static void SetInterruptPeriod(intptr_t period); 48 static void SetInterruptPeriod(intptr_t period);
40 49
41 // Register the currently running thread for interrupts. If the current thread 50 // Register the currently running thread for interrupts. If the current thread
42 // is already registered, callback and data will be updated. 51 // is already registered, callback and data will be updated.
43 static void Register(ThreadInterruptCallback callback, void* data); 52 static InterruptableThreadState* Register(ThreadInterruptCallback callback,
53 void* data);
44 // Unregister the currently running thread for interrupts. 54 // Unregister the currently running thread for interrupts.
45 static void Unregister(); 55 static void Unregister();
46 56
47 // Enable interrupts for this thread. Does not alter callback. 57 static InterruptableThreadState* GetCurrentThreadState();
48 static void Enable();
49 // Disable interrupts for this thread. Does not alter callback.
50 static void Disable();
51 58
52 private: 59 private:
53 static const intptr_t kMaxThreads = 4096; 60 static const intptr_t kMaxThreads = 4096;
54 static bool initialized_; 61 static bool initialized_;
55 static bool shutdown_; 62 static bool shutdown_;
56 static bool thread_running_; 63 static bool thread_running_;
57 static ThreadId interrupter_thread_id_; 64 static ThreadId interrupter_thread_id_;
58 static Monitor* monitor_; 65 static Monitor* monitor_;
59 static intptr_t interrupt_period_; 66 static intptr_t interrupt_period_;
60 static ThreadLocalKey thread_state_key_; 67 static ThreadLocalKey thread_state_key_;
61 // State stored per registered thread.
62 struct ThreadState {
63 ThreadId id;
64 ThreadInterruptCallback callback;
65 void* data;
66 };
67 68
69 static InterruptableThreadState* _EnsureThreadStateCreated();
68 static void UpdateStateObject(ThreadInterruptCallback callback, void* data); 70 static void UpdateStateObject(ThreadInterruptCallback callback, void* data);
69 static ThreadState* CurrentThreadState(); 71 static InterruptableThreadState* CurrentThreadState();
70 static void SetCurrentThreadState(ThreadState* state); 72 static void SetCurrentThreadState(InterruptableThreadState* state);
71 73
72 // Registered thread table. 74 static void InterruptThread(InterruptableThreadState* thread_state);
73 static ThreadState** threads_; 75 static void ThreadMain(uword parameters);
74 static intptr_t threads_capacity_;
75 static intptr_t threads_size_;
76 static void _EnsureThreadStateCreated();
77 static void _Enable();
78 static void _Disable();
79 static void ResizeThreads(intptr_t new_capacity);
80 static void AddThread(ThreadId id);
81 static intptr_t FindThreadIndex(ThreadId id);
82 static ThreadState* RemoveThread(intptr_t i);
83 76
77 friend class ThreadInterrupterVisitIsolates;
84 friend class ThreadInterrupterAndroid; 78 friend class ThreadInterrupterAndroid;
79 friend class ThreadInterrupterLinux;
85 friend class ThreadInterrupterMacOS; 80 friend class ThreadInterrupterMacOS;
86 friend class ThreadInterrupterLinux;
87 friend class ThreadInterrupterWin; 81 friend class ThreadInterrupterWin;
siva 2014/02/06 00:37:24 Do these OS specific classes need to be friends he
Cutch 2014/02/06 17:51:51 Done.
88 82
89 static void InterruptThreads(int64_t current_time);
90 static void ThreadMain(uword parameters);
91
92 static void InstallSignalHandler(); 83 static void InstallSignalHandler();
93 }; 84 };
94 85
95 void ThreadInterruptNoOp(const InterruptedThreadState& state, void* data); 86 void ThreadInterruptNoOp(const InterruptedThreadState& state, void* data);
96 87
97 } // namespace dart 88 } // namespace dart
98 89
99 #endif // VM_THREAD_INTERRUPTER_H_ 90 #endif // VM_THREAD_INTERRUPTER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698