zeromq-haskell-0.3: test/perf/local_thr.hs

import Control.Monad
import System.IO
import System.Exit
import System.Environment
import Data.Time.Clock
import qualified System.ZMQ as ZMQ
import qualified Data.ByteString as SB
import Text.Printf

main :: IO ()
main = do
    args <- getArgs
    when (length args /= 3) $ do
        hPutStrLn stderr usage
        exitFailure
    let bindTo = args !! 0
        size   = read $ args !! 1 :: Int
        count  = read $ args !! 2 :: Int
    c <- ZMQ.init 1
    s <- ZMQ.socket c ZMQ.Sub
    ZMQ.subscribe s ""
    ZMQ.bind s bindTo
    receive s size
    start <- getCurrentTime
    loop s (count - 1) size
    end <- getCurrentTime
    printStat start end size count
    ZMQ.close s
    ZMQ.term c
 where
    receive s sz = do
        msg <- ZMQ.receive s []
        when (SB.length msg /= sz) $
            error "message of incorrect size received"

    loop s c sz = unless (c <= 0) $ do
        receive s sz
        loop s (c - 1) sz

    printStat start end size count = do
        let elapsed = fromRational . toRational $ diffUTCTime end start :: Double
            through = fromIntegral count / elapsed
            mbits   = (through * fromIntegral size * 8) / 1000000
        printf "message size: %d [B]\n" size
        printf "message count: %d\n" count
        printf "mean throughput: %.3f [msg/s]\n" through
        printf "mean throughput: %.3f [Mb/s]\n" mbits

usage :: String
usage = "usage: local_thr <bind-to> <message-size> <message-count>"