dumpNodeStats bug report.

dumpNodeStats.cabal

-- Initial dumpNodeStats.cabal generated by cabal init.  For further
-- documentation, see http://haskell.org/cabal/users-guide/

name:                dumpNodeStats
version:             0.1.0.0
synopsis:            Tool to dump stats from a CH node to the console.
-- description:
license:             AllRightsReserved
license-file:        LICENSE
author:              Nicholas Clarke
maintainer:          nicholas.clarke@seagate.com
-- copyright:
category:            Testing
build-type:          Simple
-- extra-source-files:
cabal-version:       >=1.10

executable server
  main-is:             Server.hs
  build-depends:       base >=4.7 && <4.8
                      ,network-transport
                      ,network-transport-tcp
                      ,distributed-process
  -- hs-source-dirs:
  default-language:    Haskell2010

executable dumpNodeStats
  main-is:             Main.hs
  -- other-modules:
  -- other-extensions:
  build-depends:       base >=4.7 && <4.8
                      ,network-transport
                      ,network-transport-tcp
                      ,distributed-process
  -- hs-source-dirs:
  default-language:    Haskell2010

Main.hs

{-# LANGUAGE LambdaCase #-}

module Main where

import Control.Applicative
import Control.Distributed.Process
import Control.Distributed.Process.Node

import qualified Network.Transport.TCP as TCP

import System.Environment (getArgs)

myHost :: String
myHost = "127.0.0.1"

myPort :: String
myPort = "6666"

conjureRemoteNodeId :: String -> String -> NodeId
conjureRemoteNodeId host port =
    NodeId $ TCP.encodeEndPointAddress host port 0

main :: IO ()
main = getArgs >>= \case
  (host : port : []) -> let nid = conjureRemoteNodeId host port in do
    print $ "Talking to " ++ show nid
    transport <- either (error . show) id <$>
                  TCP.createTransport myHost myPort TCP.defaultTCPParameters
    lnid <- newLocalNode transport initRemoteTable
    runProcess lnid $ do
      say "Querying NodeStats...."
      Right ns <- getNodeStats nid
      liftIO $ print ns

Server.hs

{-# LANGUAGE LambdaCase #-}

module Main where

import Control.Applicative
import Control.Distributed.Process
import Control.Distributed.Process.Node

import qualified Network.Transport.TCP as TCP

import System.Environment (getArgs)

myHost :: String
myHost = "127.0.0.1"

myPort :: String
myPort = "6665"

conjureRemoteNodeId :: String -> String -> NodeId
conjureRemoteNodeId host port =
    NodeId $ TCP.encodeEndPointAddress host port 0

main :: IO ()
main = do
  transport <- either (error . show) id <$>
                TCP.createTransport myHost myPort TCP.defaultTCPParameters
  lnid <- newLocalNode transport initRemoteTable
  runProcess lnid $ do
    say "Sitting here doing nothing...."
    expect

Setup.hs

import Distribution.Simple
main = defaultMain