Function normalReconnActiveReconn

agent/process/offline.go:232–310

(options *initial.Options, proxy share.Proxy)

}

func normalReconnActiveReconn(options *initial.Options, proxy share.Proxy) net.Conn {
	var sMessage, rMessage protocol.Message

	hiMess := &protocol.HIMess{
		GreetingLen: uint16(len("Shhh...")),
		Greeting:    "Shhh...",
		UUIDLen:     uint16(len(global.G_Component.UUID)),
		UUID:        global.G_Component.UUID,
		IsAdmin:     0,
		IsReconnect: 1,
	}

	header := &protocol.Header{
		Sender:      global.G_Component.UUID,
		Accepter:    protocol.ADMIN_UUID,
		MessageType: protocol.HI,
		RouteLen:    uint32(len([]byte(protocol.TEMP_ROUTE))),
		Route:       protocol.TEMP_ROUTE,
	}

	for {
		var (
			conn net.Conn
			err  error
		)

		if proxy == nil {
			conn, err = net.Dial("tcp", options.Connect)
		} else {
			conn, err = proxy.Dial()
		}

		if err != nil {
			time.Sleep(time.Duration(options.Reconnect) * time.Second)
			continue
		}

		if err := share.ActivePreAuth(conn); err != nil {
			conn.Close()
			time.Sleep(time.Duration(options.Reconnect) * time.Second)
			continue
		}

		if global.G_TLSEnable {
			var tlsConfig *tls.Config
			tlsConfig, err = transport.NewClientTLSConfig(options.Domain)
			if err != nil {
				conn.Close()
				time.Sleep(time.Duration(options.Reconnect) * time.Second)
				continue
			}
			conn = transport.WrapTLSClientConn(conn, tlsConfig)
		}

		sMessage = protocol.PrepareAndDecideWhichSProtoToUpper(conn, options.Secret, protocol.TEMP_UUID)

		protocol.ConstructMessage(sMessage, header, hiMess, false)
		sMessage.SendMessage()