Commitd2c797c

committed

Add artificial delay in DTMD

1 parentf39bac5 commitd2c797cCopy full SHA for d2c797c

File tree

-7

lines changed

-7

lines changed

Lines changed: 0 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -171,13 +171,6 @@ static bool stream_flush(stream_t stream) {`
`171`	`171`	`/* nothing to do */`
`172`	`172`	`return true;`
`173`	`173`	`}`
`174`		`- {`
`175`		`-structtimespects;`
`176`		`-intrc;`
`177`		`-ts.tv_sec=0;`
`178`		`-ts.tv_nsec=100000;/* 100usec */`
`179`		`-while (nanosleep(&ts,&ts)<0);`
`180`		`- }`
`181`	`174`	`char*cursor=stream->output.data;`
`182`	`175`	`while (tosend>0) {`
`183`	`176`	`/* repeat sending until we send everything */`

Lines changed: 7 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@`
`6`	`6`	`#include<unistd.h>`
`7`	`7`	`#include<stdlib.h>`
`8`	`8`	`#include<assert.h>`
	`9`	`+#include<time.h>`
`9`	`10`
`10`	`11`	`#include"libdtm.h"`
`11`	`12`	`#include"dtmd/include/proto.h"`
`@@ -168,6 +169,12 @@ static int dtm_recv_results(DTMConn dtm, int maxlen, xid_t *results)`
`168`	`169`	`elog(ERROR,"The message body will not fit into the results array");`
`169`	`170`	`return0;`
`170`	`171`	`}`
	`172`	`+ {`
	`173`	`+structtimespects;`
	`174`	`+ts.tv_sec=0;`
	`175`	`+ts.tv_nsec=100000;/* 100usec */`
	`176`	`+while (nanosleep(&ts,&ts)<0);`
	`177`	`+ }`
`171`	`178`	`while (recved<needed)`
`172`	`179`	`{`
`173`	`180`	`intnewbytes=read(dtm->sock, (char*)results+recved,needed-recved);`

Comments

(0)