Function InitCfcProxy

proxy/proxy.go:23–34

()

}

func InitCfcProxy() error {
	protocol := &tcp.DefaultProtocol{}
	protocol.SetMaxPacketSize(uint32(GlobalConfig.MaxPacketSize))
	s := tcp.NewAsyncTCPServer(GlobalConfig.TCPBind, &callback{}, protocol)
	proxy = &CFCProxy{
		s,
		&tcp.TCPConn{},
		make(map[string]string),
		sync.RWMutex{},
	}
	return proxy.srv.ListenAndServe()
}

// 发送插件同步请求
func (proxy *CFCProxy) sendSyncPluginRequest(hostID string, p types.Plugin) error {