From cd648ec4b2ca37a79fcebd01f7fae54a76231262 Mon Sep 17 00:00:00 2001 From: "alexandre.hiltcher@etu.unice.fr" Date: Wed, 21 Oct 2020 20:44:36 +0200 Subject: [PATCH] Make channel write non blocking --- main.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/main.go b/main.go index 3c00a38..e306439 100644 --- a/main.go +++ b/main.go @@ -101,10 +101,17 @@ func (service *Service) HandleServiceState(cli *client.Client) (string, error) { } if status == UP { fmt.Printf("- Service %v is up\n", service.name) + fmt.Printf("up %+v\n", time.Now()) if !service.isHandled { + fmt.Printf("not handled %+v\n", time.Now()) go service.stopAfterTimeout(cli) } - service.time <- service.timeout + fmt.Printf("before write %+v\n", time.Now()) + select { + case service.time <- service.timeout: + fmt.Printf("after write %+v\n", time.Now()) + default: + } return "started", nil } else if status == STARTING { fmt.Printf("- Service %v is starting\n", service.name)