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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
|
#include "ruby.h"
#include "ruby/debug.h"
// We're testing deprecated things, don't print the compiler warnings
#if 0
#elif defined(_MSC_VER)
#pragma warning(disable : 4996)
#elif defined(__INTEL_COMPILER)
#pragma warning(disable : 1786)
#elif defined(__clang__)
#pragma clang diagnostic ignored "-Wdeprecated-declarations"
#elif defined(__GNUC__)
#pragma GCC diagnostic ignored "-Wdeprecated-declarations"
#elif defined(__SUNPRO_CC)
#pragma error_messages (off,symdeprecated)
#else
// :FIXME: improve here for your compiler.
#endif
static int counter;
static void
pjob_callback(void *data)
{
VALUE ary = (VALUE)data;
Check_Type(ary, T_ARRAY);
rb_ary_push(ary, INT2FIX(counter));
}
static VALUE
pjob_register(VALUE self, VALUE obj)
{
counter = 0;
rb_postponed_job_register(0, pjob_callback, (void *)obj);
rb_gc_start();
counter++;
rb_gc_start();
counter++;
rb_gc_start();
counter++;
return self;
}
static void
pjob_one_callback(void *data)
{
VALUE ary = (VALUE)data;
Check_Type(ary, T_ARRAY);
rb_ary_push(ary, INT2FIX(1));
}
static VALUE
pjob_register_one(VALUE self, VALUE obj)
{
rb_postponed_job_register_one(0, pjob_one_callback, (void *)obj);
rb_postponed_job_register_one(0, pjob_one_callback, (void *)obj);
rb_postponed_job_register_one(0, pjob_one_callback, (void *)obj);
return self;
}
static VALUE
pjob_call_direct(VALUE self, VALUE obj)
{
counter = 0;
pjob_callback((void *)obj);
rb_gc_start();
counter++;
rb_gc_start();
counter++;
rb_gc_start();
counter++;
return self;
}
static void pjob_noop_callback(void *data) { }
static VALUE
pjob_register_one_same(VALUE self)
{
rb_gc_start();
int r1 = rb_postponed_job_register_one(0, pjob_noop_callback, NULL);
int r2 = rb_postponed_job_register_one(0, pjob_noop_callback, NULL);
int r3 = rb_postponed_job_register_one(0, pjob_noop_callback, NULL);
VALUE ary = rb_ary_new();
rb_ary_push(ary, INT2FIX(r1));
rb_ary_push(ary, INT2FIX(r2));
rb_ary_push(ary, INT2FIX(r3));
return ary;
}
#ifdef HAVE_PTHREAD_H
#include <pthread.h>
static void *
pjob_register_in_c_thread_i(void *obj)
{
rb_postponed_job_register_one(0, pjob_one_callback, (void *)obj);
rb_postponed_job_register_one(0, pjob_one_callback, (void *)obj);
rb_postponed_job_register_one(0, pjob_one_callback, (void *)obj);
return NULL;
}
static VALUE
pjob_register_in_c_thread(VALUE self, VALUE obj)
{
pthread_t thread;
if (pthread_create(&thread, NULL, pjob_register_in_c_thread_i, (void *)obj)) {
return Qfalse;
}
if (pthread_join(thread, NULL)) {
return Qfalse;
}
return Qtrue;
}
#endif
static void
pjob_preregistered_callback(void *data)
{
VALUE ary = (VALUE)data;
Check_Type(ary, T_ARRAY);
rb_ary_push(ary, INT2FIX(counter));
}
static VALUE
pjob_preregister_and_call_with_sleep(VALUE self, VALUE obj)
{
counter = 0;
rb_postponed_job_handle_t h = rb_postponed_job_preregister(0, pjob_preregistered_callback, (void *)obj);
counter++;
rb_postponed_job_trigger(h);
rb_thread_sleep(0);
counter++;
rb_postponed_job_trigger(h);
rb_thread_sleep(0);
counter++;
rb_postponed_job_trigger(h);
rb_thread_sleep(0);
return self;
}
static VALUE
pjob_preregister_and_call_without_sleep(VALUE self, VALUE obj)
{
counter = 0;
rb_postponed_job_handle_t h = rb_postponed_job_preregister(0, pjob_preregistered_callback, (void *)obj);
counter = 3;
rb_postponed_job_trigger(h);
rb_postponed_job_trigger(h);
rb_postponed_job_trigger(h);
return self;
}
static VALUE
pjob_preregister_multiple_times(VALUE self)
{
int r1 = rb_postponed_job_preregister(0, pjob_noop_callback, NULL);
int r2 = rb_postponed_job_preregister(0, pjob_noop_callback, NULL);
int r3 = rb_postponed_job_preregister(0, pjob_noop_callback, NULL);
VALUE ary = rb_ary_new();
rb_ary_push(ary, INT2FIX(r1));
rb_ary_push(ary, INT2FIX(r2));
rb_ary_push(ary, INT2FIX(r3));
return ary;
}
struct pjob_append_data_args {
VALUE ary;
VALUE data;
};
static void
pjob_append_data_callback(void *vctx) {
struct pjob_append_data_args *ctx = (struct pjob_append_data_args *)vctx;
Check_Type(ctx->ary, T_ARRAY);
rb_ary_push(ctx->ary, ctx->data);
}
static VALUE
pjob_preregister_calls_with_last_argument(VALUE self)
{
VALUE ary = rb_ary_new();
struct pjob_append_data_args arg1 = { .ary = ary, .data = INT2FIX(1) };
struct pjob_append_data_args arg2 = { .ary = ary, .data = INT2FIX(2) };
struct pjob_append_data_args arg3 = { .ary = ary, .data = INT2FIX(3) };
struct pjob_append_data_args arg4 = { .ary = ary, .data = INT2FIX(4) };
rb_postponed_job_handle_t h;
h = rb_postponed_job_preregister(0, pjob_append_data_callback, &arg1);
rb_postponed_job_preregister(0, pjob_append_data_callback, &arg2);
rb_postponed_job_trigger(h);
rb_postponed_job_preregister(0, pjob_append_data_callback, &arg3);
rb_thread_sleep(0); // should execute with arg3
rb_postponed_job_preregister(0, pjob_append_data_callback, &arg4);
rb_postponed_job_trigger(h);
rb_thread_sleep(0); // should execute with arg4
return ary;
}
void
Init_postponed_job(VALUE self)
{
VALUE mBug = rb_define_module("Bug");
rb_define_module_function(mBug, "postponed_job_register", pjob_register, 1);
rb_define_module_function(mBug, "postponed_job_register_one", pjob_register_one, 1);
rb_define_module_function(mBug, "postponed_job_call_direct", pjob_call_direct, 1);
rb_define_module_function(mBug, "postponed_job_register_one_same", pjob_register_one_same, 0);
#ifdef HAVE_PTHREAD_H
rb_define_module_function(mBug, "postponed_job_register_in_c_thread", pjob_register_in_c_thread, 1);
#endif
rb_define_module_function(mBug, "postponed_job_preregister_and_call_with_sleep", pjob_preregister_and_call_with_sleep, 1);
rb_define_module_function(mBug, "postponed_job_preregister_and_call_without_sleep", pjob_preregister_and_call_without_sleep, 1);
rb_define_module_function(mBug, "postponed_job_preregister_multiple_times", pjob_preregister_multiple_times, 0);
rb_define_module_function(mBug, "postponed_job_preregister_calls_with_last_argument", pjob_preregister_calls_with_last_argument, 0);
}
|
