rua

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()

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