diff --git a/LICENSE b/LICENSE new file mode 100644 --- /dev/null +++ b/LICENSE @@ -0,0 +1,30 @@ +Copyright (c)2012, Ivan Perez + +All rights reserved. + +Redistribution and use in source and binary forms, with or without +modification, are permitted provided that the following conditions are met: + + * Redistributions of source code must retain the above copyright + notice, this list of conditions and the following disclaimer. + + * Redistributions in binary form must reproduce the above + copyright notice, this list of conditions and the following + disclaimer in the documentation and/or other materials provided + with the distribution. + + * Neither the name of Ivan Perez nor the names of other + contributors may be used to endorse or promote products derived + from this software without specific prior written permission. + +THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. diff --git a/Setup.hs b/Setup.hs new file mode 100644 --- /dev/null +++ b/Setup.hs @@ -0,0 +1,2 @@ +import Distribution.Simple +main = defaultMain diff --git a/keera-callbacks.cabal b/keera-callbacks.cabal new file mode 100644 --- /dev/null +++ b/keera-callbacks.cabal @@ -0,0 +1,65 @@ +-- keera-callbacks.cabal auto-generated by cabal init. For additional +-- options, see +-- http://www.haskell.org/cabal/release/cabal-latest/doc/users-guide/authors.html#pkg-descr. +-- The name of the package. +Name: keera-callbacks + +-- The package version. See the Haskell package versioning policy +-- (http://www.haskell.org/haskellwiki/Package_versioning_policy) for +-- standards guiding when and how versions should be incremented. +Version: 0.1 + +-- A short (one-line) description of the package. +Synopsis: Mutable memory locations with callbacks + +-- A longer description of the package. +Description: Mutable memory locations with handlers that are executed when the + shared values are modified. + +-- The license under which the package is released. +License: BSD3 + +-- The file containing the license text. +License-file: LICENSE + +-- The package author(s). +Author: Ivan Perez + +-- An email address to which users can send suggestions, bug reports, +-- and patches. +Maintainer: ivan.perez@keera.es + +-- A copyright notice. +-- Copyright: + +Category: Concurrency + +Build-type: Simple + +-- Extra files to be distributed with the package, such as examples or +-- a README. +-- Extra-source-files: + +-- Constraint on the version of Cabal needed to build this package. +Cabal-version: >=1.2 + + +Library + -- Modules exported by the library. + Exposed-modules: Data.CBRef + Data.CBMVar + + -- Packages needed in order to build this package. + hs-source-dirs: src/ + + ghc-options: -Wall -fno-warn-unused-do-bind -O2 + + Build-depends: base >= 4.0 && < 5.0 + , mtl + + -- Modules not exported by this package. + -- Other-modules: + + -- Extra tools (e.g. alex, hsc2hs, ...) needed to build the source. + -- Build-tools: + diff --git a/src/Data/CBMVar.hs b/src/Data/CBMVar.hs new file mode 100644 --- /dev/null +++ b/src/Data/CBMVar.hs @@ -0,0 +1,36 @@ +module Data.CBMVar + ( CBMVar + , newCBMVar + , readCBMVar + , writeCBMVar + , modifyCBMVar + , installCallbackCBMVar + ) + where + +import Control.Concurrent.MVar + +data CBMVar a = CBMVar (MVar (a, [IO ()])) + +newCBMVar :: a -> IO (CBMVar a) +newCBMVar v = fmap CBMVar $ newMVar (v,[]) + +readCBMVar :: CBMVar a -> IO a +readCBMVar (CBMVar ref) = fmap fst $ readMVar ref + +writeCBMVar :: CBMVar a -> a -> IO () +writeCBMVar (CBMVar ref) v = do + modifyMVar_ ref (\(_,cb) -> return (v,cb)) + runCallbacks ref + +runCallbacks :: MVar (a, [IO ()]) -> IO () +runCallbacks ref = (sequence_.snd) =<< readMVar ref + +modifyCBMVar :: CBMVar a -> (a -> IO a) -> IO () +modifyCBMVar (CBMVar ref) f = do + modifyMVar_ ref (\(v,cb) -> f v >>= \v' -> return (v',cb)) + runCallbacks ref + +installCallbackCBMVar :: CBMVar a -> IO () -> IO () +installCallbackCBMVar (CBMVar ref) p = + modifyMVar_ ref (\(v,cb) -> return (v,cb ++ [p])) diff --git a/src/Data/CBRef.hs b/src/Data/CBRef.hs new file mode 100644 --- /dev/null +++ b/src/Data/CBRef.hs @@ -0,0 +1,44 @@ +module Data.CBRef + ( CBRef + , newCBRef + , readCBRef + , writeCBRef + , modifyCBRef + , atomicModifyCBRef + , installCallbackCBRef + ) + where + +import Data.IORef + +data CBRef a = CBRef (IORef (a, [IO ()])) + +newCBRef :: a -> IO (CBRef a) +newCBRef v = fmap CBRef $ newIORef (v,[]) + +readCBRef :: CBRef a -> IO a +readCBRef (CBRef ref) = fmap fst $ readIORef ref + +writeCBRef :: CBRef a -> a -> IO () +writeCBRef (CBRef ref) v = do + modifyIORef ref (\(_,cb) -> (v,cb)) + runCallbacks ref + +runCallbacks :: IORef (a, [IO ()]) -> IO () +runCallbacks ref = (sequence_.snd) =<< readIORef ref + +modifyCBRef :: CBRef a -> (a -> a) -> IO () +modifyCBRef (CBRef ref) f = do + modifyIORef ref (\(v,cb) -> (f v,cb)) + runCallbacks ref + +atomicModifyCBRef :: CBRef a -> (a -> (a, b)) -> IO b +atomicModifyCBRef (CBRef ref) f = do + v <- atomicModifyIORef ref modifier + runCallbacks ref + return v + where modifier (v,cb) = let (v', r) = f v in ((v',cb), r) + +installCallbackCBRef :: CBRef a -> IO () -> IO () +installCallbackCBRef (CBRef ref) p = + modifyIORef ref (\(v,cb) -> (v,cb ++ [p]))