stomp-queue 0.0.6 → 0.0.7
raw patch · 2 files changed
+29/−18 lines, 2 files
Files
- Network/Mom/Stompl/Client/State.hs +12/−12
- stomp-queue.cabal +17/−6
Network/Mom/Stompl/Client/State.hs view
@@ -53,6 +53,18 @@ numeric = all isDigit ------------------------------------------------------------------------+ -- strict deletes+ ------------------------------------------------------------------------+ delete' :: Eq a => a -> [a] -> [a]+ delete' = deleteBy' (==) ++ deleteBy' :: (a -> a -> Bool) -> a -> [a] -> [a]+ deleteBy' _ _ [] = []+ deleteBy' f p (x:xs) | f p x = xs+ | otherwise = let !xs' = deleteBy' f p xs+ in x : xs'++ ------------------------------------------------------------------------ -- convert milliseconds to microseconds ------------------------------------------------------------------------ ms :: Int -> Int@@ -631,15 +643,3 @@ else return (c {conThrds = (tid, ts') : deleteBy' eq (tid, ts) (conThrds c)}, ()) -- ------------------------------------------------------------------------- -- Some helpers- ------------------------------------------------------------------------- delete' :: Eq a => a -> [a] -> [a]- delete' = deleteBy' (==) -- deleteBy' :: (a -> a -> Bool) -> a -> [a] -> [a]- deleteBy' _ _ [] = []- deleteBy' f p (x:xs) | f p x = xs- | otherwise = let !xs' = deleteBy' f p xs- in x : xs'
stomp-queue.cabal view
@@ -1,5 +1,5 @@ Name: stomp-queue-Version: 0.0.6+Version: 0.0.7 Cabal-Version: >= 1.8 Copyright: Copyright (c) Tobias Schoofs, 2011 - 2013 License: LGPL@@ -34,11 +34,22 @@ . - [0.0.5] Underline functions removed, - with* functions: withWriter, withPair,- new option for connection (ClientId),- Headers for broker-specific options can be passed to connection,- memory leaks solved.+ [0.0.7] Fighting with hackagedb...++ .++ [0.0.6] Heartbeats caused a memory leak by creating + many Connection instances in the connection state list.+ The connections were lazily deleted, /i.e./ were+ not deleted at all.+ Connection state is now cleaned up by a strict delete.++ .++ [0.0.5] Underscore functions removed; + with* functions: withWriter, withPair;+ new option for connection (ClientId);+ Headers for broker-specific options can be passed to connection. .