python (3.11.7)
ed3 R d dl Z d dlZd dlZd dlZd dlmZ d dlmZmZ d dl Z ej
d ej d Z ej
Z
d Z G d d e j Z G d
d e Z G d d
e j Z G d dej Zej d ZdefdZ G d de j Z G d de Z G d de Z e Z G d de j Z G d d e j Z G d d e Z e!d k r e j" dS dS ) N)support)
socket_helperwarnings_helperT)module telnetlibc * | | | \ }}| n# t $ r Y nw xY w| d S # | w xY wN)listensetacceptclose TimeoutError)evtservconnaddrs G/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_telnetlib.pyserverr s KKMMMGGIII[[]]
d
s) +A A<
A# A< "A##A< <Bc D e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
S ) GeneralTestsc t j | _ t j t j t j | _ | j d t j | j | _
t j t | j | j f | _
d| j
_ | j
| j d S )N< )targetargsT) threadingEventr socketAF_INET SOCK_STREAMsock
settimeoutr bind_portportThreadr threaddaemonstartwaitselfs r setUpzGeneralTests.setUp s ?$$M&.&2DEE R !+DI66 &fDHTY;OPPP !
c < | j | ` d S r )r% joinr) s r tearDownzGeneralTests.tearDown' s KKKr, c t t | j }|j d S r )r TelnetHOSTr# r r
r* telnets r testBasiczGeneralTests.testBasic+ s3 !!$ 22 r, c t t | j 5 }| | d d d n # 1 swxY w Y | | d S r )r r1 r2 r# assertIsNotNone
get_socket assertIsNone)r* tns r testContextManagerz GeneralTests.testContextManager0 s
dDI
.
. 2" 1 1 1 2 2 2 2 2 2 2 2 2 2 2 2 2 2 2 "--//*****s (AA !A c | t j d u t j d t t | j }t j d n# t j d w xY w| |j
d |j d S )N )
assertTruer getdefaulttimeoutsetdefaulttimeoutr r1 r2 r# assertEqualr
gettimeoutr
r3 s r testTimeoutDefaultz GeneralTests.testTimeoutDefault5 s 022d:;;; $$$ + %%dDI66F $T * * * *F $T * * * * //112666 s %A8 8Bc | t j d u t j d t t | j d }t j d n# t j d w xY w| |j d u |j
d S Nr= )timeout) r> r r? r@ r r1 r2 r# r rB r
r3 s r testTimeoutNonez GeneralTests.testTimeoutNone? s 022d:;;; $$$ + %%dDIt%DDF $T * * * *F $T * * * * ..00D8999 s 'A: :Bc t t | j d }| |j d |j d S rE )r r1 r2 r# rA r rB r
r3 s r testTimeoutValuez GeneralTests.testTimeoutValueJ s\ !!$ 2!>> //112666 r, c t }| t | j d | |j d |j d S rE ) r r1 openr2 r# rA r rB r
r3 s r testTimeoutOpenz GeneralTests.testTimeoutOpenO sk !!## D$)R 000 //112666 r, c X t t | j d }|j }| | | | | | |j d S rE ) r r1 r2 r# r rA r8 filenor
)r* r4 t_socks r testGetterszGeneralTests.testGettersU s !!$ 2!>> **,,f555 &--//::: r, N) __name__
__module__ __qualname__r+ r/ r5 r; rC rG rI rL rP r, r r r s
+ + +
r, r c & e Zd ZdZddZd Zd ZdS )
SocketStubz* a socket proxy that re-defines sendall() rT c J t | | _ g | _ d| _ d S )NF)listreadswritesblock)r* rY s r __init__zSocketStub.__init___ s! %[[
r, c : | j | d S r )rZ append)r* datas r sendallzSocketStub.sendallc s 4 r, c , d}| j rJt | |k r7|| j d z
}| j rt | |k 7t | |k r-| j d||d |d | }|S )Nr, r )rY lenpopinsert)r* sizeouts r recvzSocketStub.recve s j %SXX__ 4:>>!$$ $C j %SXX__ s88d?? J aTUU , , ,ete*C
r, N)rT )rQ rR rS __doc__r\ r` rg rT r, r rV rV ] sL 44 ! ! ! r, rV c & e Zd Zd Zd Zd Zd ZdS ) TelnetAlikec t r )NotImplementedErrorr) s r rN zTelnetAlike.filenoo s !###r, c d S r rT r) s r r
zTelnetAlike.closeq s r, c | j j S r )r r[ r) s r
sock_availzTelnetAlike.sock_availr s IO#$r, c t j 5 }t j j | |g|R d d d n # 1 swxY w Y | xj | z
c_ d S r )r captured_stdoutr r1 msg _messagesgetvalue)r* rr r rf s r rr zTelnetAlike.msgt s
$
&
& 3# s 2T 2 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 #,,..(s
9= =N)rQ rR rS rN r
ro rr rT r, r rj rj n sJ $ $ $% % % r, rj c F e Zd Zd Zed ZddZd ZddZd Z dS ) MockSelectorc i | _ d S r keysr) s r r\ zMockSelector.__init__| s
r, c dS )NgMbP?rT r) s r
resolutionzMockSelector.resolution s tr, Nc H t j |d|| }|| j |< |S )Nr ) selectors SelectorKeyry )r* fileobjeventsr_ keys r registerzMockSelector.register s) #GQ== '
r, c 6 | j | S r )ry rc )r* r s r
unregisterzMockSelector.unregister s y}}W%%%r, c d}| j D ]%}t |t r|j j } n&|rg S d | j D S )NFc g | ] }||j f S rT )r ).0r s r
<listcomp>z'MockSelector.select.<locals>.<listcomp> s DDD#S#*%DDDr, )ry
isinstancerj r r[ values)r* rF r[ r s r selectzMockSelector.select sp y G';//
*
EIDD1A1A1C1CDDD Dr, c | j S r rx r) s r get_mapzMockSelector.get_map s
yr, r )
rQ rR rS r\ propertyr{ r r r r rT r, r rv rv z s X
& & & E E E E r, rv c # K fd} t j }|t _ d V |t _ n# |t _ w xY wd S )Nc " t S r )rV )ignoredrY s r new_connz test_socket.<locals>.new_conn s % r, )r create_connection)rY r old_conns ` r test_socketr sb ! ! ! ! !,+#+
#+ 8 ++++
Fs 3 ArT c | D ]"}t | t u s
J | #t | 5 |dd }d|_ ddd n # 1 swxY w Y |S )za return a telnetlib.Telnet object that uses a SocketStub with
reads queued up to be read dummyr N)typebytesr rs )rY clsxr4 s r test_telnetr s # #Aww% U Wa Ms AA Ac e Zd Zd Zd ZdS )ExpectAndReadTestCasec J t j | _ t t _ d S r )r _TelnetSelector old_selectorrv r) s r r+ zExpectAndReadTestCase.setUp s % 5$0 !!!r, c ( | j t _ d S r )r r r r) s r r/ z ExpectAndReadTestCase.tearDown s $($5 !!!r, N)rQ rR rS r+ r/ rT r, r r r s2 1 1 16 6 6 6 6r, r c 8 e Zd Zd Zd Zd Zd Zd Zd Zd Z dS ) ReadTestsc h dg}t | }| d }| |d|j |j |j j f g d}d |dd }t | }| d }| || dS ) zc
read_until(expected, timeout=None)
test the blocking version of read_util
s xxxmatchyyy matchs xxxmatch)rr )s2 xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxr s2 yyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyr, N)r
read_untilrA cookedqrawqr rY r. )r* wantr4 r_ rY expects r test_read_untilzReadTests.test_read_until s
T"" ** { fkN_0`aaa000%*%% U## ** v&&&&&r, c g d}d | }t | }| }| || dS )zJ
read_all()
Read all data until EOF; may block.
) xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxs yyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyys zzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzr, N)r. r read_allrA )r* rY r r4 r_ s r
test_read_allzReadTests.test_read_all sU
544% U## v&&&r, c
t dg }| }| t | dk t }| }| d| dS )zQ
read_some()
Read at least one byte or EOF; may block.
r r, N)r read_somer> rb rA )r* r4 r_ s r test_read_somezReadTests.test_read_some sv j\** !! D Q''' !! d#####r, c ( d}t |g }t || }d|j _ | d | d|j _ d} | | z
}n# t
$ r Y nw xY w | || dS )z
read_*_eager()
Read all data available already queued or on the socket,
without blocking.
d xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxTr, FN)r getattrr r[ rA EOFError)r* func_namer r4 funcr_ s r _read_eagerzReadTests._read_eager s dV$$vy)) ddff%%% !
t$$$$$s
A+ +
A87A8c Z | d | d d S )N
read_eagerread_very_eager)r r) s r test_read_eagerzReadTests.test_read_eager s3
&&& *+++++r, c f d}t |g }| d| |j j r | |j j | }| || | t |j d S Nr r, )r rA read_very_lazyr rY fill_rawq assertRaisesr )r* r r4 r_ s r r zReadTests.read_very_lazy s dV$$ f 3 3 5 5666k k $$&& t$$$ (F$9:::::r, c d}t |g }| d| d} | }||z
}|s| n# t $ r Y n-w xY w| | | j| || d S r )r rA read_lazyr r r>
startswith)r* r r4 r_ read_datas r test_read_lazyzReadTests.test_read_lazy s dV$$ f . . 0 0111 3
" , , . . ! '$$&&&
OODOOD 1 1 2 2 2 3
t$$$$$s /A/ /
A<;A<N)
rQ rR rS r r r r r r r rT r, r r r s} ' ' '"
$ $ $ % % %(, , ,; ; ;% % % % %r, r c e Zd ZddZd ZdS )nego_collectorNc 0 d| _ || _ d| _ d S )Nr, )seen sb_gettersb_seen)r* r s r r\ znego_collector.__init__ s " r, c | xj ||z z
c_ |t j k r-| j r(| }| xj |z
c_ d S d S d S r )r tlSEr r )r* r cmdoptsb_datas r do_negoznego_collector.do_nego sU S3Y "%<<DN<nn&&G LLG #LLLL <<<r, r )rQ rR rS r\ r rT r, r r r s7
$ $ $ $ $r, r c e Zd ZdZd ZdS )
WriteTestszKThe only thing that write does is replace each tl.IAC for
tl.IAC+tl.IACc ddt j z dz dt j z t j z dz t j z t j dg}|D ]}t }| | d |j j }| | t j t j t j z | d S )Ns data sample without IACs data sample withs one IACs a fews iacsr, ) r IACr writer. r rZ rA replace)r* data_sampler_ r4 writtens r
test_writezWriteTests.test_write+ s 1*RV3kA "&(261H<rvEv
J JD ]]F LL hhv{ 122G T\\"& ? ? I I I I J Jr, N)rQ rR rS rh r rT r, r r r ' s2
J
J
J
J
Jr, r c e Zd Zej ej ej ej ej ej ej
ej gZ d Z
d Zd Zd Zd Zd ZdS ) OptionTestsc * t | }t d | }t }| |j | }|j }| t | dk | |dd | j
| |dd t j
| |t ||z d|_ dS )z helper for testing IAC + cmd r, r Nr )r rb r. r set_option_negotiation_callbackr r r r> assertIncmdsrA r NOOPTr )r* r_ r4 data_lennegotxtr s r
_test_commandzOptionTests._test_command; s T""sxx~~&& ..t|<<<oo i C1 %%%
c"1"gty))) QqS28,,, 3sSy>>222 r, c 0 | j D ]i}| t j |g | dt j |dg | dt j |dg j| d | j D d S )Nr sd yyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyy
xxxxxxxxxx
yyyyyyyyyyc , g | ]}t j |z S rT )r r )r r s r r z1OptionTests.test_IAC_commands.<locals>.<listcomp>O s @@@cBFSL@@@r, )r r r r )r* r s r test_IAC_commandsz OptionTests.test_IAC_commandsI s 9 B BC } - - -
BFC B C C C 263 @ A A A A @@di@@@AAAAAr, c t j t j z t j z t j z t j t j z t j z t j z t j z t j z t j t j z t j z t j z dz t j z t j z t j t j z dz t j z t j z t j z t j z t j t j z dz t j z t j z dz t j z t j z g}t | }t |j }| |j | }|
|d t j t j z dz t j z dz t j z dz }|
|j | |
d| d |_ d S )Ns aas bbs ccs ddr, s aabb)
r r SBr r r read_sb_datar r r rA r r )r* sendr4 r r want_sb_datas r test_SB_commandsz OptionTests.test_SB_commandsQ s '"%/'"&0269BEA'"&05826ABEI&/"&826ABEI&/"&85@26IBEQ T"" f 122..t|<<<oo c"""v0269EABFJUR |444 f 1 1 3 3444 r, c X dt j t dg z dft j t j z t dg z dft j t j z t dg z dft j t j z t dg z dft j t j z t dg z dfg}|D ]Y\ }}t |g }| d | }|
||j Zd S ) N) az : recv b''
X z: IAC 88 not recognized
r z : IAC DO 1
z
: IAC DONT 1
z
: IAC WILL 1
z
: IAC WONT 1
) r r r DODONTWILLWONTr set_debuglevelr r rs )r* given_a_expect_babr4 r s r test_debuglevel_readsz!OptionTests.test_debuglevel_readsc s
#
VeRDkk
!#> ?
Vbe^eQCjj
(. 9
Vbg
qc
*,< =
Vbg
qc
*,< =
Vbg
qc
*,< =
% / /DAq !%%F ! !! $ $ $//##C MM!V - . . . .r, c t }| d | d d}| ||j d S )Nr s xxxz send b'xxx'
)r r r r rs )r* r4 expecteds r test_debuglevel_writez!OptionTests.test_debuglevel_writev sS a V "
h 011111r, c t g 5 t dd }d|_ d d d n # 1 swxY w Y | d | d | |j d d S )Nr 0r r testz0.*test)r rj rs r rr assertRegexr3 s r test_debug_accepts_str_portz'OptionTests.test_debug_accepts_str_port} s
__ " " #..F !F " " " " " " " " " " " " " " " a
6 ):66666s 488N)rQ rR rS r AOAYTBRKECELGAIPNOPr r r r r r r rT r, r r r 7 s E262625"%rv FD B B B $ &2 2 27 7 7 7 7r, r c e Zd Zd ZdS ) ExpectTestsc g d}t | }| dg \ }}}| |d |dd dS )z
expect(expected, [timeout])
Read until the expected string has been seen, or a timeout is
hit (default is no timeout); may block.
)r r r r r, Nr )r r rA r. )r* r r4 _r_ s r test_expectzExpectTests.test_expect se 0// T""]]H:..
1T sxxSbS 2 233333r, N)rQ rR rS r rT r, r r r s# 4 4 4 4 4r, r __main__)#r r} r
contextlibr
r test.supportr r unittestrequires_working_socketimport_deprecatedr r2 r TestCaser objectrV r1 rj BaseSelectorrv contextmanagerr r r r r r r r r rQ mainrT r, r <module>r% s
7 7 7 7 7 7 7 7 t , , , , -O -k : : @ @ @ @ @ 8$ @ @ @ D "
)"
9) @ k 6 6 6 6 6H - 6 6 6`% `% `% `% `%% `% `% `%D
$
$
$
$
$V
$
$
$ J J J J J" J J J M7 M7 M7 M7 M7(# M7 M7 M7`
4
4
4
4
4'
4
4
4 zHMOOOOO r, 
Browse
Usage
Versions