_m = 3; goto P999;
/* PROC :init: */
- case 3: /* STATE 1 - line 225 "buffer.spin" - [i = 0] (0:0:1 - 1) */
+ case 3: /* STATE 1 - line 226 "buffer.spin" - [i = 0] (0:0:1 - 1) */
IfNotBlocked
reached[4][1] = 1;
(trpt+1)->bup.oval = ((int)((P4 *)this)->i);
#endif
;
_m = 3; goto P999; /* 0 */
- case 4: /* STATE 2 - line 227 "buffer.spin" - [((i<2))] (8:0:3 - 1) */
+ case 4: /* STATE 2 - line 228 "buffer.spin" - [((i<2))] (7:0:2 - 1) */
IfNotBlocked
reached[4][2] = 1;
if (!((((int)((P4 *)this)->i)<2)))
continue;
- /* merge: commit_count[i] = 0(8, 3, 8) */
+ /* merge: commit_count[i] = 0(7, 3, 7) */
reached[4][3] = 1;
- (trpt+1)->bup.ovals = grab_ints(3);
+ (trpt+1)->bup.ovals = grab_ints(2);
(trpt+1)->bup.ovals[0] = ((int)now.commit_count[ Index(((int)((P4 *)this)->i), 2) ]);
now.commit_count[ Index(((P4 *)this)->i, 2) ] = 0;
#ifdef VAR_RANGES
logval("commit_count[:init::i]", ((int)now.commit_count[ Index(((int)((P4 *)this)->i), 2) ]));
#endif
;
- /* merge: retrieve_count[i] = 0(8, 4, 8) */
+ /* merge: i = (i+1)(7, 4, 7) */
reached[4][4] = 1;
- (trpt+1)->bup.ovals[1] = ((int)now.retrieve_count[ Index(((int)((P4 *)this)->i), 2) ]);
- now.retrieve_count[ Index(((P4 *)this)->i, 2) ] = 0;
-#ifdef VAR_RANGES
- logval("retrieve_count[:init::i]", ((int)now.retrieve_count[ Index(((int)((P4 *)this)->i), 2) ]));
-#endif
- ;
- /* merge: i = (i+1)(8, 5, 8) */
- reached[4][5] = 1;
- (trpt+1)->bup.ovals[2] = ((int)((P4 *)this)->i);
+ (trpt+1)->bup.ovals[1] = ((int)((P4 *)this)->i);
((P4 *)this)->i = (((int)((P4 *)this)->i)+1);
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 9, 8) */
- reached[4][9] = 1;
+ /* merge: .(goto)(0, 8, 7) */
+ reached[4][8] = 1;
;
- _m = 3; goto P999; /* 4 */
- case 5: /* STATE 6 - line 231 "buffer.spin" - [((i>=2))] (17:0:2 - 1) */
+ _m = 3; goto P999; /* 3 */
+ case 5: /* STATE 5 - line 231 "buffer.spin" - [((i>=2))] (16:0:2 - 1) */
IfNotBlocked
- reached[4][6] = 1;
+ reached[4][5] = 1;
if (!((((int)((P4 *)this)->i)>=2)))
continue;
/* dead 1: i */ (trpt+1)->bup.ovals = grab_ints(2);
if (!readtrail)
#endif
((P4 *)this)->i = 0;
- /* merge: goto :b6(17, 7, 17) */
- reached[4][7] = 1;
+ /* merge: goto :b6(16, 6, 16) */
+ reached[4][6] = 1;
;
- /* merge: i = 0(17, 11, 17) */
- reached[4][11] = 1;
+ /* merge: i = 0(16, 10, 16) */
+ reached[4][10] = 1;
(trpt+1)->bup.ovals[1] = ((int)((P4 *)this)->i);
((P4 *)this)->i = 0;
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 18, 17) */
- reached[4][18] = 1;
+ /* merge: .(goto)(0, 17, 16) */
+ reached[4][17] = 1;
;
_m = 3; goto P999; /* 3 */
- case 6: /* STATE 11 - line 233 "buffer.spin" - [i = 0] (0:17:1 - 3) */
+ case 6: /* STATE 10 - line 233 "buffer.spin" - [i = 0] (0:16:1 - 3) */
IfNotBlocked
- reached[4][11] = 1;
+ reached[4][10] = 1;
(trpt+1)->bup.oval = ((int)((P4 *)this)->i);
((P4 *)this)->i = 0;
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 18, 17) */
- reached[4][18] = 1;
+ /* merge: .(goto)(0, 17, 16) */
+ reached[4][17] = 1;
;
_m = 3; goto P999; /* 1 */
- case 7: /* STATE 12 - line 235 "buffer.spin" - [((i<4))] (17:0:2 - 1) */
+ case 7: /* STATE 11 - line 235 "buffer.spin" - [((i<4))] (16:0:2 - 1) */
IfNotBlocked
- reached[4][12] = 1;
+ reached[4][11] = 1;
if (!((((int)((P4 *)this)->i)<4)))
continue;
- /* merge: buffer_use[i] = 0(17, 13, 17) */
- reached[4][13] = 1;
+ /* merge: buffer_use[i] = 0(16, 12, 16) */
+ reached[4][12] = 1;
(trpt+1)->bup.ovals = grab_ints(2);
(trpt+1)->bup.ovals[0] = ((int)now.buffer_use[ Index(((int)((P4 *)this)->i), 4) ]);
now.buffer_use[ Index(((P4 *)this)->i, 4) ] = 0;
logval("buffer_use[:init::i]", ((int)now.buffer_use[ Index(((int)((P4 *)this)->i), 4) ]));
#endif
;
- /* merge: i = (i+1)(17, 14, 17) */
- reached[4][14] = 1;
+ /* merge: i = (i+1)(16, 13, 16) */
+ reached[4][13] = 1;
(trpt+1)->bup.ovals[1] = ((int)((P4 *)this)->i);
((P4 *)this)->i = (((int)((P4 *)this)->i)+1);
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 18, 17) */
- reached[4][18] = 1;
+ /* merge: .(goto)(0, 17, 16) */
+ reached[4][17] = 1;
;
_m = 3; goto P999; /* 3 */
- case 8: /* STATE 15 - line 238 "buffer.spin" - [((i>=4))] (0:0:1 - 1) */
+ case 8: /* STATE 14 - line 238 "buffer.spin" - [((i>=4))] (0:0:1 - 1) */
IfNotBlocked
- reached[4][15] = 1;
+ reached[4][14] = 1;
if (!((((int)((P4 *)this)->i)>=4)))
continue;
/* dead 1: i */ (trpt+1)->bup.oval = ((P4 *)this)->i;
#endif
((P4 *)this)->i = 0;
_m = 3; goto P999; /* 0 */
- case 9: /* STATE 20 - line 240 "buffer.spin" - [(run reader())] (0:0:0 - 3) */
+ case 9: /* STATE 19 - line 240 "buffer.spin" - [(run reader())] (0:0:0 - 3) */
IfNotBlocked
- reached[4][20] = 1;
+ reached[4][19] = 1;
if (!(addproc(2)))
continue;
_m = 3; goto P999; /* 0 */
- case 10: /* STATE 21 - line 241 "buffer.spin" - [(run cleaner())] (29:0:1 - 1) */
+ case 10: /* STATE 20 - line 241 "buffer.spin" - [(run cleaner())] (28:0:1 - 1) */
IfNotBlocked
- reached[4][21] = 1;
+ reached[4][20] = 1;
if (!(addproc(3)))
continue;
- /* merge: i = 0(0, 22, 29) */
- reached[4][22] = 1;
+ /* merge: i = 0(0, 21, 28) */
+ reached[4][21] = 1;
(trpt+1)->bup.oval = ((int)((P4 *)this)->i);
((P4 *)this)->i = 0;
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 30, 29) */
- reached[4][30] = 1;
+ /* merge: .(goto)(0, 29, 28) */
+ reached[4][29] = 1;
;
_m = 3; goto P999; /* 2 */
- case 11: /* STATE 23 - line 244 "buffer.spin" - [((i<4))] (25:0:1 - 1) */
+ case 11: /* STATE 22 - line 244 "buffer.spin" - [((i<4))] (24:0:1 - 1) */
IfNotBlocked
- reached[4][23] = 1;
+ reached[4][22] = 1;
if (!((((int)((P4 *)this)->i)<4)))
continue;
- /* merge: refcount = (refcount+1)(0, 24, 25) */
- reached[4][24] = 1;
+ /* merge: refcount = (refcount+1)(0, 23, 24) */
+ reached[4][23] = 1;
(trpt+1)->bup.oval = ((int)now.refcount);
now.refcount = (((int)now.refcount)+1);
#ifdef VAR_RANGES
#endif
;
_m = 3; goto P999; /* 1 */
- case 12: /* STATE 25 - line 246 "buffer.spin" - [(run tracer())] (29:0:1 - 1) */
+ case 12: /* STATE 24 - line 246 "buffer.spin" - [(run tracer())] (28:0:1 - 1) */
IfNotBlocked
- reached[4][25] = 1;
+ reached[4][24] = 1;
if (!(addproc(1)))
continue;
- /* merge: i = (i+1)(0, 26, 29) */
- reached[4][26] = 1;
+ /* merge: i = (i+1)(0, 25, 28) */
+ reached[4][25] = 1;
(trpt+1)->bup.oval = ((int)((P4 *)this)->i);
((P4 *)this)->i = (((int)((P4 *)this)->i)+1);
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 30, 29) */
- reached[4][30] = 1;
+ /* merge: .(goto)(0, 29, 28) */
+ reached[4][29] = 1;
;
_m = 3; goto P999; /* 2 */
- case 13: /* STATE 27 - line 248 "buffer.spin" - [((i>=4))] (39:0:2 - 1) */
+ case 13: /* STATE 26 - line 248 "buffer.spin" - [((i>=4))] (38:0:2 - 1) */
IfNotBlocked
- reached[4][27] = 1;
+ reached[4][26] = 1;
if (!((((int)((P4 *)this)->i)>=4)))
continue;
/* dead 1: i */ (trpt+1)->bup.ovals = grab_ints(2);
if (!readtrail)
#endif
((P4 *)this)->i = 0;
- /* merge: goto :b8(39, 28, 39) */
- reached[4][28] = 1;
+ /* merge: goto :b8(38, 27, 38) */
+ reached[4][27] = 1;
;
- /* merge: i = 0(39, 32, 39) */
- reached[4][32] = 1;
+ /* merge: i = 0(38, 31, 38) */
+ reached[4][31] = 1;
(trpt+1)->bup.ovals[1] = ((int)((P4 *)this)->i);
((P4 *)this)->i = 0;
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 40, 39) */
- reached[4][40] = 1;
+ /* merge: .(goto)(0, 39, 38) */
+ reached[4][39] = 1;
;
_m = 3; goto P999; /* 3 */
- case 14: /* STATE 32 - line 250 "buffer.spin" - [i = 0] (0:39:1 - 3) */
+ case 14: /* STATE 31 - line 250 "buffer.spin" - [i = 0] (0:38:1 - 3) */
IfNotBlocked
- reached[4][32] = 1;
+ reached[4][31] = 1;
(trpt+1)->bup.oval = ((int)((P4 *)this)->i);
((P4 *)this)->i = 0;
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 40, 39) */
- reached[4][40] = 1;
+ /* merge: .(goto)(0, 39, 38) */
+ reached[4][39] = 1;
;
_m = 3; goto P999; /* 1 */
- case 15: /* STATE 33 - line 252 "buffer.spin" - [((i<1))] (35:0:1 - 1) */
+ case 15: /* STATE 32 - line 252 "buffer.spin" - [((i<1))] (34:0:1 - 1) */
IfNotBlocked
- reached[4][33] = 1;
+ reached[4][32] = 1;
if (!((((int)((P4 *)this)->i)<1)))
continue;
- /* merge: refcount = (refcount+1)(0, 34, 35) */
- reached[4][34] = 1;
+ /* merge: refcount = (refcount+1)(0, 33, 34) */
+ reached[4][33] = 1;
(trpt+1)->bup.oval = ((int)now.refcount);
now.refcount = (((int)now.refcount)+1);
#ifdef VAR_RANGES
#endif
;
_m = 3; goto P999; /* 1 */
- case 16: /* STATE 35 - line 254 "buffer.spin" - [(run switcher())] (39:0:1 - 1) */
+ case 16: /* STATE 34 - line 254 "buffer.spin" - [(run switcher())] (38:0:1 - 1) */
IfNotBlocked
- reached[4][35] = 1;
+ reached[4][34] = 1;
if (!(addproc(0)))
continue;
- /* merge: i = (i+1)(0, 36, 39) */
- reached[4][36] = 1;
+ /* merge: i = (i+1)(0, 35, 38) */
+ reached[4][35] = 1;
(trpt+1)->bup.oval = ((int)((P4 *)this)->i);
((P4 *)this)->i = (((int)((P4 *)this)->i)+1);
#ifdef VAR_RANGES
logval(":init::i", ((int)((P4 *)this)->i));
#endif
;
- /* merge: .(goto)(0, 40, 39) */
- reached[4][40] = 1;
+ /* merge: .(goto)(0, 39, 38) */
+ reached[4][39] = 1;
;
_m = 3; goto P999; /* 2 */
- case 17: /* STATE 37 - line 256 "buffer.spin" - [((i>=1))] (41:0:1 - 1) */
+ case 17: /* STATE 36 - line 256 "buffer.spin" - [((i>=1))] (40:0:1 - 1) */
IfNotBlocked
- reached[4][37] = 1;
+ reached[4][36] = 1;
if (!((((int)((P4 *)this)->i)>=1)))
continue;
/* dead 1: i */ (trpt+1)->bup.oval = ((P4 *)this)->i;
if (!readtrail)
#endif
((P4 *)this)->i = 0;
- /* merge: goto :b9(0, 38, 41) */
- reached[4][38] = 1;
+ /* merge: goto :b9(0, 37, 40) */
+ reached[4][37] = 1;
;
_m = 3; goto P999; /* 1 */
- case 18: /* STATE 43 - line 262 "buffer.spin" - [assert((((write_off-read_off)>=0)&&((write_off-read_off)<(255/2))))] (0:52:2 - 1) */
+ case 18: /* STATE 42 - line 262 "buffer.spin" - [assert((((write_off-read_off)>=0)&&((write_off-read_off)<(255/2))))] (0:50:2 - 1) */
IfNotBlocked
- reached[4][43] = 1;
+ reached[4][42] = 1;
assert((((((int)now.write_off)-((int)now.read_off))>=0)&&((((int)now.write_off)-((int)now.read_off))<(255/2))), "(((write_off-read_off)>=0)&&((write_off-read_off)<(255/2)))", II, tt, t);
- /* merge: j = 0(52, 44, 52) */
- reached[4][44] = 1;
+ /* merge: j = 0(50, 43, 50) */
+ reached[4][43] = 1;
(trpt+1)->bup.ovals = grab_ints(2);
(trpt+1)->bup.ovals[0] = ((int)((P4 *)this)->j);
((P4 *)this)->j = 0;
logval(":init::j", ((int)((P4 *)this)->j));
#endif
;
- /* merge: commit_sum = 0(52, 45, 52) */
- reached[4][45] = 1;
+ /* merge: commit_sum = 0(50, 44, 50) */
+ reached[4][44] = 1;
(trpt+1)->bup.ovals[1] = ((int)((P4 *)this)->commit_sum);
((P4 *)this)->commit_sum = 0;
#ifdef VAR_RANGES
logval(":init::commit_sum", ((int)((P4 *)this)->commit_sum));
#endif
;
- /* merge: .(goto)(0, 53, 52) */
- reached[4][53] = 1;
+ /* merge: .(goto)(0, 51, 50) */
+ reached[4][51] = 1;
;
_m = 3; goto P999; /* 3 */
- case 19: /* STATE 46 - line 266 "buffer.spin" - [((j<2))] (52:0:2 - 1) */
+ case 19: /* STATE 45 - line 266 "buffer.spin" - [((j<2))] (50:0:2 - 1) */
IfNotBlocked
- reached[4][46] = 1;
+ reached[4][45] = 1;
if (!((((int)((P4 *)this)->j)<2)))
continue;
- /* merge: commit_sum = (commit_sum+commit_count[j])(52, 47, 52) */
- reached[4][47] = 1;
+ /* merge: commit_sum = (commit_sum+commit_count[j])(50, 46, 50) */
+ reached[4][46] = 1;
(trpt+1)->bup.ovals = grab_ints(2);
(trpt+1)->bup.ovals[0] = ((int)((P4 *)this)->commit_sum);
((P4 *)this)->commit_sum = (((int)((P4 *)this)->commit_sum)+((int)now.commit_count[ Index(((int)((P4 *)this)->j), 2) ]));
logval(":init::commit_sum", ((int)((P4 *)this)->commit_sum));
#endif
;
- /* merge: assert((((commit_count[j]-retrieve_count[j])>=0)&&((commit_count[j]-retrieve_count[j])<(255/2))))(52, 48, 52) */
- reached[4][48] = 1;
- assert((((((int)now.commit_count[ Index(((int)((P4 *)this)->j), 2) ])-((int)now.retrieve_count[ Index(((int)((P4 *)this)->j), 2) ]))>=0)&&((((int)now.commit_count[ Index(((int)((P4 *)this)->j), 2) ])-((int)now.retrieve_count[ Index(((int)((P4 *)this)->j), 2) ]))<(255/2))), "(((commit_count[j]-retrieve_count[j])>=0)&&((commit_count[j]-retrieve_count[j])<(255/2)))", II, tt, t);
- /* merge: j = (j+1)(52, 49, 52) */
- reached[4][49] = 1;
+ /* merge: j = (j+1)(50, 47, 50) */
+ reached[4][47] = 1;
(trpt+1)->bup.ovals[1] = ((int)((P4 *)this)->j);
((P4 *)this)->j = (((int)((P4 *)this)->j)+1);
#ifdef VAR_RANGES
logval(":init::j", ((int)((P4 *)this)->j));
#endif
;
- /* merge: .(goto)(0, 53, 52) */
- reached[4][53] = 1;
+ /* merge: .(goto)(0, 51, 50) */
+ reached[4][51] = 1;
;
- _m = 3; goto P999; /* 4 */
- case 20: /* STATE 50 - line 273 "buffer.spin" - [((j>=2))] (58:0:1 - 1) */
+ _m = 3; goto P999; /* 3 */
+ case 20: /* STATE 48 - line 273 "buffer.spin" - [((j>=2))] (56:0:1 - 1) */
IfNotBlocked
- reached[4][50] = 1;
+ reached[4][48] = 1;
if (!((((int)((P4 *)this)->j)>=2)))
continue;
/* dead 1: j */ (trpt+1)->bup.oval = ((P4 *)this)->j;
if (!readtrail)
#endif
((P4 *)this)->j = 0;
- /* merge: goto :b10(58, 51, 58) */
- reached[4][51] = 1;
+ /* merge: goto :b10(56, 49, 56) */
+ reached[4][49] = 1;
;
- /* merge: assert((((write_off-commit_sum)>=0)&&((write_off-commit_sum)<(255/2))))(58, 55, 58) */
- reached[4][55] = 1;
+ /* merge: assert((((write_off-commit_sum)>=0)&&((write_off-commit_sum)<(255/2))))(56, 53, 56) */
+ reached[4][53] = 1;
assert((((((int)now.write_off)-((int)((P4 *)this)->commit_sum))>=0)&&((((int)now.write_off)-((int)((P4 *)this)->commit_sum))<(255/2))), "(((write_off-commit_sum)>=0)&&((write_off-commit_sum)<(255/2)))", II, tt, t);
- /* merge: assert((((4+1)>4)||(events_lost==0)))(58, 56, 58) */
- reached[4][56] = 1;
+ /* merge: assert((((4+1)>4)||(events_lost==0)))(56, 54, 56) */
+ reached[4][54] = 1;
assert((((4+1)>4)||(((int)now.events_lost)==0)), "(((4+1)>4)||(events_lost==0))", II, tt, t);
_m = 3; goto P999; /* 3 */
- case 21: /* STATE 55 - line 278 "buffer.spin" - [assert((((write_off-commit_sum)>=0)&&((write_off-commit_sum)<(255/2))))] (0:58:0 - 3) */
+ case 21: /* STATE 53 - line 278 "buffer.spin" - [assert((((write_off-commit_sum)>=0)&&((write_off-commit_sum)<(255/2))))] (0:56:0 - 3) */
IfNotBlocked
- reached[4][55] = 1;
+ reached[4][53] = 1;
assert((((((int)now.write_off)-((int)((P4 *)this)->commit_sum))>=0)&&((((int)now.write_off)-((int)((P4 *)this)->commit_sum))<(255/2))), "(((write_off-commit_sum)>=0)&&((write_off-commit_sum)<(255/2)))", II, tt, t);
- /* merge: assert((((4+1)>4)||(events_lost==0)))(58, 56, 58) */
- reached[4][56] = 1;
+ /* merge: assert((((4+1)>4)||(events_lost==0)))(56, 54, 56) */
+ reached[4][54] = 1;
assert((((4+1)>4)||(((int)now.events_lost)==0)), "(((4+1)>4)||(events_lost==0))", II, tt, t);
_m = 3; goto P999; /* 1 */
- case 22: /* STATE 58 - line 284 "buffer.spin" - [-end-] (0:0:0 - 1) */
+ case 22: /* STATE 56 - line 284 "buffer.spin" - [-end-] (0:0:0 - 1) */
IfNotBlocked
- reached[4][58] = 1;
+ reached[4][56] = 1;
if (!delproc(1, II)) continue;
_m = 3; goto P999; /* 0 */
/* PROC cleaner */
- case 23: /* STATE 1 - line 210 "buffer.spin" - [((refcount==0))] (3:0:1 - 1) */
+ case 23: /* STATE 1 - line 211 "buffer.spin" - [((refcount==0))] (3:0:1 - 1) */
IfNotBlocked
reached[3][1] = 1;
if (!((((int)now.refcount)==0)))
#endif
;
_m = 3; goto P999; /* 1 */
- case 24: /* STATE 3 - line 212 "buffer.spin" - [(run switcher())] (7:0:0 - 1) */
+ case 24: /* STATE 3 - line 213 "buffer.spin" - [(run switcher())] (7:0:0 - 1) */
IfNotBlocked
reached[3][3] = 1;
if (!(addproc(0)))
reached[3][4] = 1;
;
_m = 3; goto P999; /* 1 */
- case 25: /* STATE 9 - line 216 "buffer.spin" - [-end-] (0:0:0 - 1) */
+ case 25: /* STATE 9 - line 217 "buffer.spin" - [-end-] (0:0:0 - 1) */
IfNotBlocked
reached[3][9] = 1;
if (!delproc(1, II)) continue;
_m = 3; goto P999; /* 0 */
/* PROC reader */
- case 26: /* STATE 1 - line 169 "buffer.spin" - [((((((write_off/(4/2))-(read_off/(4/2)))>0)&&(((write_off/(4/2))-(read_off/(4/2)))<(255/2)))&&((commit_count[((read_off%4)/(4/2))]-retrieve_count[((read_off%4)/(4/2))])==(4/2))))] (0:0:0 - 1) */
+ case 26: /* STATE 1 - line 177 "buffer.spin" - [((((((write_off/(4/2))-(read_off/(4/2)))>0)&&(((write_off/(4/2))-(read_off/(4/2)))<(255/2)))&&(((commit_count[((read_off%4)/(4/2))]-(4/2))-(((read_off/4)*4)/2))==0)))] (0:0:0 - 1) */
IfNotBlocked
reached[2][1] = 1;
- if (!((((((((int)now.write_off)/(4/2))-(((int)now.read_off)/(4/2)))>0)&&(((((int)now.write_off)/(4/2))-(((int)now.read_off)/(4/2)))<(255/2)))&&((((int)now.commit_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ])-((int)now.retrieve_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ]))==(4/2)))))
+ if (!((((((((int)now.write_off)/(4/2))-(((int)now.read_off)/(4/2)))>0)&&(((((int)now.write_off)/(4/2))-(((int)now.read_off)/(4/2)))<(255/2)))&&(((((int)now.commit_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ])-(4/2))-(((((int)now.read_off)/4)*4)/2))==0))))
continue;
_m = 3; goto P999; /* 0 */
- case 27: /* STATE 2 - line 171 "buffer.spin" - [i = 0] (0:0:1 - 1) */
+ case 27: /* STATE 2 - line 179 "buffer.spin" - [i = 0] (0:0:1 - 1) */
IfNotBlocked
reached[2][2] = 1;
(trpt+1)->bup.oval = ((int)((P2 *)this)->i);
#endif
;
_m = 3; goto P999; /* 0 */
- case 28: /* STATE 3 - line 173 "buffer.spin" - [((i<(4/2)))] (9:0:2 - 1) */
+ case 28: /* STATE 3 - line 181 "buffer.spin" - [((i<(4/2)))] (9:0:2 - 1) */
IfNotBlocked
reached[2][3] = 1;
if (!((((int)((P2 *)this)->i)<(4/2))))
reached[2][10] = 1;
;
_m = 3; goto P999; /* 4 */
- case 29: /* STATE 7 - line 177 "buffer.spin" - [((i>=(4/2)))] (11:0:1 - 1) */
+ case 29: /* STATE 7 - line 185 "buffer.spin" - [((i>=(4/2)))] (11:0:1 - 1) */
IfNotBlocked
reached[2][7] = 1;
if (!((((int)((P2 *)this)->i)>=(4/2))))
reached[2][8] = 1;
;
_m = 3; goto P999; /* 1 */
-/* STATE 13 - line 187 "buffer.spin" - [i = 0] (0:0 - 1) same as 27 (0:0 - 1) */
- case 30: /* STATE 14 - line 189 "buffer.spin" - [((i<(4/2)))] (19:0:2 - 1) */
+/* STATE 13 - line 191 "buffer.spin" - [i = 0] (0:0 - 1) same as 27 (0:0 - 1) */
+ case 30: /* STATE 14 - line 193 "buffer.spin" - [((i<(4/2)))] (19:0:2 - 1) */
IfNotBlocked
reached[2][14] = 1;
if (!((((int)((P2 *)this)->i)<(4/2))))
reached[2][20] = 1;
;
_m = 3; goto P999; /* 3 */
- case 31: /* STATE 17 - line 192 "buffer.spin" - [((i>=(4/2)))] (28:0:4 - 1) */
+ case 31: /* STATE 17 - line 196 "buffer.spin" - [((i>=(4/2)))] (0:0:1 - 1) */
IfNotBlocked
reached[2][17] = 1;
if (!((((int)((P2 *)this)->i)>=(4/2))))
continue;
- /* dead 1: i */ (trpt+1)->bup.ovals = grab_ints(4);
- (trpt+1)->bup.ovals[0] = ((P2 *)this)->i;
+ /* dead 1: i */ (trpt+1)->bup.oval = ((P2 *)this)->i;
#ifdef HAS_CODE
if (!readtrail)
#endif
((P2 *)this)->i = 0;
- /* merge: goto :b4(28, 18, 28) */
- reached[2][18] = 1;
- ;
- /* merge: tmp_retrieve = (retrieve_count[((read_off%4)/(4/2))]+(4/2))(28, 22, 28) */
- reached[2][22] = 1;
- (trpt+1)->bup.ovals[1] = ((int)((P2 *)this)->tmp_retrieve);
- ((P2 *)this)->tmp_retrieve = (((int)now.retrieve_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ])+(4/2));
-#ifdef VAR_RANGES
- logval("reader:tmp_retrieve", ((int)((P2 *)this)->tmp_retrieve));
-#endif
- ;
- /* merge: retrieve_count[((read_off%4)/(4/2))] = tmp_retrieve(28, 23, 28) */
- reached[2][23] = 1;
- (trpt+1)->bup.ovals[2] = ((int)now.retrieve_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ]);
- now.retrieve_count[ Index(((now.read_off%4)/(4/2)), 2) ] = ((int)((P2 *)this)->tmp_retrieve);
-#ifdef VAR_RANGES
- logval("retrieve_count[((read_off%4)/(4/2))]", ((int)now.retrieve_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ]));
-#endif
- ;
- /* merge: read_off = (read_off+(4/2))(28, 24, 28) */
- reached[2][24] = 1;
- (trpt+1)->bup.ovals[3] = ((int)now.read_off);
- now.read_off = (((int)now.read_off)+(4/2));
-#ifdef VAR_RANGES
- logval("read_off", ((int)now.read_off));
-#endif
- ;
- /* merge: .(goto)(0, 29, 28) */
- reached[2][29] = 1;
- ;
- _m = 3; goto P999; /* 5 */
- case 32: /* STATE 22 - line 194 "buffer.spin" - [tmp_retrieve = (retrieve_count[((read_off%4)/(4/2))]+(4/2))] (0:28:3 - 3) */
+ _m = 3; goto P999; /* 0 */
+ case 32: /* STATE 22 - line 198 "buffer.spin" - [read_off = (read_off+(4/2))] (0:0:1 - 1) */
IfNotBlocked
reached[2][22] = 1;
- (trpt+1)->bup.ovals = grab_ints(3);
- (trpt+1)->bup.ovals[0] = ((int)((P2 *)this)->tmp_retrieve);
- ((P2 *)this)->tmp_retrieve = (((int)now.retrieve_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ])+(4/2));
-#ifdef VAR_RANGES
- logval("reader:tmp_retrieve", ((int)((P2 *)this)->tmp_retrieve));
-#endif
- ;
- /* merge: retrieve_count[((read_off%4)/(4/2))] = tmp_retrieve(28, 23, 28) */
- reached[2][23] = 1;
- (trpt+1)->bup.ovals[1] = ((int)now.retrieve_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ]);
- now.retrieve_count[ Index(((now.read_off%4)/(4/2)), 2) ] = ((int)((P2 *)this)->tmp_retrieve);
-#ifdef VAR_RANGES
- logval("retrieve_count[((read_off%4)/(4/2))]", ((int)now.retrieve_count[ Index(((((int)now.read_off)%4)/(4/2)), 2) ]));
-#endif
- ;
- /* merge: read_off = (read_off+(4/2))(28, 24, 28) */
- reached[2][24] = 1;
- (trpt+1)->bup.ovals[2] = ((int)now.read_off);
+ (trpt+1)->bup.oval = ((int)now.read_off);
now.read_off = (((int)now.read_off)+(4/2));
#ifdef VAR_RANGES
logval("read_off", ((int)now.read_off));
#endif
;
- /* merge: .(goto)(0, 29, 28) */
- reached[2][29] = 1;
- ;
- _m = 3; goto P999; /* 3 */
- case 33: /* STATE 26 - line 199 "buffer.spin" - [((read_off>=(4-events_lost)))] (0:0:0 - 1) */
+ _m = 3; goto P999; /* 0 */
+ case 33: /* STATE 24 - line 200 "buffer.spin" - [((read_off>=(4-events_lost)))] (0:0:0 - 1) */
IfNotBlocked
- reached[2][26] = 1;
+ reached[2][24] = 1;
if (!((((int)now.read_off)>=(4-((int)now.events_lost)))))
continue;
_m = 3; goto P999; /* 0 */
- case 34: /* STATE 31 - line 201 "buffer.spin" - [-end-] (0:0:0 - 3) */
+ case 34: /* STATE 29 - line 202 "buffer.spin" - [-end-] (0:0:0 - 3) */
IfNotBlocked
- reached[2][31] = 1;
+ reached[2][29] = 1;
if (!delproc(1, II)) continue;
_m = 3; goto P999; /* 0 */
/* PROC tracer */
- case 35: /* STATE 1 - line 99 "buffer.spin" - [prev_off = write_off] (0:10:2 - 1) */
+ case 35: /* STATE 1 - line 106 "buffer.spin" - [prev_off = write_off] (0:10:2 - 1) */
IfNotBlocked
reached[1][1] = 1;
(trpt+1)->bup.ovals = grab_ints(2);
#endif
;
_m = 3; goto P999; /* 1 */
- case 36: /* STATE 4 - line 104 "buffer.spin" - [((((new_off-read_off)>4)&&((new_off-read_off)<(255/2))))] (0:0:1 - 1) */
+ case 36: /* STATE 4 - line 111 "buffer.spin" - [((((new_off-read_off)>4)&&((new_off-read_off)<(255/2))))] (0:0:1 - 1) */
IfNotBlocked
reached[1][4] = 1;
if (!((((((int)((P1 *)this)->new_off)-((int)now.read_off))>4)&&((((int)((P1 *)this)->new_off)-((int)now.read_off))<(255/2)))))
#endif
((P1 *)this)->new_off = 0;
_m = 3; goto P999; /* 0 */
- case 37: /* STATE 7 - line 106 "buffer.spin" - [(1)] (27:0:0 - 1) */
+ case 37: /* STATE 7 - line 113 "buffer.spin" - [(1)] (27:0:0 - 1) */
IfNotBlocked
reached[1][7] = 1;
if (!(1))
reached[1][9] = 1;
;
_m = 3; goto P999; /* 1 */
- case 38: /* STATE 11 - line 111 "buffer.spin" - [((prev_off!=write_off))] (3:0:1 - 1) */
+ case 38: /* STATE 11 - line 118 "buffer.spin" - [((prev_off!=write_off))] (3:0:1 - 1) */
IfNotBlocked
reached[1][11] = 1;
if (!((((int)((P1 *)this)->prev_off)!=((int)now.write_off))))
reached[1][12] = 1;
;
_m = 3; goto P999; /* 1 */
- case 39: /* STATE 14 - line 112 "buffer.spin" - [write_off = new_off] (0:24:2 - 1) */
+ case 39: /* STATE 14 - line 119 "buffer.spin" - [write_off = new_off] (0:24:2 - 1) */
IfNotBlocked
reached[1][14] = 1;
(trpt+1)->bup.ovals = grab_ints(2);
reached[1][25] = 1;
;
_m = 3; goto P999; /* 3 */
- case 40: /* STATE 17 - line 114 "buffer.spin" - [i = 0] (0:24:1 - 2) */
+ case 40: /* STATE 17 - line 121 "buffer.spin" - [i = 0] (0:24:1 - 2) */
IfNotBlocked
reached[1][17] = 1;
(trpt+1)->bup.oval = ((int)((P1 *)this)->i);
reached[1][25] = 1;
;
_m = 3; goto P999; /* 1 */
- case 41: /* STATE 18 - line 116 "buffer.spin" - [((i<size))] (24:0:2 - 1) */
+ case 41: /* STATE 18 - line 123 "buffer.spin" - [((i<size))] (24:0:2 - 1) */
IfNotBlocked
reached[1][18] = 1;
if (!((((int)((P1 *)this)->i)<((int)((P1 *)this)->size))))
reached[1][25] = 1;
;
_m = 3; goto P999; /* 4 */
- case 42: /* STATE 22 - line 120 "buffer.spin" - [((i>=size))] (26:0:1 - 1) */
+ case 42: /* STATE 22 - line 127 "buffer.spin" - [((i>=size))] (26:0:1 - 1) */
IfNotBlocked
reached[1][22] = 1;
if (!((((int)((P1 *)this)->i)>=((int)((P1 *)this)->size))))
reached[1][23] = 1;
;
_m = 3; goto P999; /* 1 */
- case 43: /* STATE 28 - line 127 "buffer.spin" - [i = 0] (0:0:1 - 1) */
+ case 43: /* STATE 28 - line 134 "buffer.spin" - [i = 0] (0:0:1 - 1) */
IfNotBlocked
reached[1][28] = 1;
(trpt+1)->bup.oval = ((int)((P1 *)this)->i);
#endif
;
_m = 3; goto P999; /* 0 */
- case 44: /* STATE 29 - line 129 "buffer.spin" - [((i<size))] (34:0:2 - 1) */
+ case 44: /* STATE 29 - line 136 "buffer.spin" - [((i<size))] (34:0:2 - 1) */
IfNotBlocked
reached[1][29] = 1;
if (!((((int)((P1 *)this)->i)<((int)((P1 *)this)->size))))
reached[1][35] = 1;
;
_m = 3; goto P999; /* 3 */
- case 45: /* STATE 32 - line 132 "buffer.spin" - [((i>=size))] (43:0:3 - 1) */
+ case 45: /* STATE 32 - line 139 "buffer.spin" - [((i>=size))] (43:0:3 - 1) */
IfNotBlocked
reached[1][32] = 1;
if (!((((int)((P1 *)this)->i)>=((int)((P1 *)this)->size))))
#endif
;
_m = 3; goto P999; /* 3 */
- case 46: /* STATE 37 - line 134 "buffer.spin" - [tmp_commit = (commit_count[((prev_off%4)/(4/2))]+size)] (0:43:2 - 3) */
+ case 46: /* STATE 37 - line 141 "buffer.spin" - [tmp_commit = (commit_count[((prev_off%4)/(4/2))]+size)] (0:43:2 - 3) */
IfNotBlocked
reached[1][37] = 1;
(trpt+1)->bup.ovals = grab_ints(2);
#endif
;
_m = 3; goto P999; /* 1 */
- case 47: /* STATE 39 - line 137 "buffer.spin" - [(((tmp_commit%(4/2))==0))] (49:0:2 - 1) */
+ case 47: /* STATE 39 - line 145 "buffer.spin" - [((((((prev_off/4)*4)/2)+(4/2))-tmp_commit))] (49:0:3 - 1) */
IfNotBlocked
reached[1][39] = 1;
- if (!(((((int)((P1 *)this)->tmp_commit)%(4/2))==0)))
+ if (!((((((((int)((P1 *)this)->prev_off)/4)*4)/2)+(4/2))-((int)((P1 *)this)->tmp_commit))))
continue;
- /* dead 1: tmp_commit */ (trpt+1)->bup.ovals = grab_ints(2);
- (trpt+1)->bup.ovals[0] = ((P1 *)this)->tmp_commit;
+ /* dead 1: prev_off */ (trpt+1)->bup.ovals = grab_ints(3);
+ (trpt+1)->bup.ovals[0] = ((P1 *)this)->prev_off;
+#ifdef HAS_CODE
+ if (!readtrail)
+#endif
+ ((P1 *)this)->prev_off = 0;
+ /* dead 1: tmp_commit */ (trpt+1)->bup.ovals[1] = ((P1 *)this)->tmp_commit;
#ifdef HAS_CODE
if (!readtrail)
#endif
((P1 *)this)->tmp_commit = 0;
/* merge: deliver = 1(49, 40, 49) */
reached[1][40] = 1;
- (trpt+1)->bup.ovals[1] = ((int)deliver);
+ (trpt+1)->bup.ovals[2] = ((int)deliver);
deliver = 1;
#ifdef VAR_RANGES
logval("deliver", ((int)deliver));
reached[1][44] = 1;
;
_m = 3; goto P999; /* 2 */
- case 48: /* STATE 44 - line 140 "buffer.spin" - [.(goto)] (0:49:0 - 2) */
+ case 48: /* STATE 44 - line 150 "buffer.spin" - [.(goto)] (0:49:0 - 2) */
IfNotBlocked
reached[1][44] = 1;
;
_m = 3; goto P999; /* 0 */
- case 49: /* STATE 42 - line 138 "buffer.spin" - [(1)] (49:0:0 - 1) */
+ case 49: /* STATE 42 - line 148 "buffer.spin" - [(1)] (49:0:0 - 1) */
IfNotBlocked
reached[1][42] = 1;
if (!(1))
reached[1][44] = 1;
;
_m = 3; goto P999; /* 1 */
- case 50: /* STATE 47 - line 144 "buffer.spin" - [events_lost = (events_lost+1)] (0:0:1 - 2) */
+ case 50: /* STATE 47 - line 154 "buffer.spin" - [events_lost = (events_lost+1)] (0:0:1 - 2) */
IfNotBlocked
reached[1][47] = 1;
(trpt+1)->bup.oval = ((int)now.events_lost);
#endif
;
_m = 3; goto P999; /* 0 */
- case 51: /* STATE 48 - line 146 "buffer.spin" - [refcount = (refcount-1)] (0:0:1 - 2) */
+ case 51: /* STATE 48 - line 156 "buffer.spin" - [refcount = (refcount-1)] (0:0:1 - 2) */
IfNotBlocked
reached[1][48] = 1;
(trpt+1)->bup.oval = ((int)now.refcount);
#endif
;
_m = 3; goto P999; /* 0 */
- case 52: /* STATE 50 - line 148 "buffer.spin" - [-end-] (0:0:0 - 1) */
+ case 52: /* STATE 50 - line 158 "buffer.spin" - [-end-] (0:0:0 - 1) */
IfNotBlocked
reached[1][50] = 1;
if (!delproc(1, II)) continue;
_m = 3; goto P999; /* 0 */
/* PROC switcher */
- case 53: /* STATE 1 - line 56 "buffer.spin" - [prev_off = write_off] (0:9:3 - 1) */
+ case 53: /* STATE 1 - line 60 "buffer.spin" - [prev_off = write_off] (0:9:3 - 1) */
IfNotBlocked
reached[0][1] = 1;
(trpt+1)->bup.ovals = grab_ints(3);
#endif
;
_m = 3; goto P999; /* 2 */
- case 54: /* STATE 4 - line 61 "buffer.spin" - [(((((new_off-read_off)>4)&&((new_off-read_off)<(255/2)))||(size==(4/2))))] (29:0:3 - 1) */
+ case 54: /* STATE 4 - line 65 "buffer.spin" - [(((((new_off-read_off)>4)&&((new_off-read_off)<(255/2)))||(size==(4/2))))] (29:0:3 - 1) */
IfNotBlocked
reached[0][4] = 1;
if (!(((((((int)((P0 *)this)->new_off)-((int)now.read_off))>4)&&((((int)((P0 *)this)->new_off)-((int)now.read_off))<(255/2)))||(((int)((P0 *)this)->size)==(4/2)))))
reached[0][6] = 1;
;
_m = 3; goto P999; /* 2 */
- case 55: /* STATE 8 - line 64 "buffer.spin" - [(1)] (18:0:0 - 1) */
+ case 55: /* STATE 8 - line 68 "buffer.spin" - [(1)] (18:0:0 - 1) */
IfNotBlocked
reached[0][8] = 1;
if (!(1))
reached[0][10] = 1;
;
_m = 3; goto P999; /* 1 */
- case 56: /* STATE 12 - line 69 "buffer.spin" - [((prev_off!=write_off))] (11:0:1 - 1) */
+ case 56: /* STATE 12 - line 73 "buffer.spin" - [((prev_off!=write_off))] (11:0:1 - 1) */
IfNotBlocked
reached[0][12] = 1;
if (!((((int)((P0 *)this)->prev_off)!=((int)now.write_off))))
reached[0][13] = 1;
;
_m = 3; goto P999; /* 1 */
- case 57: /* STATE 17 - line 72 "buffer.spin" - [.(goto)] (0:28:0 - 1) */
+ case 57: /* STATE 17 - line 76 "buffer.spin" - [.(goto)] (0:28:0 - 1) */
IfNotBlocked
reached[0][17] = 1;
;
_m = 3; goto P999; /* 0 */
- case 58: /* STATE 15 - line 70 "buffer.spin" - [write_off = new_off] (0:28:1 - 1) */
+ case 58: /* STATE 15 - line 74 "buffer.spin" - [write_off = new_off] (0:28:1 - 1) */
IfNotBlocked
reached[0][15] = 1;
(trpt+1)->bup.oval = ((int)now.write_off);
reached[0][17] = 1;
;
_m = 3; goto P999; /* 1 */
- case 59: /* STATE 19 - line 75 "buffer.spin" - [tmp_commit = (commit_count[((prev_off%4)/(4/2))]+size)] (0:25:2 - 1) */
+ case 59: /* STATE 19 - line 79 "buffer.spin" - [tmp_commit = (commit_count[((prev_off%4)/(4/2))]+size)] (0:25:2 - 1) */
IfNotBlocked
reached[0][19] = 1;
(trpt+1)->bup.ovals = grab_ints(2);
#endif
;
_m = 3; goto P999; /* 1 */
- case 60: /* STATE 21 - line 78 "buffer.spin" - [(((tmp_commit%(4/2))==0))] (29:0:3 - 1) */
+ case 60: /* STATE 21 - line 83 "buffer.spin" - [((((((prev_off/4)*4)/2)+(4/2))-tmp_commit))] (29:0:4 - 1) */
IfNotBlocked
reached[0][21] = 1;
- if (!(((((int)((P0 *)this)->tmp_commit)%(4/2))==0)))
+ if (!((((((((int)((P0 *)this)->prev_off)/4)*4)/2)+(4/2))-((int)((P0 *)this)->tmp_commit))))
continue;
- /* dead 1: tmp_commit */ (trpt+1)->bup.ovals = grab_ints(3);
- (trpt+1)->bup.ovals[0] = ((P0 *)this)->tmp_commit;
+ /* dead 1: prev_off */ (trpt+1)->bup.ovals = grab_ints(4);
+ (trpt+1)->bup.ovals[0] = ((P0 *)this)->prev_off;
+#ifdef HAS_CODE
+ if (!readtrail)
+#endif
+ ((P0 *)this)->prev_off = 0;
+ /* dead 1: tmp_commit */ (trpt+1)->bup.ovals[1] = ((P0 *)this)->tmp_commit;
#ifdef HAS_CODE
if (!readtrail)
#endif
((P0 *)this)->tmp_commit = 0;
/* merge: deliver = 1(29, 22, 29) */
reached[0][22] = 1;
- (trpt+1)->bup.ovals[1] = ((int)deliver);
+ (trpt+1)->bup.ovals[2] = ((int)deliver);
deliver = 1;
#ifdef VAR_RANGES
logval("deliver", ((int)deliver));
;
/* merge: refcount = (refcount-1)(29, 27, 29) */
reached[0][27] = 1;
- (trpt+1)->bup.ovals[2] = ((int)now.refcount);
+ (trpt+1)->bup.ovals[3] = ((int)now.refcount);
now.refcount = (((int)now.refcount)-1);
#ifdef VAR_RANGES
logval("refcount", ((int)now.refcount));
#endif
;
_m = 3; goto P999; /* 3 */
- case 61: /* STATE 26 - line 81 "buffer.spin" - [.(goto)] (0:29:1 - 2) */
+ case 61: /* STATE 26 - line 88 "buffer.spin" - [.(goto)] (0:29:1 - 2) */
IfNotBlocked
reached[0][26] = 1;
;
#endif
;
_m = 3; goto P999; /* 1 */
- case 62: /* STATE 24 - line 79 "buffer.spin" - [(1)] (29:0:1 - 1) */
+ case 62: /* STATE 24 - line 86 "buffer.spin" - [(1)] (29:0:1 - 1) */
IfNotBlocked
reached[0][24] = 1;
if (!(1))
#endif
;
_m = 3; goto P999; /* 2 */
- case 63: /* STATE 30 - line 85 "buffer.spin" - [-end-] (0:0:0 - 1) */
+ case 63: /* STATE 30 - line 92 "buffer.spin" - [-end-] (0:0:0 - 1) */
IfNotBlocked
reached[0][30] = 1;
if (!delproc(1, II)) continue;
projects / lttv.git / blobdiff