, pingCmdMagic :: !Word32
+
, pingCmdQuery :: !Bool
pingClient :: Tracer IO CNP.LogMsg -> Tracer IO String -> PingCmd -> [CNP.NodeVersion] -> AddrInfo -> IO ()
pingClient stdout stderr cmd = CNP.pingClient stdout stderr opts
where opts = CNP.PingOpts
-
{ CNP.pingOptsQuiet = pingCmdQuiet cmd
-
, CNP.pingOptsJson = pingCmdJson cmd
-
, CNP.pingOptsCount = pingCmdCount cmd
-
, CNP.pingOptsHost = maybeHostEndPoint (pingCmdEndPoint cmd)
-
, CNP.pingOptsUnixSock = maybeUnixSockEndPoint (pingCmdEndPoint cmd)
-
, CNP.pingOptsPort = pingCmdPort cmd
-
, CNP.pingOptsMagic = pingCmdMagic cmd
+
{ CNP.pingOptsQuiet = pingCmdQuiet cmd
+
, CNP.pingOptsJson = pingCmdJson cmd
+
, CNP.pingOptsCount = pingCmdCount cmd
+
, CNP.pingOptsHost = maybeHostEndPoint (pingCmdEndPoint cmd)
+
, CNP.pingOptsUnixSock = maybeUnixSockEndPoint (pingCmdEndPoint cmd)
+
, CNP.pingOptsPort = pingCmdPort cmd
+
, CNP.pingOptsMagic = pingCmdMagic cmd
+
, CNP.pingOptsHandshakeQuery = pingCmdQuery cmd
runPingCmd :: PingCmd -> ExceptT PingClientCmdError IO ()
return ([addr], CNP.supportedNodeToClientVersions $ pingCmdMagic options)
-- Logger async thread handle
-
laid <- liftIO . async $ CNP.logger msgQueue $ pingCmdJson options
+
laid <- liftIO . async $ CNP.logger msgQueue (pingCmdJson options) (pingCmdQuery options)
-- Ping client thread handles
caids <- forM addresses $ liftIO . async . pingClient (Tracer $ doLog msgQueue) (Tracer doErrLog) options versions
res <- L.zip addresses <$> mapM (liftIO . waitCatch) caids
, Opt.help "Quiet flag, CSV/JSON only output"
+
<*> ( Opt.switch $ mconcat
+
, Opt.help "Query flag."
