|
Server : Apache/2.2.2 (Fedora) System : Linux App1.pathumtani.go.th 2.6.20-1.2320.fc5smp #1 SMP Tue Jun 12 19:40:16 EDT 2007 i686 User : apache ( 48) PHP Version : 5.2.9 Disable Function : NONE Directory : /proc/self/root/usr/lib/python2.4/ |
Upload File : |
mņ
Ļ=Ec @ sq d Z d k Z d k Z d k l Z d e i f d YZ d f d YZ d f d YZ d Z d S(
s„ A class supporting chat-style (command/response) protocols.
This class adds support for 'chat' style protocols - where one side
sends a 'command', and the other sends a response (examples would be
the common internet protocols - smtp, nntp, ftp, etc..).
The handle_read() method looks at the input stream for the current
'terminator' (usually '\r\n' for single-line responses, '\r\n.\r\n'
for multi-line output), calling self.found_terminator() on its
receipt.
for example:
Say you build an async nntp client using this class. At the start
of the connection, you'll have self.terminator set to '\r\n', in
order to process the single-line greeting. Just before issuing a
'LIST' command you'll set it to '\r\n.\r\n'. The output of the LIST
command will be accumulated (using your own 'collect_incoming_data'
method) up to the terminator, and then control will be returned to
you - by calling your self.found_terminator() method.
N( s dequet
async_chatc B s t Z d Z d Z d Z e d Z d Z d Z d Z d Z
d Z d Z d Z
d
Z d Z d Z d
Z d Z d Z d Z d Z RS( s This is an abstract class. You must derive from this class, and add
the two methods collect_incoming_data() and found_terminator()i c C s5 d | _ d | _ t | _ t i i | | d S( Nt ( t selft ac_in_buffert
ac_out_buffert fifot
producer_fifot asyncoret
dispatchert __init__t conn( R R
( ( t /usr/lib/python2.4/asynchat.pyR > s c C s
t d d S( Ns must be implemented in subclass( t NotImplementedError( R t data( ( R t collect_incoming_dataD s c C s
t d d S( Ns must be implemented in subclass( R ( R ( ( R t found_terminatorG s c C s
| | _ d S( sR Set the input delimiter. Can be a fixed string of any length, an integer, or NoneN( t termR t
terminator( R R ( ( R t set_terminatorJ s c C s | i S( N( R R ( R ( ( R t get_terminatorN s c C s" y | i | i } Wn& t i j
o } | i d Sn X| i | | _ xĢ| i oĮt | i } | i } | d j p
| d j o | i | i d | _ qR t | t o{ | } | | j o- | i | i d | _ | i | | _ q| i | i | | i | | _ d | _ | i qR t | } | i i | } | d j oG | d j o | i | i | n | i | | | _ | i qR t | i | } | o< | | j o* | i | i | | i | | _ n PqR | i | i d | _ qR Wd S( NR i i’’’’( R t recvt ac_in_buffer_sizeR
t sockett errort whyt handle_errorR t lent lbR R t NoneR t
isinstancet intt nR t terminator_lent findt indext find_prefix_at_end( R R" R R R R R
R ( ( R t handle_readV sL
c C s | i d S( N( R t
initiate_send( R ( ( R t handle_write s c C s | i d S( N( R t close( R ( ( R t handle_close s c C s$ | i i t | | i d S( N( R R t pusht simple_producerR
R% ( R R
( ( R R) s c C s | i i | | i d S( N( R R R) t producerR% ( R R+ ( ( R t push_with_producer¢ s c C s t | i | i j S( s4 predicate for inclusion in the readable for select()N( R R R R ( R ( ( R t readable¦ s c C s( | i d j o | i i o | i S( s4 predicate for inclusion in the writable for select()R N( R R R t is_emptyt connected( R ( ( R t writableŖ s c C s | i i d d S( sA automatically close this channel once the outgoing queue is emptyN( R R R) R ( R ( ( R t close_when_done“ s c C sŚ xÓ t | i oŗ | i i } | d j o- | i p | i i | i n d Sn6 t | t
o% | i i | i | | _ d Sn | i } | o | i | | _ d SqŃ | i i q d Sq Wd S( Ni (
R R R t firstt pR R t popR' R t strt moreR
( R R3 R
( ( R t
refill_bufferŗ s&
c C s§ | i } t | i | j o | i n | i ol | i ob y5 | i | i | } | o | i | | _ n Wq£ t i
j
o } | i d Sq£ Xn d S( N(
R t ac_out_buffer_sizet obsR R R7 R/ t sendt num_sentR R R R ( R R9 R R; ( ( R R% Ņ s
c C s5 d | _ d | _ x | i o | i i q Wd S( NR ( R R R R R4 ( R ( ( R t discard_buffersć s
( t __name__t
__module__t __doc__R R8 R R R R R R R$ R& R( R) R, R- R0 R1 R7 R% R< ( ( ( R R 5 s& B
R* c B s t Z d d Z d Z RS( Ni c C s | | _ | | _ d S( N( R
R t buffer_size( R R
R@ ( ( R R ķ s c C s^ t | i | i j o+ | i | i } | i | i | _ | Sn | i } d | _ | Sd S( NR ( R R R
R@ t result( R RA ( ( R R6 ń s ( R= R> R R6 ( ( ( R R* ė s R c B sA t Z d d Z d Z d Z d Z d Z d Z RS( Nc C s* | p t | _ n t | | _ d S( N( t listt dequeR ( R RB ( ( R R ü s c C s
t | i S( N( R R RB ( R ( ( R t __len__ s c C s | i S( N( R RB ( R ( ( R R. s c C s | i d S( Ni ( R RB ( R ( ( R R2 s c C s | i i | d S( N( R RB t appendR
( R R
( ( R R) s c C s) | i o d | i i f Sn d Sd S( Ni i ( i N( R RB t popleftR ( R ( ( R R4 s
( R= R> R R RD R. R2 R) R4 ( ( ( R R ū s c C sB t | d } x+ | o# | i | | o | d 8} q W| S( Ni ( R t needlet lt haystackt endswith( RI RG RH ( ( R R# # s
(
R? R R t collectionsRC R R R* R R# ( RC R R R# R* R R ( ( R t ?/ s
¶(