??? 123123123123 .....................................................................................................................................??? 123123123123 .....................................................................................................................................3 :)gB@s4ddlmZyddlmZWn ek r<ddlmZYnXddlmZddlZ ddl m Z ddl Z ddl Z ddlZddlZddlmZmZmZmZmZddlmZdd lmZdZd Zd Zd Zd ZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/d Z0d!Z1d"Z2d#Z3d$Z4d%Z5ed&ed'ed(ed)ed*ed+ed,e d-e!d.e"d/e#d0e$d1e%d2e&d3e'd4e(d5e)d6e*d7e+d8e,d9e-d:e.d;e/de2d?e3d@e4dAe5dBiZ6dCa7dDZ8dEZ9dFdGZ:d~dHdIZ;dJdKZdPdQZ?dRdSZ@GdTdUdUeZAGdVdWdWeAZBGdXdYdYeBZCGdZd[d[eAZDGd\d]d]eDZEGd^d_d_eDZFGd`dadaZGGdbdcdceDZHGdddedeeDZIGdfdgdgeBZJGdhdidieJZKGdjdkdkeDZLGdldmdmeAZMGdndodoeAZNGdpdqdqeDZOGdrdsdseDZPGdtdudueDZQGdvdwdweDZRGdxdydyeBZSGdzd{d{eAZTGd|d}d}ZUdS))print_function)MutableMapping)strftimeN)reduce)lib _RAW_CB_TYPE _LOST_CB_TYPE_RINGBUF_CB_TYPEbcc_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(AicCs\d}d}x6||||dks*||dkr,P|d7}|d7}q W||krX|ddd}|S)Nrr*+)valval_maxwidthitextr0r0/usr/lib/python3.6/table.py_starscs  r7c Csg}d}x$tt|D]}||dkr|}qWd}d}xftt|D]V}|dkrD||krD|d}i}||d<t|d|d<t|||d<|j||}qDWtd||d} |r|d| |d<t| dS) Nrrrzinterval-startz interval-endcountz%Y-%m-%d %H:%M:%S)Ztsval_typedata)rangelenintappendrprint) valsr9section_bucketZ hist_listZmax_nonzero_idxr4indexprevZlist_objZ histogramr0r0r6_print_json_histos(  rDc Csd}d }d}x,t|D] \}}|dkr*|}||kr|}qW|dkrPd}d} t} nd}d} ttd } |dkrxt||xtd|dD]~}d|>d?} d|>d} | | kr| d8} ||} |r| rt| | | | | t| || fd }qt| | | | | t| || fqWdS) N@rr z# %-19s : count distributionz%10d -> %-10d : %-8d |%-*s|z- %-29s : count distributionz%20d -> %-20d : %-8d |%-*s|rFr/) enumerate stars_maxr=r?r;r7)r@r9strip_leading_zero log2_dist_maxidx_maxr2r4vheaderbodystarsZlowZhighr1r0r0r6_print_log2_hists<      rPc Csd}d}d}x,t|D] \}}|dkr*|}||kr|}qWd}d} t} |dkrZt||xdtd|dD]R}||} |r| rt| || | t| || fd}qjt| || | t| || fqjWdS)NrErrz# %-13s : count distributionz %-10d : %-8d |%-*s|Fr/)rGrHr?r;r7) r@r9rIrJrKr2r4rLrMrNrOr1r0r0r6_print_linear_hists,   rQc Cs"yt|Stk rdSXdS)Nz ) map_type_nameKeyError)ttyper0r0r6get_table_type_namesrUc Cstjtjtjtjtjtjtjtjtjtjtjtjtjtjtjtjtj tj tj tj tj tj dtj dtj d}t jd}g}tj|jj|j}d}x||krrtj|jj|j|j}t jd|}|jd}|jd} t jd| rd} |j| }yD|r |j|||jdt|jdfn|j||| fWn2tk rftd | tjd tjdYnX|d7}qWtd tj fd |iS) Nr)charZs8z unsigned charu8zu8 *zchar *ZshortZs16zunsigned shortu16r=Zs32enumz unsigned intu32Zlongz unsigned longz long longZs64zunsigned long longZu64Z__int128zunsigned __int128zvoid *z([^ ]+) ?\[([0-9]+)\]$rz (.*)#(.*)rzenum .*rYzGType: '%s' not recognized. Please define the data with ctypes manually.)filer,_fields_)!ctZc_charZc_ubyteZc_char_pZc_shortZc_ushortc_intc_uintZc_longZc_ulongZ c_longlongZ c_ulonglongZc_void_precompilerZbpf_perf_event_fieldsbpfmodule_nameZbpf_perf_event_fielddecodematchgroupr>r=rSr?sysstderrexittype Structure) Z event_mapZ ct_mappingZ array_typeZfields num_fieldsr4ZfieldmZ field_nameZ field_typer0r0r6_get_event_classs\        ( roc Ks8tj|j|}d}|tkr.t|||||}n|tkrJt|||||}n|tkrft|||||}n|t krt ||||||}n|t krt |||||f|}nz|t krt|||||f|}nZ|tkrt|||||}n>|tkrt|||||}n"|tkrt|||||}n|tkr6t|||||}n|tkrRt|||||}n|tkrnt|||||}n|tkrt|||||}n|tkrt|||||}nx|tkrt |||||}n\|t!krt"|||||}n@|t#ks|t$krt%||||}n|t&krt'||||||}|dkr4t(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))rbpf_table_type_idrcBPF_MAP_TYPE_HASH HashTableBPF_MAP_TYPE_ARRAYArrayBPF_MAP_TYPE_PROG_ARRAY ProgArrayBPF_MAP_TYPE_PERF_EVENT_ARRAYPerfEventArrayBPF_MAP_TYPE_PERCPU_HASH PerCpuHashBPF_MAP_TYPE_PERCPU_ARRAY PerCpuArrayBPF_MAP_TYPE_LPM_TRIELpmTrieBPF_MAP_TYPE_STACK_TRACE StackTraceBPF_MAP_TYPE_LRU_HASHLruHashBPF_MAP_TYPE_LRU_PERCPU_HASH LruPerCpuHashBPF_MAP_TYPE_CGROUP_ARRAY CgroupArrayBPF_MAP_TYPE_DEVMAPDevMapBPF_MAP_TYPE_CPUMAPCpuMapBPF_MAP_TYPE_XSKMAPXskMapBPF_MAP_TYPE_ARRAY_OF_MAPS MapInMapArrayBPF_MAP_TYPE_HASH_OF_MAPS MapInMapHashBPF_MAP_TYPE_QUEUEBPF_MAP_TYPE_STACK QueueStackBPF_MAP_TYPE_RINGBUFRingBuf Exception) rbmap_idmap_fdkeytypeleaftypenamekwargsrTtr0r0r6Table sR           rc@seZdZdDddZddZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ ddZ ddZddZddZdEdd ZdFd!d"Zd#d$ZdGd%d&Zd'd(Zd)d*ZdHd,d-Zd.d/Zd0d1Zd2d3Zd4d5ZGd6d7d7eZd8d9Zd:d;ZdId>d?Z dJd@dAZ!dKdBdCZ"dS)L TableBaseNcCsn||_||_||_||_||_tj|jj|j|_tj |jj|j|_ i|_ ||_ t tj|jj|j|_dS)N)rbrrKeyLeafrrprcrTbpf_table_flags_idflags_cbsrdr=bpf_table_max_entries_id max_entries)selfrbrrrrrr0r0r6__init__?s zTableBase.__init__cCs|jS)N)r)rr0r0r6get_fdLszTableBase.get_fdcCsNtjtj|jd}tj|jj|j|t |tj |}|dkrHt d|j S)NrrzCould not printf key) r]create_string_buffersizeofrrZbpf_table_key_snprintfrbrcrr<byrefrvalue)rkeybufresr0r0r6 key_sprintfOs zTableBase.key_sprintfcCsNtjtj|jd}tj|jj|j|t |tj |}|dkrHt d|j S)NrrzCould not printf leaf) r]rrrrbpf_table_leaf_snprintfrbrcrr<rrr)rleafrrr0r0r6 leaf_sprintfWs zTableBase.leaf_sprintfcCs8|j}tj|jj|j|tj|}|dkr4td|S)NrzCould not scanf key) rrZbpf_table_key_sscanfrbrcrr]rr)rZkey_strrrr0r0r6 key_scanf_s  zTableBase.key_scanfcCs8|j}tj|jj|j|tj|}|dkr4td|S)NrzCould not scanf leaf) rrbpf_table_leaf_sscanfrbrcrr]rr)rleaf_strrrr0r0r6 leaf_scanfgs  zTableBase.leaf_scanfcCs4|j}tj|jtj|tj|}|dkr0t|S)Nr)rrbpf_lookup_elemrr]rrS)rrrrr0r0r6 __getitem__os zTableBase.__getitem__cCsDtj|jtj|tj|d}|dkr@tjtj}td|dS)NrzCould not update table: %s) rbpf_update_elemrr]rosstrerror get_errnor)rrrrerrstrr0r0r6 __setitem__vszTableBase.__setitem__cCs$tj|jtj|}|dkr tdS)Nr)rZbpf_delete_elemrr]rrS)rrrr0r0r6 __delitem__|szTableBase.__delitem__c cs6x0|D](}y||VWqtk r,YqXqWdS)N)rS)rrr0r0r6 itervaluess  zTableBase.itervaluesc cs:x4|D],}y|||fVWqtk r0YqXqWdS)N)rS)rrr0r0r6 iteritemss  zTableBase.iteritemscCsdd|jDS)NcSsg|]}|qSr0r0).0itemr0r0r6 sz#TableBase.items..)r)rr0r0r6itemsszTableBase.itemscCsdd|jDS)NcSsg|]}|qSr0r0)rrr0r0r6rsz$TableBase.values..)r)rr0r0r6valuesszTableBase.valuescCs x|jD]}|j|q WdS)N)keysr)rkr0r0r6clearszTableBase.clearFcCszd}}| r$| r$tjdddfS|s0|j}n|dksB||jkrJtd|rZ|j|}|rj|j|}tj|||fS)aAllocate 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. Nrrz Wrong count)r]c_uint32r ValueErrorrr)ralloc_kalloc_vr8rrr0r0r6_alloc_keys_valuess   zTableBase._alloc_keys_valuescCsvd}xF||gD]:}|rt|tjs&tt|}|dks@||jkrtdqW|rl|rlt|t|krltdtj|S)aCheck 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 rrzArray's length is wrongz(keys array length != values array length) isinstancer]rt TypeErrorr<rrr)rrrZarr_lenelemr0r0r6_sanity_check_keys_valuess   z#TableBase._sanity_check_keys_valuesccs(x"|jddD]\}}||fVqWdS)aLook 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)rrrLr0r0r6items_lookup_batchs zTableBase.items_lookup_batchcCsh|dk rP|j|d}tj|jtj|tj|}|dkrdtdtjtj nx|j D]}dSWdS)aDelete 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)rrz#BPF_MAP_DELETE_BATCH has failed: %s) rrZbpf_delete_batchrr]rrrrritems_lookup_and_delete_batch)rct_keysct_cntr_r0r0r6items_delete_batchs  zTableBase.items_delete_batchcCsT|j||d}tj|jtj|tj|tj|}|dkrPtdtjtj dS)aqUpdate 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. )rrrz#BPF_MAP_UPDATE_BATCH has failed: %sN) rrZbpf_update_batchrr]rrrrr)rr ct_valuesrrr0r0r6items_update_batch s  zTableBase.items_update_batchccs(x"|jddD]\}}||fVqWdS)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)rN)r)rrrLr0r0r6r s z'TableBase.items_lookup_and_delete_batchTc cs4|dkrtj}d}n tj}d}|jddd\}}}tjd}}d} x|j| |_||j| rftj|ndtj|tj|tj |j | tj|tj |j | tj|} tj } | |j7} | dkr| t jkrtd|tj| f| dkrP| |jkrP|jdkrFPqFWx&td| D]} || || fVqWdS)aLook 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. TZBPF_MAP_LOOKUP_AND_DELETE_BATCHZBPF_MAP_LOOKUP_BATCH)rrrNz%s has failed: %s)rZbpf_lookup_and_delete_batchZbpf_lookup_batchrr]rrrrrrrrerrnoENOENTrrrr;) rrZ bpf_batchZbpf_cmdZ ct_buf_sizerrZ ct_out_batchrZtotalrZerrcoder4r0r0r6r/s<     z3TableBase._items_lookup_and_optionally_delete_batchcCs&x t|jD]}|j||<qWdS)N)listrr)rrr0r0r6zerofszTableBase.zerocCs tj|S)N)rIter)rr0r0r6__iter__nszTableBase.__iter__cCs|jS)N)r)rr0r0r6iterqszTableBase.itercCs|jS)N)r)rr0r0r6rrszTableBase.keysc@s,eZdZddZddZddZddZd S) zTableBase.ItercCs||_d|_dS)N)tabler)rrr0r0r6ruszTableBase.Iter.__init__cCs|S)Nr0)rr0r0r6rxszTableBase.Iter.__iter__cCs|jS)N)next)rr0r0r6__next__zszTableBase.Iter.__next__cCs|jj|j|_|jS)N)rrr)rr0r0r6r|szTableBase.Iter.nextN)__name__ __module__ __qualname__rrrrr0r0r0r6rtsrcCs^|j}|dkr0tj|jtj|tj|j}ntj|jtj|tj|}|dkrZt|S)Nr) rrZbpf_get_first_keyrr]rrZbpf_get_next_key StopIteration)rrZnext_keyrr0r0r6rs zTableBase.nextc Cs|jjdd}|jjdd}|dkrHt|jjdkrH|jjdd}xX|jD]L\}}t||} |rp|| } |j| dgt} || <t||} |j| | <qRWt|j } |r|| } x| D]} |j | qWdS)NrrZ__pad_1rr) rr\r<rgetattrgetlog2_index_maxrrrr>) rtmpbuckets bucket_fnbucket_sort_fnf1f2rrLbucketr@ZslotZ buckets_lstr0r0r6decode_c_structs     zTableBase.decode_c_structr Bucket ptrc Cst|jtjrfi}g}|j||||xr|D]2}||} |rL|||f} n||f} t| || q.Wn6dgt} x |jD]\} } | j| | j<qzWt| |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. rN) rrr]rlrrDrrr) rr9section_headersection_print_fnrrrrrr@rArrLr0r0r6print_json_hists  zTableBase.print_json_histc Cst|jtjrvi}g}|j||||x|D]B} || } |rTtd||| fntd|| ft| ||q.Wn8dgt} x |jD]\} } | j | | j <qWt| ||dS)aprint_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 = %rrN) rrr]rlrr?rPrrr) rr9rrrrIrrrrr@rrLr0r0r6print_log2_hists  zTableBase.print_log2_histc Cst|jtjrvi}g}|j||||x|D]B} || } |rTtd||| fntd|| ft| ||q.Wnddgt} xL|jD]@\} } y| j | | j <Wqt k rt d| j tfYqXqWt| ||dS)aprint_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 = %rrz#Index in print_linear_hist() of %d zexceeds max of %d.Nz5Index in print_linear_hist() of %d exceeds max of %d.) rrr]rlrr?rQlinear_index_maxrr IndexError) rr9rrrrIrrrrr@rrLr0r0r6print_linear_hists&  zTableBase.print_linear_hist)N)FFN)NN)N)T)rrNNN)rrNNNN)rrNNNN)#rrrrrrrrrrrrrrrrrrrrrrrrrrrrobjectrrrrrrr0r0r0r6r=sH   #   7  # &rcs$eZdZfddZddZZS)rrcstt|j||dS)N)superrrr)rargsr) __class__r0r6r"szHashTable.__init__cCsd}x|D] }|d7}q W|S)Nrrr0)rr4rr0r0r6__len__%s zHashTable.__len__)rrrrr __classcell__r0r0)rr6rr!s rrcseZdZfddZZS)rcstt|j||dS)N)rrr)rrr)rr0r6r+szLruHash.__init__)rrrrrr0r0)rr6r*srcspeZdZfddZddZddZfddZfd d Zfd d Zd dZ ddZ Gddde Z Z S) ArrayBasecstt|j||dS)N)rrr)rrr)rr0r6r/szArrayBase.__init__cCsVt|tr(|dkrt||}|j|}t|tjs||d@dkrtdx tD]}|j|||||q WdS)azopen_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. rrz+Perf buffer page_cnt must be a power of twoN)rr _open_perf_buffer)rcallbackpage_cntlost_cb wakeup_eventsr4r0r0r6open_perf_buffers  zPerfEventArray.open_perf_bufferc sfdd}fdd}t|}r.t|n tjdt} t} d| _| _|| _tj || d|tj | } | svt dtj | } |j | ||j<| |jjt|f<|| f|j<d|j<dS) NcsPy||Wn:tk rJ}z|jtjkr6tn|WYdd}~XnXdS)N)IOErrorrEPIPErj)rr:sizee)rcpur0r6raw_cb_s  z1PerfEventArray._open_perf_buffer..raw_cb_csLy |Wn:tk rF}z|jtjkr2tn|WYdd}~XnXdS)N)r"rr#rj)rZlostr%)rr0r6lost_cb_s   z2PerfEventArray._open_perf_buffer..lost_cb_rzCould not open perf bufferr/r/)rr r]rr pidr&r rZbpf_open_perf_buffer_optsrrZperf_reader_fdrrrbrrrr) rr&rrrr r'r(fnZlost_fnZoptsreaderr r0)rr&rr6rs   z PerfEventArray._open_perf_buffercCsBtj||d|}|dkr td|j|||j|<||j|<dS)Nrrzbpf_open_perf_event failedr/)rZbpf_open_perf_eventrrrr)rr&typconfigr r0r0r6_open_perf_events zPerfEventArray._open_perf_eventcCs"xtD]}|j|||qWdS)zopen_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.)rr,r-r4r0r0r6open_perf_events zPerfEventArray.open_perf_event)rNr) rrrrr rrr!rr.r/rr0r0)rr6rxs   "rxcsTeZdZfddZfddZddZfddZd d Zd d Zd dZ Z S)rzcs|jdd|_tt|j|||j|_tt|_ t j |jd|_ |j dkr`|j|j |_n@|jt j kr|t j|j |_n$|jt jkrt j|j |_ntddS)NreducerrrzLeaf must be aligned to 8 bytes)popr0rrzrrsLeafr<r total_cpur]r alignmentr_c_uint64r^c_int64r)rrr)rr0r6rs    zPerCpuHash.__init__csTtt|j|}|jdkr |}n0|j|j}x td|jD]}||||<q.ringbuf_cb_rN)r rbZ_open_ring_bufferrr)rrrHrIr*r0)rr6open_ring_buffers zRingBuf.open_ring_buffer)N) rrrrZ_RingBuf__delitemr rrrJrr0r0)rr6rs   rc@sReZdZdZddZddZddZdd d Zd d Zd dZ ddZ ddZ dS)rrcCs\||_||_||_||_tj|jj|j|_tj|jj|j|_ t tj |jj|j|_ dS)N) rbrrrrrprcrTrrr=rr)rrbrrrr0r0r6rs zQueueStack.__init__cCsNtjtj|jd}tj|jj|j|t |tj |}|dkrHt d|j S)NrrzCould not printf leaf) r]rrrrrrbrcrr<rrr)rrrrr0r0r6rs zQueueStack.leaf_sprintfcCs8|j}tj|jj|j|tj|}|dkr4td|S)NrzCould not scanf leaf) rrrrbrcrr]rr)rrrrr0r0r6rs  zQueueStack.leaf_scanfrcCs>tj|jdtj||}|dkr:tjtj}td|dS)NrzCould not push to table: %s) rrrr]rrrrr)rrrrrr0r0r6pushszQueueStack.pushcCs2|j}tj|jdtj|}|dkr.td|S)NrzCould not pop from table)rrZbpf_lookup_and_deleterr]rrS)rrrr0r0r6r1$s zQueueStack.popcCs2|j}tj|jdtj|}|dkr.td|S)NrzCould not peek table)rrrrr]rrS)rrrr0r0r6peek+s zQueueStack.peekc cs@|j}x4|r:y|jV|d8}Wqtk r6dSXqWdS)Nr)rr1rS)rZcntr0r0r6r2s  zQueueStack.itervaluescCsdd|jDS)NcSsg|]}|qSr0r0)rrr0r0r6r=sz%QueueStack.values..)r)rr0r0r6r<szQueueStack.valuesN)r) rrrZ BPF_EXISTrrrrKr1rLrrr0r0r0r6rs   r)N)VZ __future__rcollections.abcr ImportError collectionsZtimerZctypesr] functoolsrrrr`rhZlibbccrrr r r Zutilsr r rqrsrurwryr{rrrrr}rrrZBPF_MAP_TYPE_SOCKMAPrrZBPF_MAP_TYPE_SOCKHASHZBPF_MAP_TYPE_CGROUP_STORAGEZ BPF_MAP_TYPE_REUSEPORT_SOCKARRAYZ"BPF_MAP_TYPE_PERCPU_CGROUP_STORAGErrZBPF_MAP_TYPE_SK_STORAGEZBPF_MAP_TYPE_DEVMAP_HASHZBPF_MAP_TYPE_STRUCT_OPSrZBPF_MAP_TYPE_INODE_STORAGEZBPF_MAP_TYPE_TASK_STORAGErRrHrrr7rDrPrQrUrorrrrrrrtrvr rrxrzrr|r~rrrrrrrrr0r0r0r6s      &;0g 8 l4849