ping pong TLS

actor/deadletter.go

@@ -32,7 +32,7 @@ func (d *deadLetter) Receive(ctx *Context) {
 	case Initialized:
 		slog.Debug("default deadletter actor initialized")
 	case *DeadLetterEvent:
-		slog.Warn("deadletter arrived", "msg-type", reflect.TypeOf(msg),
+		slog.Warn("[DEADLETTER]", "msg", reflect.TypeOf(msg.Message),
 			"sender", msg.Sender, "target", msg.Target, "msg", msg.Message)
 	default:
 		slog.Error("unknown message arrived at deadletter", "msg", msg)

actor/response.go

@@ -2,6 +2,7 @@ package actor
 
 import (
 	"context"
+	"math"
 	"math/rand"
 	"strconv"
 	"sync"
@@ -20,7 +21,7 @@ func NewResponse(e *Engine, timeout time.Duration) *Response {
 		engine:  e,
 		result:  make(chan any, 1),
 		timeout: timeout,
-		pid:     NewPID(e.address, "response", strconv.Itoa(rand.Intn(100000))),
+		pid:     NewPID(e.address, "response", strconv.Itoa(rand.Intn(math.MaxInt))),
 	}
 }
 

cluster/agent.go

@@ -1,7 +1,6 @@
 package cluster
 
 import (
-	fmt "fmt"
 	"log/slog"
 
 	"github.com/anthdm/hollywood/actor"
@@ -33,9 +32,6 @@ func (a *Agent) handleMembers(members []*Member) {
 	joined := NewMemberSet(members...).Except(a.members.Slice())
 	left := a.members.Except(members)
 
-	fmt.Println("joined", joined)
-	fmt.Println("left", left)
-
 	for _, member := range joined {
 		a.memberJoin(member)
 	}

cluster/selfmanaged.go

@@ -1,7 +1,6 @@
 package cluster
 
 import (
-	fmt "fmt"
 	"log/slog"
 	"time"
 
@@ -63,25 +62,25 @@ func (s *SelfManaged) Receive(c *actor.Context) {
 			s.cluster.engine.Send(s.cluster.PID(), members)
 		}
 	case memberPing:
-		fmt.Println("pinging all the members", s.members.Len())
+		// fmt.Println("pinging all the members", s.members.Len())
 		s.members.ForEach(func(member *Member) bool {
 			ping := &actor.Ping{
 				From: c.PID(),
 			}
-			_, err := c.Request(memberToProviderPID(member), ping, time.Millisecond*100).Result()
+			pong, err := c.Request(memberToProviderPID(member), ping, time.Millisecond*1000).Result()
 			if err != nil {
 				slog.Error("member ping failed", "err", err, "memberID", member.ID)
 				s.removeMember(member)
 			}
 			// TODO: Something is not quite right here!
-			// if _, ok := pong.(*actor.Pong); !ok {
-			// 	slog.Error("member ping failed", "err", err, "memberID", member.ID)
-			// 	s.removeMember(member)
-			// }
+			if _, ok := pong.(*actor.Pong); !ok {
+				slog.Error("member ping failed", "err", err, "memberID", member.ID)
+				s.removeMember(member)
+			}
 			return true
 		})
 	case *actor.Ping:
-		// c.Respond(&actor.Pong{From: c.PID()})
+		c.Respond(&actor.Pong{From: c.PID()})
 	}
 }