From 06a10e18c12d52a2d1b345cc8f10255fc2b30d33 Mon Sep 17 00:00:00 2001 From: 9seconds Date: Wed, 30 May 2018 18:43:00 +0300 Subject: [PATCH] Tune tcp config of telegram connections --- server/telegram.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/server/telegram.go b/server/telegram.go index da7e854..1d36cec 100644 --- a/server/telegram.go +++ b/server/telegram.go @@ -22,17 +22,18 @@ func dialToTelegram(dcIdx int16) (net.Conn, error) { return nil, errors.New("Incorrect DC IDX") } - conn, err := net.Dial("tcp", telegramDCIPs[dcIdx]) + tcpAddr, _ := net.ResolveTCPAddr("tcp", telegramDCIPs[dcIdx]) + conn, err := net.DialTCP("tcp", nil, tcpAddr) if err != nil { return nil, errors.Annotate(err, "Cannot dial") } - // if err := conn.SetKeepAlive(true); err != nil { - // return nil, errors.Annotate(err, "Cannot establish keepalive connection") - // } - // if err := conn.SetKeepAlivePeriod(telegramKeepAlive); err != nil { - // return nil, errors.Annotate(err, "Cannot set keepalive timeout") - // } + if err := conn.SetKeepAlive(true); err != nil { + return nil, errors.Annotate(err, "Cannot establish keepalive connection") + } + if err := conn.SetKeepAlivePeriod(telegramKeepAlive); err != nil { + return nil, errors.Annotate(err, "Cannot set keepalive timeout") + } return conn, nil }