Nexus File Manager
v2.0
🏠
Dashboard
⚡
System
🌐
›
usr
›
lib
›
python3.6
›
site-packages
›
bcc
›
__pycache__
Quick:
⬆️ Parent
🌐 Root
🏠 Home
🌍 WWW
📁 Temp
⚙️ Etc
📤 Upload
📁 Create
⚡ WordPress Admin
🔄 Refresh
✏️ table.cpython-36.pyc
← Back
3 :�)g� � B @ s4 d dl mZ yd dlmZ W n ek r< d dlmZ Y nX d dlmZ d dlZ d dl m Z d dl Z d dl Z d dlZd dlZddlmZmZmZmZmZ ddlmZ dd lmZ dZd Zd Zd Z d Z dZ dZ dZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+d Z,d Z-d Z.d Z/d Z0d!Z1d"Z2d#Z3d$Z4d%Z5ed&ed'ed(e d)e d*e d+e d,e d-e!d.e"d/e#d0e$d1e%d2e&d3e'd4e(d5e)d6e*d7e+d8e,d9e-d:e.d;e/d<e0d=e1d>e2d?e3d@e4dAe5dBi Z6dCa7dDZ8dEZ9dFdG� Z:d~dHdI�Z;dJdK� Z<dLdM� Z=dNdO� Z>dPdQ� Z?dRdS� Z@G dTdU� dUe�ZAG dVdW� dWeA�ZBG dXdY� dYeB�ZCG dZd[� d[eA�ZDG d\d]� d]eD�ZEG d^d_� d_eD�ZFG d`da� da�ZGG dbdc� dceD�ZHG ddde� deeD�ZIG dfdg� dgeB�ZJG dhdi� dieJ�ZKG djdk� dkeD�ZLG dldm� dmeA�ZMG dndo� doeA�ZNG dpdq� dqeD�ZOG drds� dseD�ZPG dtdu� dueD�ZQG dvdw� dweD�ZRG dxdy� dyeB�ZSG dzd{� d{eA�ZTG d|d}� d}�ZUdS )� )�print_function)�MutableMapping)�strftimeN)�reduce� )�lib� _RAW_CB_TYPE� _LOST_CB_TYPE�_RINGBUF_CB_TYPE�bcc_perf_buffer_opts)�get_online_cpus)�get_possible_cpus� � � � � � � � � � � � � � � � � � � � � � � � � � � � ZHASHZARRAYZ PROG_ARRAYZPERF_EVENT_ARRAYZ PERCPU_HASHZ PERCPU_ARRAYZ STACK_TRACEZ CGROUP_ARRAYZLRU_HASHZLRU_PERCPU_HASHZLPM_TRIEZ ARRAY_OF_MAPSZ HASH_OF_MAPSZDEVMAPZSOCKMAPZCPUMAPZXSKMAPZSOCKHASHZCGROUP_STORAGEZREUSEPORT_SOCKARRAYZPERCPU_CGROUP_STORAGEZQUEUEZSTACKZ SK_STORAGEZ DEVMAP_HASHZ STRUCT_OPSZRINGBUFZ INODE_STORAGEZ TASK_STORAGE�( �A i c C s\ d}d}x6||| | d ks*||d kr,P |d7 }|d7 }q W | |krX|d d� d }|S )Nr � r �*�+���� )�val�val_max�width�i�textr0 r0 �/usr/lib/python3.6/table.py�_starsc s r7 c C s� g }d}x$t t| ��D ]}| | dkr|}qW d}d}xft t| ��D ]V}|dkrD||krD|d }i }||d< t|�d |d< t| | �|d< |j|� |}qDW td�||d�} |r�|d | |d < t| � d S ) Nr r r zinterval-startz interval-end�countz%Y-%m-%d %H:%M:%S)Zts�val_type�data)�range�len�int�appendr �print) �valsr9 �section_bucketZ hist_listZmax_nonzero_idxr4 �index�prevZlist_objZ histogramr0 r0 r6 �_print_json_histo s( rD c C s d}d }d}x,t | �D ] \}}|dkr*|}||kr|}qW |dkrPd}d} t} nd}d} ttd �} |dkrxt|| � x�td|d �D ]~}d|> d? } d|> d } | | kr�| d8 } | | } |r�| r�t| | | | | t| || �f � d }q�t| | | | | t| || �f � q�W d S ) N�@ r r � z# %-19s : count distributionz%10d -> %-10d : %-8d |%-*s|z- %-29s : count distributionz%20d -> %-20d : %-8d |%-*s|r Fr/ )� enumerate� stars_maxr= r? r; r7 )r@ r9 �strip_leading_zero� log2_dist_max�idx_maxr2 r4 �v�header�body�starsZlowZhighr1 r0 r0 r6 �_print_log2_hist� s< rP c C s� d}d}d}x,t | �D ] \}}|dkr*|}||kr|}qW d}d} t} |dkrZt|| � xdtd|d �D ]R}| | } |r�| r�t| || | t| || �f � d}qjt| || | t| || �f � qjW d S )NrE r r z# %-13s : count distributionz %-10d : %-8d |%-*s|Fr/ )rG rH r? r; r7 ) r@ r9 rI rJ rK r2 r4 rL rM rN rO r1 r0 r0 r6 �_print_linear_hist� s, rQ c C s" yt | S tk r dS X d S )Nz <unknown>)� map_type_name�KeyError)�ttyper0 r0 r6 �get_table_type_name� s rU c C s� t jt jt jt jt jt jt jt jt jt jt jt jt jt jt jt jt j t j t j t j t j t j d t j d t j d�}t jd�}g }tj| jj| j�}d}x�||k �rrtj| jj| j|�j� }t jd|�}|jd�}|jd�} t jd| �r�d} |j| �}yD|�r |j|||jd� t|jd�� f� n|j||| f� W n2 tk �rf td | t j d � t j d� Y nX |d7 }q�W t d t j fd |i�S ) Nr )�charZs8z unsigned char�u8zu8 *zchar *ZshortZs16zunsigned short�u16r= Zs32�enumz unsigned int�u32Zlongz unsigned longz long longZs64zunsigned long longZu64Z__int128zunsigned __int128zvoid *z([^ ]+) ?\[([0-9]+)\]$r z (.*)#(.*)r zenum .*rY zGType: '%s' not recognized. Please define the data with ctypes manually.)�filer, �_fields_)!�ctZc_charZc_ubyteZc_char_pZc_shortZc_ushort�c_int�c_uintZc_longZc_ulongZ c_longlongZ c_ulonglongZc_void_p�re�compiler Zbpf_perf_event_fields�bpf�module�_nameZbpf_perf_event_field�decode�match�groupr> r= rS r? �sys�stderr�exit�type� Structure) Z event_mapZ ct_mappingZ array_typeZfields� num_fieldsr4 Zfield�mZ field_nameZ field_typer0 r0 r6 �_get_event_class� s\ ( ro c K s8 t j| j|�}d}|tkr.t| ||||�}�n�|tkrJt| ||||�}�n�|tkrft| ||||�}�n�|t kr�t | |||||�}�n�|t kr�t | ||||f|�}�nz|t kr�t| ||||f|�}�nZ|tkr�t| ||||�}�n>|tkr�t| ||||�}�n"|tk�rt| ||||�}�n|tk�r6t| ||||�}n�|tk�rRt| ||||�}n�|tk�rnt| ||||�}n�|tk�r�t | ||||�}n�|t k�r�t | ||||�}nx|t k�r�t | ||||�}n\|t!k�r�t"| ||||�}n@|t#k�s�|t$k�rt%| |||�}n |t&k�r t'| |||||�}|dk�r4t(d| ��|S )z|Table(bpf, map_id, map_fd, keytype, leaftype, **kwargs) Create a python object out of a reference to a bpf table handleNzUnknown table type %d))r �bpf_table_type_idrc �BPF_MAP_TYPE_HASH� HashTable�BPF_MAP_TYPE_ARRAY�Array�BPF_MAP_TYPE_PROG_ARRAY� ProgArray� BPF_MAP_TYPE_PERF_EVENT_ARRAY�PerfEventArray�BPF_MAP_TYPE_PERCPU_HASH� PerCpuHash�BPF_MAP_TYPE_PERCPU_ARRAY� PerCpuArray�BPF_MAP_TYPE_LPM_TRIE�LpmTrie�BPF_MAP_TYPE_STACK_TRACE� StackTrace�BPF_MAP_TYPE_LRU_HASH�LruHash� BPF_MAP_TYPE_LRU_PERCPU_HASH� LruPerCpuHash�BPF_MAP_TYPE_CGROUP_ARRAY� CgroupArray�BPF_MAP_TYPE_DEVMAP�DevMap�BPF_MAP_TYPE_CPUMAP�CpuMap�BPF_MAP_TYPE_XSKMAP�XskMap�BPF_MAP_TYPE_ARRAY_OF_MAPS� MapInMapArray�BPF_MAP_TYPE_HASH_OF_MAPS� MapInMapHash�BPF_MAP_TYPE_QUEUE�BPF_MAP_TYPE_STACK� QueueStack�BPF_MAP_TYPE_RINGBUF�RingBuf� Exception) rb �map_id�map_fd�keytype�leaftype�name�kwargsrT �tr0 r0 r6 �Table sR r� c @ s e Zd ZdDdd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd d � ZdEd d �ZdFd!d"�Zd#d$� ZdGd%d&�Zd'd(� Zd)d*� ZdHd,d-�Zd.d/� Zd0d1� Zd2d3� Zd4d5� ZG d6d7� d7e �Z d8d9� Z d:d;� Z dId>d?�Z dJd@dA�Z!dKdBdC�Z"dS )L� TableBaseNc C sn || _ || _|| _|| _|| _tj| j j| j�| _tj | j j| j�| _ i | _ || _ t tj| j j| j��| _d S )N)rb r� r� �Key�Leafr rp rc rT �bpf_table_flags_id�flags�_cbsrd r= �bpf_table_max_entries_id� max_entries)�selfrb r� r� r� r� r� r0 r0 r6 �__init__? s zTableBase.__init__c C s | j S )N)r� )r� r0 r0 r6 �get_fdL s zTableBase.get_fdc C sN t jt j| j�d �}tj| jj| j|t |�t j |��}|dk rHt d��|j S )Nr r zCould not printf key) r] �create_string_buffer�sizeofr� r Zbpf_table_key_snprintfrb rc r� r< �byrefr� �value)r� �key�buf�resr0 r0 r6 � key_sprintfO s zTableBase.key_sprintfc C sN t jt j| j�d �}tj| jj| j|t |�t j |��}|dk rHt d��|j S )Nr r zCould not printf leaf) r] r� r� r� r �bpf_table_leaf_snprintfrb rc r� r< r� r� r� )r� �leafr� r� r0 r0 r6 � leaf_sprintfW s zTableBase.leaf_sprintfc C s8 | j � }tj| jj| j|tj|��}|dk r4td��|S )Nr zCould not scanf key) r� r Zbpf_table_key_sscanfrb rc r� r] r� r� )r� Zkey_strr� r� r0 r0 r6 � key_scanf_ s zTableBase.key_scanfc C s8 | j � }tj| jj| j|tj|��}|dk r4td��|S )Nr zCould not scanf leaf) r� r �bpf_table_leaf_sscanfrb rc r� r] r� r� )r� �leaf_strr� r� r0 r0 r6 � leaf_scanfg s zTableBase.leaf_scanfc C s4 | j � }tj| jtj|�tj|��}|dk r0t�|S )Nr )r� r �bpf_lookup_elemr� r] r� rS )r� r� r� r� r0 r0 r6 � __getitem__o s zTableBase.__getitem__c C sD t j| jtj|�tj|�d�}|dk r@tjtj� �}td| ��d S )Nr zCould not update table: %s) r �bpf_update_elemr� r] r� �os�strerror� get_errnor� )r� r� r� r� �errstrr0 r0 r6 � __setitem__v s zTableBase.__setitem__c C s$ t j| jtj|��}|dk r t�d S )Nr )r Zbpf_delete_elemr� r] r� rS )r� r� r� r0 r0 r6 � __delitem__| s zTableBase.__delitem__c c s6 x0| D ](}y| | V W q t k r, Y qX qW d S )N)rS )r� r� r0 r0 r6 � itervalues� s zTableBase.itervaluesc c s: x4| D ],}y|| | fV W q t k r0 Y qX qW d S )N)rS )r� r� r0 r0 r6 � iteritems� s zTableBase.iteritemsc C s dd� | j � D �S )Nc S s g | ]}|�qS r0 r0 )�.0�itemr0 r0 r6 � <listcomp>� s z#TableBase.items.<locals>.<listcomp>)r� )r� r0 r0 r6 �items� s zTableBase.itemsc C s dd� | j � D �S )Nc S s g | ]}|�qS r0 r0 )r� r� r0 r0 r6 r� � s z$TableBase.values.<locals>.<listcomp>)r� )r� r0 r0 r6 �values� s zTableBase.valuesc C s x| j � D ]}| j|� q W d S )N)�keysr� )r� �kr0 r0 r6 �clear� s zTableBase.clearFc C sz d }}| r$| r$t jd�ddfS |s0| j}n|dk sB|| jkrJtd��|rZ| j| � }|rj| j| � }t j|�||fS )a� Allocate keys and/or values arrays. Useful for in items_*_batch. Args: alloc_k (bool): True to allocate keys array, False otherwise. Default is False. alloc_v (bool): True to allocate values array, False otherwise. Default is False. count (int): number of elements in the array(s) to allocate. If count is None then it allocates the maximum number of elements i.e self.max_entries. Returns: tuple: (count, keys, values). Where count is ct.c_uint32, and keys and values an instance of ct.Array Raises: ValueError: If count is less than 1 or greater than self.max_entries. Nr r z Wrong count)r] �c_uint32r� � ValueErrorr� r� )r� �alloc_k�alloc_vr8 r� r� r0 r0 r6 �_alloc_keys_values� s z TableBase._alloc_keys_valuesc C sv d}xF||gD ]:}|rt |tj�s&t�t|�}|dk s@|| jkrtd��qW |rl|rlt|�t|�krltd��tj|�S )a� Check if the given keys or values have the right type and size. Args: keys (ct.Array): keys array to check values (ct.Array): values array to check Returns: ct.c_uint32 : the size of the array(s) Raises: ValueError: If length of arrays is less than 1 or greater than self.max_entries, or when both arrays length are different. TypeError: If the keys and values are not an instance of ct.Array r r zArray's length is wrongz(keys array length != values array length)� isinstancer] rt � TypeErrorr< r� r� r� )r� r� r� Zarr_len�elemr0 r0 r6 �_sanity_check_keys_values� s z#TableBase._sanity_check_keys_valuesc c s( x"| j dd�D ]\}}||fV qW dS )a Look up all the key-value pairs in the map. Args: None Yields: tuple: The tuple of (key,value) for every entries that have been looked up. Notes: lookup batch on a keys subset is not supported by the kernel. F)�deleteN)�)_items_lookup_and_optionally_delete_batch)r� r� rL r0 r0 r6 �items_lookup_batch� s z TableBase.items_lookup_batchc C sh |dk rP| j |d�}tj| jtj|�tj|��}|dkrdtdtjtj � � ��nx| j � D ]}dS W dS )a� Delete the key-value pairs related to the keys given as parameters. Note that if no key are given, it is faster to call lib.bpf_lookup_and_delete_batch than create keys array and then call lib.bpf_delete_batch on these keys. Args: ct_keys (ct.Array): keys array to delete. If an array of keys is given then it deletes all the related keys-values. If keys is None (default) then it deletes all entries. Yields: tuple: The tuple of (key,value) for every entries that have been deleted. Raises: Exception: If bpf syscall return value indicates an error. N)r� r z#BPF_MAP_DELETE_BATCH has failed: %s) r� r Zbpf_delete_batchr� r] r� r� r� r� r� � items_lookup_and_delete_batch)r� �ct_keys�ct_cntr� �_r0 r0 r6 �items_delete_batch� s z TableBase.items_delete_batchc C sT | j ||d�}tj| jtj|�tj|�tj|��}|dkrPtdtjtj � � ��dS )aq Update all the key-value pairs in the map provided. The arrays must be the same length, between 1 and the maximum number of entries. Args: ct_keys (ct.Array): keys array to update ct_values (ct.Array): values array to update Raises: Exception: If bpf syscall return value indicates an error. )r� r� r z#BPF_MAP_UPDATE_BATCH has failed: %sN) r� r Zbpf_update_batchr� r] r� r� r� r� r� )r� r� � ct_valuesr� r� r0 r0 r6 �items_update_batch s z TableBase.items_update_batchc c s( x"| j dd�D ]\}}||fV qW dS )a? Look up and delete all the key-value pairs in the map. Args: None Yields: tuple: The tuple of (key,value) for every entries that have been looked up and deleted. Notes: lookup and delete batch on a keys subset is not supported by the kernel. T)r� N)r� )r� r� rL r0 r0 r6 r� s z'TableBase.items_lookup_and_delete_batchTc c s4 |dkrt j}d}n t j}d}| jddd�\}}}tjd� }}d} x�|j| |_|| j| rftj|�ndtj|�tj|tj | j �| �tj|tj | j �| �tj|��} tj � } | |j7 } | dkr�| t jkr�td|tj| �f ��| dkr�P | |jkr�P |jdkrFP qFW x&td| �D ]} || || fV �qW dS )a� Look up and optionally delete all the key-value pairs in the map. Args: delete (bool) : look up and delete the key-value pairs when True, else just look up. Yields: tuple: The tuple of (key,value) for every entries that have been looked up and deleted. Raises: Exception: If bpf syscall return value indicates an error. Notes: lookup and delete batch on a keys subset is not supported by the kernel. TZ BPF_MAP_LOOKUP_AND_DELETE_BATCHZBPF_MAP_LOOKUP_BATCH)r� r� r Nz%s has failed: %s)r Zbpf_lookup_and_delete_batchZbpf_lookup_batchr� r] r� r� r� r� r� r� r� r� �errno�ENOENTr� r� r� r; ) r� r� Z bpf_batchZbpf_cmdZ ct_buf_sizer� r� Z ct_out_batchr� Ztotalr� Zerrcoder4 r0 r0 r6 r� / s< z3TableBase._items_lookup_and_optionally_delete_batchc C s& x t | j� �D ]}| j� | |< qW d S )N)�listr� r� )r� r� r0 r0 r6 �zerof s zTableBase.zeroc C s t j| �S )N)r� �Iter)r� r0 r0 r6 �__iter__n s zTableBase.__iter__c C s | j � S )N)r� )r� r0 r0 r6 �iterq s zTableBase.iterc C s | j � S )N)r� )r� r0 r0 r6 r� r s zTableBase.keysc @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) zTableBase.Iterc C s || _ d | _d S )N)�tabler� )r� r� r0 r0 r6 r� u s zTableBase.Iter.__init__c C s | S )Nr0 )r� r0 r0 r6 r� x s zTableBase.Iter.__iter__c C s | j � S )N)�next)r� r0 r0 r6 �__next__z s zTableBase.Iter.__next__c C s | j j| j�| _| jS )N)r� r� r� )r� r0 r0 r6 r� | s zTableBase.Iter.nextN)�__name__� __module__� __qualname__r� r� r� r� r0 r0 r0 r6 r� t s r� c C s^ | j � }|d kr0tj| jtj|�tj| j ��}n tj| jtj|�tj|��}|dk rZt� �|S )Nr ) r� r Zbpf_get_first_keyr� r] r� r� Zbpf_get_next_key� StopIteration)r� r� Znext_keyr� r0 r0 r6 r� � s zTableBase.nextc C s� | j jd d }| j jd d }|dkrHt| j j�dkrH| j jd d }xX| j� D ]L\}}t||�} |rp|| �} |j| dgt � } || < t||�} |j| | < qRW t|j � �} |r�|| �} x| D ]} |j | � q�W d S )Nr r Z__pad_1r r ) r� r\ r< r� �getattr�get�log2_index_maxr� r� r� r> ) r� �tmp�buckets� bucket_fn�bucket_sort_fn�f1�f2r� rL �bucketr@ ZslotZ buckets_lstr0 r0 r6 �decode_c_struct� s zTableBase.decode_c_structr� � Bucket ptrc C s� t | j� tj�rfi }g }| j||||� xr|D ]2}|| } |rL|||�f} n||f} t| || � q.W n6dgt } x | j� D ]\} } | j| | j< qzW t| |� dS )a. print_json_hist(val_type="value", section_header="Bucket ptr", section_print_fn=None, bucket_fn=None, bucket_sort_fn=None): Prints a table as a json histogram. The table must be stored as log2. The val_type argument is optional, and is a column header. If the histogram has a secondary key, the dictionary will be split by secondary key If section_print_fn is not None, it will be passed the bucket value to format into a string as it sees fit. If bucket_fn is not None, it will be used to produce a bucket value for the histogram keys. If bucket_sort_fn is not None, it will be used to sort the buckets before iterating them, and it is useful when there are multiple fields in the secondary key. The maximum index allowed is log2_index_max (65), which will accommodate any 64-bit integer in the histogram. r N) r� r� r] rl r� rD r� r� r� ) r� r9 �section_header�section_print_fnr� r� r� r� r� r@ rA r� rL r0 r0 r6 �print_json_hist� s zTableBase.print_json_histc C s� t | j� tj�rvi }g }| j||||� x�|D ]B} || } |rTtd||| �f � ntd|| f � t| ||� q.W n8dgt } x | j� D ]\} } | j | | j < q�W t| ||� dS )a� print_log2_hist(val_type="value", section_header="Bucket ptr", section_print_fn=None, bucket_fn=None, strip_leading_zero=None, bucket_sort_fn=None): Prints a table as a log2 histogram. The table must be stored as log2. The val_type argument is optional, and is a column header. If the histogram has a secondary key, multiple tables will print and section_header can be used as a header description for each. If section_print_fn is not None, it will be passed the bucket value to format into a string as it sees fit. If bucket_fn is not None, it will be used to produce a bucket value for the histogram keys. If the value of strip_leading_zero is not False, prints a histogram that is omitted leading zeros from the beginning. If bucket_sort_fn is not None, it will be used to sort the buckets before iterating them, and it is useful when there are multiple fields in the secondary key. The maximum index allowed is log2_index_max (65), which will accommodate any 64-bit integer in the histogram. z %s = %sz %s = %rr N) r� r� r] rl r� r? rP r� r� r� ) r� r9 r� r� r� rI r� r� r� r� r@ r� rL r0 r0 r6 �print_log2_hist� s zTableBase.print_log2_histc C s� t | j� tj�rvi }g }| j||||� x�|D ]B} || } |rTtd||| �f � ntd|| f � t| ||� q.W nddgt } xL| j� D ]@\} } y| j | | j < W q� t k r� t d| j tf ��Y q�X q�W t| ||� dS )a� print_linear_hist(val_type="value", section_header="Bucket ptr", section_print_fn=None, bucket_fn=None, strip_leading_zero=None, bucket_sort_fn=None) Prints a table as a linear histogram. This is intended to span integer ranges, eg, from 0 to 100. The val_type argument is optional, and is a column header. If the histogram has a secondary key, multiple tables will print and section_header can be used as a header description for each. If section_print_fn is not None, it will be passed the bucket value to format into a string as it sees fit. If bucket_fn is not None, it will be used to produce a bucket value for the histogram keys. If the value of strip_leading_zero is not False, prints a histogram that is omitted leading zeros from the beginning. If bucket_sort_fn is not None, it will be used to sort the buckets before iterating them, and it is useful when there are multiple fields in the secondary key. The maximum index allowed is linear_index_max (1025), which is hoped to be sufficient for integer ranges spanned. z %s = %sz %s = %rr z#Index in print_linear_hist() of %d zexceeds max of %d.Nz5Index in print_linear_hist() of %d exceeds max of %d.) r� r� r] rl r� r? rQ �linear_index_maxr� r� � IndexError) r� r9 r� r� r� rI r� r� r� r� r@ r� rL r0 r0 r6 �print_linear_hist� s& zTableBase.print_linear_hist)N)FFN)NN)N)T)r� r� NNN)r� r� NNNN)r� r� NNNN)#r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� �objectr� r� r� r� r� r� r0 r0 r0 r6 r� = sH # 7 # & r� c s$ e Zd Z� fdd�Zdd� Z� ZS )rr c s t t| �j||� d S )N)�superrr r� )r� �argsr� )� __class__r0 r6 r� " s zHashTable.__init__c C s d}x| D ] }|d7 }q W |S )Nr r r0 )r� r4 r� r0 r0 r6 �__len__% s zHashTable.__len__)r� r� r� r� r � __classcell__r0 r0 )r r6 rr ! s rr c s e Zd Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� + s zLruHash.__init__)r� r� r� r� r r0 r0 )r r6 r� * s r� c sp e Zd Z� fdd�Zdd� Zdd� Z� fdd�Z� fd d �Z� fd d �Zd d� Z dd� Z G dd� de �Z � Z S )� ArrayBasec s t t| �j||� d S )N)r r r� )r� r r� )r r0 r6 r� / s zArrayBase.__init__c C sV t |t�r(|dk r t| �| }| j|�}t |tj�s<td��|jt| �krRtd��|S )Nr z#Array index must be an integer typezArray index out of range)r� r= r< r� r] Z _SimpleCDatar� r� )r� r� r0 r0 r6 �_normalize_key2 s zArrayBase._normalize_keyc C s | j S )N)r� )r� r0 r0 r6 r = s zArrayBase.__len__c s | j |�}tt| �j|�S )N)r r r r� )r� r� )r r0 r6 r� @ s zArrayBase.__getitem__c s | j |�}tt| �j||� d S )N)r r r r� )r� r� r� )r r0 r6 r� D s zArrayBase.__setitem__c s | j |�}tt| �j|� d S )N)r r r r� )r� r� )r r0 r6 r� H s zArrayBase.__delitem__c C sD | j |�}| j� }tj| jtj|�tj|�d�}|dk r@td��d S )Nr zCould not clear item)r r� r r� r� r] r� r� )r� r� r� r� r0 r0 r6 � clearitemL s zArrayBase.clearitemc C s t j| | j�S )N)r r� r� )r� r0 r0 r6 r� S s zArrayBase.__iter__c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) zArrayBase.Iterc C s || _ || _d| _d S )Nr r/ )r� r� r4 )r� r� r� r0 r0 r6 r� W s zArrayBase.Iter.__init__c C s | S )Nr0 )r� r0 r0 r6 r� \ s zArrayBase.Iter.__iter__c C s | j � S )N)r� )r� r0 r0 r6 r� ^ s zArrayBase.Iter.__next__c C s0 | j d7 _ | j t| j�kr$t� �| j| j �S )Nr )r4 r< r� r� r� )r� r0 r0 r6 r� ` s zArrayBase.Iter.nextN)r� r� r� r� r� r� r� r0 r0 r0 r6 r� V s r� )r� r� r� r� r r r� r� r� r r� r r� r r0 r0 )r r6 r . s r c s$ e Zd Z� fdd�Zdd� Z� ZS )rt c s t t| �j||� d S )N)r rt r� )r� r r� )r r0 r6 r� g s zArray.__init__c C s | j |� d S )N)r )r� r� r0 r0 r6 r� j s zArray.__delitem__)r� r� r� r� r� r r0 r0 )r r6 rt f s rt c s( e Zd Z� fdd�Z� fdd�Z� ZS )rv c s t t| �j||� d S )N)r rv r� )r� r r� )r r0 r6 r� o s zProgArray.__init__c sD t |t�r| j|�}t || jj�r.| j|j�}tt| �j||� d S )N) r� r= r� rb ZFunction�fdr rv r� )r� r� r� )r r0 r6 r� r s zProgArray.__setitem__)r� r� r� r� r� r r0 r0 )r r6 rv n s rv c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �FileDescc C s" |d ks|dk rt d��|| _d S )Nr zInvalid file descriptor)r� r )r� r r0 r0 r6 r� z s zFileDesc.__init__c C s* | j d k r&| j dkr&tj| j � d | _ d S )Nr )r r� �close)r� r0 r0 r6 �clean_up s zFileDesc.clean_upc C s | j � d S )N)r )r� r0 r0 r6 �__del__� s zFileDesc.__del__c O s | S )Nr0 )r� r r� r0 r0 r6 � __enter__� s zFileDesc.__enter__c O s | j � d S )N)r )r� r r� r0 r0 r6 �__exit__� s zFileDesc.__exit__N)r� r� r� r� r r r r r0 r0 r0 r6 r y s r c s( e Zd Z� fdd�Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� � s zCgroupArray.__init__c st t |t�r$tt| �j|| j|�� nLt |t�rhttj |tj ��� }tt| �j|| j|j �� W d Q R X nt d��d S )Nz1Cgroup array key must be either FD or cgroup path) r� r= r r� r� r� �strr r� �open�O_RDONLYr r� )r� r� r� �f)r r0 r6 r� � s &zCgroupArray.__setitem__)r� r� r� r� r� r r0 r0 )r r6 r� � s r� c sZ e Zd Z� fdd�Zdd� Z� fdd�Zdd� Zdd d �Zdd� Zdd� Z dd� Z � Z S )rx c s" t t| �j||� i | _d | _d S )N)r rx r� � _open_key_fds� _event_class)r� r r� )r r0 r6 r� � s zPerfEventArray.__init__c C s& t | jj� �}x|D ] }| |= qW d S )N)r� r r� )r� r� r� r0 r0 r6 r � s zPerfEventArray.__del__c sx || j krd S tt| �j|� t| �|f}|| jjkr\tj| jj| � | jj|= | j |= ntj | j | � | j |= d S )N) r r rx r� �idrb � perf_buffersr Zperf_reader_freer� Zbpf_close_perf_event_fd)r� r� Zkey_id)r r0 r6 r� � s zPerfEventArray.__delitem__c C s* | j dkrt| �| _ tj|tj| j ��jS )a event(data) When perf buffers are opened to receive custom perf event, the underlying event data struct which is defined in C in the BPF program can be deduced via this function. This avoids redundant definitions in Python. N)r ro r] �cast�POINTER�contents)r� r: r0 r0 r6 �event� s zPerfEventArray.eventr Nr c C s> ||d @ dkrt d��x t� D ]}| j|||||� q W dS )az open_perf_buffers(callback) Opens a set of per-cpu ring buffer to receive custom perf event data from the bpf program. The callback will be invoked for each event submitted from the kernel, up to millions per second. Use page_cnt to change the size of the per-cpu ring buffer. The value must be a power of two and defaults to 8. r r z+Perf buffer page_cnt must be a power of twoN)r� r �_open_perf_buffer)r� �callback�page_cnt�lost_cb� wakeup_eventsr4 r0 r0 r6 �open_perf_buffer� s z PerfEventArray.open_perf_bufferc s� � �fdd�}�fdd�}t |�}�r.t|�n tjd t�} t� } d| _�| _|| _tj || d |tj | ��} | svt d��tj | �} | j | �| | j��< | | jjt| ��f< || f| j�< d| j�< d S ) Nc sP y� �||� W n: t k rJ } z |jtjkr6t� n|�W Y d d }~X nX d S )N)�IOErrorr� �EPIPErj )r� r: �size�e)r �cpur0 r6 �raw_cb_� s z1PerfEventArray._open_perf_buffer.<locals>.raw_cb_c sL y � |� W n: t k rF } z |jtjkr2t� n|�W Y d d }~X nX d S )N)r" r� r# rj )r� Zlostr% )r r0 r6 �lost_cb_� s z2PerfEventArray._open_perf_buffer.<locals>.lost_cb_r zCould not open perf bufferr/ r/ )r r r] r r �pidr& r r Zbpf_open_perf_buffer_optsr� r� Zperf_reader_fdr� r� rb r r r� r ) r� r& r r r r r' r( �fnZlost_fnZopts�readerr r0 )r r& r r6 r � s z PerfEventArray._open_perf_bufferc C sB t j||d|�}|dk r td��| j|�| | j|�< || j|< d S )Nr r zbpf_open_perf_event failedr/ )r Zbpf_open_perf_eventr� r� r� r )r� r& �typ�configr r0 r0 r6 �_open_perf_event� s z PerfEventArray._open_perf_eventc C s" x t � D ]}| j|||� qW dS )z�open_perf_event(typ, config) Configures the table such that calls from the bpf program to table.perf_read(CUR_CPU_IDENTIFIER) will return the hardware counter denoted by event ev on the local cpu. N)r r. )r� r, r- r4 r0 r0 r6 �open_perf_event� s z PerfEventArray.open_perf_event)r Nr ) r� r� r� r� r r� r r! r r. r/ r r0 r0 )r r6 rx � s "rx c sT e Zd Z� fdd�Z� fdd�Zdd� Z� fdd�Zd d � Zd d � Zd d� Z � Z S )rz c s� |j dd �| _tt| �j||� | j| _tt� �| _ t j | j�d | _ | j dkr`| j| j | _n@| jt j kr|t j| j | _n$| jt jkr�t j| j | _ntd��d S )N�reducerr r z Leaf must be aligned to 8 bytes)�popr0 r rz r� r� �sLeafr< r � total_cpur] r� � alignmentr_ �c_uint64r^ �c_int64r� )r� r r� )r r0 r6 r� s zPerCpuHash.__init__c sT t t| �j|�}| jdkr |}n0| j| j � }x td| j�D ]}|| ||< q<W |S )Nr )r rz r� r4 r2 r3 r; )r� r� �result�retr4 )r r0 r6 �getvalue s zPerCpuHash.getvaluec C s& | j rt| j | j|��S | j|�S d S )N)r0 r r9 )r� r� r0 r0 r6 r� $ s zPerCpuHash.__getitem__c s t t| �j||� d S )N)r rz r� )r� r� r� )r r0 r6 r� * s zPerCpuHash.__setitem__c C s, t | j� tj�rtd��| jt| j|���S )Nz6Leaf must be an integer type for default sum functions)r� r� r] rl r� r2 �sumr9 )r� r� r0 r0 r6 r: - s zPerCpuHash.sumc C s, t | j� tj�rtd��| jt| j|���S )Nz6Leaf must be an integer type for default max functions)r� r� r] rl r� r2 �maxr9 )r� r� r0 r0 r6 r; 2 s zPerCpuHash.maxc C s | j |�}|j| j S )N)r: r� r3 )r� r� r7 r0 r0 r6 �average7 s zPerCpuHash.average) r� r� r� r� r9 r� r� r: r; r< r r0 r0 )r r6 rz s rz c s e Zd Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� < s zLruPerCpuHash.__init__)r� r� r� r� r r0 r0 )r r6 r� ; s r� c s\ e Zd Z� fdd�Z� fdd�Zdd� Z� fdd�Zd d � Zd d � Zd d� Z dd� Z � Z S )r| c s� |j dd �| _tt| �j||� | j| _tt� �| _ t j | j�d | _ | j dkr`| j| j | _n@| jt j kr|t j| j | _n$| jt jkr�t j| j | _ntd��d S )Nr0 r r z Leaf must be aligned to 8 bytes)r1 r0 r r| r� r� r2 r< r r3 r] r� r4 r_ r5 r^ r6 r� )r� r r� )r r0 r6 r� @ s zPerCpuArray.__init__c sT t t| �j|�}| jdkr |}n0| j| j � }x td| j�D ]}|| ||< q<W |S )Nr )r r| r� r4 r2 r3 r; )r� r� r7 r8 r4 )r r0 r6 r9 R s zPerCpuArray.getvaluec C s& | j rt| j | j|��S | j|�S d S )N)r0 r r9 )r� r� r0 r0 r6 r� \ s zPerCpuArray.__getitem__c s t t| �j||� d S )N)r r| r� )r� r� r� )r r0 r6 r� b s zPerCpuArray.__setitem__c C s | j |� d S )N)r )r� r� r0 r0 r6 r� e s zPerCpuArray.__delitem__c C s, t | j� tj�rtd��| jt| j|���S )Nz6Leaf must be an integer type for default sum functions)r� r� r] rl r� r2 r: r9 )r� r� r0 r0 r6 r: i s zPerCpuArray.sumc C s, t | j� tj�rtd��| jt| j|���S )Nz6Leaf must be an integer type for default max functions)r� r� r] rl r� r2 r; r9 )r� r� r0 r0 r6 r; n s zPerCpuArray.maxc C s | j |�}|j| j S )N)r: r� r3 )r� r� r7 r0 r0 r6 r< s s zPerCpuArray.average) r� r� r� r� r9 r� r� r� r: r; r< r r0 r0 )r r6 r| ? s r| c s$ e Zd Z� fdd�Zdd� Z� ZS )r~ c s t t| �j||� d S )N)r r~ r� )r� r r� )r r0 r6 r� x s zLpmTrie.__init__c C s t �d S )N)�NotImplementedError)r� r0 r0 r6 r { s zLpmTrie.__len__)r� r� r� r� r r r0 r0 )r r6 r~ w s r~ c sZ e Zd ZdZdZdZdZdZ� fdd�ZG dd � d e �Z dd d �Z d d� Z dd� Z � ZS )r� � r r r r c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� � s zStackTrace.__init__c @ s. e Zd Zd dd�Zdd� Zdd� Zdd � ZdS ) zStackTrace.StackWalkerNc C s || _ d| _|| _|| _d S )Nr r/ )�stack�n�resolver� )r� r? r� rA r0 r0 r6 r� � s z StackTrace.StackWalker.__init__c C s | S )Nr0 )r� r0 r0 r6 r� � s z StackTrace.StackWalker.__iter__c C s | j � S )N)r� )r� r0 r0 r6 r� � s z StackTrace.StackWalker.__next__c C s� | j d7 _ | j tjkr t� �| jtj@ rZ| jj| j }|jtj ksR|jtj krht� �n| jj | j }|dkrvt� �| j r�| j |�S |S )Nr r ) r@ r� � MAX_DEPTHr� r� �BPF_F_STACK_BUILD_IDr? ZtraceZstatus�BPF_STACK_BUILD_ID_IP�BPF_STACK_BUILD_ID_EMPTYZiprA )r� Zaddrr0 r0 r6 r� � s zStackTrace.StackWalker.next)N)r� r� r� r� r� r� r� r0 r0 r0 r6 � StackWalker� s rF Nc C s t j| | j|� | j|�S )N)r� rF r� r� )r� Zstack_idrA r0 r0 r6 �walk� s zStackTrace.walkc C s d}x| D ] }|d7 }q W |S )Nr r r0 )r� r4 r� r0 r0 r6 r � s zStackTrace.__len__c C s d S )Nr0 )r� r0 r0 r6 r� � s zStackTrace.clearrF )N)r� r� r� rB rC rE ZBPF_STACK_BUILD_ID_VALIDrD r� r rF rG r r� r r0 r0 )r r6 r� s r� c s e Zd Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� � s zDevMap.__init__)r� r� r� r� r r0 r0 )r r6 r� � s r� c s e Zd Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� � s zCpuMap.__init__)r� r� r� r� r r0 r0 )r r6 r� � s r� c s e Zd Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� � s zXskMap.__init__)r� r� r� r� r r0 r0 )r r6 r� � s r� c s e Zd Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� � s zMapInMapArray.__init__)r� r� r� r� r r0 r0 )r r6 r� � s r� c s e Zd Z� fdd�Z� ZS )r� c s t t| �j||� d S )N)r r� r� )r� r r� )r r0 r6 r� � s zMapInMapHash.__init__)r� r� r� r� r r0 r0 )r r6 r� � s r� c sF e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d � Zdd d �Z� Z S )r� c s" t t| �j||� d | _d | _d S )N)r r� r� Z_ringbufr )r� r r� )r r0 r6 r� � s zRingBuf.__init__c C s d S )Nr0 )r� r� r0 r0 r6 Z __delitem� s zRingBuf.__delitemc C s d S )Nr0 )r� r0 r0 r6 r � s zRingBuf.__del__c C s dS )Nr r0 )r� r0 r0 r6 r � s zRingBuf.__len__c C s* | j dkrt| �| _ tj|tj| j ��jS )a event(data) When ring buffers are opened to receive custom event, the underlying event data struct which is defined in C in the BPF program can be deduced via this function. This avoids redundant definitions in Python. N)r ro r] r r r )r� r: r0 r0 r6 r � s z RingBuf.eventNc s4 � fdd�}t |�}| jj| j||� || jd< dS )z�open_ring_buffer(callback) Opens a ring buffer to receive custom event data from the bpf program. The callback will be invoked for each event submitted from the kernel, up to millions per second. c sn y.� | ||�}y t |�}W n d}Y nX W n: tk rh } z |jtjkrTt� n|�W Y d d }~X nX |S )Nr )r= r" r� r# rj )�ctxr: r$ r8 r% )r r0 r6 � ringbuf_cb_� s z-RingBuf.open_ring_buffer.<locals>.ringbuf_cb_r N)r rb Z_open_ring_bufferr� r� )r� r rH rI r* r0 )r r6 �open_ring_buffer� s zRingBuf.open_ring_buffer)N) r� r� r� r� Z_RingBuf__delitemr r r rJ r r0 r0 )r r6 r� � s r� c @ sR e Zd ZdZdd� Zdd� Zdd� Zdd d �Zd d � Zd d� Z dd� Z dd� Z dS )r� r c C s\ || _ || _|| _|| _tj| j j| j�| _tj| j j| j�| _ t tj | j j| j��| _ d S )N) rb r� r� r� r rp rc rT r� r� r= r� r� )r� rb r� r� r� r0 r0 r6 r� s zQueueStack.__init__c C sN t jt j| j�d �}tj| jj| j|t |�t j |��}|dk rHt d��|j S )Nr r zCould not printf leaf) r] r� r� r� r r� rb rc r� r< r� r� r� )r� r� r� r� r0 r0 r6 r� s zQueueStack.leaf_sprintfc C s8 | j � }tj| jj| j|tj|��}|dk r4td��|S )Nr zCould not scanf leaf) r� r r� rb rc r� r] r� r� )r� r� r� r� r0 r0 r6 r� s zQueueStack.leaf_scanfr c C s> t j| jd tj|�|�}|dk r:tjtj� �}td| ��d S )Nr zCould not push to table: %s) r r� r� r] r� r� r� r� r� )r� r� r� r� r� r0 r0 r6 �push s zQueueStack.pushc C s2 | j � }tj| jd tj|��}|dk r.td��|S )Nr zCould not pop from table)r� r Zbpf_lookup_and_deleter� r] r� rS )r� r� r� r0 r0 r6 r1 $ s zQueueStack.popc C s2 | j � }tj| jd tj|��}|dk r.td��|S )Nr zCould not peek table)r� r r� r� r] r� rS )r� r� r� r0 r0 r6 �peek+ s zQueueStack.peekc c s@ | j }x4|r:y| j� V |d8 }W q tk r6 d S X qW d S )Nr )r� r1 rS )r� Zcntr0 r0 r6 r� 2 s zQueueStack.itervaluesc C s dd� | j � D �S )Nc S s g | ]}|�qS r0 r0 )r� r� r0 r0 r6 r� = s z%QueueStack.values.<locals>.<listcomp>)r� )r� r0 r0 r6 r� < s zQueueStack.valuesN)r ) r� r� r� Z BPF_EXISTr� r� r� rK r1 rL r� r� r0 r0 r0 r6 r� s r� )N)VZ __future__r �collections.abcr � ImportError� collectionsZtimer Zctypesr] � functoolsr r� r� r` rh Zlibbccr r r r r Zutilsr r rq rs ru rw ry r{ r r� r� r� r} r� r� r� ZBPF_MAP_TYPE_SOCKMAPr� r� ZBPF_MAP_TYPE_SOCKHASHZBPF_MAP_TYPE_CGROUP_STORAGEZ BPF_MAP_TYPE_REUSEPORT_SOCKARRAYZ"BPF_MAP_TYPE_PERCPU_CGROUP_STORAGEr� r� ZBPF_MAP_TYPE_SK_STORAGEZBPF_MAP_TYPE_DEVMAP_HASHZBPF_MAP_TYPE_STRUCT_OPSr� ZBPF_MAP_TYPE_INODE_STORAGEZBPF_MAP_TYPE_TASK_STORAGErR rH r� r� r7 rD rP rQ rU ro r� r� rr r� r rt rv r r� rx rz r� r| r~ r� r� r� r� r� r� r� r� r0 r0 r0 r6 �<module> s� & ;0 g 8 l4849
💻
System Info
Current path
/usr/lib/python3.6/site-packages/bcc/__pycache__
Contents
0 folders, 22 files
Disk free
100.11 GB
PHP version
8.3.30
🚀
Quick Actions
📍 Script location
🌐 Web root
🗑️ Temp
📁 /usr/lib/python3.6/site-packages/bcc/__pycache__
⚡ Nexus File Manager • 22 items