qbit/go
1
0
Fork 0
mirror of https://github.com/golang/go synced 2024-11-17 04:55:07 -07:00
Code Releases Activity

chan bool offset bug

Browse Source 
SVN=127537
This commit is contained in:
Ken Thompson 2008-07-16 11:46:33 -07:00
parent ac048ce7f4
commit 90da10d7ac
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/runtime/chan.c
View File

@ -15,7 +15,8 @@ struct Hchan
uint32 dataqsiz; // size of the circular q uint32 dataqsiz; // size of the circular q
uint32 qcount; // total data in the q uint32 qcount; // total data in the q
uint32 eo; // vararg of element uint32 eo; // vararg of element
uint32 po; // vararg of present bool uint32 po1; // vararg of present bool in next structure
uint32 po2; // vararg of present bool in same structure
Alg* elemalg; // interface for element type Alg* elemalg; // interface for element type
Link* senddataq; // pointer for sender Link* senddataq; // pointer for sender
Link* recvdataq; // pointer for receiver Link* recvdataq; // pointer for receiver
@ -74,7 +75,8 @@ sys·newchan(uint32 elemsize, uint32 elemalg, uint32 hint,
// these calculations are compiler dependent // these calculations are compiler dependent
c->eo = rnd(sizeof(c), elemsize); c->eo = rnd(sizeof(c), elemsize);
c->po = rnd(c->eo+elemsize, 1); c->po1 = rnd(c->eo+elemsize, 8); // next structure
c->po2 = rnd(c->eo+elemsize, 1); // same structure
ret = c; ret = c;
FLUSH(&ret); FLUSH(&ret);
@ -90,7 +92,6 @@ sys·newchan(uint32 elemsize, uint32 elemalg, uint32 hint,
sys·printint(c->dataqsiz); sys·printint(c->dataqsiz);
prints("\n"); prints("\n");
} }
} }
// chansend1(hchan *chan any, elem any); // chansend1(hchan *chan any, elem any);
@ -145,7 +146,8 @@ sys·chansend2(Hchan* c, ...)
G *gr; G *gr;
ae = (byte*)&c + c->eo; ae = (byte*)&c + c->eo;
ap = (byte*)&c + c->po; ap = (byte*)&c + c->po1;
if(debug) { if(debug) {
prints("chansend: chan="); prints("chansend: chan=");
sys·printpointer(c); sys·printpointer(c);
@ -230,7 +232,8 @@ sys·chanrecv2(Hchan* c, ...)
G *gs; G *gs;
ae = (byte*)&c + c->eo; ae = (byte*)&c + c->eo;
ap = (byte*)&c + c->po; ap = (byte*)&c + c->po2;
if(debug) { if(debug) {
prints("chanrecv2: chan="); prints("chanrecv2: chan=");
sys·printpointer(c); sys·printpointer(c);