Merge pull request #29 from ldsec/timeouts

Added timeouts for channels

app/medco.go

@@ -24,6 +24,9 @@ const (
 	optionConfig      = "config"
 	optionConfigShort = "c"
 
+	optionTimeout      = "timeout"
+	optionTimeoutShort = "t"
+
 	optionGroupFile      = "file"
 	optionGroupFileShort = "f"
 
@@ -122,6 +125,12 @@ func main() {
 			Name:  optionConfig + ", " + optionConfigShort,
 			Usage: "Configuration file of the server",
 		},
+		cli.Int64Flag{
+			Name:     optionTimeout + ", " + optionTimeoutShort,
+			Usage:    "Communication timeout (in minutes)",
+			Required: false,
+			Value:    20,
+		},
 	}
 
 	nonInteractiveSetupFlags := []cli.Flag{

app/server.go

@@ -1,6 +1,9 @@
 package main
 
 import (
+	servicesmedco "github.com/ldsec/medco-unlynx/services"
+	"time"
+
 	// Empty imports to have the init-functions called which should
 	// register the protocol
 	_ "github.com/ldsec/medco-unlynx/services"
@@ -12,8 +15,10 @@ import (
 func runServer(ctx *cli.Context) error {
 	// first check the options
 	config := ctx.String("config")
+	timeout := ctx.Int64("timeout")
 
 	app.RunServer(config)
 
+	servicesmedco.TimeoutService = time.Duration(timeout) * time.Minute
 	return nil
 }