| 33 | } |
| 34 | |
| 35 | type ServerImpl struct { |
| 36 | LogWriter io.Writer |
| 37 | Router *wshutil.WshRouter |
| 38 | RpcClient *wshutil.WshRpc |
| 39 | IsLocal bool |
| 40 | InitialEnv map[string]string |
| 41 | JobManagerMap map[string]*JobManagerConnection |
| 42 | SockName string |
| 43 | Lock sync.Mutex |
| 44 | } |
| 45 | |
| 46 | func MakeRemoteRpcServerImpl(logWriter io.Writer, router *wshutil.WshRouter, rpcClient *wshutil.WshRpc, isLocal bool, initialEnv map[string]string, sockName string) *ServerImpl { |
| 47 | return &ServerImpl{ |
nothing calls this directly
no outgoing calls
no test coverage detected