/opt/alt/python38/lib64/python3.8/site-packages/playhouse/__pycache__
Edit: /opt/alt/python38/lib64/python3.8/site-packages/playhouse/__pycache__/sqliteq.cpython-38.pyc (9306B)
U
SW[! @ s d dl Z d dlZd dlmZ d dlmZ zd dlmZ W n ek
rX d dlmZ Y nX z0d dlZd dlm Z
d dl mZ d dl
mZ W n ek
r d Z
ZZ Y nX d dlmZ e dZG dd d eZG d
d d eZd Zd
ZG dd deZG dd deZG dd deZdS ) NEvent)Thread)Queue)Greenlet)SqliteExtDatabasezpeewee.sqliteqc @ s e Zd ZdS )
ResultTimeoutN)__name__
__module__ __qualname__ r r D/opt/alt/python38/lib64/python3.8/site-packages/playhouse/sqliteq.pyr s r c @ s| e Zd ZdZdd ZdddZdddZd d
Zd d ZeZ e
d
d Z e
dd Z e
dd Z
dd Zdd Zdd ZdS ) AsyncCursor) sqlparamscommittimeout_event_cursor_exc_idx_rowsc C s: || _ || _|| _|| _|| _d | _ | _ | _| _d S N) r r r r r r r r r )selfeventr r r r r r r
__init__ s zAsyncCursor.__init__Nc C s6 || _ || _d| _|d kr"| ng | _| j | S )Nr )r r r fetchallr r set)r cursorexcr r r
set_result( s
zAsyncCursor.set_resultc C s@ |d k r |n| j }| jj|ds,|r,td| jd k r<| jd S )N)r z results not ready, timed out.)r r waitr r )r r r r r
_wait0 s
zAsyncCursor._waitc C s | | jd k r| j| S r )r" r _execr r r r
__iter__7 s
zAsyncCursor.__iter__c C s@ z| j | j }W n tk
r( tY nX | jd7 _|S d S )N )r r
IndexError
StopIteration)r objr r r
next= s
zAsyncCursor.nextc C s | | jjS r )r" r lastrowidr$ r r r
r+ G s zAsyncCursor.lastrowidc C s | | jjS r )r" r rowcountr$ r r r
r, L s zAsyncCursor.rowcountc C s | j jS r )r descriptionr$ r r r
r- Q s zAsyncCursor.descriptionc C s | j d S r )r closer$ r r r
r. U s zAsyncCursor.closec C s t | S r )listr$ r r r
r X s zAsyncCursor.fetchallc C s. | z
t| W S tk
r( Y d S X d S r )r" r* r( r$ r r r
fetchone[ s
zAsyncCursor.fetchone)N)N)r r
r __slots__r r r" r% r* __next__propertyr+ r, r- r. r r0 r r r r
r s
r zthreadlocals cannot be set to True when using the Sqlite thread / queue database. All queries are serialized through a single connection, so allowing multiple threads to connect defeats the purpose of this database.zSQLite must be configured to use the WAL journal mode when using this feature. WAL mode allows one or more readers to continue reading while another connection writes to the database.c sr e Zd Zd fdd Zdd Zd dd Zd
d Zd d
Zdd Zdd Z d ddZ
dd Z dd Z dd Z
ZS ) SqliteQueueDatabaseFr& Nc s | drttd|d< d|d< | |dd |dd } tt| }
|
j| _|
j |f|d| i| || _
|| _ || _ d| _
| ||| _| | j
r| d S )N threadlocalsFZcheck_same_thread journal_modepragmasT)get
ValueErrorTHREADLOCAL_ERROR_MESSAGE_validate_journal_modepopsuperr4 execute_sql!_SqliteQueueDatabase__execute_sqlr Z
_autostart_results_timeout _num_readers _is_stoppedget_thread_impl_thread_helper_create_queues_and_workersstart) r database
use_geventZ autostartZreadersqueue_max_sizeZresults_timeoutargskwargsr7 ZParent __class__r r
r o s&
z SqliteQueueDatabase.__init__c C s |rt S tS r )GreenletHelper ThreadHelper)r rH r r r
rC s z#SqliteQueueDatabase.get_thread_implc C sh |r| dkrtt|r^tdd |D }|dd dkrJttdd |D dg S dgS d S )Nwalc s s | ]\}}| |fV qd S r )lower.0kvr r r
s z=SqliteQueueDatabase._validate_journal_mode..r6 c S s g | ]\}}|d kr||fqS )r6 r rR r r r
s z>SqliteQueueDatabase._validate_journal_mode..)r6 rP )rQ r9 WAL_MODE_ERROR_MESSAGEdictr8 )r r6 r7 Zpdictr r r
r; s z*SqliteQueueDatabase._validate_journal_modec sP j _ j _ j j j _ fddt jD _ d S )Nc s g | ]} j jqS r )rD thread _read_queue)rS _r targetr r
rW s zBSqliteQueueDatabase._create_queues_and_workers..)
rD queue _write_queuer[ _run_worker_looprZ _writerrangerA _readersr$ r r] r
rE s z.SqliteQueueDatabase._create_queues_and_workersc C s< | }|tkr td d S td|j | | q d S )Nzworker shutting down.zreceived query %s)r8 r( loggerinfodebugr _process_execution)r r_ async_cursorr r r
ra s
z$SqliteQueueDatabase._run_worker_loopc
C sP z| |j|j|j}W n& tk
r> } zd }W 5 d }~X Y nX d }|||S r )r? r r r Exceptionr )r ri r r r r r
rh s z&SqliteQueueDatabase._process_executionc C s | j | j fS r )r` Zqsizer[ r$ r r r
queue_size s z SqliteQueueDatabase.queue_sizeTc C sD t | j ||||d kr | jn|d}|r0| jn| j}|| |S )N)r r r r r )r rD r r@ r` r[ put)r r r require_commitr r r_ r r r
r> s
z SqliteQueueDatabase.execute_sqlc C sb | j R | js W 5 Q R dS | j | jD ] }| q,td d| _W 5 Q R dS Q R X d S )NFzworkers started.T)
_conn_lockrB rb rF rd re rf )r readerr r r
rF s
zSqliteQueueDatabase.startc C s t d | jf | jr&W 5 Q R dS | jt | jD ]}| jt q8| j
| jD ] }|
qZW 5 Q R dS Q R X d S )Nzenvironment stop requested.FT) re rg rn rB r` rl r( rd r[ rb join)r r\ ro r r r
stop s
zSqliteQueueDatabase.stopc
C s$ | j | jW 5 Q R S Q R X d S r )rn rB r$ r r r
is_stopped s z SqliteQueueDatabase.is_stopped)FFr& NN)NN)NTN)r r
r r rC r; rE ra rh rk r> rF rq rr
__classcell__r r rL r
r4 n s !
r4 c @ s4 e Zd ZdZd ddZdd Zd ddZd d
ZdS )
rO rI Nc C s
|| _ d S r rt )r rI r r r
r s zThreadHelper.__init__c C s t S r r r$ r r r
r zThreadHelper.eventc C s |d k r |n| j }t|pddS Nr )maxsize)rI r r Zmax_sizer r r
r_ s zThreadHelper.queuec O s t |||d}d|_|S )N)r^ rJ rK T)r daemon)r fnrJ rK rZ r r r
rZ s zThreadHelper.thread)N)N)r r
r r1 r r r_ rZ r r r r
rO s
rO c @ s* e Zd ZdZdd Zd ddZdd ZdS )
rN rt c C s t S r )GEventr$ r r r
r ru zGreenletHelper.eventNc C s |d k r |n| j }t|pddS rv )rI GQueuerx r r r
r_ s zGreenletHelper.queuec s fdd}t |f||S )Nc s t | |S r )geventsleep)arT rz r r
wrap s z#GreenletHelper.thread..wrap)GThread)r rz rJ rK r r r r
rZ s zGreenletHelper.thread)N)r r
r r1 r r_ rZ r r r r
rN s
rN ) loggingweakref threadingr r r ImportErrorr_ r} r r Z gevent.eventr{ Z gevent.queuer| Zplayhouse.sqlite_extr getLoggerre rj r objectr r: rX r4 rO rN r r r r
s.
G{