Swap test program delays

jmaralo · jmaralo · commit 313ca4b38290 · 2024-05-22T13:48:25.000+02:00
diff --git a/state-order-tester/main.go b/state-order-tester/main.go
@@ -74,21 +74,21 @@ func writeConn(conn *net.TCPConn, closeChan chan<- error) {
 	addPayload := generateAddPayload()
 	removePayload := generateRemovePayload()
 	for {
+		<-time.After(*delayFlag)
 		fmt.Println("< write add")
 		_, err := io.Copy(conn, bytes.NewReader(addPayload))
 		if err != nil {
 			closeChan <- err
 			return
 		}
-		<-time.After(*delayFlag)
 
+		<-time.After(*delayFlag)
 		fmt.Println("< write remove")
 		_, err = io.Copy(conn, bytes.NewReader(removePayload))
 		if err != nil {
 			closeChan <- err
 			return
 		}
-		<-time.After(*delayFlag)
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -74,21 +74,21 @@ func writeConn(conn *net.TCPConn, closeChan chan<- error) {`
`74`	`74`	`addPayload := generateAddPayload()`
`75`	`75`	`removePayload := generateRemovePayload()`
`76`	`76`	`for {`
	`77`	`+ <-time.After(*delayFlag)`
`77`	`78`	`fmt.Println("< write add")`
`78`	`79`	`_, err := io.Copy(conn, bytes.NewReader(addPayload))`
`79`	`80`	`if err != nil {`
`80`	`81`	`closeChan <- err`
`81`	`82`	`return`
`82`	`83`	`}`
`83`		`- <-time.After(*delayFlag)`
`84`	`84`
	`85`	`+ <-time.After(*delayFlag)`
`85`	`86`	`fmt.Println("< write remove")`
`86`	`87`	`_, err = io.Copy(conn, bytes.NewReader(removePayload))`
`87`	`88`	`if err != nil {`
`88`	`89`	`closeChan <- err`
`89`	`90`	`return`
`90`	`91`	`}`
`91`		`- <-time.After(*delayFlag)`
`92`	`92`	`}`
`93`	`93`	`}`
`94`	`94`