bug fix port

src/crane/worker.go

@@ -165,7 +165,8 @@ func sendProcessedData(tuple []interface{}, bolt BoltInfo) {
 		}
 		//fmt.Printf("Data send to %v\n", masterServNum)
 		data := Data{ID: 0, Tuple: tuple}
-		sendDataToWorker(data, masterServNum)
+		port := strconv.Itoa(shared.CraneDataCollectionPort)
+		sendDataToWorker(data, masterServNum, port)
 	} else {
 		for _, child := range bolt.Children {
 			// Construct data to be sent
@@ -173,15 +174,16 @@ func sendProcessedData(tuple []interface{}, bolt BoltInfo) {
 			// Find correct servNum
 			servNum := child.ServNum
 			// Send data
+			port := strconv.Itoa(shared.CraneWorkerPort)
 			sendDataToWorker(data, servNum)
 		}
 	}
 }
 
-func sendDataToWorker(data Data, servNum int) {
+func sendDataToWorker(data Data, servNum int, port string) {
 	// Established connection if haven't done that yet
 	if _, ok := servNumWorker[servNum]; !ok {
-		conn, err := net.Dial("tcp", shared.GetServerAddressFromNumber(servNum)+":"+strconv.Itoa(shared.CraneWorkerPort))
+		conn, err := net.Dial("tcp", shared.GetServerAddressFromNumber(servNum)+":"+port)
 		if err != nil {
 			panic(err)
 		}