diff options
Diffstat (limited to 'internal/server/server.go')
| -rw-r--r-- | internal/server/server.go | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/internal/server/server.go b/internal/server/server.go index 7956703..2a809fe 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -10,12 +10,14 @@ import ( "codeberg.org/snonux/gorum/internal/vote" ) +const packageStr = "Server" + func Start(ctx context.Context, conf config.Config, quo quorum.Quorum) { go func() { for { - log.Println("Starting server") - if err := run(ctx, conf, quo); err != nil { - log.Println(err) + log.Println(packageStr, "starting") + if err := runServer(ctx, conf, quo); err != nil { + log.Println(packageStr, err) } select { @@ -27,7 +29,7 @@ func Start(ctx context.Context, conf config.Config, quo quorum.Quorum) { }() } -func run(ctx context.Context, conf config.Config, quo quorum.Quorum) error { +func runServer(ctx context.Context, conf config.Config, quo quorum.Quorum) error { serverCtx, cancel := context.WithCancel(ctx) defer cancel() @@ -46,6 +48,6 @@ func run(ctx context.Context, conf config.Config, quo quorum.Quorum) error { return tcpServerRun(serverCtx, conf, func(message string) string { ch <- vote.New(conf, message) - return "ok" + return "ok - I received your message, dear client" }) } |