Skip to content

Commit

Permalink
Tibit EOAM implementation.
Browse files Browse the repository at this point in the history
  • Loading branch information
Nathan Knuth committed Sep 19, 2016
1 parent 8dc1f5e commit adcc556
Show file tree
Hide file tree
Showing 4 changed files with 1,244 additions and 1 deletion.
7 changes: 6 additions & 1 deletion setup.mk
View file
Expand Up @@ -14,7 +14,11 @@
# limitations under the License.
#

#### VERBOSE ####
##
## Makefile Setup
##

## VERBOSE Option
# Set V (for VERBOSE) on the comand line (make V=1) to see additional
# output
ifeq ("$(origin V)", "command line")
Expand All @@ -24,4 +28,5 @@ export Q=@
export MAKEFLAGS+=--no-print-directory
endif

## Common commands
FLAKE8:=flake8
195 changes: 195 additions & 0 deletions voltha/adapters/tibit/EOAM.py
View file
@@ -0,0 +1,195 @@
#!/usr/bin/env python
#--------------------------------------------------------------------------#
# Copyright (C) 2015 - 2016 by Tibit Communications, Inc. #
# All rights reserved. #
# #
# _______ ____ _ ______ #
# /_ __(_) __ )(_)_ __/ #
# / / / / __ / / / / #
# / / / / /_/ / / / / #
# /_/ /_/_____/_/ /_/ #
# #
#--------------------------------------------------------------------------#
""" EOAM protocol implementation in scapy """

TIBIT_VERSION_NUMBER = '1.1.2'

import time
import logging
import argparse
import sys
import inspect

logging.getLogger("scapy.runtime").setLevel(logging.ERROR)
from scapy.all import Dot1Q
from scapy.all import sniff
from scapy.all import IP, UDP
from scapy.packet import Packet, bind_layers
from scapy.fields import StrField
from scapy.layers.l2 import Ether
from scapy.main import interact
from scapy.sendrecv import sendp
from scapy.sendrecv import srp1

import fcntl, socket, struct # for get hw address

# TODO should remove import *
from EOAM_TLV import *

EOAM_MULTICAST_ADDRESS = '01:80:c2:00:00:02'
IGMP_MULTICAST_ADDRESS = '01:00:5e:00:00:01' # for test

class EOAM():
""" EOAM frame layer """
def __init__(self, ctag=None, dryrun=False, stag=None,
verbose=False, etype='8809',
dst=EOAM_MULTICAST_ADDRESS,
hexdump=False, interface='eth0',
sleep=0.5):
self.verbose = verbose
self.dst = dst
self.dryrun = dryrun
self.hexdump = hexdump
self.interface = interface
self.etype = int(etype, 16)
self.stag = stag
self.ctag = ctag
self.sleep = sleep
if (self.verbose == True):
print("=== Settings ================")
print("ctag = %s" % self.ctag)
print("dst = %s" % self.dst)
print("dryrun = %s" % self.dryrun)
print("hexdump = %s" % self.hexdump)
print("interface = %s" % self.interface)
print("etype = 0x%04x" % self.etype)
print("stag = %s" % self.stag)
print("verbose = %s" % self.verbose)
print("=== END Settings ============")

def send_frame(self, frame_body):
PACKET = Ether()
PACKET.length = 64
PACKET.dst = self.dst
PACKET.src = self.getHwAddr(self.interface)
if self.stag:
# WARNING: September/2016: This should be 0x88a8, but the Intel 10G
# hardware I am currently using does not support a TPID of
# 0x88a8. Setting to 0x8100.
PACKET.type = 0x8100
if self.ctag:
PACKET/=Dot1Q(type=0x8100,vlan=int(self.stag))
PACKET/=Dot1Q(type=self.etype,vlan=int(self.ctag))
else:
PACKET/=Dot1Q(type=self.etype,vlan=int(self.stag))
else:
if self.ctag:
PACKET.type = 0x8100
PACKET/=Dot1Q(type=self.etype,vlan=int(self.ctag))
else:
PACKET.type = self.etype
PACKET/=Dot1Q(type=self.etype, vlan=int(self.ctag))
PACKET/=SlowProtocolsSubtype()/FlagsBytes()/OAMPDU()
PACKET/=frame_body
PACKET/=EndOfPDU()
if (self.verbose == True):
PACKET.show()
print '###[ Frame Length %d (before padding) ]###' % len(PACKET)
if (self.hexdump == True):
print hexdump(PACKET)
if (self.dryrun != True):
sendp(PACKET, iface=self.interface)
time.sleep(self.sleep)
return PACKET

def get_request(self, TLV):
return self.send_frame(CablelabsOUI()/DPoEOpcode_GetRequest()/TLV)

def set_request(self, TLV):
return self.send_frame(CablelabsOUI()/DPoEOpcode_SetRequest()/TLV)

def send_multicast_register(self, TLV):
'''
Note, for mulicast, the standard specifies a register message
with ActionFlags of either Register or Deregister
'''
return self.send_frame(CablelabsOUI()/DPoEOpcode_MulticastRegister()/TLV)

def set_request_broadcom(self, TLV):
return self.send_frame(BroadcomOUI()/DPoEOpcode_SetRequest()/TLV)

def getHwAddr(self, ifname):
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
info = fcntl.ioctl(s.fileno(), 0x8927, struct.pack('256s', ifname[:15]))
return ':'.join(['%02x' % ord(char) for char in info[18:24]])


if __name__ == "__main__":
parser = argparse.ArgumentParser()
parser.add_argument('-d', '--dst', dest='dst', action='store', default=EOAM_MULTICAST_ADDRESS,
help='MAC destination (default: %s)' % EOAM_MULTICAST_ADDRESS)
parser.add_argument('-e', '--etype', dest='etype', action='store', default='8809',
help='EtherType value (default: 0x8809)')
parser.add_argument('-i', '--interface', dest='interface', action='store', default='eth0',
help='ETH interface to send (default: eth0)')
parser.add_argument('-s', '--stag', dest='stag', action='store', default=None,
help='STAG value (default: None)')
parser.add_argument('-c', '--ctag', dest='ctag', action='store', default=None,
help='CTAG value (default: None)')
parser.add_argument('-p', '--sleep', dest='sleep', action='store', default='0.5', type=float,
help='SLEEP time after frame (default: 2)')
parser.add_argument('-v', '--verbose', dest='verbose', action='store_true', default=False,
help='verbose frame print out')
parser.add_argument('-x', '--hexdump', dest='hexdump', action='store_true', default=False,
help='Hexdump the frame')
parser.add_argument('-y', '--dryrun', dest='dryrun', action='store_true', default=False,
help='Dry run test, dont send - just print')
parser.add_argument('-t', '--test', dest='test', action='store_true', default=False,
help='Run commands under test')


parser.add_argument('-r', '--critical', dest='critical', action='store_true', default=False,
help='Send the critical OAM set of set_request()')


parser.add_argument('-ta', '--test_add', dest='test_add', action='store_true', default=False,
help='Run commands under test')
parser.add_argument('-td', '--test_del', dest='test_del', action='store_true', default=False,
help='Run commands under test')
parser.add_argument('-tc', '--test_clr', dest='test_clr', action='store_true', default=False,
help='Run commands under test')

args = parser.parse_args()

if (args.dryrun == True):
args.sleep = 0.0

eoam = EOAM(
dryrun=args.dryrun,
dst=args.dst,
etype=args.etype,
hexdump=args.hexdump,
interface=args.interface,
stag=args.stag,
ctag=args.ctag,
verbose=args.verbose,
)

if (args.test == True):
print 'SET - Multicast Register Message 01'
eoam.send_multicast_register(MulticastRegisterSet(MulticastLink=0x3fe0, UnicastLink=0x1008))

print 'SET - Multicast Deregister Message 02'
eoam.send_multicast_register(MulticastRegisterSet(ActionFlags="Deregister",MulticastLink=0x3fe0, UnicastLink=0x1008))

if (args.test_clr == True):
print 'SET Clear Static MAC Table -- User Port Object'
eoam.set_request(ClearStaticMacTable())

if (args.test_add == True):
print 'SET Add Static MAC Address -- User Port Object'
eoam.set_request(AddStaticMacAddress(mac=IGMP_MULTICAST_ADDRESS))

if (args.test_del == True):
print 'SET Delete Static MAC Address -- User Port Object'
eoam.set_request(DeleteStaticMacAddress(mac=IGMP_MULTICAST_ADDRESS))

0 comments on commit adcc556

Please sign in to comment.