
    !ni
                         d dl Z d dlmZ e j                  j	                  d      Zej                  ZdgZg dZd Z	ddZ
y)    N)get_hubselect)devpollpollepollkqueuekeventc                     	 | j                   } |       }t        |t              st        dt	        |      z        |S # t
        $ r, t        | t              st        dt	        |       z        | cY S w xY w)NzExpected int or long, got %s)fileno
isinstanceint	TypeErrortypeAttributeError)objfrvs      U/home/homepc/tiktok-worker/venv/lib/python3.12/site-packages/eventlet/green/select.py
get_filenor      sr    

JJ S"c":T"XEFF	  #s#:T#YFGG
s   > 2A32A3c           
      Z   |	 t        |      }t               g t	        j
                         j                  u rt        d      i | D ]  }d|it        |      <    |D ]   }|j                  t        |      i       d<   " |D ]   }|j                  t        |      i       d<   " g }fd}fd}	fdfd	}
|!j                  j                  ||
             	 j                         D ]  \  }}|j                  d      r9|j                  j                  j                  ||j                   d
              |j                  d      sb|j                  j                  j"                  ||	j                   d               	 j%                         |D ]  }j'                  |        	 D ]  }|j)                           S # t        $ r t        d      w xY w# |D ]  }j'                  |        w xY w# D ]  }|j)                           w xY w)NzExpected number for timeoutz0do not call blocking functions from the mainloopreadwriteerrorc                 R    t        |          d   }j                  |gg g f       y )Nr   r   switchdoriginalcurrentdss     r   on_readzselect.<locals>.on_read3   s+    jm$V,
B+,    c                 R    t        |          d   }j                  g |gg f       y )Nr   r   r   s     r   on_writezselect.<locals>.on_write7   s+    jm$W-XJ+,r#   c                  .     j                  g g g f       y N)r   )r    s   r   on_timeout2zselect.<locals>.on_timeout2;   s    B|$r#   c                  H    j                   j                  d             y )Nr   )appendschedule_call_global)hubr(   timerss   r   
on_timeoutzselect.<locals>.on_timeout>   s     	c..q+>?r#   c                       y r'    r0   r#   r   <lambda>zselect.<locals>.<lambda>L       r#   c                       y r'   r0   r0   r#   r   r1   zselect.<locals>.<lambda>N   r2   r#   )float
ValueErrorr   r   eventlet
getcurrentgreenletRuntimeErrorr   
setdefaultr*   r+   itemsgetaddREADthrowWRITEr   removecancel)	read_list
write_list
error_listtimeoutrwe	listenersr"   r%   r.   kvltr    r!   r,   r(   r-   s                  @@@@@r   r   r      s   	;GnG )CF!!#G
||wMNN	B (#QK:a=( 645jmR(16 645jmR(16 I--%@ c..w
CDHHJ 	_DAquuV}  1gw}}l![\uuW~  AxP\!]^		_
	::< 

1  	AHHJ	g  	;9::	;`  

1  	AHHJ	s6   G .A1H  ;H G4 +H G14HH H*r'   )r6   eventlet.hubsr   patcherr   __selectr   __patched____deleted__r   r   r0   r#   r   <module>rT      sB     !$$X. j>$9r#   