/snap/core22/2437/usr/share/subiquity/subiquitycore/controllers/__pycache__
Edit: /snap/core22/2437/usr/share/subiquity/subiquitycore/controllers/__pycache__/network.cpython-310.pyc (20202B)
o
K^Z @ s8 d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlZd dlm Z m
Z
d dl m Z d dl
mZ d dlmZ d dlmZmZmZmZmZ d dlmZ d d lmZ d d
lm Z d d l m Z d d l m Z d d
l!m"Z" d dl#m$Z$m%Z% e&dZ'G dd de
Z(dZ)G dd deZ*G dd dZ+G dd de*e e+Z,dS ) N)Optional)IFF_UPNetworkEventReceiver)SingleInstanceTask) with_context)
write_file)
BondConfig DHCPState NetDevAction StaticConfig
WLANConfig)netplan)BaseController) CoreChannels)
TuiController)StretchyOverlay) NetworkView) arun_command run_commandz subiquitycore.controller.networkc s< e Zd Zdd Zdd Zdd Zdd Z fd d
Z ZS ) SubiquityNetworkEventReceiverc C s || _ |j| _t | _d S N)
controllermodelsetdefault_routes)selfr r 9/usr/share/subiquity/subiquitycore/controllers/network.py__init__6 s z&SubiquityNetworkEventReceiver.__init__c C s* | j ||}|d ur| j| d S d S r )r new_linkr )r ifindexlinknetdevr r r r ; s z&SubiquityNetworkEventReceiver.new_linkc C sL | j |}|| jv r| j| | j| j |d ur$| j| d S d S r )r del_linkr remover update_default_routes)r r r" r r r r# @ s
z&SubiquityNetworkEventReceiver.del_linkc C sb | j |}|d u r d S t|jdd}|t@ s)|| jv r)| j| | j| j | j| d S )Nflagsr ) r update_linkgetattrinfor r r$ r r% )r r r" r& r r r r' H s z)SubiquityNetworkEventReceiver.update_linkc s t || |d dkrd S |d dkrd S |d }|dks#|dkr*| j| n|dkr9|| jv r9| j| td | j | j| j d S )
Ndstdefaulttable r NEWCHANGEDELzdefault routes %s) super route_changer addr$ logdebugr r% )r actiondatar __class__r r r2 R s z*SubiquityNetworkEventReceiver.route_change) __name__
__module__ __qualname__r r r# r' r2
__classcell__r r r8 r r 5 s
r a
network:
version: 2
ethernets:
"all-en":
match:
name: "en*"
addresses:
- 10.0.2.15/24
gateway4: 10.0.2.2
nameservers:
addresses:
- 8.8.8.8
- 8.4.8.4
search:
- foo
- bar
"all-eth":
match:
name: "eth*"
dhcp4: true
wifis:
"wlsp4":
dhcp4: true
access-points:
"some-ap":
password: password
c s e Zd ZdZdZ fddZdd Zdd Zd d
Zd d Z d
d Z
dd Z e dd Z
dLddZdd Zdd Zdd Zed d d d d!d" Zd#ed$ed%ed&dfd'd(Zd#ed$ed&dfd)d*Zd#ed$ed&dfd+d,Zd#ed-efd.d/Zd#efd0d1Zd2e e d3ed4e d&dfd5d6Z d#ed&efd7d8Z d#ed9e d&dfd:d;Z!d#ed&dfd
d? Z%e#j$d@dA Z&e#j$dBdC Z'e#j$dDdE Z(e#j$dFdG Z)e#j$dHdI Z*e#j$dJdK Z+ Z,S )MBaseNetworkControllernetwork/c s t | t| j| _| jjrPtj | jj
| _ | j }tj
|}tj|r1dd l}|| t| t|d
}|t W d n1 sKw Y | d| _t| | _d S )Nr wF)r1 r r
_apply_configapply_config_taskoptsdry_runospathabspath output_baseroot netplan_pathdirnameexistsshutilrmtreemakedirsopenwritedefault_netplanparse_netplan_configs _watchingr network_event_receiver)r apprK netplan_dirrN fpr8 r r r s
z BaseNetworkController.__init__c C s | j | j d S r )r rT rJ r r r r rT s z+BaseNetworkController.parse_netplan_configsc C s* g | _ | jj| j\| _| _| d S r )_observer_handlesrW prober
probe_networkrV observer
_observer_fdsstart_watchingrZ r r r start s
zBaseNetworkController.startc C s2 | j sd S t }| jD ]}|| q d| _ d S NF)rU asyncioget_event_loopr_
remove_readerr loopfdr r r
stop_watching s
z#BaseNetworkController.stop_watchingc C s8 | j rd S t }| jD ]
}||| j| q d| _ d S )NT)rU rc rd r_
add_reader _data_readyrf r r r r` s
z$BaseNetworkController.start_watchingc C sR t g d}|jdkr!td | t }|d| j d S | j
| d S )N)udevadmsettlez-t0r z*waiting 0.1 to let udev event queue settle皙?) r
returncoder4 r5 ri rc rd
call_laterr` r^
data_ready)r rh cprg r r r rk s
z!BaseNetworkController._data_readyc C s t d | j D ]7}d}|jd u s|jsq
|jj D ] }|jdkr(d} nq |sA| d | d t d|j
t d|_ q
d S ) Nzupdating initial NIC configFglobalT z disabling %szautoconfiguration failed)
r4 r5 r get_all_netdevsr) config addressesvaluesscope remove_ip_networks_for_versionname_disabled_reason)r devhas_global_addressar r r update_initial_configs s"
z,BaseNetworkController.update_initial_configsc C s( | j jdkr d}nd}tj| jd|S )N subiquityz00-installer-config.yamlz00-snapd-config.yamlz etc/netplan)rD projectrF rG joinrJ )r netplan_config_file_namer r r rK s z"BaseNetworkController.netplan_pathNFc C s | j j||d d S )N)contextsilent)rC
start_sync)r r r r r r apply_config s z"BaseNetworkController.apply_configc sT |D ]$}zt d|j | jj|jt W q ty' t d|j Y qw d S )Nz
downing %sz unset_link_flags failed for %s)
r4 r5 r} r^
rtlistenerunset_link_flagsr r RuntimeError exception)r devsr r r r
_down_devs s z BaseNetworkController._down_devsc s| |D ]8}t d|j dddd|jg}z t|ddI d H W q tjy; } zt d|j|j W Y d }~qd }~ww d S ) Nz deleting %sipr! deleter Tcheckzdeleting %s failed with %r)r4 r5 r} r
subprocessCalledProcessErrorr) stderr)r r r cmdrs r r r _delete_devs s z"BaseNetworkController._delete_devsc C s | j }tdtjt|dd tj| j ddD ]}|| j
kr#qt ||d | j
j qt| j
| j | | d S )Nznetwork config:
%sFdefault_flow_styleT)maskedz.dist-)r
render_configr4 r5 yamldumpr
sanitize_configconfigs_in_rootrJ rK rF renamerD r r stringify_configrT )r rx pr r r
_write_config s
z#BaseNetworkController._write_configr zsilent={silent}INFO)r} descriptionlevelc s g }g }g }t } jjddD ]T}i |_dD ]-}||rEs0||tj j |j
n||tj t
|j|< } || q|jd u rLq|j jj|jkre|jr`|| q|| q sp z fdd}
jjrd jj } tdt| gI d H t j drtd d
d j gdd I d H nz|s|rztg d
dd I d H tg ddd I d H W n
t j!y |
d w |rֈ "|I d H |r #|I d H |s|rtg ddd I d H z
td dgdd I d H W n t j!y
|
d w |s|r tg ddd I d H W s$ $ n s- $ w w |s3d S zt %t &dd |D dI d H W n t j'yQ Y nw |D ] \}}i |_|( | sp||tj) j |j
qTd S )NT)include_deleted)ru rv c s s | d S d S r ) apply_error)stager r r r error s z2BaseNetworkController._apply_config..error sleepz/lib/netplan/generater
generatez--rootr ) systemctlmask --runtimesystemd-networkd.servicesystemd-networkd.socket)r stopr r z
stop-networkd)r unmaskr r r apply)r ra r Fc S s h | ]}| qS r )wait).0er r r W s z6BaseNetworkController._apply_config..
)*r r rw dhcp_events dhcp_enabledset_dhcp_stater PENDINGrV r' r RECONFIGURErc Eventr3 r) rx config_for_device
is_virtualappendr apply_startingrD rE rW scale_factorr strrF rG rM rJ r r r r apply_stoppingwait_forr TimeoutErrordhcp_addresses TIMED_OUT) r r r devs_to_delete devs_to_downdhcp_device_versionsr r vr r delayr r r rB s
z#BaseNetworkController._apply_configdev_name
ip_version
static_configreturnc C s | j |}|| |jdg |j dj|d}|jr&|j|j|< n|j |d |jdi }|dg |j
|dg |j | | |
d S )Nry z
gateway{v}r nameserverssearch)r get_netdev_by_namer| rx
setdefaultextendry formatgatewaypopr
searchdomainsr' r )r r r r r gwkeynsr r r set_static_configb s
z'BaseNetworkController.set_static_configc C sB | j |}|| dj|d}d|j|< | | | d S )Nzdhcp{v}r T)r r r| r rx r' r )r r r r dhcpkeyr r r enable_dhcpr s
z!BaseNetworkController.enable_dhcpc C s, | j |}|| | | | d S r )r r r| r' r )r r r r r r r disable_networkz s
z%BaseNetworkController.disable_networkidc C s: | j ||}| | | j |}| | | d S r )r new_vlanr r r' r )r r r newr r r r add_vlan s
z BaseNetworkController.add_vlanc C s | j |}t }|jdkr"|jd D ]
}| j |}|| qn|jdkr5| j |jd }|| d |_| | |D ]}| | q?| d S )Nbond
interfacesvlanr! ) r r r typerx r3 r# r' r )r r r touched_devices device_name interfacer! r r r delete_link s
z!BaseNetworkController.delete_link
existing_namenew_namenew_infoc
C s | j j}t }|jD ]}||}i |_|| q
|d u r*| j ||}| | n<||} | jd D ] }
|||
q3| j| | j
|kra| j} d | _| | | | _|| _
| | n|| |D ]} | | qh|
d S )Nr )r r r r rx r3 new_bondr update to_configr} r# r' r )
r r r r r r r devicenew_devexistingr rx r r r r add_or_update_bond s0
z(BaseNetworkController.add_or_update_bondc s: | j |}|jd urtj|j ddS dj|jdS )NFr z0Configured but not yet created {type} interface.)r )r r r) r r serializer r )r r r r r r get_info_for_netdev s
z)BaseNetworkController.get_info_for_netdevwlanc C sP | j |}|j\}}|jr|sd|jd< ||j|j | | | d S )NTdhcp4) r r configured_ssidssidrx set_ssid_pskpskr' r )r r r r cur_ssidcur_pskr r r set_wlan s
z BaseNetworkController.set_wlanc
C sd | j |}z | j|j W n ty* } zd|f |jjd< W Y d }~nd }~ww | | d S )Nzerror %s
scan_state) r r r^ trigger_scanr r r) r r' )r r r rr r r
start_scan s z BaseNetworkController.start_scanc C d S r r rZ r r r r z$BaseNetworkController.apply_startingc C r r r rZ r r r r r z$BaseNetworkController.apply_stoppingc C r r r r r r r r r r z!BaseNetworkController.apply_errorc C s |r | j jtj d S d S r )rW hub broadcastr
NETWORK_UPr routesr r r r% s z+BaseNetworkController.update_default_routesc C r r r r r" r r r r r z BaseNetworkController.new_linkc C s: |j D ]\}}| | r||tj | qd S r )r itemsr r r
CONFIGUREDr )r r" r r r r r r' s z!BaseNetworkController.update_linkc C r r r r r r r r# r z BaseNetworkController.del_linkrb )-r: r; r<
model_namerJ r rT ra ri r` rk r propertyrK r r r r r rB r intr r r r r r r r r r r r r
abcabstractmethodr r r r% r r' r# r= r r r8 r r> sj
e
r> c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
NetworkAnswersMixinc sV | j ddr| d S | j ddr)| j d }| j | |I d H d S d S )Nzaccept-defaultFactions)answersgetdoneclear _run_actions)r r r r r run_answers s
z NetworkAnswersMixin.run_answersc C sh |d }|d dkr-|d dkr | jjt|d }n
|d dkr'|d }| jj| S td|)Nr r r index r} zcould not resolve {})splitviewcur_netdev_namesr dev_name_to_table Exceptionr )r r dev_specr} r r r _action_get s z NetworkAnswersMixin._action_getc s" fdd|D }t d| |S )Nc s g | ] } |jjqS r )r. dev_infor} )r r rZ r r
s z@NetworkAnswersMixin._action_clean_interfaces..z%s)r4 r5 )r devicesr r rZ r _action_clean_interfaces s z,NetworkAnswersMixin._action_clean_interfacesc C sr t d| d|v r| |d }t| jjd|d }tt|d }| jjd ||f| d V | jjj }|d dkrjd}|j
j | j j
v rdtdI d H |d7 }|dkr\td |j
j | j j
v sHt d
| t|tsqd S | D ]8\}}|d squd } d
}
d|v r|dd } | d } | d }
| t|j| |||
d2 z3 d H W } q6 qud S |d dkr#| jj d V | jjj }|d }
d|
v r|
d|
d< | |jj |
|d
d2 z3 d H W } q6 d}|
d | j j
vrtdI d H |d7 }|dkr td|
d | j j
vs|dkr t d| d V d S |d dkr2| jj d S td|)Nz_answers_action %robjz
_action_{}r6 DELETEg ro g @z%interface did not disappear in 5 secsz$waited %s for interface to disappearr7 formsubmit-r _formz-submitTz create-bondr1 r r} z bond did not appear in 5 secsz waited %s for bond to appearr" zcould not process action {}) r4 r5 r. r( uibodyr r
_action_wr/ r} r) r* rc r r,
isinstancer r endswithr( _enter_form_datastretchyr! _create_bondcopyr r5 r" )r r6 r, meth
action_objr: tkr form_name
submit_keyprefixr~ r7 r r r _answers_action s
z#NetworkAnswersMixin._answers_actionN)r: r; r< r% r. r2 rJ r r r r r s
r c s e Zd Z fddZdd Zdd Zdd Zd d
Z fd d Z fd
dZ fddZ
fddZ fddZ fddZ
fddZ ZS )NetworkControllerc s t | d | _d| _d S rb )r1 r r)
view_shown)r rW r8 r r r M s
zNetworkController.__init__c C s\ | j s| dd | j D }t| || _| j s#| jdd d| _ | j| jj | jS )Nc S s g | ]}| qS r ) netdev_info)r r r r r r0 U s z-NetworkController.make_ui..T)r )
rL r r rw r r) r r% rV r )r netdev_infosr r r make_uiR s zNetworkController.make_uic C s
d | _ d S r )r) rZ r r r end_ui` s
zNetworkController.end_uic C s( t d t| jj| j_| j d S )Nz"NetworkController.done next_screen) r4 r5 boolrV r r has_networkrW next_screenrZ r r r r" c s
zNetworkController.donec C s | j d S r )rW prev_screenrZ r r r canceli s zNetworkController.cancelc & t | jd ur| j d S d S r )r1 r r) show_apply_spinnerrZ r8 r r r l
z NetworkController.apply_startingc rV r )r1 r r) hide_apply_spinnerrZ r8 r r r q rX z NetworkController.apply_stoppingc s* t | | jd ur| j| d S d S r )r1 r r) show_network_errorr r8 r r r v s
z NetworkController.apply_errorc s& t | | jr| j| d S d S r )r1 r% r) r r8 r r r% { s z'NetworkController.update_default_routesc . t | | jd ur| j| d S d S r )r1 r r) rM r r8 r r r
zNetworkController.new_linkc r[ r )r1 r' r) rM r r8 r r r' r\ z NetworkController.update_linkc r[ r )r1 r# r) rM r r8 r r r# r\ zNetworkController.del_link)r: r; r< r rO rP r" rU r r r r% r r' r# r= r r r8 r rK J s rK )-r rc loggingrF r typingr r probert.networkr r subiquitycore.async_helpersr subiquitycore.contextr subiquitycore.file_utilr subiquitycore.models.networkr r r
r r
subiquitycorer
subiquitycore.controllerr subiquitycore.pubsubr subiquitycore.tuicontrollerr subiquitycore.ui.stretchyr subiquitycore.ui.views.networkr subiquitycore.utilsr r getLoggerr4 r rS r> r rK r r r r s:
, uX