From 25018527ec18ec2830801983d19e63a0ebf7b263 Mon Sep 17 00:00:00 2001
From: Jimmy Hu <jimmy.hu@dexon.org>
Date: Wed, 9 Jan 2019 15:32:08 +0800
Subject: simulation: fix k8s dmoment issue (#416)

* Handshake with server dmoment
* Start simulation from dMoment
* Update k8s config
---
 simulation/peer-server.go | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'simulation/peer-server.go')

diff --git a/simulation/peer-server.go b/simulation/peer-server.go
index 69ed029..11785f4 100644
--- a/simulation/peer-server.go
+++ b/simulation/peer-server.go
@@ -175,15 +175,18 @@ func (p *PeerServer) mainLoop() {
 // Setup prepares simualtion.
 func (p *PeerServer) Setup(
 	cfg *config.Config) (serverEndpoint interface{}, err error) {
+	dMoment := time.Now().UTC()
 	// Setup transport layer.
 	switch cfg.Networking.Type {
 	case "tcp", "tcp-local":
 		p.trans = test.NewTCPTransportServer(&jsonMarshaller{}, peerPort)
+		dMoment = dMoment.Add(5 * time.Second)
 	case "fake":
 		p.trans = test.NewFakeTransportServer()
 	default:
 		panic(fmt.Errorf("unknown network type: %v", cfg.Networking.Type))
 	}
+	p.trans.SetDMoment(dMoment)
 	p.msgChannel, err = p.trans.Host()
 	if err != nil {
 		return
-- 
cgit v1.2.3