From 0d82218c8da36eff2879c5cbf70104b929953608 Mon Sep 17 00:00:00 2001
From: Xinyuv <li.cynthia.f@gmail.com>
Date: Mon, 3 Dec 2018 01:43:53 -0600
Subject: [PATCH] rua
---
src/crane/crane_master.go | 2 +-
src/shared/shared.go | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/crane/crane_master.go b/src/crane/crane_master.go
index 5189944..92a4b2c 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 135f5de..816e637 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
--
GitLab