[fix ]: worker wait 0.5sec then stop the grpc server after receive th…

…e End signal Signed-off-by: Bo-Wei Chen(BWbwchen) <tim.chenbw@gmail.com>
BWbwchen · Nov 7, 2023 · c7bab39 · c7bab39
1 parent bde2b11
commit c7bab39
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/worker/mainInterface.go b/worker/mainInterface.go
@@ -4,6 +4,7 @@ import (
 	"net"
 	"os"
 	"plugin"
+	"time"
 
 	"github.com/BWbwchen/MapReduce/rpc"
 	log "github.com/sirupsen/logrus"
@@ -41,6 +42,7 @@ func StartWorker(pluginFile string, nReduce int, addr string, storeInRAM bool) {
 	defer workerStruct.Client.(*masterClient).conn.Close()
 
 	<-workerStruct.EndChan
+	time.Sleep(500 * time.Millisecond)
 	baseServer.Stop()
 }