socket.SOL_SOCKET

All Samples(23) | Call(0) | Derive(0) | Import(23)

int(x[, base]) -> integer

Convert a string or number to an integer, if possible.  A floating point
argument will be truncated towards zero (this does not include a string
representation of a floating point number!)  When converting a string, use
the optional base.  It is an error to supply a base when converting a
non-string.  If base is zero, the proper base is guessed based on the
string content.  If the argument is outside the integer range a
long object will be returned instead.

src/w/e/weightless-HEAD/weightless/_server.py weightless(Download)

#
## end license ##
from __future__ import with_statement
from socket import socket, SHUT_RDWR, SOL_SOCKET, SOL_TCP, SO_REUSEADDR, SO_LINGER, TCP_CORK, SO_ERROR
from struct import pack
from _observable import Observable
from _gio import Gio, SocketContext
 
class Server(Observable):
    def __init__(self, reactor, port):
        Observable.__init__(self)
        ear = socket()
        err = ear.getsockopt(SOL_SOCKET, SO_ERROR)

    def __init__(self, reactor, port):
        Observable.__init__(self)
        ear = socket()
        err = ear.getsockopt(SOL_SOCKET, SO_ERROR)
        if err != 0:    # connection created succesfully?
            raise IOError(err)
        ear.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)

src/w/e/weightless-HEAD/weightless/_acceptor.py weightless(Download)

#    Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
#
## end license ##
from socket import socket, SOL_SOCKET, SO_REUSEADDR, SO_LINGER, SOL_TCP, TCP_CORK, TCP_NODELAY
from struct import pack
 
class Acceptor(object):
    """Listens on a port for incoming internet (TCP/IP) connections and calls a factory to create a handler for the new connection.  It does not use threads but a asynchronous reactor instead."""
 
    def __init__(self, reactor, port, sinkFactory, prio=None):
        """The reactor is a user specified reactor for dispatching I/O events asynchronously. The sinkFactory is called with the newly created socket as its single argument. It is supposed to return a callable callback function that is called by the reactor when data is available."""
        sok = socket()
        sok.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-MWE/version_1/meresco/oai/oaiharvester.py meresco(Download)

## end license ##
 
import sys
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-MWE/version_0/meresco/oai/oaiharvester.py meresco(Download)

## end license ##
 
import sys
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-Edurep/version_8/meresco/oai/oaiharvester.py meresco(Download)

#
## end license ##
 
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse, ElementTree
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-Edurep/version_7/meresco/oai/oaiharvester.py meresco(Download)

#
## end license ##
 
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse, ElementTree
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-Edurep/version_6/meresco/oai/oaiharvester.py meresco(Download)

#
## end license ##
 
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse, ElementTree
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-Edurep/version_5/meresco/oai/oaiharvester.py meresco(Download)

#
## end license ##
 
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse, ElementTree
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-Edurep/version_4/meresco/oai/oaiharvester.py meresco(Download)

#
## end license ##
 
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse, ElementTree
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

src/m/e/meresco-HEAD/meresco-oai/workingsets/3.3-Edurep/version_3/meresco/oai/oaiharvester.py meresco(Download)

## end license ##
 
import sys
from socket import socket, error as SocketError, SHUT_WR, SHUT_RD, SOL_SOCKET, SO_ERROR
from errno import EINPROGRESS, ECONNREFUSED
from lxml.etree import parse
from StringIO import StringIO

            yield
            self._reactor.removeWriter(sok)
 
            err = sok.getsockopt(SOL_SOCKET, SO_ERROR)
            if err == ECONNREFUSED:
                yield self._retryAfterError("Connection to %s:%s%s refused." % (self._host, self._port, self._path))
                continue

1 | 2 | 3 Next