common

Documentation

Index

• Constants
• Variables
• func DelAllCacheContainer()
• func DelCacheContainer(key string)
• func GetCacheContainer(key string) *cacheContainer
• func GetClientInfoByConn(conn net.Conn, cb_ok func(*ClientInfo), cb_fail func())
• func GetClientInfoByName(ServerName string, cb_ok func(*ClientInfo), cb_fail func())
• func GetId(name string) string
• func GetOnlineServiceNumByName(userName string) int
• func GetOnlineServiceNumByNameAndIP(userName, ip string) int
• func GetServerInfoByConn(conn net.Conn, cb_ok func(*ClientInfo), cb_fail func())
• func HashPasswd(pass string) string
• func Id_test(name string)
• func Md5(msg string) string
• func Read(conn net.Conn, callback ReadCallBack)
• func ReadFromUDP(conn *net.UDPConn, addr *net.UDPAddr, data []byte, callback ReadUDPCallBack) bool
• func RmId(name, id string)
• func Write(conn net.Conn, id string, action string, content string) error
• type AdminInfo
• type ClientInfo
  • func (s *ClientInfo) AddClient(conn net.Conn, clientInfo ClientSetting)
  • func (s *ClientInfo) DelClient(conn net.Conn) string
  • func (s *ClientInfo) GetSession(conn net.Conn) *Session
  • func (s *ClientInfo) Loop()
• type ClientSetting
• type ReadCallBack
• type ReadUDPCallBack
• type Session
  • func (session *Session) Down()
  • func (session *Session) Loop()
  • func (session *Session) RestartSession(ServerName string)
  • func (session *Session) StartCSMode()
  • func (session *Session) StartSession(n int, ServerName, sessionId string)
  • func (session *Session) String() string
• type UDPMakeSession
  • func (udpsession *UDPMakeSession) BeginMakeHole(step int, content string)
  • func (udpsession *UDPMakeSession) Loop()
  • func (udpsession *UDPMakeSession) Remove(bTimeout bool)

Constants

const Version = 0.50

Variables

var Conn2Admin map[net.Conn]*AdminInfo

var Conn2ClientInfo map[net.Conn]*ClientInfo

var ServerName2Conn map[string]net.Conn

Functions

func DelAllCacheContainer

func DelAllCacheContainer()

func DelCacheContainer

func DelCacheContainer(key string)

func GetCacheContainer

func GetCacheContainer(key string) *cacheContainer

func GetClientInfoByConn

func GetClientInfoByConn(conn net.Conn, cb_ok func(*ClientInfo), cb_fail func())

func GetClientInfoByName

func GetClientInfoByName(ServerName string, cb_ok func(*ClientInfo), cb_fail func())

func GetId

func GetId(name string) string

func GetOnlineServiceNumByName

func GetOnlineServiceNumByName(userName string) int

func GetOnlineServiceNumByNameAndIP

func GetOnlineServiceNumByNameAndIP(userName, ip string) int

func GetServerInfoByConn

func GetServerInfoByConn(conn net.Conn, cb_ok func(*ClientInfo), cb_fail func())

func HashPasswd

func HashPasswd(pass string) string

func Id_test

func Id_test(name string)

func Md5

func Md5(msg string) string

func Read

func Read(conn net.Conn, callback ReadCallBack)

func ReadFromUDP

func ReadFromUDP(conn *net.UDPConn, addr *net.UDPAddr, data []byte, callback ReadUDPCallBack) bool

udp

func RmId

func RmId(name, id string)

func Write

func Write(conn net.Conn, id string, action string, content string) error

Types

type AdminInfo

type AdminInfo struct {
	Conn net.Conn
}

type ClientInfo

type ClientInfo struct {
	Conn       net.Conn
	ClientMap  map[net.Conn]*Session
	Id2Session map[string]*Session

	UserName  string
	ClientKey string

	ResponseTime int64

	Quit chan bool

	IsServer       bool
	ServerName     string // is serverName != "", this client is a server!
	Id2MakeSession map[string]*UDPMakeSession
}

func (*ClientInfo) AddClient

func (s *ClientInfo) AddClient(conn net.Conn, clientInfo ClientSetting)

func (*ClientInfo) DelClient

func (s *ClientInfo) DelClient(conn net.Conn) string

func (*ClientInfo) GetSession

func (s *ClientInfo) GetSession(conn net.Conn) *Session

func (*ClientInfo) Loop

func (s *ClientInfo) Loop()

type ClientSetting

type ClientSetting struct {
	AccessKey string
	ClientKey string

	Name       string
	ClientType string
	Version    float32
	Delay      int
	Mode       int
	PipeNum    int
	AesKey     string
}

type ReadCallBack

type ReadCallBack func(conn net.Conn, id string, action string, arg string)

type ReadUDPCallBack

type ReadUDPCallBack func(conn *net.UDPConn, addr *net.UDPAddr, id string, action string, arg string)

type Session

type Session struct {
	Id                string
	ClientA           net.Conn
	ClientB           net.Conn
	Status            string
	OverTime          int64
	Method            string
	Setting           ClientSetting
	MakeHoleResponseN int
	MakeHoleHasFail   bool
	Quit              chan bool
}

func (*Session) Down

func (session *Session) Down()

func (*Session) Loop

func (session *Session) Loop()

func (*Session) RestartSession

func (session *Session) RestartSession(ServerName string)

func (*Session) StartCSMode

func (session *Session) StartCSMode()

func (*Session) StartSession

func (session *Session) StartSession(n int, ServerName, sessionId string)

func (*Session) String

func (session *Session) String() string

type UDPMakeSession

type UDPMakeSession struct {
	Id         string
	CreateTime int64
	ClientA    net.Conn
	ClientB    net.Conn
	SessionId  string
	PipeType   string
	Status     string
	ServerName string
	Quit       chan bool
}

func (*UDPMakeSession) BeginMakeHole

func (udpsession *UDPMakeSession) BeginMakeHole(step int, content string)

func (*UDPMakeSession) Loop

func (udpsession *UDPMakeSession) Loop()

func (*UDPMakeSession) Remove

func (udpsession *UDPMakeSession) Remove(bTimeout bool)