blob: f60987acae5597596d319e3056de718fc2418c52 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
// -*- c++ -*-
#ifndef RUST_KERNEL_H
#define RUST_KERNEL_H
#include "memory_region.h"
#include "rust_log.h"
struct rust_scheduler;
/**
* A global object shared by all thread domains. Most of the data structures
* in this class are synchronized since they are accessed from multiple
* threads.
*/
class rust_kernel {
memory_region _region;
rust_log _log;
public:
rust_srv *srv;
private:
lock_and_signal _kernel_lock;
array_list<rust_scheduler *> threads;
randctx rctx;
rust_scheduler *create_scheduler(int id);
void destroy_scheduler(rust_scheduler *sched);
void create_schedulers();
void destroy_schedulers();
rust_task_id max_id;
hash_map<rust_task_id, rust_task *> task_table;
int rval;
public:
const size_t num_threads;
volatile int live_tasks;
struct rust_env *env;
rust_kernel(rust_srv *srv, size_t num_threads);
bool is_deadlocked();
void signal_kernel_lock();
void wakeup_schedulers();
void log_all_scheduler_state();
void log(uint32_t level, char const *fmt, ...);
void fatal(char const *fmt, ...);
virtual ~rust_kernel();
void *malloc(size_t size, const char *tag);
void *realloc(void *mem, size_t size);
void free(void *mem);
void fail();
int start_task_threads();
#ifdef __WIN32__
void win32_require(LPCTSTR fn, BOOL ok);
#endif
rust_task_id create_task(rust_task *spawner, const char *name);
rust_task *get_task_by_id(rust_task_id id);
void release_task_id(rust_task_id tid);
void set_exit_status(int code);
};
#endif /* RUST_KERNEL_H */
|
