From 18ca93effe37754b6642462325df02be37eb75ae Mon Sep 17 00:00:00 2001 From: bt Date: Sun, 8 Mar 2026 01:19:47 +0100 Subject: Ping and pong --- cmd/client/main.go | 20 +++++++++++++------- cmd/daemon/main.go | 6 ++---- 2 files changed, 15 insertions(+), 11 deletions(-) (limited to 'cmd') diff --git a/cmd/client/main.go b/cmd/client/main.go index 244e543..a229632 100644 --- a/cmd/client/main.go +++ b/cmd/client/main.go @@ -4,6 +4,7 @@ import ( "flag" "log" "net" + "time" "git.sr.ht/~rctt/solecd/core" ) @@ -18,16 +19,21 @@ func main() { conn, err := d.Dial("tcp", serverAddr) if err != nil { - log.Fatalf("cannot dial", err) + log.Fatal("cannot dial: ", err) } defer conn.Close() - for { - d, err := core.Read(conn) - if err != nil { - log.Fatalf("cannot read data: %v", err) - } + go ping(conn) + if err := core.Loop(conn); err != nil { + log.Fatal("event loop error ", err) + } +} - log.Print(d) +func ping(conn net.Conn) { + for { + log.Print("ping") + p := core.Ping{} + core.Send(conn, core.TypePing, p) + time.Sleep(time.Second) } } diff --git a/cmd/daemon/main.go b/cmd/daemon/main.go index ad503c5..b344caf 100644 --- a/cmd/daemon/main.go +++ b/cmd/daemon/main.go @@ -45,9 +45,7 @@ func handle(conn net.Conn) { return } - test := core.Test{Message: "solec kujawski jest zajebisty"} - if err := core.Send(conn, core.TypeTest, test); err != nil { - log.Print("cannot send test message ", err) - return + if err := core.Loop(conn); err != nil { + log.Fatal("event loop error ", err) } } -- cgit v1.2.3