#define ENABLE_OVERLOADING \
(!defined(__HADDOCK_VERSION__))
module GI.Gio.Objects.ThreadedSocketService
(
ThreadedSocketService(..) ,
IsThreadedSocketService ,
toThreadedSocketService ,
noThreadedSocketService ,
threadedSocketServiceNew ,
#if ENABLE_OVERLOADING
ThreadedSocketServiceMaxThreadsPropertyInfo,
#endif
constructThreadedSocketServiceMaxThreads,
getThreadedSocketServiceMaxThreads ,
#if ENABLE_OVERLOADING
threadedSocketServiceMaxThreads ,
#endif
C_ThreadedSocketServiceRunCallback ,
ThreadedSocketServiceRunCallback ,
#if ENABLE_OVERLOADING
ThreadedSocketServiceRunSignalInfo ,
#endif
afterThreadedSocketServiceRun ,
genClosure_ThreadedSocketServiceRun ,
mk_ThreadedSocketServiceRunCallback ,
noThreadedSocketServiceRunCallback ,
onThreadedSocketServiceRun ,
wrap_ThreadedSocketServiceRunCallback ,
) where
import Data.GI.Base.ShortPrelude
import qualified Data.GI.Base.ShortPrelude as SP
import qualified Data.GI.Base.Overloading as O
import qualified Prelude as P
import qualified Data.GI.Base.Attributes as GI.Attributes
import qualified Data.GI.Base.ManagedPtr as B.ManagedPtr
import qualified Data.GI.Base.GError as B.GError
import qualified Data.GI.Base.GVariant as B.GVariant
import qualified Data.GI.Base.GValue as B.GValue
import qualified Data.GI.Base.GParamSpec as B.GParamSpec
import qualified Data.GI.Base.CallStack as B.CallStack
import qualified Data.Text as T
import qualified Data.ByteString.Char8 as B
import qualified Data.Map as Map
import qualified Foreign.Ptr as FP
import qualified GI.GObject.Objects.Object as GObject.Object
import {-# SOURCE #-} qualified GI.Gio.Objects.SocketConnection as Gio.SocketConnection
import {-# SOURCE #-} qualified GI.Gio.Objects.SocketListener as Gio.SocketListener
import {-# SOURCE #-} qualified GI.Gio.Objects.SocketService as Gio.SocketService
newtype ThreadedSocketService = ThreadedSocketService (ManagedPtr ThreadedSocketService)
foreign import ccall "g_threaded_socket_service_get_type"
c_g_threaded_socket_service_get_type :: IO GType
instance GObject ThreadedSocketService where
gobjectType :: ThreadedSocketService -> IO GType
gobjectType _ = IO GType
c_g_threaded_socket_service_get_type
class GObject o => IsThreadedSocketService o
#if MIN_VERSION_base(4,9,0)
instance {-# OVERLAPPABLE #-} (GObject a, O.UnknownAncestorError ThreadedSocketService a) =>
IsThreadedSocketService a
#endif
instance IsThreadedSocketService ThreadedSocketService
instance Gio.SocketService.IsSocketService ThreadedSocketService
instance Gio.SocketListener.IsSocketListener ThreadedSocketService
instance GObject.Object.IsObject ThreadedSocketService
toThreadedSocketService :: (MonadIO m, IsThreadedSocketService o) => o -> m ThreadedSocketService
toThreadedSocketService :: o -> m ThreadedSocketService
toThreadedSocketService = IO ThreadedSocketService -> m ThreadedSocketService
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO (IO ThreadedSocketService -> m ThreadedSocketService)
-> (o -> IO ThreadedSocketService) -> o -> m ThreadedSocketService
forall b c a. (b -> c) -> (a -> b) -> a -> c
. (ManagedPtr ThreadedSocketService -> ThreadedSocketService)
-> o -> IO ThreadedSocketService
forall o o'.
(HasCallStack, GObject o, GObject o') =>
(ManagedPtr o' -> o') -> o -> IO o'
unsafeCastTo ManagedPtr ThreadedSocketService -> ThreadedSocketService
ThreadedSocketService
noThreadedSocketService :: Maybe ThreadedSocketService
noThreadedSocketService :: Maybe ThreadedSocketService
noThreadedSocketService = Maybe ThreadedSocketService
forall a. Maybe a
Nothing
#if ENABLE_OVERLOADING
type family ResolveThreadedSocketServiceMethod (t :: Symbol) (o :: *) :: * where
ResolveThreadedSocketServiceMethod "accept" o = Gio.SocketListener.SocketListenerAcceptMethodInfo
ResolveThreadedSocketServiceMethod "acceptAsync" o = Gio.SocketListener.SocketListenerAcceptAsyncMethodInfo
ResolveThreadedSocketServiceMethod "acceptFinish" o = Gio.SocketListener.SocketListenerAcceptFinishMethodInfo
ResolveThreadedSocketServiceMethod "acceptSocket" o = Gio.SocketListener.SocketListenerAcceptSocketMethodInfo
ResolveThreadedSocketServiceMethod "acceptSocketAsync" o = Gio.SocketListener.SocketListenerAcceptSocketAsyncMethodInfo
ResolveThreadedSocketServiceMethod "acceptSocketFinish" o = Gio.SocketListener.SocketListenerAcceptSocketFinishMethodInfo
ResolveThreadedSocketServiceMethod "addAddress" o = Gio.SocketListener.SocketListenerAddAddressMethodInfo
ResolveThreadedSocketServiceMethod "addAnyInetPort" o = Gio.SocketListener.SocketListenerAddAnyInetPortMethodInfo
ResolveThreadedSocketServiceMethod "addInetPort" o = Gio.SocketListener.SocketListenerAddInetPortMethodInfo
ResolveThreadedSocketServiceMethod "addSocket" o = Gio.SocketListener.SocketListenerAddSocketMethodInfo
ResolveThreadedSocketServiceMethod "bindProperty" o = GObject.Object.ObjectBindPropertyMethodInfo
ResolveThreadedSocketServiceMethod "bindPropertyFull" o = GObject.Object.ObjectBindPropertyFullMethodInfo
ResolveThreadedSocketServiceMethod "close" o = Gio.SocketListener.SocketListenerCloseMethodInfo
ResolveThreadedSocketServiceMethod "forceFloating" o = GObject.Object.ObjectForceFloatingMethodInfo
ResolveThreadedSocketServiceMethod "freezeNotify" o = GObject.Object.ObjectFreezeNotifyMethodInfo
ResolveThreadedSocketServiceMethod "getv" o = GObject.Object.ObjectGetvMethodInfo
ResolveThreadedSocketServiceMethod "isActive" o = Gio.SocketService.SocketServiceIsActiveMethodInfo
ResolveThreadedSocketServiceMethod "isFloating" o = GObject.Object.ObjectIsFloatingMethodInfo
ResolveThreadedSocketServiceMethod "notify" o = GObject.Object.ObjectNotifyMethodInfo
ResolveThreadedSocketServiceMethod "notifyByPspec" o = GObject.Object.ObjectNotifyByPspecMethodInfo
ResolveThreadedSocketServiceMethod "ref" o = GObject.Object.ObjectRefMethodInfo
ResolveThreadedSocketServiceMethod "refSink" o = GObject.Object.ObjectRefSinkMethodInfo
ResolveThreadedSocketServiceMethod "runDispose" o = GObject.Object.ObjectRunDisposeMethodInfo
ResolveThreadedSocketServiceMethod "start" o = Gio.SocketService.SocketServiceStartMethodInfo
ResolveThreadedSocketServiceMethod "stealData" o = GObject.Object.ObjectStealDataMethodInfo
ResolveThreadedSocketServiceMethod "stealQdata" o = GObject.Object.ObjectStealQdataMethodInfo
ResolveThreadedSocketServiceMethod "stop" o = Gio.SocketService.SocketServiceStopMethodInfo
ResolveThreadedSocketServiceMethod "thawNotify" o = GObject.Object.ObjectThawNotifyMethodInfo
ResolveThreadedSocketServiceMethod "unref" o = GObject.Object.ObjectUnrefMethodInfo
ResolveThreadedSocketServiceMethod "watchClosure" o = GObject.Object.ObjectWatchClosureMethodInfo
ResolveThreadedSocketServiceMethod "getData" o = GObject.Object.ObjectGetDataMethodInfo
ResolveThreadedSocketServiceMethod "getProperty" o = GObject.Object.ObjectGetPropertyMethodInfo
ResolveThreadedSocketServiceMethod "getQdata" o = GObject.Object.ObjectGetQdataMethodInfo
ResolveThreadedSocketServiceMethod "setBacklog" o = Gio.SocketListener.SocketListenerSetBacklogMethodInfo
ResolveThreadedSocketServiceMethod "setData" o = GObject.Object.ObjectSetDataMethodInfo
ResolveThreadedSocketServiceMethod "setProperty" o = GObject.Object.ObjectSetPropertyMethodInfo
ResolveThreadedSocketServiceMethod l o = O.MethodResolutionFailed l o
instance (info ~ ResolveThreadedSocketServiceMethod t ThreadedSocketService, O.MethodInfo info ThreadedSocketService p) => O.IsLabelProxy t (ThreadedSocketService -> p) where
fromLabelProxy _ = O.overloadedMethod (O.MethodProxy :: O.MethodProxy info)
#if MIN_VERSION_base(4,9,0)
instance (info ~ ResolveThreadedSocketServiceMethod t ThreadedSocketService, O.MethodInfo info ThreadedSocketService p) => O.IsLabel t (ThreadedSocketService -> p) where
#if MIN_VERSION_base(4,10,0)
fromLabel = O.overloadedMethod (O.MethodProxy :: O.MethodProxy info)
#else
fromLabel _ = O.overloadedMethod (O.MethodProxy :: O.MethodProxy info)
#endif
#endif
#endif
type ThreadedSocketServiceRunCallback =
Gio.SocketConnection.SocketConnection
-> GObject.Object.Object
-> IO Bool
noThreadedSocketServiceRunCallback :: Maybe ThreadedSocketServiceRunCallback
noThreadedSocketServiceRunCallback :: Maybe ThreadedSocketServiceRunCallback
noThreadedSocketServiceRunCallback = Maybe ThreadedSocketServiceRunCallback
forall a. Maybe a
Nothing
type C_ThreadedSocketServiceRunCallback =
Ptr () ->
Ptr Gio.SocketConnection.SocketConnection ->
Ptr GObject.Object.Object ->
Ptr () ->
IO CInt
foreign import ccall "wrapper"
mk_ThreadedSocketServiceRunCallback :: C_ThreadedSocketServiceRunCallback -> IO (FunPtr C_ThreadedSocketServiceRunCallback)
genClosure_ThreadedSocketServiceRun :: ThreadedSocketServiceRunCallback -> IO Closure
genClosure_ThreadedSocketServiceRun :: ThreadedSocketServiceRunCallback -> IO Closure
genClosure_ThreadedSocketServiceRun cb :: ThreadedSocketServiceRunCallback
cb = do
let cb' :: C_ThreadedSocketServiceRunCallback
cb' = ThreadedSocketServiceRunCallback
-> C_ThreadedSocketServiceRunCallback
wrap_ThreadedSocketServiceRunCallback ThreadedSocketServiceRunCallback
cb
C_ThreadedSocketServiceRunCallback
-> IO (FunPtr C_ThreadedSocketServiceRunCallback)
mk_ThreadedSocketServiceRunCallback C_ThreadedSocketServiceRunCallback
cb' IO (FunPtr C_ThreadedSocketServiceRunCallback)
-> (FunPtr C_ThreadedSocketServiceRunCallback -> IO Closure)
-> IO Closure
forall (m :: * -> *) a b. Monad m => m a -> (a -> m b) -> m b
>>= FunPtr C_ThreadedSocketServiceRunCallback -> IO Closure
forall a. FunPtr a -> IO Closure
newCClosure
wrap_ThreadedSocketServiceRunCallback ::
ThreadedSocketServiceRunCallback ->
C_ThreadedSocketServiceRunCallback
wrap_ThreadedSocketServiceRunCallback :: ThreadedSocketServiceRunCallback
-> C_ThreadedSocketServiceRunCallback
wrap_ThreadedSocketServiceRunCallback _cb :: ThreadedSocketServiceRunCallback
_cb _ connection :: Ptr SocketConnection
connection sourceObject :: Ptr Object
sourceObject _ = do
SocketConnection
connection' <- ((ManagedPtr SocketConnection -> SocketConnection)
-> Ptr SocketConnection -> IO SocketConnection
forall a b.
(HasCallStack, GObject a, GObject b) =>
(ManagedPtr a -> a) -> Ptr b -> IO a
newObject ManagedPtr SocketConnection -> SocketConnection
Gio.SocketConnection.SocketConnection) Ptr SocketConnection
connection
Object
sourceObject' <- ((ManagedPtr Object -> Object) -> Ptr Object -> IO Object
forall a b.
(HasCallStack, GObject a, GObject b) =>
(ManagedPtr a -> a) -> Ptr b -> IO a
newObject ManagedPtr Object -> Object
GObject.Object.Object) Ptr Object
sourceObject
Bool
result <- ThreadedSocketServiceRunCallback
_cb SocketConnection
connection' Object
sourceObject'
let result' :: CInt
result' = (Int -> CInt
forall a b. (Integral a, Num b) => a -> b
fromIntegral (Int -> CInt) -> (Bool -> Int) -> Bool -> CInt
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Bool -> Int
forall a. Enum a => a -> Int
fromEnum) Bool
result
CInt -> IO CInt
forall (m :: * -> *) a. Monad m => a -> m a
return CInt
result'
onThreadedSocketServiceRun :: (IsThreadedSocketService a, MonadIO m) => a -> ThreadedSocketServiceRunCallback -> m SignalHandlerId
onThreadedSocketServiceRun :: a -> ThreadedSocketServiceRunCallback -> m SignalHandlerId
onThreadedSocketServiceRun obj :: a
obj cb :: ThreadedSocketServiceRunCallback
cb = IO SignalHandlerId -> m SignalHandlerId
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO (IO SignalHandlerId -> m SignalHandlerId)
-> IO SignalHandlerId -> m SignalHandlerId
forall a b. (a -> b) -> a -> b
$ do
let cb' :: C_ThreadedSocketServiceRunCallback
cb' = ThreadedSocketServiceRunCallback
-> C_ThreadedSocketServiceRunCallback
wrap_ThreadedSocketServiceRunCallback ThreadedSocketServiceRunCallback
cb
FunPtr C_ThreadedSocketServiceRunCallback
cb'' <- C_ThreadedSocketServiceRunCallback
-> IO (FunPtr C_ThreadedSocketServiceRunCallback)
mk_ThreadedSocketServiceRunCallback C_ThreadedSocketServiceRunCallback
cb'
a
-> String
-> FunPtr C_ThreadedSocketServiceRunCallback
-> SignalConnectMode
-> IO SignalHandlerId
forall o a.
GObject o =>
o -> String -> FunPtr a -> SignalConnectMode -> IO SignalHandlerId
connectSignalFunPtr a
obj "run" FunPtr C_ThreadedSocketServiceRunCallback
cb'' SignalConnectMode
SignalConnectBefore
afterThreadedSocketServiceRun :: (IsThreadedSocketService a, MonadIO m) => a -> ThreadedSocketServiceRunCallback -> m SignalHandlerId
afterThreadedSocketServiceRun :: a -> ThreadedSocketServiceRunCallback -> m SignalHandlerId
afterThreadedSocketServiceRun obj :: a
obj cb :: ThreadedSocketServiceRunCallback
cb = IO SignalHandlerId -> m SignalHandlerId
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO (IO SignalHandlerId -> m SignalHandlerId)
-> IO SignalHandlerId -> m SignalHandlerId
forall a b. (a -> b) -> a -> b
$ do
let cb' :: C_ThreadedSocketServiceRunCallback
cb' = ThreadedSocketServiceRunCallback
-> C_ThreadedSocketServiceRunCallback
wrap_ThreadedSocketServiceRunCallback ThreadedSocketServiceRunCallback
cb
FunPtr C_ThreadedSocketServiceRunCallback
cb'' <- C_ThreadedSocketServiceRunCallback
-> IO (FunPtr C_ThreadedSocketServiceRunCallback)
mk_ThreadedSocketServiceRunCallback C_ThreadedSocketServiceRunCallback
cb'
a
-> String
-> FunPtr C_ThreadedSocketServiceRunCallback
-> SignalConnectMode
-> IO SignalHandlerId
forall o a.
GObject o =>
o -> String -> FunPtr a -> SignalConnectMode -> IO SignalHandlerId
connectSignalFunPtr a
obj "run" FunPtr C_ThreadedSocketServiceRunCallback
cb'' SignalConnectMode
SignalConnectAfter
getThreadedSocketServiceMaxThreads :: (MonadIO m, IsThreadedSocketService o) => o -> m Int32
getThreadedSocketServiceMaxThreads :: o -> m Int32
getThreadedSocketServiceMaxThreads obj :: o
obj = IO Int32 -> m Int32
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO (IO Int32 -> m Int32) -> IO Int32 -> m Int32
forall a b. (a -> b) -> a -> b
$ o -> String -> IO Int32
forall a. GObject a => a -> String -> IO Int32
getObjectPropertyInt32 o
obj "max-threads"
constructThreadedSocketServiceMaxThreads :: (IsThreadedSocketService o) => Int32 -> IO (GValueConstruct o)
constructThreadedSocketServiceMaxThreads :: Int32 -> IO (GValueConstruct o)
constructThreadedSocketServiceMaxThreads val :: Int32
val = String -> Int32 -> IO (GValueConstruct o)
forall o. String -> Int32 -> IO (GValueConstruct o)
constructObjectPropertyInt32 "max-threads" Int32
val
#if ENABLE_OVERLOADING
data ThreadedSocketServiceMaxThreadsPropertyInfo
instance AttrInfo ThreadedSocketServiceMaxThreadsPropertyInfo where
type AttrAllowedOps ThreadedSocketServiceMaxThreadsPropertyInfo = '[ 'AttrConstruct, 'AttrGet]
type AttrSetTypeConstraint ThreadedSocketServiceMaxThreadsPropertyInfo = (~) Int32
type AttrBaseTypeConstraint ThreadedSocketServiceMaxThreadsPropertyInfo = IsThreadedSocketService
type AttrGetType ThreadedSocketServiceMaxThreadsPropertyInfo = Int32
type AttrLabel ThreadedSocketServiceMaxThreadsPropertyInfo = "max-threads"
type AttrOrigin ThreadedSocketServiceMaxThreadsPropertyInfo = ThreadedSocketService
attrGet _ = getThreadedSocketServiceMaxThreads
attrSet _ = undefined
attrConstruct _ = constructThreadedSocketServiceMaxThreads
attrClear _ = undefined
#endif
#if ENABLE_OVERLOADING
instance O.HasAttributeList ThreadedSocketService
type instance O.AttributeList ThreadedSocketService = ThreadedSocketServiceAttributeList
type ThreadedSocketServiceAttributeList = ('[ '("active", Gio.SocketService.SocketServiceActivePropertyInfo), '("listenBacklog", Gio.SocketListener.SocketListenerListenBacklogPropertyInfo), '("maxThreads", ThreadedSocketServiceMaxThreadsPropertyInfo)] :: [(Symbol, *)])
#endif
#if ENABLE_OVERLOADING
threadedSocketServiceMaxThreads :: AttrLabelProxy "maxThreads"
threadedSocketServiceMaxThreads = AttrLabelProxy
#endif
#if ENABLE_OVERLOADING
data ThreadedSocketServiceRunSignalInfo
instance SignalInfo ThreadedSocketServiceRunSignalInfo where
type HaskellCallbackType ThreadedSocketServiceRunSignalInfo = ThreadedSocketServiceRunCallback
connectSignal _ obj cb connectMode = do
let cb' = wrap_ThreadedSocketServiceRunCallback cb
cb'' <- mk_ThreadedSocketServiceRunCallback cb'
connectSignalFunPtr obj "run" cb'' connectMode
type instance O.SignalList ThreadedSocketService = ThreadedSocketServiceSignalList
type ThreadedSocketServiceSignalList = ('[ '("event", Gio.SocketListener.SocketListenerEventSignalInfo), '("incoming", Gio.SocketService.SocketServiceIncomingSignalInfo), '("notify", GObject.Object.ObjectNotifySignalInfo), '("run", ThreadedSocketServiceRunSignalInfo)] :: [(Symbol, *)])
#endif
foreign import ccall "g_threaded_socket_service_new" g_threaded_socket_service_new ::
Int32 ->
IO (Ptr ThreadedSocketService)
threadedSocketServiceNew ::
(B.CallStack.HasCallStack, MonadIO m) =>
Int32
-> m ThreadedSocketService
threadedSocketServiceNew :: Int32 -> m ThreadedSocketService
threadedSocketServiceNew maxThreads :: Int32
maxThreads = IO ThreadedSocketService -> m ThreadedSocketService
forall (m :: * -> *) a. MonadIO m => IO a -> m a
liftIO (IO ThreadedSocketService -> m ThreadedSocketService)
-> IO ThreadedSocketService -> m ThreadedSocketService
forall a b. (a -> b) -> a -> b
$ do
Ptr ThreadedSocketService
result <- Int32 -> IO (Ptr ThreadedSocketService)
g_threaded_socket_service_new Int32
maxThreads
Text -> Ptr ThreadedSocketService -> IO ()
forall a. HasCallStack => Text -> Ptr a -> IO ()
checkUnexpectedReturnNULL "threadedSocketServiceNew" Ptr ThreadedSocketService
result
ThreadedSocketService
result' <- ((ManagedPtr ThreadedSocketService -> ThreadedSocketService)
-> Ptr ThreadedSocketService -> IO ThreadedSocketService
forall a b.
(HasCallStack, GObject a, GObject b) =>
(ManagedPtr a -> a) -> Ptr b -> IO a
wrapObject ManagedPtr ThreadedSocketService -> ThreadedSocketService
ThreadedSocketService) Ptr ThreadedSocketService
result
ThreadedSocketService -> IO ThreadedSocketService
forall (m :: * -> *) a. Monad m => a -> m a
return ThreadedSocketService
result'
#if ENABLE_OVERLOADING
#endif