← Back
Editing: launch_index.cpython-38.pyc
U Ӈg` � @ sD d dl Z d dlZd dlmZ d dlmZ e�e�ZG dd� d�Z dS )� N)� user_data)�utilc @ s. e Zd Zd dd�Zdd� Zdd� Zdd � Zd S ) �FilterTc C s || _ || _d S �N)� wanted_idx� allow_none)�selfr r � r �@/usr/lib/python3/dist-packages/cloudinit/filters/launch_index.py�__init__ s zFilter.__init__c C s: |� dd �}| jr |d kr dS t�|�}|| jkr6dS dS )Nz Launch-IndexTF)�getr r Zsafe_intr )r �messageZmsg_idxr r r �_select s zFilter._selectc C s� | � |�sd S |�� r�|jdd�}g }d}|D ]*}| �|�}|d k rP|�|� q.|d7 }q.t�d|| j� t�|�}|� |� t t |��|t j < |S t�|�S d S )NF)�decoder � zCDiscarding %s multipart messages which do not match launch index %s)r Z is_multipartZ get_payload� _do_filter�append�LOG�debugr �copyZ set_payload�str�len�udZATTACHMENT_FIELD)r r Z prev_msgsZnew_msgsZ discarded�mZ new_messager r r r " s* � zFilter._do_filterc C s | j d kr|S | �|�S r )r r )r Z root_messager r r �apply? s z Filter.applyN)T)�__name__� __module__� __qualname__r r r r r r r r r s r ) r ZloggingZ cloudinitr r r Z getLoggerr r r r r r r �<module> s
Save File
Cancel