Skip to content
Snippets Groups Projects
Commit 7fe7c623 authored by ptangu01's avatar ptangu01
Browse files

format code style pep8 but not on methods yet

git-svn-id: https://redmine.imt-atlantique.fr/svn/xaal/code/Python/trunk@1360 b32b6428-25c9-4566-ad07-03861ab6144f
parent 93d2e626
No related branches found
No related tags found
No related merge requests found
# -*- coding: utf-8 -*-
#
# Copyright 2014, Jérôme Colin, Jérôme Kerdreux, Philippe Tanguy, Telecom Bretagne.
# Copyright 2014, Jérôme Colin, Jérôme Kerdreux, Philippe Tanguy,
# Telecom Bretagne.
#
# This file is part of xAAL.
#
......@@ -30,6 +31,7 @@ import logging
logger = logging.getLogger(__name__)
class NetworkConnector():
UDP_MAX_SIZE = 65507
......@@ -50,13 +52,27 @@ class NetworkConnector():
# TBD add bind_addr attrib
bind_addr = ''
self.__sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
#self.__sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1) #formac os ???
self.__sock = socket.socket(
socket.AF_INET,
socket.SOCK_DGRAM,
socket.IPPROTO_UDP)
# self.__sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1)
# #formac os ???
self.__sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
self.__sock.bind((bind_addr, self.__port))
mreq = struct.pack('4sl', socket.inet_aton(self.__address), socket.INADDR_ANY)
self.__sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)
self.__sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, self.__hops)
mreq = struct.pack(
'4sl',
socket.inet_aton(
self.__address),
socket.INADDR_ANY)
self.__sock.setsockopt(
socket.IPPROTO_IP,
socket.IP_ADD_MEMBERSHIP,
mreq)
self.__sock.setsockopt(
socket.IPPROTO_IP,
socket.IP_MULTICAST_TTL,
self.__hops)
def disconnect(self):
logger.info("Disconnecting from the bus")
......@@ -80,7 +96,8 @@ class NetworkConnector():
def send(self, message):
try:
self.__sock.sendto(codecs.encode(message), (self.__address, self.__port))
self.__sock.sendto(
codecs.encode(message), (self.__address, self.__port))
except socket.error as e:
self.networkError(e)
......@@ -95,4 +112,3 @@ class NetworkConnector():
def getPort(self):
return self.__port
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment