GstRtspServer.RTSPServer¶

Subclasses:: GstRtspServer.RTSPOnvifServer

Methods¶

Inherited:: GObject.Object (37)
Structs:: GObject.ObjectClass (5)

class	`io_func` (socket, condition, server)
class	`new` ()
	`attach` (context)
	`client_filter` (func, *user_data)
	`create_socket` (cancellable)
	`create_source` (cancellable)
	`get_address` ()
	`get_auth` ()
	`get_backlog` ()
	`get_bound_port` ()
	`get_content_length_limit` ()
	`get_mount_points` ()
	`get_service` ()
	`get_session_pool` ()
	`get_thread_pool` ()
	`set_address` (address)
	`set_auth` (auth)
	`set_backlog` (backlog)
	`set_content_length_limit` (limit)
	`set_mount_points` (mounts)
	`set_service` (service)
	`set_session_pool` (pool)
	`set_thread_pool` (pool)
	`transfer_connection` (socket, ip, port, initial_buffer)

Virtual Methods¶

Inherited:: GObject.Object (7)

do_client_connected (client)

Properties¶

Name	Type	Flags	Short Description
`address`	`str`	r/w	The address the server uses to listen on
`backlog`	`int`	r/w	The maximum length to which the queue of pending connections may grow
`bound-port`	`int`	r	The port number the server is listening on
`content-length-limit`	`int`	r/w	Limitation of Content-Length
`mount-points`	`GstRtspServer.RTSPMountPoints`	r/w	The mount points to use for client session
`service`	`str`	r/w	The service or port number the server uses to listen on
`session-pool`	`GstRtspServer.RTSPSessionPool`	r/w	The session pool to use for client session

Signals¶

Inherited:: GObject.Object (1)

Name	Short Description
`client-connected`

Fields¶

Inherited:: GObject.Object (1)

Name	Type	Access	Description
parent	`GObject.Object`	r

Class Details¶

class GstRtspServer.RTSPServer(**kwargs)¶

Bases:: GObject.Object
Abstract:: No
Structure:: GstRtspServer.RTSPServerClass

This object listens on a port, creates and manages the clients connected to it.

classmethod io_func(socket, condition, server)[source]¶

Parameters:

socket (Gio.Socket) – a Gio.Socket
condition (GLib.IOCondition) – the condition on source
server (GstRtspServer.RTSPServer) – a GstRtspServer.RTSPServer

Returns:

True if the source could be connected, False if an error occurred.

Return type:

bool

A default Gio.SocketSourceFunc that creates a new GstRtspServer.RTSPClient to accept and handle a new connection on socket or server.

classmethod new()[source]¶

Returns:: a new GstRtspServer.RTSPServer
Return type:: GstRtspServer.RTSPServer

Create a new GstRtspServer.RTSPServer instance.

attach(context)[source]¶

Parameters:: context (GLib.MainContext or None) – a GLib.MainContext
Returns:: the ID (greater than 0) for the source within the GLib.MainContext.
Return type:: int

Attaches self to context. When the mainloop for context is run, the server will be dispatched. When context is None, the default context will be used).

This function should be called when the server properties and urls are fully configured and the server is ready to start.

This takes a reference on self until the source is destroyed. Note that if context is not the default main context as returned by GLib.MainContext.default() (or None), GLib.Source.remove() cannot be used to destroy the source. In that case it is recommended to use GstRtspServer.RTSPServer.create_source() and attach it to context manually.

client_filter(func, *user_data)[source]¶

Parameters:

func (GstRtspServer.RTSPServerClientFilterFunc or None) – a callback
user_data (object or None) – user GstRtsp.data passed to func

Returns:

a GLib.List with all clients for which func returned GstRtspServer.RTSPFilterResult.REF. After usage, each element in the GLib.List should be unreffed before the list is freed.

Return type:

[GstRtspServer.RTSPClient]

Call func for each client managed by self. The result value of func determines what happens to the client. func will be called with self locked so no further actions on self can be performed from func.

If func returns GstRtspServer.RTSPFilterResult.REMOVE, the client will be removed from self.

If func returns GstRtspServer.RTSPFilterResult.KEEP, the client will remain in self.

If func returns GstRtspServer.RTSPFilterResult.REF, the client will remain in self but will also be added with an additional ref to the result GLib.List of this function..

When func is None, GstRtspServer.RTSPFilterResult.REF will be assumed for each client.

create_socket(cancellable)[source]¶

Parameters:: cancellable (Gio.Cancellable or None) – a Gio.Cancellable
Raises:: GLib.Error
Returns:: the Gio.Socket for self or None when an error occurred.
Return type:: Gio.Socket

Create a Gio.Socket for self. The socket will listen on the configured service.

create_source(cancellable)[source]¶

Parameters:: cancellable (Gio.Cancellable or None) – a Gio.Cancellable or None.
Raises:: GLib.Error
Returns:: the GLib.Source for self or None when an error occurred. Free with GLib.Source.unref ()
Return type:: GLib.Source

Create a GLib.Source for self. The new source will have a default Gio.SocketSourceFunc of GstRtspServer.RTSPServer.io_func().

cancellable if not None can be used to cancel the source, which will cause the source to trigger, reporting the current condition (which is likely 0 unless cancellation happened at the same time as a condition change). You can check for this in the callback using Gio.Cancellable.is_cancelled().

This takes a reference on self until source is destroyed.

get_address()[source]¶

Returns:: the server address. GLib.free() after usage.
Return type:: str or None

Get the address on which the server will accept connections.

get_auth()[source]¶

Returns:: the GstRtspServer.RTSPAuth of self. GObject.Object.unref() after usage.
Return type:: GstRtspServer.RTSPAuth or None

Get the GstRtspServer.RTSPAuth used as the authentication manager of self.

get_backlog()[source]¶

Returns:: the server backlog.
Return type:: int

The maximum amount of queued requests for the server.

get_bound_port()[source]¶

Returns:: the port number
Return type:: int

Get the port number where the server was bound to.

get_content_length_limit()[source]¶

Returns:: the Content-Length limit.
Return type:: int

Get the Content-Length limit of self.

New in version 1.18.

get_mount_points()[source]¶

Returns:: the GstRtspServer.RTSPMountPoints of self. GObject.Object.unref() after usage.
Return type:: GstRtspServer.RTSPMountPoints or None

Get the GstRtspServer.RTSPMountPoints used as the mount points of self.

get_service()[source]¶

Returns:: the service. use GLib.free() after usage.
Return type:: str

Get the service on which the server will accept connections.

get_session_pool()[source]¶

Returns:: the GstRtspServer.RTSPSessionPool used for sessions. GObject.Object.unref() after usage.
Return type:: GstRtspServer.RTSPSessionPool or None

Get the GstRtspServer.RTSPSessionPool used as the session pool of self.

get_thread_pool()[source]¶

Returns:: the GstRtspServer.RTSPThreadPool of self. GObject.Object.unref() after usage.
Return type:: GstRtspServer.RTSPThreadPool or None

Get the GstRtspServer.RTSPThreadPool used as the thread pool of self.

set_address(address)[source]¶

Parameters:: address (str) – the address

Configure self to accept connections on the given address.

This function must be called before the server is bound.

set_auth(auth)[source]¶

Parameters:: auth (GstRtspServer.RTSPAuth or None) – a GstRtspServer.RTSPAuth

configure auth to be used as the authentication manager of self.

set_backlog(backlog)[source]¶

Parameters:: backlog (int) – the backlog

configure the maximum amount of requests that may be queued for the server.

This function must be called before the server is bound.

set_content_length_limit(limit)[source]¶

Parameters:: limit (int) –

Define an appropriate GstRtsp.request size limit and reject requests exceeding the limit.

New in version 1.18.

set_mount_points(mounts)[source]¶

Parameters:: mounts (GstRtspServer.RTSPMountPoints or None) – a GstRtspServer.RTSPMountPoints

configure mounts to be used as the mount points of self.

set_service(service)[source]¶

Parameters:: service (str) – the service

Configure self to accept connections on the given service. service should be a string containing the service name (see services(5)) or a string containing a port number between 1 and 65535.

When service is set to “0”, the server will listen on a random free port. The actual used port can be retrieved with GstRtspServer.RTSPServer.get_bound_port().

This function must be called before the server is bound.

set_session_pool(pool)[source]¶

Parameters:: pool (GstRtspServer.RTSPSessionPool or None) – a GstRtspServer.RTSPSessionPool

configure pool to be used as the session pool of self.

set_thread_pool(pool)[source]¶

Parameters:: pool (GstRtspServer.RTSPThreadPool or None) – a GstRtspServer.RTSPThreadPool

configure pool to be used as the thread pool of self.

transfer_connection(socket, ip, port, initial_buffer)[source]¶

Parameters:

socket (Gio.Socket) – a network socket
ip (str) – the IP address of the remote client
port (int) – the port used by the other end
initial_buffer (str or None) – any initial GstRtsp.data that was already read from the socket

Returns:

True if all was ok, False if an error occurred.

Return type:

bool

Take an existing network socket and use it for an RTSP connection. This is used when transferring a socket from an HTTP server which should be used as an RTSP over HTTP tunnel. The initial_buffer contains any remaining GstRtsp.data that the HTTP server read from the socket while parsing the HTTP header.

do_client_connected(client) virtual¶

Parameters:: client (GstRtspServer.RTSPClient) –

emitted when a new client connected.

Signal Details¶

GstRtspServer.RTSPServer.signals.client_connected(r_t_s_p_server, object)¶

Signal Name:

client-connected

Flags:

RUN_LAST

Parameters:

r_t_s_p_server (GstRtspServer.RTSPServer) – The object which received the signal
object (GstRtspServer.RTSPClient) –

Property Details¶

GstRtspServer.RTSPServer.props.address¶

Name:: address
Type:: str
Default Value:: '0.0.0.0'
Flags:: READABLE, WRITABLE

The address the server uses to listen on

GstRtspServer.RTSPServer.props.backlog¶

Name:: backlog
Type:: int
Default Value:: 5
Flags:: READABLE, WRITABLE

The maximum length to which the queue of pending connections may grow

GstRtspServer.RTSPServer.props.bound_port¶

Name:: bound-port
Type:: int
Default Value:: -1
Flags:: READABLE

The port number the server is listening on

GstRtspServer.RTSPServer.props.content_length_limit¶

Name:: content-length-limit
Type:: int
Default Value:: 4294967295
Flags:: READABLE, WRITABLE

Limitation of Content-Length

GstRtspServer.RTSPServer.props.mount_points¶

Name:: mount-points
Type:: GstRtspServer.RTSPMountPoints
Default Value:: None
Flags:: READABLE, WRITABLE

The mount points to use for client session

GstRtspServer.RTSPServer.props.service¶

Name:: service
Type:: str
Default Value:: '8554'
Flags:: READABLE, WRITABLE

The service or port number the server uses to listen on

GstRtspServer.RTSPServer.props.session_pool¶

Name:: session-pool
Type:: GstRtspServer.RTSPSessionPool
Default Value:: None
Flags:: READABLE, WRITABLE

The session pool to use for client session