diff --git a/src/crane/crane_master.go b/src/crane/crane_master.go index 518994427f7c3f4b70c017b6305b26680b9efb16..92a4b2cc7bde30b54ca1dac16ce366570c5e6018 100644 --- a/src/crane/crane_master.go +++ b/src/crane/crane_master.go @@ -374,7 +374,7 @@ func runSpout() { fmt.Println("New job started running...") scanner := bufio.NewScanner(file) for scanner.Scan() { - time.Sleep(shared.CraneSpoutInterval) + // time.Sleep(shared.CraneSpoutInterval) // activeListMux.Lock() // fmt.Println(activeList) // activeListMux.Unlock() diff --git a/src/shared/shared.go b/src/shared/shared.go index 135f5deadc8566aa995df772643cd5f4458400fa..816e6370ec408d1b27ac418115bc23a53d991aef 100644 --- a/src/shared/shared.go +++ b/src/shared/shared.go @@ -44,7 +44,7 @@ const NumFileReplicas = 4 // How long to wait to get the membership list from the introducer const IntroducerTimeout = 3 * time.Second const GrepTimeout = 5 * time.Second -const ACKTimeout = 6000 * time.Millisecond +const ACKTimeout = 4000 * time.Millisecond const PingInterval = 6000 * time.Millisecond // Simulate false positives by dropping packets before they are sent out