Gecko [ oric.aiou.edu.pk ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
_pydoctortemplates	[ DIR ]	drwxr-xr-x
test	[ DIR ]	drwxr-xr-x
__init__.py	674 B	-rw-r--r--
_appdirs.py	788 B	-rw-r--r--
_inotify.py	3.37 KB	-rw-r--r--
_oldstyle.py	2.53 KB	-rw-r--r--
_release.py	18.11 KB	-rw-r--r--
_setup.py	12.65 KB	-rw-r--r--
_shellcomp.py	24.25 KB	-rw-r--r--
_textattributes.py	8.87 KB	-rw-r--r--
_tzhelper.py	3.12 KB	-rw-r--r--
_url.py	253 B	-rw-r--r--
compat.py	22.65 KB	-rw-r--r--
components.py	13.96 KB	-rw-r--r--
constants.py	544 B	-rw-r--r--
context.py	3.93 KB	-rw-r--r--
deprecate.py	26.15 KB	-rw-r--r--
failure.py	26.01 KB	-rw-r--r--
fakepwd.py	5.99 KB	-rw-r--r--
filepath.py	57.51 KB	-rw-r--r--
formmethod.py	11.19 KB	-rw-r--r--
htmlizer.py	3.46 KB	-rw-r--r--
lockfile.py	7.54 KB	-rw-r--r--
log.py	21.95 KB	-rw-r--r--
logfile.py	9.85 KB	-rw-r--r--
modules.py	26.5 KB	-rw-r--r--
monkey.py	2.17 KB	-rw-r--r--
procutils.py	1.39 KB	-rw-r--r--
randbytes.py	3.87 KB	-rw-r--r--
rebuild.py	9.05 KB	-rw-r--r--
reflect.py	19.02 KB	-rw-r--r--
release.py	1.16 KB	-rw-r--r--
roots.py	7.23 KB	-rw-r--r--
runtime.py	6.12 KB	-rw-r--r--
sendmsg.py	3.34 KB	-rw-r--r--
shortcut.py	2.2 KB	-rw-r--r--
syslog.py	3.64 KB	-rw-r--r--
systemd.py	2.77 KB	-rw-r--r--
text.py	5.35 KB	-rw-r--r--
threadable.py	3.22 KB	-rw-r--r--
threadpool.py	9.61 KB	-rw-r--r--
twisted-completion.zsh	1.34 KB	-rw-r--r--
url.py	244 B	-rw-r--r--
urlpath.py	8.87 KB	-rw-r--r--
usage.py	34.19 KB	-rw-r--r--
util.py	27.28 KB	-rw-r--r--
versions.py	322 B	-rw-r--r--
win32.py	4.22 KB	-rw-r--r--
zippath.py	9.02 KB	-rw-r--r--
zipstream.py	9.53 KB	-rw-r--r--

Code Editor : sendmsg.py

# -*- test-case-name: twisted.test.test_sendmsg -*-
# Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.

"""
sendmsg(2) and recvmsg(2) support for Python.
"""

from __future__ import absolute_import, division

from collections import namedtuple
from twisted.python.compat import _PY3

__all__ = ["sendmsg", "recvmsg", "getSocketFamily", "SCM_RIGHTS"]

if not _PY3:
    from twisted.python._sendmsg import send1msg, recv1msg
    from twisted.python._sendmsg import getsockfam, SCM_RIGHTS
    __all__ += ["send1msg", "recv1msg", "getsockfam"]
else:
    from socket import SCM_RIGHTS, CMSG_SPACE

RecievedMessage = namedtuple('RecievedMessage', ['data', 'ancillary', 'flags'])

def sendmsg(socket, data, ancillary=[], flags=0):
    """
    Send a message on a socket.

@param socket: The socket to send the message on.
    @type socket: L{socket.socket}

@param data: Bytes to write to the socket.
    @type data: bytes

@param ancillary: Extra data to send over the socket outside of the normal
        datagram or stream mechanism.  By default no ancillary data is sent.
    @type ancillary: C{list} of C{tuple} of C{int}, C{int}, and C{bytes}.

@param flags: Flags to affect how the message is sent.  See the C{MSG_}
        constants in the sendmsg(2) manual page.  By default no flags are set.
    @type flags: C{int}

@return: The return value of the underlying syscall, if it succeeds.
    """
    if _PY3:
        return socket.sendmsg([data], ancillary, flags)
    else:
        return send1msg(socket.fileno(), data, flags, ancillary)

def recvmsg(socket, maxSize=8192, cmsgSize=4096, flags=0):
    """
    Receive a message on a socket.

@param socket: The socket to receive the message on.
    @type socket: L{socket.socket}

@param maxSize: The maximum number of bytes to receive from the socket using
        the datagram or stream mechanism. The default maximum is 8192.
    @type maxSize: L{int}

@param cmsgSize: The maximum number of bytes to receive from the socket
        outside of the normal datagram or stream mechanism. The default maximum
        is 4096.
    @type cmsgSize: L{int}

@param flags: Flags to affect how the message is sent.  See the C{MSG_}
        constants in the sendmsg(2) manual page. By default no flags are set.
    @type flags: L{int}

@return: A named 3-tuple of the bytes received using the datagram/stream
        mechanism, a L{list} of L{tuple}s giving ancillary received data, and
        flags as an L{int} describing the data received.
    """
    if _PY3:
        # In Twisted's sendmsg.c, the csmg_space is defined as:
        #     int cmsg_size = 4096;
        #     cmsg_space = CMSG_SPACE(cmsg_size);
        # Since the default in Python 3's socket is 0, we need to define our
        # own default of 4096. -hawkie
        data, ancillary, flags = socket.recvmsg(
            maxSize, CMSG_SPACE(cmsgSize), flags)[0:3]
    else:
        data, flags, ancillary = recv1msg(
            socket.fileno(), flags, maxSize, cmsgSize)

return RecievedMessage(data=data, ancillary=ancillary, flags=flags)

def getSocketFamily(socket):
    """
    Return the family of the given socket.

@param socket: The socket to get the family of.
    @type socket: L{socket.socket}

@rtype: L{int}
    """
    if _PY3:
        return socket.family
    else:
        return getsockfam(socket.fileno())

${this.title}

Code Editor : sendmsg.py