summaryrefslogtreecommitdiff
path: root/internal/server/server.go
diff options
context:
space:
mode:
authorKyren223 <Kyren223@proton.me>2025-07-21 13:46:40 +0300
committerKyren223 <Kyren223@proton.me>2025-07-21 13:46:40 +0300
commit5f6845c3997bd5478a1f51a8f108b71afa427a72 (patch)
tree1a713c28657f15715f337286cc770e93d2739fd6 /internal/server/server.go
parent3fcaf100334897e314a86a53576639410055989b (diff)
Added the ability to delete users
Diffstat (limited to 'internal/server/server.go')
-rw-r--r--internal/server/server.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/internal/server/server.go b/internal/server/server.go
index 48d7d38..15c3a7a 100644
--- a/internal/server/server.go
+++ b/internal/server/server.go
@@ -60,7 +60,7 @@ const (
RateLimitCountThresholdMalicious = 10
)
-func getTlsConfig() *tls.Config {
+func getTLSConfig() *tls.Config {
path, ok := os.LookupEnv(CertFile)
if !ok {
// DEV MODE ONLY, DUMMY CERT
@@ -219,7 +219,7 @@ func (s *server) Node() *snowflake.Node {
func (s *server) Run() {
slog.Info("starting eko-server...")
- listener, err := tls.Listen("tcp4", ":"+strconv.Itoa(int(s.Port)), getTlsConfig())
+ listener, err := tls.Listen("tcp4", ":"+strconv.Itoa(int(s.Port)), getTLSConfig())
if err != nil {
slog.Error("error starting server", "error", err)
assert.Abort("see logs")
@@ -286,7 +286,7 @@ func (server *server) handleConnection(conn net.Conn) {
defer conn.Close()
var writerWg sync.WaitGroup
- done := make(chan struct{})
+ writeDone := make(chan struct{})
framer := packet.NewFramer()
sess := session.NewSession(server, addr, cancel, &writerWg)
@@ -306,7 +306,7 @@ func (server *server) handleConnection(conn net.Conn) {
// Writer
go func() {
- defer close(done)
+ defer close(writeDone)
defer conn.Close() // To unblock reader
writeQueue := sess.Read()
@@ -406,7 +406,7 @@ func (server *server) handleConnection(conn net.Conn) {
close(framer.Out) // stop processing
slog.InfoContext(ctx, "reader done, closed framer")
- <-done
+ <-writeDone
}
func processPacket(ctx context.Context, sess *session.Session, pkt packet.Packet) bool {