socket.SO_REUSEADDR

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

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

    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/e/u/eurasia-HEAD/Eurasia/web.py eurasia(Download)

from cStringIO import StringIO
from errno import EALREADY, EINPROGRESS, EWOULDBLOCK, ECONNRESET, \
     ENOTCONN, ESHUTDOWN, EINTR, EISCONN, errorcode
from socket import socket as Socket, error as SocketError, AF_INET, SOCK_STREAM, \
	SOL_SOCKET, SO_REUSEADDR, SO_REUSEADDR
from select import poll as Poll, error as SelectError, \
	POLLIN, POLLPRI, POLLOUT, POLLERR, POLLHUP, POLLNVAL

	def __init__(self):
		global server_socket, serverpid
		server_socket = Socket(AF_INET, SOCK_STREAM)
		server_socket.setblocking(0)
		try:
			server_socket.setsockopt(SOL_SOCKET, SO_REUSEADDR,
				server_socket.getsockopt(SOL_SOCKET, SO_REUSEADDR) | 1)

src/f/u/fusil-1.3.2/fusil/network/server.py fusil(Download)

from fusil.project_agent import ProjectAgent
from fusil.network.server_client import ServerClient
from fusil.network.tools import formatAddress
from socket import (socket, error as socket_error,
    AF_INET, SOCK_STREAM, SOL_SOCKET, SO_REUSEADDR)
from ptrace.error import writeError
from select import select

    def bind(self, address, family=AF_INET, type=SOCK_STREAM, reuse_address=True):
        try:
            self.socket = socket(family, type)
            if reuse_address:
                self.socket.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
            self.family = family
            self.socket.bind(address)

src/s/h/sheared-HEAD/src/sheared/core.py sheared(Download)

from py.magic import greenlet
from select import select
from select import error as SelectError
from socket import socket, SOL_SOCKET, SO_ERROR, SO_REUSEADDR
from socket import error as SocketError
from fcntl import fcntl, F_SETFL
from errno import EINPROGRESS, EINTR

    def listen(self, factory, addr, backlog=5):
        domain, addr = parse_address_uri(addr)
        sock = socket(*domain)
        fcntl(sock.fileno(), F_SETFL, os.O_NONBLOCK)
        # we do not want 'address already in use' because of TCP-
        # connections in TIME_WAIT state
        sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)

src/n/e/neitris-HEAD/neitris/trunk/neitris_server.py neitris(Download)

import struct
import sys, time, pygame
from select import select
from socket import socket, AF_INET, SOCK_STREAM, SOL_SOCKET, SO_REUSEADDR
import neitris_utils
import neitris_cfg

# Create Reading Sockets:
for PORT in PORTS:
    portsock = socket(AF_INET, SOCK_STREAM)
    portsock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
    portsock.bind((HOSTNAME, PORT))
 
    portsock.listen(5)

src/s/q/sqmediumlite-1.7.1/_sqmediumlite/__init__.py sqmediumlite(Download)

from os.path import abspath, basename, dirname, join
from threading import Lock, currentThread
from weakref import ref
from socket import \
        AF_INET, SOCK_STREAM, SOL_SOCKET, SO_REUSEADDR, \
        error as socket_error, socket
from marshal import loads, dumps

    def bind (self, address):
        self._id1 = "L"
        if verbose: log ("bind", address, Socket.__str__ (self))
        self._s.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
        try:
            self._s.bind (address)
        except socket_error as e:

src/b/n/bnc-HEAD/bnc.py bnc(Download)

#!/usr/local/bin/python
from os import environ
environ['NCORE_CONFIG'] = '/home/synack/src/ircbnc/'
 
from ncore.config import conf
from socket import socket, SO_REUSEADDR, SOL_SOCKET
from traceback import format_exc

        self.push = PushServer(upstream.address[0])
 
        self.sock = socket()
        self.sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
        self.sock.bind(self.address)
        self.sock.listen(2)

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

from __future__ import with_statement
from urllib2 import urlopen, Request, urlopen
from StringIO import StringIO
from socket import socket, SHUT_RD, SHUT_WR, SHUT_RDWR, SO_REUSEADDR, SOL_SOCKET
from select import select
import sys
from subprocess import Popen, PIPE

    def testReuseAddress(self):
        remoteport = self.port + 1
        server = socket()
        server.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
        server.bind(('127.0.0.1', remoteport))
        server.listen(1)
        local = socket()
        local.connect(('127.0.0.1', remoteport))
        server.close()
        server = socket()
        server.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)

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

#
## end license ##
from socket import socketpair, socket
from socket import socket, SOL_SOCKET, SO_REUSEADDR, SO_LINGER, SOL_TCP, TCP_CORK, TCP_NODELAY
from struct import pack
from time import sleep
from random import randint

            def __init__(self, reactor, port):
                ear = socket()
                ear.bind(('0.0.0.0', port))
                ear.listen(127)
                ear.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
                reactor.addReader(ear, self)
                self._ear = ear