GI.Gio.Objects.ThreadedSocketService

A ThreadedSocketService is a simple subclass of SocketService that handles incoming connections by creating a worker thread and dispatching the connection to it by emitting the ThreadedSocketService::run signal in the new thread.

The signal handler may perform blocking IO and need not return until the connection is closed.

The service is implemented using a thread pool, so there is a limited amount of threads available to serve incoming requests. The service automatically stops the SocketService from accepting new connections when all threads are busy.

As with SocketService, you may connect to ThreadedSocketService::run, or subclass and override the default handler.

Exported types

newtype ThreadedSocketService

Constructors

ThreadedSocketService (ManagedPtr ThreadedSocketService)

Instances

GObject ThreadedSocketService

Methods

gobjectType :: ThreadedSocketService -> IO GType

IsObject ThreadedSocketService

IsSocketService ThreadedSocketService

IsSocketListener ThreadedSocketService

IsThreadedSocketService ThreadedSocketService

class GObject o => IsThreadedSocketService o

Instances

(GObject a, UnknownAncestorError Constraint ThreadedSocketService a) => IsThreadedSocketService a

IsThreadedSocketService ThreadedSocketService

toThreadedSocketService :: (MonadIO m, IsThreadedSocketService o) => o -> m ThreadedSocketService

noThreadedSocketService :: Maybe ThreadedSocketService

Methods

new

threadedSocketServiceNew

Arguments

:: (HasCallStack, MonadIO m)

=> Int32

maxThreads: the maximal number of threads to execute concurrently handling incoming clients, -1 means no limit

-> m ThreadedSocketService

Returns: a new SocketService.

Creates a new ThreadedSocketService with no listeners. Listeners must be added with one of the SocketListener "add" methods.

Since: 2.22

Properties

maxThreads

constructThreadedSocketServiceMaxThreads :: IsThreadedSocketService o => Int32 -> IO (GValueConstruct o)

getThreadedSocketServiceMaxThreads :: (MonadIO m, IsThreadedSocketService o) => o -> m Int32

Signals

run

type C_ThreadedSocketServiceRunCallback = Ptr () -> Ptr SocketConnection -> Ptr Object -> Ptr () -> IO CInt

type ThreadedSocketServiceRunCallback = SocketConnection -> Object -> IO Bool

afterThreadedSocketServiceRun :: (IsThreadedSocketService a, MonadIO m) => a -> ThreadedSocketServiceRunCallback -> m SignalHandlerId

genClosure_ThreadedSocketServiceRun :: ThreadedSocketServiceRunCallback -> IO Closure

mk_ThreadedSocketServiceRunCallback :: C_ThreadedSocketServiceRunCallback -> IO (FunPtr C_ThreadedSocketServiceRunCallback)

noThreadedSocketServiceRunCallback :: Maybe ThreadedSocketServiceRunCallback

onThreadedSocketServiceRun :: (IsThreadedSocketService a, MonadIO m) => a -> ThreadedSocketServiceRunCallback -> m SignalHandlerId

wrap_ThreadedSocketServiceRunCallback :: ThreadedSocketServiceRunCallback -> Ptr () -> Ptr SocketConnection -> Ptr Object -> Ptr () -> IO CInt