tKg39 ,dZddlZejddddlmZmZddlZddlZddlZddl Z ddl m Z ddl m Z dd lmZd Zd Zd ZGd d e ZGddeZGddeZGddeZGddeZGddeZdaej4Zej8ddZGddej<ZGddeZ e!dk(rejDddD]Z#ejFjIejFjKe#Z#e e#5Z&e'e&jPe'e&jRe'e&jTe&D]Z+e'e,e+e-e+d dddyy#1swYxYw)aYUse Gstreamer to decode audio files. To read an audio file, pass it to the constructor for GstAudioFile() and then iterate over the contents: >>> f = GstAudioFile('something.mp3') >>> try: >>> for block in f: >>> ... >>> finally: >>> f.close() Note that there are a few complications caused by Gstreamer's asynchronous architecture. This module spawns its own Gobject main- loop thread; I'm not sure how that will interact with other main loops if your program has them. Also, in order to stop the thread and terminate your program normally, you need to call the close() method on every GstAudioFile you create. Conveniently, the file can be used as a context manager to make this simpler: >>> with GstAudioFile('something.mp3') as f: >>> for block in f: >>> ... Iterating a GstAudioFile yields strings containing short integer PCM data. You can also read the sample rate and channel count from the file: >>> with GstAudioFile('something.mp3') as f: >>> print f.samplerate >>> print f.channels >>> print f.duration NGstz1.0)GLibr)quote) DecodeError) AudioFile __GSTDEC_SENTINEL__c eZdZy)GStreamerErrorN)__name__ __module__ __qualname__T/home/alanp/www/video.onchill/myenv/lib/python3.12/site-packages/audioread/gstdec.pyr r Esrr c"eZdZdZfdZxZS)UnknownTypeErrorz7Raised when Gstreamer can't decode the given file type.c8t|d|z||_y)Nzcan't decode stream: )super__init__ streaminfo)selfr __class__s rrzUnknownTypeError.__init__Ks!  #j 0 %rr rr__doc__r __classcell__rs@rrrIsA%%rrceZdZdZy) FileReadErrorz*Raised when the file can't be read at all.Nr rrrrrrr r Rs4rr c"eZdZdZfdZxZS) NoStreamErrorzTRaised when the file was read successfully but no audio streams were found. c$t|dy)Nzno audio streams foundrrrrs rrzNoStreamError.__init__[s 12rrrs@rr#r#Ws33rr#ceZdZdZy)MetadataMissingErrorzdRaised when GStreamer fails to report stream metadata (duration, channels, or sample rate). Nr!rrrr(r(_s  rr(c"eZdZdZfdZxZS)IncompleteGStreamerErrorzkRaised when necessary components of GStreamer (namely, the principal plugin packages) are missing. c$t|dy)Nzmissing GStreamer base pluginsr%r&s rrz!IncompleteGStreamerError.__init__js  , rrrs@rr*r*fs  rr*ct5tstatjtcdddS#1swYyxYw)z%Get the shared main-loop thread. N)_loop_thread_lock_shared_loop_threadMainLoopThreadstartrrrget_loop_threadr1ws. ""0"2   % % '"   s *;Ac(eZdZdZfdZdZxZS)r/z7A daemon thread encapsulating a Gobject main loop. czt|tjj dd|_d|_y)NFT)rrrMainLoopnewloopdaemonr&s rrzMainLoopThread.__init__s- MM%%dE2  rc8|jjyN)r6runrs rr:zMainLoopThread.runs r)r rrrrr:rrs@rr/r/s rr/cdeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z dd Zd ZdZdZy) GstAudioFileaReads raw audio data from any audio file that Gstreamer knows how to decode. >>> with GstAudioFile('something.mp3') as f: >>> print f.samplerate >>> print f.channels >>> print f.duration >>> for block in f: >>> do_something(block) Iterating the object yields blocks of 16-bit PCM data. Three pieces of stream information are also available: samplerate (in Hz), number of channels, and duration (in seconds). It's very important that the client call close() when it's done with the object. Otherwise, the program is likely to hang on exit. Alternatively, of course, one can just use the file as a context manager, as shown above. cd|_d|_tj|_tj j dd|_tj j dd|_tj j dd|_ |j|j |j t|jj}|j|jd|j|jd|jdtt j"j%|z}|jj'd||jjd |j(|jjd |j*|jjd |j,|jj'd tj.j1d |jj'dd|jj'dt2|jj'dd|jj'dd|jjd|j4t7j8d|_|jj=djd|j>|_ |jjC|j|jjC|j|jjC|j|jjE|jtGjHtJ|_#tM|_'d|_(d|_d|_)|jjUtjVjX|j:j[|jPr|j]d|jPy)NF uridecodebin audioconvertappsinkz message::eoszmessage::errorzfile://uriz pad-addedz no-more-padsz unknown-typecapsz!audio/x-raw, format=(string)S16LEdropz max-bufferssyncz emit-signalsTz new-samplersinkz notify::caps)/runningfinishedrPipelinepipelineElementFactorymakedecconvrFr*get_busadd_signal_watchconnect_messagerospathabspath set_property _pad_added _no_more_pads _unkown_typeCaps from_string BUFFER_SIZE _new_sample threading Semaphore ready_semget_static_pad _notify_caps caps_handleraddlinkqueueQueue QUEUE_SIZEr1threadread_excgot_caps set_stateStatePLAYINGacquireclose)rrTbusrBs rrzGstAudioFile.__init__s     %%**>4@&&++NDA &&++It< 88 tyy0DII4E+, ,mm##%  NDMM2 $dmm4% 566 eS) doo6 ););< ):):;   HH !D E  vu- }k: vu- ~t4 ,(8(89 #,,Q/ II44V<DD D--  $((# $))$ $))$ tyy![[, %'      1 12  == JJt --  rcd|_|jjd}|jdd|_|jdd|_|j jtjj\}}|r |dz |_ ntd|_ |jjy) z>The callback for the sinkpad's "notify::caps" signal. Trchannelsrrateiʚ;zduration not availableN)rkget_current_caps get_structureget_intrs samplerateget_peerquery_durationrFormatTIMEdurationr(rjr`release)rpadargsinfosuccesslengths rrbzGstAudioFile._notify_capss  ##%33A6 Z03 ,,v.q1,,.77 H "Z/DM01IJDM  rFc|jdj}|jdrE|jj d}|j sd|_|j|yyy)z:The callback for GstElement's "pad-added" signal. Nz audio/x-rawrFT) query_caps to_string startswithrNra is_linked _got_a_padre)relementrnamenextpads rrWzGstAudioFile._pad_addedsd~~d#--/ ??= )ii..v6G$$&"&!' *rcp|js*t|_|jj yy)z=The callback for GstElement's "no-more-pads" signal. N)rr#rjr`r~)rrs rrXzGstAudioFile._no_more_pads s) )ODM NN " " $rc"|jr|jdj}|j}|j t j j\}}|rt|jtrt|j}n |j}|j||jj|t j j"Stdt j j"S)z8The callback for appsink's "new-sample" signal. z pull-samplez3Unable to map buffer memory while reading the file.)rGemit get_bufferget_all_memorymaprMapFlagsREAD isinstancedata memoryviewbytesunmaprfputr FlowReturnOK)rrFbufmemrrrs rr]zGstAudioFile._new_sample*s <<))M*557C$$&CGGCLL$5$56MGTdii4!+D 99D $ t$~~   %%Z[[~~   rc|j}|jdsyt||_|jj y)zrs~ D 5% #  #     [ %~% N 3N3 >  ~ #IOO% # Y%% P9Ph z wwrww11$78 $ 1 !**  !,,  !** c!fc!A$i(   s 'AF  F