Struct gio::ThreadedSocketService

#[repr(transparent)]
pub struct ThreadedSocketService { /* private fields */ }

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 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 run, or subclass and override the default handler.

Properties

max-threads

Readable | Writeable | Construct Only

SocketService

active

Whether the service is currently accepting connections.

Readable | Writeable | Construct

SocketListener

listen-backlog

Readable | Writeable | Construct

Signals

run

The ::run signal is emitted in a worker thread in response to an incoming connection. This thread is dedicated to handling connection and may perform blocking IO. The signal handler need not return until the connection is closed.

SocketService

incoming

The ::incoming signal is emitted when a new incoming connection to service needs to be handled. The handler must initiate the handling of connection, but may not block; in essence, asynchronous operations must be used.

connection will be unreffed once the signal handler returns, so you need to ref it yourself if you are planning to use it.

SocketListener

event

Emitted when listener’s activity on socket changes state. Note that when listener is used to listen on both IPv4 and IPv6, a separate set of signals will be emitted for each, and the order they happen in is undefined.

Implements

ThreadedSocketServiceExt, SocketServiceExt, SocketListenerExt, glib::ObjectExt

Implementations

impl ThreadedSocketService

pub fn new(max_threads: Option<u32>) -> ThreadedSocketService

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

max_threads

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

Returns

a new SocketService.

impl ThreadedSocketService

pub const NONE: Option<&'static ThreadedSocketService> = None

Trait Implementations

impl Clone for ThreadedSocketService

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ThreadedSocketService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for ThreadedSocketService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl HasParamSpec for ThreadedSocketService

type ParamSpec = ParamSpecObject

type SetValue = ThreadedSocketService

Preferred value to be used as setter for the associated ParamSpec.

type BuilderFn = fn(_: &str) -> ParamSpecObjectBuilder<'_, ThreadedSocketService>

fn param_spec_builder() -> Self::BuilderFn

impl Hash for ThreadedSocketService

fn hash<H>(&self, state: &mut H)where H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for ThreadedSocketService

fn cmp(&self, other: &Self) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Selfwhere Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Selfwhere Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Selfwhere Self: Sized + PartialOrd<Self>,

Restrict a value to a certain interval.

impl ParentClassIs for ThreadedSocketService

type Parent = SocketService

impl<OT: ObjectType> PartialEq<OT> for ThreadedSocketService

fn eq(&self, other: &OT) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<OT: ObjectType> PartialOrd<OT> for ThreadedSocketService

fn partial_cmp(&self, other: &OT) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

This method tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

This method tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

This method tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

This method tests greater than or equal to (for self and other) and is used by the >= operator.

impl StaticType for ThreadedSocketService

fn static_type() -> Type

Returns the type identifier of Self.

impl Eq for ThreadedSocketService

impl IsA<SocketListener> for ThreadedSocketService

impl IsA<SocketService> for ThreadedSocketService