Documentation ¶
Index ¶
- Constants
- type FConn
- func (this *FConn) Close() error
- func (this *FConn) Desc() string
- func (this *FConn) ErrClose(err error)
- func (this *FConn) LocalAddr() net.Addr
- func (this *FConn) Read(b []byte) (n int, err error)
- func (this *FConn) RecvFromSM(msg []byte)
- func (this *FConn) RemoteAddr() net.Addr
- func (this *FConn) SendToSM(msg []byte)
- func (this *FConn) SetDeadline(t time.Time) error
- func (this *FConn) SetReadDeadline(t time.Time) error
- func (this *FConn) SetTimeOut(t time.Duration)
- func (this *FConn) SetWriteDeadline(t time.Time) error
- func (this *FConn) Write(b []byte) (n int, err error)
- type FConnFactory
- type ForwardConnItf
- type ServiceManager
- func (this *ServiceManager) Close()
- func (this *ServiceManager) Drop(no int64)
- func (this *ServiceManager) GetFConn(no int64) (ForwardConnItf, bool)
- func (this *ServiceManager) Regitster(no int64, desc string) (conn ForwardConnItf, isExist bool)
- func (this *ServiceManager) Send(p *smn_base.FPkg)
- func (this *ServiceManager) Work()
Constants ¶
View Source
const (
//ErrServerNumNotExist don's exist that server num.
ErrServerNumNotExist = "ErrServerNumNotExist :[%d]"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FConn ¶
type FConn struct {
// contains filtered or unexported fields
}
func (*FConn) RecvFromSM ¶
func (*FConn) RemoteAddr ¶
func (*FConn) SetTimeOut ¶
type FConnFactory ¶
type FConnFactory func(no int64, mgr *ServiceManager, desc string, localAddr, remoteAddr net.Addr) ForwardConnItf
FConnFactory .
type ForwardConnItf ¶
type ServiceManager ¶
type ServiceManager struct { OnErr smn_err.OnErr TimeOut time.Duration FConnFactory FConnFactory // contains filtered or unexported fields }
ServiceManager .
func NewServiceManager ¶
func NewServiceManager(conn net.Conn) *ServiceManager
func (*ServiceManager) Close ¶
func (this *ServiceManager) Close()
func (*ServiceManager) Drop ¶
func (this *ServiceManager) Drop(no int64)
func (*ServiceManager) GetFConn ¶
func (this *ServiceManager) GetFConn(no int64) (ForwardConnItf, bool)
func (*ServiceManager) Regitster ¶
func (this *ServiceManager) Regitster(no int64, desc string) (conn ForwardConnItf, isExist bool)
func (*ServiceManager) Send ¶
func (this *ServiceManager) Send(p *smn_base.FPkg)
func (*ServiceManager) Work ¶
func (this *ServiceManager) Work()
Click to show internal directories.
Click to hide internal directories.