- loop :: Socket -> IO ()
- loop so
- -- 本當は Network.accept を使ひたいが、このアクションは勝手に
- -- リモートのIPを逆引きするので、使へない。
- = so `seq`
- do (h, addr) <- accept' so
- tQueue <- newInteractionQueue
- readerTID <- forkIO $ requestReader cnf tree h addr tQueue
- writerTID <- forkIO $ responseWriter cnf h tQueue readerTID
- loop so
+ launchListener ∷ SocketLike s ⇒ s → IO ()
+ launchListener so
+ = do p ← SL.socketPort so
+ -- FIXME: Don't throw away the thread ID as we can't
+ -- kill it later then. [1]
+ void $ forkIO $ httpLoop p so
+
+ listenOn ∷ Family → HostName → ServiceName → IO Socket
+ listenOn fam host srv
+ = do proto ← getProtocolNumber "tcp"
+ let hints = defaultHints {
+ addrFlags = [AI_PASSIVE]
+ , addrFamily = fam
+ , addrSocketType = Stream
+ , addrProtocol = proto
+ }
+ addrs ← getAddrInfo (Just hints) (Just host) (Just srv)
+ let addr = head addrs
+ bracketOnError
+ (socket (addrFamily addr) (addrSocketType addr) (addrProtocol addr))
+ sClose
+ (\ sock →
+ do setSocketOption sock ReuseAddr 1
+ bindSocket sock (addrAddress addr)
+ listen sock maxListenQueue
+ return sock
+ )
+
+ httpLoop ∷ SocketLike s ⇒ PortNumber → s → IO ()
+ httpLoop port so
+ = do (h, addr) ← SL.accept so
+ tQueue ← mkInteractionQueue
+ readerTID ← forkIO $ requestReader cnf tree fbs h port addr tQueue
+ _writerTID ← forkIO $ responseWriter cnf h tQueue readerTID
+ httpLoop port so