From 02b70a1c7ee923b85a44febf99e31476272fcf41 Mon Sep 17 00:00:00 2001 From: Gregor Kleen Date: Sun, 31 Jan 2016 21:13:16 +0000 Subject: Fixed queue order --- server/src/Thermoprint/Server/Printer.hs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'server/src') diff --git a/server/src/Thermoprint/Server/Printer.hs b/server/src/Thermoprint/Server/Printer.hs index 7f41430..5dc593e 100644 --- a/server/src/Thermoprint/Server/Printer.hs +++ b/server/src/Thermoprint/Server/Printer.hs @@ -25,7 +25,7 @@ import Thermoprint.Server.Database import Database.Persist import Database.Persist.Sql -import Data.Sequence (Seq, ViewL(..), viewl, (<|), (|>)) +import Data.Sequence (Seq, ViewR(..), viewr, (<|), (|>)) import qualified Data.Sequence as Seq import Data.Map (Map) import qualified Data.Map as Map @@ -91,9 +91,9 @@ runPrinter :: ( MonadReader ConnectionPool m runPrinter Printer{..} = forever $ do entry@(QueueEntry{..}) <- atomically' $ do (Queue queuePending Nothing history) <- readTVar queue - case viewl queuePending of - EmptyL -> retry - (current :< remaining) -> do + case viewr queuePending of + EmptyR -> retry + (remaining :> current) -> do writeTVar queue $!! Queue remaining (Just current) history return current job <- runSqlPool (get jobId) =<< ask -- cgit v1.2.3