How to use SetDeadline method of conn Package

Best Gauge code snippet using conn.SetDeadline

socks5.go

Source:socks5.go Github

copy

Full Screen

...102 buf = append(buf, byte(len(host)))103 buf = append(buf, host...)104 }105 buf = append(buf, byte(port>>8), byte(port))106 (*s.conn).SetDeadline(time.Now().Add(s.timeout))107 if _, err := (*s.conn).Write(buf); err != nil {108 return errors.New("proxy: failed to write connect request to SOCKS5 proxy at " + s.addr + ": " + err.Error())109 }110 (*s.conn).SetDeadline(time.Time{})111 (*s.conn).SetDeadline(time.Now().Add(s.timeout))112 if _, err := io.ReadFull((*s.conn), buf[:4]); err != nil {113 return errors.New("proxy: failed to read connect reply from SOCKS5 proxy at " + s.addr + ": " + err.Error())114 }115 (*s.conn).SetDeadline(time.Time{})116 failure := "unknown error"117 if int(buf[1]) < len(socks5c.Socks5Errors) {118 failure = socks5c.Socks5Errors[buf[1]]119 }120 if len(failure) > 0 {121 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " failed to connect: " + failure)122 }123 bytesToDiscard := 0124 switch buf[3] {125 case socks5c.ATYP_IPV4:126 bytesToDiscard = net.IPv4len127 case socks5c.ATYP_IPV6:128 bytesToDiscard = net.IPv6len129 case socks5c.ATYP_DOMAIN:130 (*s.conn).SetDeadline(time.Now().Add(s.timeout))131 _, err := io.ReadFull((*s.conn), buf[:1])132 (*s.conn).SetDeadline(time.Time{})133 if err != nil {134 return errors.New("proxy: failed to read domain length from SOCKS5 proxy at " + s.addr + ": " + err.Error())135 }136 bytesToDiscard = int(buf[0])137 default:138 return errors.New("proxy: got unknown address type " + strconv.Itoa(int(buf[3])) + " from SOCKS5 proxy at " + s.addr)139 }140 if cap(buf) < bytesToDiscard {141 buf = make([]byte, bytesToDiscard)142 } else {143 buf = buf[:bytesToDiscard]144 }145 (*s.conn).SetDeadline(time.Now().Add(s.timeout))146 if _, err := io.ReadFull((*s.conn), buf); err != nil {147 return errors.New("proxy: failed to read address from SOCKS5 proxy at " + s.addr + ": " + err.Error())148 }149 (*s.conn).SetDeadline(time.Time{})150 var ip net.IP151 ip = buf152 ipStr := ""153 if bytesToDiscard == net.IPv4len || bytesToDiscard == net.IPv6len {154 if ipv4 := ip.To4(); ipv4 != nil {155 ipStr = ipv4.String()156 } else {157 ipStr = ip.To16().String()158 }159 }160 /​/​log.Printf("%v", ipStr)161 /​/​ Also need to discard the port number162 (*s.conn).SetDeadline(time.Now().Add(s.timeout))163 if _, err := io.ReadFull((*s.conn), buf[:2]); err != nil {164 return errors.New("proxy: failed to read port from SOCKS5 proxy at " + s.addr + ": " + err.Error())165 }166 p := binary.BigEndian.Uint16([]byte{buf[0], buf[1]})167 /​/​log.Printf("%v", p)168 s.udpAddr = net.JoinHostPort(ipStr, fmt.Sprintf("%d", p))169 /​/​log.Printf("%v", s.udpAddr)170 (*s.conn).SetDeadline(time.Time{})171 return nil172}173func (s *ClientConn) SendUDP(data []byte, addr string) (respData []byte, err error) {174 c, err := net.DialTimeout("udp", s.udpAddr, s.timeout)175 if err != nil {176 return177 }178 conn := c.(*net.UDPConn)179 p := socks5c.NewPacketUDP()180 p.Build(addr, data)181 conn.SetDeadline(time.Now().Add(s.timeout))182 conn.Write(p.Bytes())183 conn.SetDeadline(time.Time{})184 buf := make([]byte, 1024)185 conn.SetDeadline(time.Now().Add(s.timeout))186 n, _, err := conn.ReadFrom(buf)187 conn.SetDeadline(time.Time{})188 if err != nil {189 return190 }191 respData = buf[:n]192 return193}194func (s *ClientConn) auth(host string) error {195 /​/​ the size here is just an estimate196 buf := make([]byte, 0, 6+len(host))197 buf = append(buf, socks5c.VERSION_V5)198 if len(s.user) > 0 && len(s.user) < 256 && len(s.password) < 256 {199 buf = append(buf, 2 /​* num auth methods */​, socks5c.Method_NO_AUTH, socks5c.Method_USER_PASS)200 } else {201 buf = append(buf, 1 /​* num auth methods */​, socks5c.Method_NO_AUTH)202 }203 (*s.conn).SetDeadline(time.Now().Add(s.timeout))204 if _, err := (*s.conn).Write(buf); err != nil {205 return errors.New("proxy: failed to write greeting to SOCKS5 proxy at " + s.addr + ": " + err.Error())206 }207 (*s.conn).SetDeadline(time.Time{})208 (*s.conn).SetDeadline(time.Now().Add(s.timeout))209 if _, err := io.ReadFull((*s.conn), buf[:2]); err != nil {210 return errors.New("proxy: failed to read greeting from SOCKS5 proxy at " + s.addr + ": " + err.Error())211 }212 (*s.conn).SetDeadline(time.Time{})213 if buf[0] != 5 {214 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " has unexpected version " + strconv.Itoa(int(buf[0])))215 }216 if buf[1] == 0xff {217 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " requires authentication")218 }219 /​/​ See RFC 1929220 if buf[1] == socks5c.Method_USER_PASS {221 buf = buf[:0]222 buf = append(buf, 1 /​* password protocol version */​)223 buf = append(buf, uint8(len(s.user)))224 buf = append(buf, s.user...)225 buf = append(buf, uint8(len(s.password)))226 buf = append(buf, s.password...)227 (*s.conn).SetDeadline(time.Now().Add(s.timeout))228 if _, err := (*s.conn).Write(buf); err != nil {229 return errors.New("proxy: failed to write authentication request to SOCKS5 proxy at " + s.addr + ": " + err.Error())230 }231 (*s.conn).SetDeadline(time.Time{})232 (*s.conn).SetDeadline(time.Now().Add(s.timeout))233 if _, err := io.ReadFull((*s.conn), buf[:2]); err != nil {234 return errors.New("proxy: failed to read authentication reply from SOCKS5 proxy at " + s.addr + ": " + err.Error())235 }236 (*s.conn).SetDeadline(time.Time{})237 if buf[1] != 0 {238 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " rejected username/​password")239 }240 }241 return nil242}...

Full Screen

Full Screen

client.go

Source:client.go Github

copy

Full Screen

...95 buf = append(buf, byte(len(host)))96 buf = append(buf, host...)97 }98 buf = append(buf, byte(port>>8), byte(port))99 (*s.conn).SetDeadline(time.Now().Add(s.timeout))100 if _, err := (*s.conn).Write(buf); err != nil {101 return errors.New("proxy: failed to write connect request to SOCKS5 proxy at " + s.addr + ": " + err.Error())102 }103 (*s.conn).SetDeadline(time.Time{})104 (*s.conn).SetDeadline(time.Now().Add(s.timeout))105 if _, err := io.ReadFull((*s.conn), buf[:4]); err != nil {106 return errors.New("proxy: failed to read connect reply from SOCKS5 proxy at " + s.addr + ": " + err.Error())107 }108 (*s.conn).SetDeadline(time.Time{})109 failure := "unknown error"110 if int(buf[1]) < len(socks5Errors) {111 failure = socks5Errors[buf[1]]112 }113 if len(failure) > 0 {114 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " failed to connect: " + failure)115 }116 bytesToDiscard := 0117 switch buf[3] {118 case ATYP_IPV4:119 bytesToDiscard = net.IPv4len120 case ATYP_IPV6:121 bytesToDiscard = net.IPv6len122 case ATYP_DOMAIN:123 (*s.conn).SetDeadline(time.Now().Add(s.timeout))124 _, err := io.ReadFull((*s.conn), buf[:1])125 (*s.conn).SetDeadline(time.Time{})126 if err != nil {127 return errors.New("proxy: failed to read domain length from SOCKS5 proxy at " + s.addr + ": " + err.Error())128 }129 bytesToDiscard = int(buf[0])130 default:131 return errors.New("proxy: got unknown address type " + strconv.Itoa(int(buf[3])) + " from SOCKS5 proxy at " + s.addr)132 }133 if cap(buf) < bytesToDiscard {134 buf = make([]byte, bytesToDiscard)135 } else {136 buf = buf[:bytesToDiscard]137 }138 (*s.conn).SetDeadline(time.Now().Add(s.timeout))139 if _, err := io.ReadFull((*s.conn), buf); err != nil {140 return errors.New("proxy: failed to read address from SOCKS5 proxy at " + s.addr + ": " + err.Error())141 }142 (*s.conn).SetDeadline(time.Time{})143 var ip net.IP144 ip = buf145 ipStr := ""146 if bytesToDiscard == net.IPv4len || bytesToDiscard == net.IPv6len {147 if ipv4 := ip.To4(); ipv4 != nil {148 ipStr = ipv4.String()149 } else {150 ipStr = ip.To16().String()151 }152 }153 /​/​log.Printf("%v", ipStr)154 /​/​ Also need to discard the port number155 (*s.conn).SetDeadline(time.Now().Add(s.timeout))156 if _, err := io.ReadFull((*s.conn), buf[:2]); err != nil {157 return errors.New("proxy: failed to read port from SOCKS5 proxy at " + s.addr + ": " + err.Error())158 }159 p := binary.BigEndian.Uint16([]byte{buf[0], buf[1]})160 /​/​log.Printf("%v", p)161 s.UDPAddr = net.JoinHostPort(ipStr, fmt.Sprintf("%d", p))162 /​/​log.Printf("%v", s.udpAddr)163 (*s.conn).SetDeadline(time.Time{})164 return nil165}166func (s *ClientConn) SendUDP(data []byte, addr string) (respData []byte, err error) {167 c, err := net.DialTimeout("udp", s.UDPAddr, s.timeout)168 if err != nil {169 return170 }171 conn := c.(*net.UDPConn)172 p := NewPacketUDP()173 p.Build(addr, data)174 conn.SetDeadline(time.Now().Add(s.timeout))175 conn.Write(p.Bytes())176 conn.SetDeadline(time.Time{})177 buf := make([]byte, 1024)178 conn.SetDeadline(time.Now().Add(s.timeout))179 n, _, err := conn.ReadFrom(buf)180 conn.SetDeadline(time.Time{})181 if err != nil {182 return183 }184 respData = buf[:n]185 return186}187func (s *ClientConn) handshake(host string) error {188 /​/​ the size here is just an estimate189 buf := make([]byte, 0, 6+len(host))190 buf = append(buf, VERSION_V5)191 if len(s.user) > 0 && len(s.user) < 256 && len(s.password) < 256 {192 buf = append(buf, 2 /​* num auth methods */​, Method_NO_AUTH, Method_USER_PASS)193 } else {194 buf = append(buf, 1 /​* num auth methods */​, Method_NO_AUTH)195 }196 (*s.conn).SetDeadline(time.Now().Add(s.timeout))197 if _, err := (*s.conn).Write(buf); err != nil {198 return errors.New("proxy: failed to write greeting to SOCKS5 proxy at " + s.addr + ": " + err.Error())199 }200 (*s.conn).SetDeadline(time.Time{})201 (*s.conn).SetDeadline(time.Now().Add(s.timeout))202 if _, err := io.ReadFull((*s.conn), buf[:2]); err != nil {203 return errors.New("proxy: failed to read greeting from SOCKS5 proxy at " + s.addr + ": " + err.Error())204 }205 (*s.conn).SetDeadline(time.Time{})206 if buf[0] != 5 {207 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " has unexpected version " + strconv.Itoa(int(buf[0])))208 }209 if buf[1] == 0xff {210 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " requires authentication")211 }212 /​/​ See RFC 1929213 if buf[1] == Method_USER_PASS {214 buf = buf[:0]215 buf = append(buf, 1 /​* password protocol version */​)216 buf = append(buf, uint8(len(s.user)))217 buf = append(buf, s.user...)218 buf = append(buf, uint8(len(s.password)))219 buf = append(buf, s.password...)220 (*s.conn).SetDeadline(time.Now().Add(s.timeout))221 if _, err := (*s.conn).Write(buf); err != nil {222 return errors.New("proxy: failed to write authentication request to SOCKS5 proxy at " + s.addr + ": " + err.Error())223 }224 (*s.conn).SetDeadline(time.Time{})225 (*s.conn).SetDeadline(time.Now().Add(s.timeout))226 if _, err := io.ReadFull((*s.conn), buf[:2]); err != nil {227 return errors.New("proxy: failed to read authentication reply from SOCKS5 proxy at " + s.addr + ": " + err.Error())228 }229 (*s.conn).SetDeadline(time.Time{})230 if buf[1] != 0 {231 return errors.New("proxy: SOCKS5 proxy at " + s.addr + " rejected username/​password")232 }233 }234 return nil235}...

Full Screen

Full Screen

handshake.go

Source:handshake.go Github

copy

Full Screen

...93 C2 := C0C1C2[1536+1:]94 S0S1S2 := random[1536*2+1:]95 C0[0] = 396 /​/​ > C0C197 conn.Conn.SetDeadline(time.Now().Add(timeout))98 if _, err = conn.rw.Write(C0C1); err != nil {99 return100 }101 conn.Conn.SetDeadline(time.Now().Add(timeout))102 if err = conn.rw.Flush(); err != nil {103 return104 }105 /​/​ < S0S1S2106 conn.Conn.SetDeadline(time.Now().Add(timeout))107 if _, err = io.ReadFull(conn.rw, S0S1S2); err != nil {108 return109 }110 S1 := S0S1S2[1 : 1536+1]111 if ver := pio.U32BE(S1[4:8]); ver != 0 {112 C2 = S1113 } else {114 C2 = S1115 }116 /​/​ > C2117 conn.Conn.SetDeadline(time.Now().Add(timeout))118 if _, err = conn.rw.Write(C2); err != nil {119 return120 }121 conn.Conn.SetDeadline(time.Time{})122 return123}124func (conn *Conn) HandshakeServer() (err error) {125 var random [(1 + 1536*2) * 2]byte126 C0C1C2 := random[:1536*2+1]127 C0 := C0C1C2[:1]128 C1 := C0C1C2[1 : 1536+1]129 C0C1 := C0C1C2[:1536+1]130 C2 := C0C1C2[1536+1:]131 S0S1S2 := random[1536*2+1:]132 S0 := S0S1S2[:1]133 S1 := S0S1S2[1 : 1536+1]134 S0S1 := S0S1S2[:1536+1]135 S2 := S0S1S2[1536+1:]136 /​/​ < C0C1137 conn.Conn.SetDeadline(time.Now().Add(timeout))138 if _, err = io.ReadFull(conn.rw, C0C1); err != nil {139 return140 }141 conn.Conn.SetDeadline(time.Now().Add(timeout))142 if C0[0] != 3 {143 err = fmt.Errorf("rtmp: handshake version=%d invalid", C0[0])144 return145 }146 S0[0] = 3147 clitime := pio.U32BE(C1[0:4])148 srvtime := clitime149 srvver := uint32(0x0d0e0a0d)150 cliver := pio.U32BE(C1[4:8])151 if cliver != 0 {152 var ok bool153 var digest []byte154 if ok, digest = hsParse1(C1, hsClientPartialKey, hsServerFullKey); !ok {155 err = fmt.Errorf("rtmp: handshake server: C1 invalid")156 return157 }158 hsCreate01(S0S1, srvtime, srvver, hsServerPartialKey)159 hsCreate2(S2, digest)160 } else {161 copy(S1, C2)162 copy(S2, C1)163 }164 /​/​ > S0S1S2165 conn.Conn.SetDeadline(time.Now().Add(timeout))166 if _, err = conn.rw.Write(S0S1S2); err != nil {167 return168 }169 conn.Conn.SetDeadline(time.Now().Add(timeout))170 if err = conn.rw.Flush(); err != nil {171 return172 }173 /​/​ < C2174 conn.Conn.SetDeadline(time.Now().Add(timeout))175 if _, err = io.ReadFull(conn.rw, C2); err != nil {176 return177 }178 conn.Conn.SetDeadline(time.Time{})179 return180}...

Full Screen

Full Screen

SetDeadline

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 conn, err := net.Dial("tcp", "www.google.com:80")4 if err != nil {5 fmt.Println(err)6 }7 conn.SetDeadline(time.Now().Add(1 * time.Second))8 fmt.Println("Connected to server")9 defer conn.Close()10}

Full Screen

Full Screen

SetDeadline

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 conn, err := net.Dial("tcp", "localhost:8080")4 if err != nil {5 fmt.Println(err)6 }7 defer conn.Close()8 conn.SetDeadline(time.Now().Add(10 * time.Second))9 for {10 n, err := conn.Read(buf[0:])11 if err != nil {12 fmt.Println(err)13 }14 fmt.Println(string(buf[0:n]))15 }16}

Full Screen

Full Screen

SetDeadline

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 fmt.Println("Starting the server ...")4 ln, err := net.Listen("tcp", ":8081")5 if err != nil {6 fmt.Println(err)7 }8 for {9 conn, err := ln.Accept()10 if err != nil {11 fmt.Println(err)12 }13 conn.SetDeadline(time.Now().Add(5 * time.Second))14 go handleRequest(conn)15 }16}17func handleRequest(conn net.Conn) {18 buf := make([]byte, 1024)19 reqLen, err := conn.Read(buf)20 if err != nil {21 fmt.Println("Error reading:", err.Error())22 }23 if reqLen > 0 {24 fmt.Printf("Received data: %v25", string(buf))26 }27 conn.Close()28}

Full Screen

Full Screen

SetDeadline

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 conn, err := net.DialTimeout("tcp", "golang.org:80", 5 * time.Second)4 if err != nil {5 fmt.Println(err)6 }7 defer conn.Close()8 conn.SetDeadline(time.Now().Add(10 * time.Second))9 conn.SetReadDeadline(time.Now().Add(5 * time.Second))10 conn.SetWriteDeadline(time.Now().Add(5 * time.Second))11}12The SetDeadline method of the net.Listener class takes a time.Time type value as an argument. The time.Time type value can be created by using the time.Now() function. The time.Now() function returns the current time. The time.Now().Add() function adds the specified duration to the current time and returns the time.Time type value. The time.Duration type value can be created by using the

Full Screen

Full Screen

SetDeadline

Using AI Code Generation

copy

Full Screen

1func main() {2 ln, err := net.Listen("tcp", ":8080")3 if err != nil {4 }5 for {6 conn, err := ln.Accept()7 if err != nil {8 }9 conn.SetDeadline(time.Now().Add(2 * time.Second))10 reader := bufio.NewReader(conn)11 str, err := reader.ReadString('12 if err != nil {13 }14 fmt.Print("Message Received:", string(str))15 newmessage := strings.ToUpper(str)16 conn.Write([]byte(newmessage + "17 }18}19I hope this article helped you to understand how to use SetDeadline() method of conn class in Golang. If you have any doubts, please leave a comment below. Thanks for reading!20Recommended Posts: Golang | net.Conn.Write() Method21Golang | net.Conn.Read() Method22Golang | net.Conn.LocalAddr() Method23Golang | net.Conn.RemoteAddr() Method24Golang | net.Conn.SetDeadline() Method25Golang | net.Conn.SetReadDeadline() Method26Golang | net.Conn.SetWriteDeadline() Method27Golang | net.Dial() Method28Golang | net.DialTimeout() Method29Golang | net.DialUDP() Method30Golang | net.DialTCP() Method31Golang | net.DialUnix() Method32Golang | net.LookupAddr() Method33Golang | net.LookupCNAME() Method34Golang | net.LookupHost() Method35Golang | net.LookupIP() Method36Golang | net.LookupMX() Method37Golang | net.LookupNS() Method38Golang | net.LookupPort() Method39Golang | net.LookupSRV() Method40Golang | net.LookupTXT() Method41Golang | net.ParseCIDR() Method42Golang | net.ParseIP() Method43Golang | net.ParseMAC() Method44Golang | net.ParseUnixAddr() Method45Golang | net.Pipe() Method

Full Screen

Full Screen

SetDeadline

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 conn, err := net.Dial("tcp", "localhost:6000")4 if err != nil {5 fmt.Println(err)6 }7 defer conn.Close()8 conn.SetDeadline(time.Now().Add(2 * time.Second))9 req := make([]byte, 4096)10 _, err = conn.Read(req)11 if err != nil {12 fmt.Println("Error reading:", err.Error())13 }14}15import (16func main() {17 conn, err := net.Dial("tcp", "localhost:6000")18 if err != nil {19 fmt.Println(err)20 }21 defer conn.Close()22 conn.SetReadDeadline(time.Now().Add(2 * time.Second))23 req := make([]byte, 4096)24 _, err = conn.Read(req)25 if err != nil {26 fmt.Println("Error reading:", err.Error())27 }28}29import (30func main() {31 conn, err := net.Dial("tcp", "localhost:6000")32 if err != nil {33 fmt.Println(err)34 }35 defer conn.Close()

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Gauge automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful