1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- package proxy
- import (
- "github.com/fatedier/frp/pkg/config"
- )
- type STCPProxy struct {
- *BaseProxy
- cfg *config.STCPProxyConf
- }
- func (pxy *STCPProxy) Run() (remoteAddr string, err error) {
- xl := pxy.xl
- listener, errRet := pxy.rc.VisitorManager.Listen(pxy.GetName(), pxy.cfg.Sk)
- if errRet != nil {
- err = errRet
- return
- }
- pxy.listeners = append(pxy.listeners, listener)
- xl.Info("stcp proxy custom listen success")
- pxy.startListenHandler(pxy, HandleUserTCPConnection)
- return
- }
- func (pxy *STCPProxy) GetConf() config.ProxyConf {
- return pxy.cfg
- }
- func (pxy *STCPProxy) Close() {
- pxy.BaseProxy.Close()
- pxy.rc.VisitorManager.CloseListener(pxy.GetName())
- }
|