7 #include <cdsannotate.h>
8 #include <specannotation.h>
9 #include <model_memory.h>
14 #define RW_LOCK_BIAS 0x00100000
15 #define WRITE_LOCK_CMP RW_LOCK_BIAS
27 /* All other user-defined structs */
28 static bool writer_lock_acquired;
29 static int reader_lock_cnt;
30 /* All other user-defined functions */
31 /* Definition of interface info struct: Write_Trylock */
32 typedef struct Write_Trylock_info {
36 /* End of info struct definition: Write_Trylock */
38 /* ID function of interface: Write_Trylock */
39 inline static call_id_t Write_Trylock_id(void *info, thread_id_t __TID__) {
40 Write_Trylock_info* theInfo = (Write_Trylock_info*)info;
41 int __RET__ = theInfo->__RET__;
42 rwlock_t * rw = theInfo->rw;
47 /* End of ID function: Write_Trylock */
49 /* Check action function of interface: Write_Trylock */
50 inline static bool Write_Trylock_check_action(void *info, call_id_t __ID__, thread_id_t __TID__) {
52 Write_Trylock_info* theInfo = (Write_Trylock_info*)info;
53 int __RET__ = theInfo->__RET__;
54 rwlock_t * rw = theInfo->rw;
56 if ( __RET__ == 1 ) writer_lock_acquired = true ;
59 /* End of check action function: Write_Trylock */
61 /* Definition of interface info struct: Read_Trylock */
62 typedef struct Read_Trylock_info {
66 /* End of info struct definition: Read_Trylock */
68 /* ID function of interface: Read_Trylock */
69 inline static call_id_t Read_Trylock_id(void *info, thread_id_t __TID__) {
70 Read_Trylock_info* theInfo = (Read_Trylock_info*)info;
71 int __RET__ = theInfo->__RET__;
72 rwlock_t * rw = theInfo->rw;
77 /* End of ID function: Read_Trylock */
79 /* Check action function of interface: Read_Trylock */
80 inline static bool Read_Trylock_check_action(void *info, call_id_t __ID__, thread_id_t __TID__) {
82 Read_Trylock_info* theInfo = (Read_Trylock_info*)info;
83 int __RET__ = theInfo->__RET__;
84 rwlock_t * rw = theInfo->rw;
86 if ( __RET__ ) reader_lock_cnt ++ ;
87 check_passed = __RET__ == ! writer_lock_acquired || ! __RET__;
92 /* End of check action function: Read_Trylock */
94 /* Definition of interface info struct: Write_Lock */
95 typedef struct Write_Lock_info {
98 /* End of info struct definition: Write_Lock */
100 /* ID function of interface: Write_Lock */
101 inline static call_id_t Write_Lock_id(void *info, thread_id_t __TID__) {
102 Write_Lock_info* theInfo = (Write_Lock_info*)info;
103 rwlock_t * rw = theInfo->rw;
105 call_id_t __ID__ = 0;
108 /* End of ID function: Write_Lock */
110 /* Check action function of interface: Write_Lock */
111 inline static bool Write_Lock_check_action(void *info, call_id_t __ID__, thread_id_t __TID__) {
113 Write_Lock_info* theInfo = (Write_Lock_info*)info;
114 rwlock_t * rw = theInfo->rw;
116 check_passed = ! writer_lock_acquired && reader_lock_cnt == 0;
119 writer_lock_acquired = true ;
122 /* End of check action function: Write_Lock */
124 /* Definition of interface info struct: Write_Unlock */
125 typedef struct Write_Unlock_info {
128 /* End of info struct definition: Write_Unlock */
130 /* ID function of interface: Write_Unlock */
131 inline static call_id_t Write_Unlock_id(void *info, thread_id_t __TID__) {
132 Write_Unlock_info* theInfo = (Write_Unlock_info*)info;
133 rwlock_t * rw = theInfo->rw;
135 call_id_t __ID__ = 0;
138 /* End of ID function: Write_Unlock */
140 /* Check action function of interface: Write_Unlock */
141 inline static bool Write_Unlock_check_action(void *info, call_id_t __ID__, thread_id_t __TID__) {
143 Write_Unlock_info* theInfo = (Write_Unlock_info*)info;
144 rwlock_t * rw = theInfo->rw;
146 check_passed = reader_lock_cnt == 0 && writer_lock_acquired;
149 writer_lock_acquired = false ;
152 /* End of check action function: Write_Unlock */
154 /* Definition of interface info struct: Read_Unlock */
155 typedef struct Read_Unlock_info {
158 /* End of info struct definition: Read_Unlock */
160 /* ID function of interface: Read_Unlock */
161 inline static call_id_t Read_Unlock_id(void *info, thread_id_t __TID__) {
162 Read_Unlock_info* theInfo = (Read_Unlock_info*)info;
163 rwlock_t * rw = theInfo->rw;
165 call_id_t __ID__ = 0;
168 /* End of ID function: Read_Unlock */
170 /* Check action function of interface: Read_Unlock */
171 inline static bool Read_Unlock_check_action(void *info, call_id_t __ID__, thread_id_t __TID__) {
173 Read_Unlock_info* theInfo = (Read_Unlock_info*)info;
174 rwlock_t * rw = theInfo->rw;
176 check_passed = reader_lock_cnt > 0 && ! writer_lock_acquired;
182 /* End of check action function: Read_Unlock */
184 /* Definition of interface info struct: Read_Lock */
185 typedef struct Read_Lock_info {
188 /* End of info struct definition: Read_Lock */
190 /* ID function of interface: Read_Lock */
191 inline static call_id_t Read_Lock_id(void *info, thread_id_t __TID__) {
192 Read_Lock_info* theInfo = (Read_Lock_info*)info;
193 rwlock_t * rw = theInfo->rw;
195 call_id_t __ID__ = 0;
198 /* End of ID function: Read_Lock */
200 /* Check action function of interface: Read_Lock */
201 inline static bool Read_Lock_check_action(void *info, call_id_t __ID__, thread_id_t __TID__) {
203 Read_Lock_info* theInfo = (Read_Lock_info*)info;
204 rwlock_t * rw = theInfo->rw;
206 check_passed = ! writer_lock_acquired;
212 /* End of check action function: Read_Lock */
214 #define INTERFACE_SIZE 6
215 static void** func_ptr_table;
216 static hb_rule** hb_rule_table;
217 static commutativity_rule** commutativity_rule_table;
218 inline static bool CommutativityCondition0(void *info1, void *info2) {
219 Read_Lock_info *_info1 = (Read_Lock_info*) info1;
220 Read_Lock_info *_info2 = (Read_Lock_info*) info2;
223 inline static bool CommutativityCondition1(void *info1, void *info2) {
224 Read_Lock_info *_info1 = (Read_Lock_info*) info1;
225 Read_Unlock_info *_info2 = (Read_Unlock_info*) info2;
228 inline static bool CommutativityCondition2(void *info1, void *info2) {
229 Read_Lock_info *_info1 = (Read_Lock_info*) info1;
230 Read_Trylock_info *_info2 = (Read_Trylock_info*) info2;
233 inline static bool CommutativityCondition3(void *info1, void *info2) {
234 Read_Lock_info *_info1 = (Read_Lock_info*) info1;
235 Write_Trylock_info *_info2 = (Write_Trylock_info*) info2;
236 return ! _info2-> __RET__;
238 inline static bool CommutativityCondition4(void *info1, void *info2) {
239 Read_Unlock_info *_info1 = (Read_Unlock_info*) info1;
240 Read_Unlock_info *_info2 = (Read_Unlock_info*) info2;
243 inline static bool CommutativityCondition5(void *info1, void *info2) {
244 Read_Unlock_info *_info1 = (Read_Unlock_info*) info1;
245 Read_Trylock_info *_info2 = (Read_Trylock_info*) info2;
248 inline static bool CommutativityCondition6(void *info1, void *info2) {
249 Read_Unlock_info *_info1 = (Read_Unlock_info*) info1;
250 Write_Trylock_info *_info2 = (Write_Trylock_info*) info2;
251 return ! _info2-> __RET__;
253 inline static bool CommutativityCondition7(void *info1, void *info2) {
254 Read_Trylock_info *_info1 = (Read_Trylock_info*) info1;
255 Read_Trylock_info *_info2 = (Read_Trylock_info*) info2;
258 inline static bool CommutativityCondition8(void *info1, void *info2) {
259 Read_Trylock_info *_info1 = (Read_Trylock_info*) info1;
260 Write_Trylock_info *_info2 = (Write_Trylock_info*) info2;
261 return ! _info1-> __RET__ || ! _info2-> __RET__;
263 inline static bool CommutativityCondition9(void *info1, void *info2) {
264 Read_Trylock_info *_info1 = (Read_Trylock_info*) info1;
265 Write_Lock_info *_info2 = (Write_Lock_info*) info2;
266 return ! _info1-> __RET__;
268 inline static bool CommutativityCondition10(void *info1, void *info2) {
269 Read_Trylock_info *_info1 = (Read_Trylock_info*) info1;
270 Write_Unlock_info *_info2 = (Write_Unlock_info*) info2;
271 return ! _info1-> __RET__;
273 inline static bool CommutativityCondition11(void *info1, void *info2) {
274 Write_Trylock_info *_info1 = (Write_Trylock_info*) info1;
275 Write_Trylock_info *_info2 = (Write_Trylock_info*) info2;
276 return ! _info1-> __RET__ || ! _info2-> __RET__;
278 inline static bool CommutativityCondition12(void *info1, void *info2) {
279 Write_Trylock_info *_info1 = (Write_Trylock_info*) info1;
280 Write_Unlock_info *_info2 = (Write_Unlock_info*) info2;
281 return ! _info1-> __RET__;
283 inline static bool CommutativityCondition13(void *info1, void *info2) {
284 Write_Trylock_info *_info1 = (Write_Trylock_info*) info1;
285 Write_Lock_info *_info2 = (Write_Lock_info*) info2;
286 return ! _info1-> __RET__;
289 /* Initialization of sequential varialbes */
290 static void __SPEC_INIT__() {
291 writer_lock_acquired = false ;
292 reader_lock_cnt = 0 ;
295 /* Cleanup routine of sequential variables */
296 static bool __SPEC_CLEANUP__() {
300 /* Define function for sequential code initialization */
301 inline static void __sequential_init() {
302 /* Init func_ptr_table */
303 func_ptr_table = (void**) malloc(sizeof(void*) * 6 * 2);
304 func_ptr_table[2 * 3] = (void*) &Write_Trylock_id;
305 func_ptr_table[2 * 3 + 1] = (void*) &Write_Trylock_check_action;
306 func_ptr_table[2 * 2] = (void*) &Read_Trylock_id;
307 func_ptr_table[2 * 2 + 1] = (void*) &Read_Trylock_check_action;
308 func_ptr_table[2 * 1] = (void*) &Write_Lock_id;
309 func_ptr_table[2 * 1 + 1] = (void*) &Write_Lock_check_action;
310 func_ptr_table[2 * 5] = (void*) &Write_Unlock_id;
311 func_ptr_table[2 * 5 + 1] = (void*) &Write_Unlock_check_action;
312 func_ptr_table[2 * 4] = (void*) &Read_Unlock_id;
313 func_ptr_table[2 * 4 + 1] = (void*) &Read_Unlock_check_action;
314 func_ptr_table[2 * 0] = (void*) &Read_Lock_id;
315 func_ptr_table[2 * 0 + 1] = (void*) &Read_Lock_check_action;
316 /* Read_Unlock(true) -> Write_Lock(true) */
317 struct hb_rule *hbConditionInit0 = (struct hb_rule*) malloc(sizeof(struct hb_rule));
318 hbConditionInit0->interface_num_before = 4; // Read_Unlock
319 hbConditionInit0->hb_condition_num_before = 0; //
320 hbConditionInit0->interface_num_after = 1; // Write_Lock
321 hbConditionInit0->hb_condition_num_after = 0; //
322 /* Read_Unlock(true) -> Write_Trylock(HB_Write_Trylock_Succ) */
323 struct hb_rule *hbConditionInit1 = (struct hb_rule*) malloc(sizeof(struct hb_rule));
324 hbConditionInit1->interface_num_before = 4; // Read_Unlock
325 hbConditionInit1->hb_condition_num_before = 0; //
326 hbConditionInit1->interface_num_after = 3; // Write_Trylock
327 hbConditionInit1->hb_condition_num_after = 1; // HB_Write_Trylock_Succ
328 /* Write_Unlock(true) -> Write_Lock(true) */
329 struct hb_rule *hbConditionInit2 = (struct hb_rule*) malloc(sizeof(struct hb_rule));
330 hbConditionInit2->interface_num_before = 5; // Write_Unlock
331 hbConditionInit2->hb_condition_num_before = 0; //
332 hbConditionInit2->interface_num_after = 1; // Write_Lock
333 hbConditionInit2->hb_condition_num_after = 0; //
334 /* Write_Unlock(true) -> Write_Trylock(HB_Write_Trylock_Succ) */
335 struct hb_rule *hbConditionInit3 = (struct hb_rule*) malloc(sizeof(struct hb_rule));
336 hbConditionInit3->interface_num_before = 5; // Write_Unlock
337 hbConditionInit3->hb_condition_num_before = 0; //
338 hbConditionInit3->interface_num_after = 3; // Write_Trylock
339 hbConditionInit3->hb_condition_num_after = 1; // HB_Write_Trylock_Succ
340 /* Write_Unlock(true) -> Read_Lock(true) */
341 struct hb_rule *hbConditionInit4 = (struct hb_rule*) malloc(sizeof(struct hb_rule));
342 hbConditionInit4->interface_num_before = 5; // Write_Unlock
343 hbConditionInit4->hb_condition_num_before = 0; //
344 hbConditionInit4->interface_num_after = 0; // Read_Lock
345 hbConditionInit4->hb_condition_num_after = 0; //
346 /* Write_Unlock(true) -> Read_Trylock(HB_Read_Trylock_Succ) */
347 struct hb_rule *hbConditionInit5 = (struct hb_rule*) malloc(sizeof(struct hb_rule));
348 hbConditionInit5->interface_num_before = 5; // Write_Unlock
349 hbConditionInit5->hb_condition_num_before = 0; //
350 hbConditionInit5->interface_num_after = 2; // Read_Trylock
351 hbConditionInit5->hb_condition_num_after = 2; // HB_Read_Trylock_Succ
352 /* Init hb_rule_table */
353 hb_rule_table = (hb_rule**) malloc(sizeof(hb_rule*) * 6);
354 #define HB_RULE_TABLE_SIZE 6
355 hb_rule_table[0] = hbConditionInit0;
356 hb_rule_table[1] = hbConditionInit1;
357 hb_rule_table[2] = hbConditionInit2;
358 hb_rule_table[3] = hbConditionInit3;
359 hb_rule_table[4] = hbConditionInit4;
360 hb_rule_table[5] = hbConditionInit5;
361 /* Init commutativity_rule_table */
362 commutativity_rule_table = (commutativity_rule**) malloc(sizeof(commutativity_rule*) * 14);
363 commutativity_rule* rule;
364 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
365 rule->interface_num_before = 0;
366 rule->interface_num_after = 0;
368 rule->condition = CommutativityCondition0;
369 commutativity_rule_table[0] = rule;
370 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
371 rule->interface_num_before = 0;
372 rule->interface_num_after = 4;
374 rule->condition = CommutativityCondition1;
375 commutativity_rule_table[1] = rule;
376 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
377 rule->interface_num_before = 0;
378 rule->interface_num_after = 2;
380 rule->condition = CommutativityCondition2;
381 commutativity_rule_table[2] = rule;
382 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
383 rule->interface_num_before = 0;
384 rule->interface_num_after = 3;
385 rule->rule = "! _Method2 . __RET__";
386 rule->condition = CommutativityCondition3;
387 commutativity_rule_table[3] = rule;
388 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
389 rule->interface_num_before = 4;
390 rule->interface_num_after = 4;
392 rule->condition = CommutativityCondition4;
393 commutativity_rule_table[4] = rule;
394 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
395 rule->interface_num_before = 4;
396 rule->interface_num_after = 2;
398 rule->condition = CommutativityCondition5;
399 commutativity_rule_table[5] = rule;
400 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
401 rule->interface_num_before = 4;
402 rule->interface_num_after = 3;
403 rule->rule = "! _Method2 . __RET__";
404 rule->condition = CommutativityCondition6;
405 commutativity_rule_table[6] = rule;
406 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
407 rule->interface_num_before = 2;
408 rule->interface_num_after = 2;
410 rule->condition = CommutativityCondition7;
411 commutativity_rule_table[7] = rule;
412 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
413 rule->interface_num_before = 2;
414 rule->interface_num_after = 3;
415 rule->rule = "! _Method1 . __RET__ || ! _Method2 . __RET__";
416 rule->condition = CommutativityCondition8;
417 commutativity_rule_table[8] = rule;
418 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
419 rule->interface_num_before = 2;
420 rule->interface_num_after = 1;
421 rule->rule = "! _Method1 . __RET__";
422 rule->condition = CommutativityCondition9;
423 commutativity_rule_table[9] = rule;
424 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
425 rule->interface_num_before = 2;
426 rule->interface_num_after = 5;
427 rule->rule = "! _Method1 . __RET__";
428 rule->condition = CommutativityCondition10;
429 commutativity_rule_table[10] = rule;
430 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
431 rule->interface_num_before = 3;
432 rule->interface_num_after = 3;
433 rule->rule = "! _Method1 . __RET__ || ! _Method2 . __RET__";
434 rule->condition = CommutativityCondition11;
435 commutativity_rule_table[11] = rule;
436 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
437 rule->interface_num_before = 3;
438 rule->interface_num_after = 5;
439 rule->rule = "! _Method1 . __RET__";
440 rule->condition = CommutativityCondition12;
441 commutativity_rule_table[12] = rule;
442 rule = (commutativity_rule*) malloc (sizeof(commutativity_rule));
443 rule->interface_num_before = 3;
444 rule->interface_num_after = 1;
445 rule->rule = "! _Method1 . __RET__";
446 rule->condition = CommutativityCondition13;
447 commutativity_rule_table[13] = rule;
448 /* Pass init info, including function table info & HB rules & Commutativity Rules */
449 struct anno_init *anno_init = (struct anno_init*) malloc(sizeof(struct anno_init));
450 anno_init->init_func = (void_func_t) __SPEC_INIT__;
451 anno_init->cleanup_func = (cleanup_func_t) __SPEC_CLEANUP__;
452 anno_init->func_table = func_ptr_table;
453 anno_init->func_table_size = INTERFACE_SIZE;
454 anno_init->hb_rule_table = hb_rule_table;
455 anno_init->hb_rule_table_size = HB_RULE_TABLE_SIZE;
456 anno_init->commutativity_rule_table = commutativity_rule_table;
457 anno_init->commutativity_rule_table_size = 14;
458 struct spec_annotation *init = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
460 init->annotation = anno_init;
461 cdsannotate(SPEC_ANALYSIS, init);
465 /* End of Global construct generation in class */
468 static inline int read_can_lock(rwlock_t *lock)
470 return atomic_load_explicit(&lock->lock, memory_order_relaxed) > 0;
473 static inline int write_can_lock(rwlock_t *lock)
475 return atomic_load_explicit(&lock->lock, memory_order_relaxed) == RW_LOCK_BIAS;
479 void __wrapper__read_lock(rwlock_t * rw);
481 void read_lock(rwlock_t * rw) {
482 /* Interface begins */
483 struct anno_interface_begin *interface_begin = (struct anno_interface_begin*) malloc(sizeof(struct anno_interface_begin));
484 interface_begin->interface_num = 0; // Read_Lock
485 interface_begin->interface_name = "Read_Lock";
486 struct spec_annotation *annotation_interface_begin = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
487 annotation_interface_begin->type = INTERFACE_BEGIN;
488 annotation_interface_begin->annotation = interface_begin;
489 cdsannotate(SPEC_ANALYSIS, annotation_interface_begin);
490 __wrapper__read_lock(rw);
491 struct anno_hb_condition *hb_condition = (struct anno_hb_condition*) malloc(sizeof(struct anno_hb_condition));
492 hb_condition->interface_num = 0; // Read_Lock
493 hb_condition->hb_condition_num = 0;
494 struct spec_annotation *annotation_hb_condition = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
495 annotation_hb_condition->type = HB_CONDITION;
496 annotation_hb_condition->annotation = hb_condition;
497 cdsannotate(SPEC_ANALYSIS, annotation_hb_condition);
499 Read_Lock_info* info = (Read_Lock_info*) malloc(sizeof(Read_Lock_info));
501 struct anno_interface_end *interface_end = (struct anno_interface_end*) malloc(sizeof(struct anno_interface_end));
502 interface_end->interface_num = 0; // Read_Lock
503 interface_end->info = info;
504 struct spec_annotation *annoation_interface_end = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
505 annoation_interface_end->type = INTERFACE_END;
506 annoation_interface_end->annotation = interface_end;
507 cdsannotate(SPEC_ANALYSIS, annoation_interface_end);
510 void __wrapper__read_lock(rwlock_t * rw)
512 int priorvalue = atomic_fetch_sub_explicit(&rw->lock, 1, memory_order_acquire);
513 /* Automatically generated code for commit point define check: Read_Lock_Success_1 */
515 if (priorvalue > 0) {
516 struct anno_cp_define_check *cp_define_check = (struct anno_cp_define_check*) malloc(sizeof(struct anno_cp_define_check));
517 cp_define_check->label_num = 0;
518 cp_define_check->label_name = "Read_Lock_Success_1";
519 cp_define_check->interface_num = 0;
520 struct spec_annotation *annotation_cp_define_check = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
521 annotation_cp_define_check->type = CP_DEFINE_CHECK;
522 annotation_cp_define_check->annotation = cp_define_check;
523 cdsannotate(SPEC_ANALYSIS, annotation_cp_define_check);
526 while (priorvalue <= 0) {
527 atomic_fetch_add_explicit(&rw->lock, 1, memory_order_relaxed);
528 while (atomic_load_explicit(&rw->lock, memory_order_relaxed) <= 0) {
531 priorvalue = atomic_fetch_sub_explicit(&rw->lock, 1, memory_order_acquire);
532 /* Automatically generated code for commit point define check: Read_Lock_Success_2 */
534 if (priorvalue > 0) {
535 struct anno_cp_define_check *cp_define_check = (struct anno_cp_define_check*) malloc(sizeof(struct anno_cp_define_check));
536 cp_define_check->label_num = 1;
537 cp_define_check->label_name = "Read_Lock_Success_2";
538 cp_define_check->interface_num = 0;
539 struct spec_annotation *annotation_cp_define_check = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
540 annotation_cp_define_check->type = CP_DEFINE_CHECK;
541 annotation_cp_define_check->annotation = cp_define_check;
542 cdsannotate(SPEC_ANALYSIS, annotation_cp_define_check);
549 void __wrapper__write_lock(rwlock_t * rw);
551 void write_lock(rwlock_t * rw) {
552 /* Interface begins */
553 struct anno_interface_begin *interface_begin = (struct anno_interface_begin*) malloc(sizeof(struct anno_interface_begin));
554 interface_begin->interface_num = 1; // Write_Lock
555 interface_begin->interface_name = "Write_Lock";
556 struct spec_annotation *annotation_interface_begin = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
557 annotation_interface_begin->type = INTERFACE_BEGIN;
558 annotation_interface_begin->annotation = interface_begin;
559 cdsannotate(SPEC_ANALYSIS, annotation_interface_begin);
560 __wrapper__write_lock(rw);
561 struct anno_hb_condition *hb_condition = (struct anno_hb_condition*) malloc(sizeof(struct anno_hb_condition));
562 hb_condition->interface_num = 1; // Write_Lock
563 hb_condition->hb_condition_num = 0;
564 struct spec_annotation *annotation_hb_condition = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
565 annotation_hb_condition->type = HB_CONDITION;
566 annotation_hb_condition->annotation = hb_condition;
567 cdsannotate(SPEC_ANALYSIS, annotation_hb_condition);
569 Write_Lock_info* info = (Write_Lock_info*) malloc(sizeof(Write_Lock_info));
571 struct anno_interface_end *interface_end = (struct anno_interface_end*) malloc(sizeof(struct anno_interface_end));
572 interface_end->interface_num = 1; // Write_Lock
573 interface_end->info = info;
574 struct spec_annotation *annoation_interface_end = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
575 annoation_interface_end->type = INTERFACE_END;
576 annoation_interface_end->annotation = interface_end;
577 cdsannotate(SPEC_ANALYSIS, annoation_interface_end);
580 void __wrapper__write_lock(rwlock_t * rw)
582 int priorvalue = atomic_fetch_sub_explicit(&rw->lock, RW_LOCK_BIAS, memory_order_acquire);
583 /* Automatically generated code for commit point define check: Write_Lock_Success_1 */
585 if (priorvalue == RW_LOCK_BIAS) {
586 struct anno_cp_define_check *cp_define_check = (struct anno_cp_define_check*) malloc(sizeof(struct anno_cp_define_check));
587 cp_define_check->label_num = 2;
588 cp_define_check->label_name = "Write_Lock_Success_1";
589 cp_define_check->interface_num = 1;
590 struct spec_annotation *annotation_cp_define_check = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
591 annotation_cp_define_check->type = CP_DEFINE_CHECK;
592 annotation_cp_define_check->annotation = cp_define_check;
593 cdsannotate(SPEC_ANALYSIS, annotation_cp_define_check);
596 while (priorvalue != RW_LOCK_BIAS) {
597 atomic_fetch_add_explicit(&rw->lock, RW_LOCK_BIAS, memory_order_relaxed);
598 while (atomic_load_explicit(&rw->lock, memory_order_relaxed) != RW_LOCK_BIAS) {
601 priorvalue = atomic_fetch_sub_explicit(&rw->lock, RW_LOCK_BIAS, memory_order_acquire);
602 /* Automatically generated code for commit point define check: Write_Lock_Success_2 */
604 if (priorvalue == RW_LOCK_BIAS) {
605 struct anno_cp_define_check *cp_define_check = (struct anno_cp_define_check*) malloc(sizeof(struct anno_cp_define_check));
606 cp_define_check->label_num = 3;
607 cp_define_check->label_name = "Write_Lock_Success_2";
608 cp_define_check->interface_num = 1;
609 struct spec_annotation *annotation_cp_define_check = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
610 annotation_cp_define_check->type = CP_DEFINE_CHECK;
611 annotation_cp_define_check->annotation = cp_define_check;
612 cdsannotate(SPEC_ANALYSIS, annotation_cp_define_check);
618 int __wrapper__read_trylock(rwlock_t * rw);
620 int read_trylock(rwlock_t * rw) {
621 /* Interface begins */
622 struct anno_interface_begin *interface_begin = (struct anno_interface_begin*) malloc(sizeof(struct anno_interface_begin));
623 interface_begin->interface_num = 2; // Read_Trylock
624 interface_begin->interface_name = "Read_Trylock";
625 struct spec_annotation *annotation_interface_begin = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
626 annotation_interface_begin->type = INTERFACE_BEGIN;
627 annotation_interface_begin->annotation = interface_begin;
628 cdsannotate(SPEC_ANALYSIS, annotation_interface_begin);
629 int __RET__ = __wrapper__read_trylock(rw);
631 struct anno_hb_condition *hb_condition = (struct anno_hb_condition*) malloc(sizeof(struct anno_hb_condition));
632 hb_condition->interface_num = 2; // Read_Trylock
633 hb_condition->hb_condition_num = 2;
634 struct spec_annotation *annotation_hb_condition = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
635 annotation_hb_condition->type = HB_CONDITION;
636 annotation_hb_condition->annotation = hb_condition;
637 cdsannotate(SPEC_ANALYSIS, annotation_hb_condition);
640 Read_Trylock_info* info = (Read_Trylock_info*) malloc(sizeof(Read_Trylock_info));
641 info->__RET__ = __RET__;
643 struct anno_interface_end *interface_end = (struct anno_interface_end*) malloc(sizeof(struct anno_interface_end));
644 interface_end->interface_num = 2; // Read_Trylock
645 interface_end->info = info;
646 struct spec_annotation *annoation_interface_end = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
647 annoation_interface_end->type = INTERFACE_END;
648 annoation_interface_end->annotation = interface_end;
649 cdsannotate(SPEC_ANALYSIS, annoation_interface_end);
653 int __wrapper__read_trylock(rwlock_t * rw)
655 int priorvalue = atomic_fetch_sub_explicit(&rw->lock, 1, memory_order_acquire);
656 /* Automatically generated code for potential commit point: Potential_Read_Trylock_Point */
659 struct anno_potential_cp_define *potential_cp_define = (struct anno_potential_cp_define*) malloc(sizeof(struct anno_potential_cp_define));
660 potential_cp_define->label_num = 4;
661 potential_cp_define->label_name = "Potential_Read_Trylock_Point";
662 struct spec_annotation *annotation_potential_cp_define = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
663 annotation_potential_cp_define->type = POTENTIAL_CP_DEFINE;
664 annotation_potential_cp_define->annotation = potential_cp_define;
665 cdsannotate(SPEC_ANALYSIS, annotation_potential_cp_define);
668 if (priorvalue > 0) {
669 /* Automatically generated code for commit point define: Read_Trylock_Succ_Point */
672 struct anno_cp_define *cp_define = (struct anno_cp_define*) malloc(sizeof(struct anno_cp_define));
673 cp_define->label_num = 5;
674 cp_define->label_name = "Read_Trylock_Succ_Point";
675 cp_define->potential_cp_label_num = 4;
676 cp_define->potential_label_name = "Potential_Read_Trylock_Point";
677 cp_define->interface_num = 2;
678 struct spec_annotation *annotation_cp_define = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
679 annotation_cp_define->type = CP_DEFINE;
680 annotation_cp_define->annotation = cp_define;
681 cdsannotate(SPEC_ANALYSIS, annotation_cp_define);
686 /* Automatically generated code for commit point define: Read_Trylock_Fail_Point */
689 struct anno_cp_define *cp_define = (struct anno_cp_define*) malloc(sizeof(struct anno_cp_define));
690 cp_define->label_num = 6;
691 cp_define->label_name = "Read_Trylock_Fail_Point";
692 cp_define->potential_cp_label_num = 4;
693 cp_define->potential_label_name = "Potential_Read_Trylock_Point";
694 cp_define->interface_num = 2;
695 struct spec_annotation *annotation_cp_define = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
696 annotation_cp_define->type = CP_DEFINE;
697 annotation_cp_define->annotation = cp_define;
698 cdsannotate(SPEC_ANALYSIS, annotation_cp_define);
701 atomic_fetch_add_explicit(&rw->lock, 1, memory_order_relaxed);
705 int __wrapper__write_trylock(rwlock_t * rw);
707 int write_trylock(rwlock_t * rw) {
708 /* Interface begins */
709 struct anno_interface_begin *interface_begin = (struct anno_interface_begin*) malloc(sizeof(struct anno_interface_begin));
710 interface_begin->interface_num = 3; // Write_Trylock
711 interface_begin->interface_name = "Write_Trylock";
712 struct spec_annotation *annotation_interface_begin = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
713 annotation_interface_begin->type = INTERFACE_BEGIN;
714 annotation_interface_begin->annotation = interface_begin;
715 cdsannotate(SPEC_ANALYSIS, annotation_interface_begin);
716 int __RET__ = __wrapper__write_trylock(rw);
718 struct anno_hb_condition *hb_condition = (struct anno_hb_condition*) malloc(sizeof(struct anno_hb_condition));
719 hb_condition->interface_num = 3; // Write_Trylock
720 hb_condition->hb_condition_num = 1;
721 struct spec_annotation *annotation_hb_condition = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
722 annotation_hb_condition->type = HB_CONDITION;
723 annotation_hb_condition->annotation = hb_condition;
724 cdsannotate(SPEC_ANALYSIS, annotation_hb_condition);
727 Write_Trylock_info* info = (Write_Trylock_info*) malloc(sizeof(Write_Trylock_info));
728 info->__RET__ = __RET__;
730 struct anno_interface_end *interface_end = (struct anno_interface_end*) malloc(sizeof(struct anno_interface_end));
731 interface_end->interface_num = 3; // Write_Trylock
732 interface_end->info = info;
733 struct spec_annotation *annoation_interface_end = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
734 annoation_interface_end->type = INTERFACE_END;
735 annoation_interface_end->annotation = interface_end;
736 cdsannotate(SPEC_ANALYSIS, annoation_interface_end);
740 int __wrapper__write_trylock(rwlock_t * rw)
742 int priorvalue = atomic_fetch_sub_explicit(&rw->lock, RW_LOCK_BIAS, memory_order_acquire);
743 /* Automatically generated code for potential commit point: Potential_Write_Trylock_Point */
746 struct anno_potential_cp_define *potential_cp_define = (struct anno_potential_cp_define*) malloc(sizeof(struct anno_potential_cp_define));
747 potential_cp_define->label_num = 7;
748 potential_cp_define->label_name = "Potential_Write_Trylock_Point";
749 struct spec_annotation *annotation_potential_cp_define = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
750 annotation_potential_cp_define->type = POTENTIAL_CP_DEFINE;
751 annotation_potential_cp_define->annotation = potential_cp_define;
752 cdsannotate(SPEC_ANALYSIS, annotation_potential_cp_define);
755 if (priorvalue == RW_LOCK_BIAS) {
756 /* Automatically generated code for commit point define: Write_Trylock_Succ_Point */
759 struct anno_cp_define *cp_define = (struct anno_cp_define*) malloc(sizeof(struct anno_cp_define));
760 cp_define->label_num = 8;
761 cp_define->label_name = "Write_Trylock_Succ_Point";
762 cp_define->potential_cp_label_num = 7;
763 cp_define->potential_label_name = "Potential_Write_Trylock_Point";
764 cp_define->interface_num = 3;
765 struct spec_annotation *annotation_cp_define = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
766 annotation_cp_define->type = CP_DEFINE;
767 annotation_cp_define->annotation = cp_define;
768 cdsannotate(SPEC_ANALYSIS, annotation_cp_define);
773 /* Automatically generated code for commit point define: Write_Trylock_Fail_Point */
776 struct anno_cp_define *cp_define = (struct anno_cp_define*) malloc(sizeof(struct anno_cp_define));
777 cp_define->label_num = 9;
778 cp_define->label_name = "Write_Trylock_Fail_Point";
779 cp_define->potential_cp_label_num = 7;
780 cp_define->potential_label_name = "Potential_Write_Trylock_Point";
781 cp_define->interface_num = 3;
782 struct spec_annotation *annotation_cp_define = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
783 annotation_cp_define->type = CP_DEFINE;
784 annotation_cp_define->annotation = cp_define;
785 cdsannotate(SPEC_ANALYSIS, annotation_cp_define);
788 atomic_fetch_add_explicit(&rw->lock, RW_LOCK_BIAS, memory_order_relaxed);
792 void __wrapper__read_unlock(rwlock_t * rw);
794 void read_unlock(rwlock_t * rw) {
795 /* Interface begins */
796 struct anno_interface_begin *interface_begin = (struct anno_interface_begin*) malloc(sizeof(struct anno_interface_begin));
797 interface_begin->interface_num = 4; // Read_Unlock
798 interface_begin->interface_name = "Read_Unlock";
799 struct spec_annotation *annotation_interface_begin = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
800 annotation_interface_begin->type = INTERFACE_BEGIN;
801 annotation_interface_begin->annotation = interface_begin;
802 cdsannotate(SPEC_ANALYSIS, annotation_interface_begin);
803 __wrapper__read_unlock(rw);
804 struct anno_hb_condition *hb_condition = (struct anno_hb_condition*) malloc(sizeof(struct anno_hb_condition));
805 hb_condition->interface_num = 4; // Read_Unlock
806 hb_condition->hb_condition_num = 0;
807 struct spec_annotation *annotation_hb_condition = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
808 annotation_hb_condition->type = HB_CONDITION;
809 annotation_hb_condition->annotation = hb_condition;
810 cdsannotate(SPEC_ANALYSIS, annotation_hb_condition);
812 Read_Unlock_info* info = (Read_Unlock_info*) malloc(sizeof(Read_Unlock_info));
814 struct anno_interface_end *interface_end = (struct anno_interface_end*) malloc(sizeof(struct anno_interface_end));
815 interface_end->interface_num = 4; // Read_Unlock
816 interface_end->info = info;
817 struct spec_annotation *annoation_interface_end = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
818 annoation_interface_end->type = INTERFACE_END;
819 annoation_interface_end->annotation = interface_end;
820 cdsannotate(SPEC_ANALYSIS, annoation_interface_end);
823 void __wrapper__read_unlock(rwlock_t * rw)
826 atomic_fetch_add_explicit(&rw->lock, 1, memory_order_release);
827 /* Automatically generated code for commit point define check: Read_Unlock_Point */
830 struct anno_cp_define_check *cp_define_check = (struct anno_cp_define_check*) malloc(sizeof(struct anno_cp_define_check));
831 cp_define_check->label_num = 10;
832 cp_define_check->label_name = "Read_Unlock_Point";
833 cp_define_check->interface_num = 4;
834 struct spec_annotation *annotation_cp_define_check = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
835 annotation_cp_define_check->type = CP_DEFINE_CHECK;
836 annotation_cp_define_check->annotation = cp_define_check;
837 cdsannotate(SPEC_ANALYSIS, annotation_cp_define_check);
842 void __wrapper__write_unlock(rwlock_t * rw);
844 void write_unlock(rwlock_t * rw) {
845 /* Interface begins */
846 struct anno_interface_begin *interface_begin = (struct anno_interface_begin*) malloc(sizeof(struct anno_interface_begin));
847 interface_begin->interface_num = 5; // Write_Unlock
848 interface_begin->interface_name = "Write_Unlock";
849 struct spec_annotation *annotation_interface_begin = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
850 annotation_interface_begin->type = INTERFACE_BEGIN;
851 annotation_interface_begin->annotation = interface_begin;
852 cdsannotate(SPEC_ANALYSIS, annotation_interface_begin);
853 __wrapper__write_unlock(rw);
854 struct anno_hb_condition *hb_condition = (struct anno_hb_condition*) malloc(sizeof(struct anno_hb_condition));
855 hb_condition->interface_num = 5; // Write_Unlock
856 hb_condition->hb_condition_num = 0;
857 struct spec_annotation *annotation_hb_condition = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
858 annotation_hb_condition->type = HB_CONDITION;
859 annotation_hb_condition->annotation = hb_condition;
860 cdsannotate(SPEC_ANALYSIS, annotation_hb_condition);
862 Write_Unlock_info* info = (Write_Unlock_info*) malloc(sizeof(Write_Unlock_info));
864 struct anno_interface_end *interface_end = (struct anno_interface_end*) malloc(sizeof(struct anno_interface_end));
865 interface_end->interface_num = 5; // Write_Unlock
866 interface_end->info = info;
867 struct spec_annotation *annoation_interface_end = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
868 annoation_interface_end->type = INTERFACE_END;
869 annoation_interface_end->annotation = interface_end;
870 cdsannotate(SPEC_ANALYSIS, annoation_interface_end);
873 void __wrapper__write_unlock(rwlock_t * rw)
876 atomic_fetch_add_explicit(&rw->lock, RW_LOCK_BIAS, memory_order_release);
877 /* Automatically generated code for commit point define check: Write_Unlock_Point */
880 struct anno_cp_define_check *cp_define_check = (struct anno_cp_define_check*) malloc(sizeof(struct anno_cp_define_check));
881 cp_define_check->label_num = 11;
882 cp_define_check->label_name = "Write_Unlock_Point";
883 cp_define_check->interface_num = 5;
884 struct spec_annotation *annotation_cp_define_check = (struct spec_annotation*) malloc(sizeof(struct spec_annotation));
885 annotation_cp_define_check->type = CP_DEFINE_CHECK;
886 annotation_cp_define_check->annotation = cp_define_check;
887 cdsannotate(SPEC_ANALYSIS, annotation_cp_define_check);
897 static void a(void *obj)
901 write_unlock(&mylock);
904 static void b(void *obj)
906 if (read_trylock(&mylock)) {
907 read_unlock(&mylock);
911 int user_main(int argc, char **argv)
916 atomic_init(&mylock.lock, RW_LOCK_BIAS);
918 thrd_create(&t1, (thrd_start_t)&a, NULL);
919 thrd_create(&t2, (thrd_start_t)&b, NULL);