Change to WriteMsgUDP within AddPeer method

main_test.go

@@ -74,7 +74,7 @@ func emulatedKMS(myName string, myUDPAddr string, peerUDPAddr string) {
 		return
 	}
 
-	myQL.QuantumElementLink.AddPeer(*udpQL2Addr)
+	myQL.QuantumElementLink.AddPeer(udpQL2Addr)
 
 	// Start the SDN/management and key retrieval interface
 	go kms.StartETSI(peerUDPAddr, emuKMS)

quantumlayer/quantumlayer-emu-prng.go

@@ -150,7 +150,7 @@ func (qlemuprng *QuantumlayerEmuPRNG) PowerOff() {
 	log.Println("QuantumlayerEmuPRNG is powered off...discharging.")
 }
 
-func (qlemuprng *QuantumlayerEmuPRNG) AddPeer(addr net.UDPAddr) {
+func (qlemuprng *QuantumlayerEmuPRNG) AddPeer(addr *net.UDPAddr) {
 	if qlemuprng.poweron == false {
 		return
 	}
@@ -184,7 +184,7 @@ func (qlemuprng *QuantumlayerEmuPRNG) AddPeer(addr net.UDPAddr) {
 						log.Printf("json.Marshal error %s", err)
 					}
 
-					_, _, err = qlemuprng.udpSrvConn.WriteMsgUDPAddrPort(jsonPayload, nil, addr.AddrPort())
+					_, _, err = qlemuprng.udpSrvConn.WriteMsgUDP(jsonPayload, nil, addr)
 					if err != nil {
 						log.Fatalf("WriteMsgUDPAddrPort failed: %s", err)
 					}

quantumlayer/quantumlayer-emu-prng_test.go

@@ -35,8 +35,8 @@ func TestQuantumLayer(t *testing.T) {
 		return
 	}
 
-	ql1.AddPeer(*udpQL2Addr)
-	ql2.AddPeer(*udpQL1Addr)
+	ql1.AddPeer(udpQL2Addr)
+	ql2.AddPeer(udpQL1Addr)
 
 	for n := 0; n < 2; n++ {
 		resultQl1, err := ql1.GetKeyBatchPeer()
@@ -59,5 +59,4 @@ func TestQuantumLayer(t *testing.T) {
 		time.Sleep(5 * time.Second)
 
 	}
-
 }