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

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
« no previous file with comments | « runtime/vm/profiler.cc ('k') | runtime/vm/thread_interrupter.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 class InterruptableThreadState {
35 public:
36 ThreadId id;
37 ThreadInterruptCallback callback;
38 void* data;
39 };
40
33 class ThreadInterrupter : public AllStatic { 41 class ThreadInterrupter : public AllStatic {
34 public: 42 public:
35 static void InitOnce(); 43 static void InitOnce();
44
45 static void Startup();
36 static void Shutdown(); 46 static void Shutdown();
37 47
38 // Delay between interrupts. 48 // Delay between interrupts.
39 static void SetInterruptPeriod(intptr_t period); 49 static void SetInterruptPeriod(intptr_t period);
40 50
41 // Register the currently running thread for interrupts. If the current thread 51 // Register the currently running thread for interrupts. If the current thread
42 // is already registered, callback and data will be updated. 52 // is already registered, callback and data will be updated.
43 static void Register(ThreadInterruptCallback callback, void* data); 53 static InterruptableThreadState* Register(ThreadInterruptCallback callback,
54 void* data);
44 // Unregister the currently running thread for interrupts. 55 // Unregister the currently running thread for interrupts.
45 static void Unregister(); 56 static void Unregister();
46 57
47 // Enable interrupts for this thread. Does not alter callback. 58 // Get the current thread state. Will create a thread state if one hasn't
48 static void Enable(); 59 // been allocated.
49 // Disable interrupts for this thread. Does not alter callback. 60 static InterruptableThreadState* GetCurrentThreadState();
50 static void Disable(); 61 // Get the current thread state. Will not create one if one doesn't exist.
62 static InterruptableThreadState* CurrentThreadState();
51 63
52 private: 64 private:
53 static const intptr_t kMaxThreads = 4096; 65 static const intptr_t kMaxThreads = 4096;
54 static bool initialized_; 66 static bool initialized_;
55 static bool shutdown_; 67 static bool shutdown_;
56 static bool thread_running_; 68 static bool thread_running_;
57 static ThreadId interrupter_thread_id_; 69 static ThreadId interrupter_thread_id_;
58 static Monitor* monitor_; 70 static Monitor* monitor_;
59 static intptr_t interrupt_period_; 71 static intptr_t interrupt_period_;
60 static ThreadLocalKey thread_state_key_; 72 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 73
74 static InterruptableThreadState* _EnsureThreadStateCreated();
68 static void UpdateStateObject(ThreadInterruptCallback callback, void* data); 75 static void UpdateStateObject(ThreadInterruptCallback callback, void* data);
69 static ThreadState* CurrentThreadState();
70 static void SetCurrentThreadState(ThreadState* state);
71 76
72 // Registered thread table. 77 static void SetCurrentThreadState(InterruptableThreadState* state);
73 static ThreadState** threads_;
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 78
84 friend class ThreadInterrupterAndroid; 79 static void InterruptThread(InterruptableThreadState* thread_state);
85 friend class ThreadInterrupterMacOS;
86 friend class ThreadInterrupterLinux;
87 friend class ThreadInterrupterWin;
88
89 static void InterruptThreads(int64_t current_time);
90 static void ThreadMain(uword parameters); 80 static void ThreadMain(uword parameters);
91 81
92 static void InstallSignalHandler(); 82 static void InstallSignalHandler();
83
84 friend class ThreadInterrupterVisitIsolates;
93 }; 85 };
94 86
95 void ThreadInterruptNoOp(const InterruptedThreadState& state, void* data); 87 void ThreadInterruptNoOp(const InterruptedThreadState& state, void* data);
96 88
97 } // namespace dart 89 } // namespace dart
98 90
99 #endif // VM_THREAD_INTERRUPTER_H_ 91 #endif // VM_THREAD_INTERRUPTER_H_
OLDNEW
« no previous file with comments | « runtime/vm/profiler.cc ('k') | runtime/vm/thread_interrupter.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698