(reason string, exitCode int, quiet bool)
| 126 | var shutdownOnce sync.Once |
| 127 | |
| 128 | func DoShutdown(reason string, exitCode int, quiet bool) { |
| 129 | shutdownOnce.Do(func() { |
| 130 | defer os.Exit(exitCode) |
| 131 | if !quiet && reason != "" { |
| 132 | log.Printf("shutting down: %s\n", reason) |
| 133 | } |
| 134 | }) |
| 135 | } |
| 136 | |
| 137 | func SetupPacketRpcClient(input io.Reader, output io.Writer, serverImpl ServerImpl, debugStr string) (*WshRpc, chan []byte) { |
| 138 | messageCh := make(chan baseds.RpcInputChType, DefaultInputChSize) |
no outgoing calls
no test coverage detected