|
|
@@ -74,7 +74,7 @@ const publisherGuess = 0.15
|
|
|
var dbWriteSize float64 = numClients * dbSizeFactor * publisherGuess
|
|
|
|
|
|
//this is the number of positions for auditing
|
|
|
-var extraPositions int = 2
|
|
|
+var extraPositions int = 10
|
|
|
var collisionCounter []float64
|
|
|
var clientsConnected float64
|
|
|
|
|
|
@@ -307,6 +307,7 @@ func main() {
|
|
|
|
|
|
round++
|
|
|
|
|
|
+ fmt.Println("Round", round)
|
|
|
fmt.Println("clientsServedPhase1", clientsServedPhase1[round-1])
|
|
|
fmt.Println("clientsServedPhase3", clientsServedPhase3[round-1])
|
|
|
|
|
|
@@ -824,11 +825,6 @@ func phase3(id int, phase []byte, followerConnection net.Conn, wg *sync.WaitGrou
|
|
|
for clientConnection := range phase3Channel {
|
|
|
clientsServedPhase3[round] = clientsServedPhase3[round] + 1
|
|
|
|
|
|
- if clientsServedPhase3[round]%1000 == 0 {
|
|
|
- fmt.Println("clientsServedPhase3", clientsServedPhase3[round])
|
|
|
- fmt.Println("timeTaken", time.Since(startPhase3).Seconds())
|
|
|
- }
|
|
|
-
|
|
|
gotClient[0] = 1
|
|
|
//tells follower that this worker got a clientConnection
|
|
|
writeToWError(followerConnection, gotClient, nil, 0)
|
