diff options
| author | Jimmy Hu <jimmy.hu@dexon.org> | 2019-01-09 15:32:08 +0800 |
|---|---|---|
| committer | Wei-Ning Huang <w@dexon.org> | 2019-01-09 15:32:08 +0800 |
| commit | 25018527ec18ec2830801983d19e63a0ebf7b263 (patch) | |
| tree | 6c6f1bc251b24da1fd9d6df7375f931fbae35a00 /simulation/peer-server.go | |
| parent | c62ce07468cea07035ddcad3c89b0a5c0b25746a (diff) | |
| download | tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.gz tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.bz2 tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.lz tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.xz tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.tar.zst tangerine-consensus-25018527ec18ec2830801983d19e63a0ebf7b263.zip | |
simulation: fix k8s dmoment issue (#416)
* Handshake with server dmoment
* Start simulation from dMoment
* Update k8s config
Diffstat (limited to 'simulation/peer-server.go')
| -rw-r--r-- | simulation/peer-server.go | 3 |
1 files changed, 3 insertions, 0 deletions
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 |