ó
̍EYc@sð
dZd
dl
Z
d
dlZd
dlmZ
d
dlmZ
d
dlm	Z	
d
dl
mZ
d
dl
mZ
d
dl
m
Z

ejeƒ
Zdd	„
Zddd
„Zd„Ze
jjddddd„ƒ
Ze
jjdddd
„ƒ
Ze
jjdd„
ƒ
Zd„Zd„Ze
jjd„ƒ
Ze
jjd„ƒ
Ze
jjd„ƒ
Ze
jjd„ƒ
Ze
jjd„ƒ
Z e
jjd„ƒ
Z!ddd„Z"e
jjd„ƒ
Z#e
jjdd„
ƒ
Z$e
jjdd„
ƒ
Z%dS(s0Implements vlans, bridges using linux utilities.iÿÿÿÿN(
tprocessutils(
tlog(
texcutils(
t	constants(
t	exception(
tprivsepcCsŽd
g
}|
dk	r)|d|
g
7}n||7}yt
j|ŒSWnCtk
r‰
}
tjdi|d6|d6ƒ
tjd|ƒ
‚
n
XdS(Ns	ovs-vsctls--timeout=%ss3Unable to execute %(cmd)s. Exception: %(exception)stcmdRtmethod(tNoneRtexecutet	ExceptiontLOGterrorRt
AgentError(targsttimeoutt	full_argst
e((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyt
_ovs_vsctl$s
	







	

cCszd
dd|
d
d||
d
dd|
d|dd	|d
|g}|r\|d|g
7}n|rv|d|g
7}n|S(
Ns--s--if-existssdel-portsadd-porttsett	Interfacesexternal-ids:iface-id=%ss external-ids:iface-status=activesexternal-ids:attached-mac=%ssexternal-ids:vm-uuid=%sstype=%ssoptions:vhost-server-path=%s((tbridgetdevtiface_idtmactinstance_idtinterface_typetvhost_server_pathR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyt_create_ovs_vif_cmd1s
	










c
Cs#d
dd|d
dd|d|
g	S(Ns--s--may-existsadd-brRtBridgesdatapath_type=%s((Rt
datapath_type((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyt_create_ovs_bridge_cmdBs

c			CsBtt
||
|||||ƒd
|ƒ


t|
||d
|ƒ

dS(NR(RRt_update_device_mtu(	RRRRRtmtuRRR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pytcreate_ovs_vif_portGs
	

cCst||
|d
|ƒ

dS(NR(
R (RR!RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pytupdate_ovs_vif_portQscCs-td
dd||
gd|ƒ


t
|
ƒ

dS(Ns--s--if-existssdel-portR(Rt_delete_net_dev(RRR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pytdelete_ovs_vif_portVs

c

Cstj
jd
|ƒ
S(s Check if ethernet device exists.s/sys/class/net/%s(tostpathtexists(
tdevice((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyt
device_exists]sc

	Cs†t|ƒ
r‚y9t
jd
dd|ddddgƒ

tjd|ƒ
Wq‚t
jk
r~


tjƒ
tjd	|ƒ
Wd
QXq‚Xnd
S(s*Delete a network device only if it exists.tiptlinktdeletetcheck_exit_codeiiiþsNet device removed: '%s's Failed removing net device: '%s'N(	R*RR	RtdebugtProcessExecutionErrorRtsave_and_reraise_exceptionR(
R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyR$bs







c
Cs£x||
gD]}t|ƒ

q
Wt
jd
dd|dddd|
ƒ	
xV||
gD]H}t
jd
dd|d	ƒ
t
jd
dd|d
dƒ
t||ƒ
qSWdS(
spCreate a pair of veth devices with the specified names,
    deleting any previous devices with those names.
    R+R,taddttypetvethtpeertnameRtuptpromisctonN(R$RR	R (t	dev1_namet	dev2_nameR!R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pytcreate_veth_pairns





cCs(x!||
gD]}t||ƒ
q
Wd
S(s5Update a pair of veth devices with new configuration.N(
R (R:R;R!R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pytupdate_veth_pair~s
cCstt
||
ƒƒ

dS(
N(RR(RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pytensure_ovs_bridge…sc
CsÞt|ƒ
sÁt
jd
d|ƒ
t
jd
d|dƒ
t
jd
d|dƒ
d}
|
|}
t
jd|
d	d
dddgƒ
d
|}tjj|ƒ
rÁt
jd|d	ddddgƒ
qÁnt
jddd|dƒ
dS(Ntbrctltaddbrtsetfditstptoffs+/sys/class/net/%s/bridge/multicast_snoopingtteet
process_inputt
0R.i
s'/proc/sys/net/ipv6/conf/%s/disable_ipv6t
1R+R,RR7(R*RR	R&R'R((Rtsyspathtdisv6((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyt
ensure_bridgeŠs 












	


cCsUt|ƒ
rQt
jd
d||
ƒ
t
jddd|dƒ
t
jd
d|ƒ
ndS(NR?tdelifR+R,Rtdowntdelbr(R*RR	(RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyt
delete_bridgeŸs


cCstj
d
d||
ƒ
dS(NR?taddif(RR	(RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pytadd_bridge_port§sixcCsŽ|
s
dS|tj
tjgkrGtjtjkrŠt||
ƒ
qŠnCtd
|ƒ
rlt||
d
|ƒ

nt	j
di|d6|d6ƒ
dS(NRsGMTU not set on %(interface_name)s interface of type %(interface_type)s.tinterface_nameR(RtOVS_VHOSTUSER_INTERFACE_TYPEt#OVS_VHOSTUSER_CLIENT_INTERFACE_TYPEtsystplatformtPLATFORM_WIN32t_set_device_mtut_ovs_supports_mtu_requestst_set_mtu_requestRR/(RR!RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyR ¬s







	

cCs/tj
d
dd|d|
ddddgƒ

d	S(
sSet the device MTU.R+R,RR!R.iiiþN(RR	(RR!((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyRWÁs
cCs-d
dd|d|
g}t|d|ƒ


dS(Ns--Rt	interfacesmtu_request=%sR(
R(RR!RR((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyRYÈs


c
Cs?d
ddg}
t|
d|ƒ

\}}|ddkr;t
StS(Ns--columns=mtu_requesttlistRZRs%ovs-vsctl: Interface does not contains* a column whose name matches "mtu_request"(RtFalsetTrue(RRt
_R((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyRXÏs





(&t__doc__R&RTtoslo_concurrencyRtoslo_logR
tloggingt
oslo_utilsRtvif_plug_ovsRRRt	getLoggert__name__RRRRRtvif_plugt
entrypointR"R#R%R*R$R<R=R>RJRNRPR RWRYRX(((sK/home/tvault/.virtenv/lib/python2.7/site-packages/vif_plug_ovs/linux_net.pyt<module>sD