1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- package proxy
- import (
- "github.com/fatedier/frp/models/config"
- )
- type StcpProxy struct {
- *BaseProxy
- cfg *config.StcpProxyConf
- }
- func (pxy *StcpProxy) Run() (remoteAddr string, err error) {
- listener, errRet := pxy.rc.VisitorManager.Listen(pxy.GetName(), pxy.cfg.Sk)
- if errRet != nil {
- err = errRet
- return
- }
- listener.AddLogPrefix(pxy.name)
- pxy.listeners = append(pxy.listeners, listener)
- pxy.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())
- }
|