12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683368436853686368736883689369036913692369336943695369636973698369937003701370237033704370537063707370837093710371137123713371437153716371737183719372037213722372337243725372637273728372937303731373237333734373537363737373837393740374137423743374437453746374737483749375037513752375337543755375637573758375937603761376237633764376537663767376837693770377137723773377437753776377737783779378037813782378337843785378637873788378937903791379237933794379537963797379837993800380138023803380438053806380738083809381038113812381338143815381638173818381938203821382238233824382538263827382838293830383138323833383438353836383738383839384038413842384338443845384638473848384938503851385238533854385538563857385838593860386138623863386438653866386738683869387038713872387338743875387638773878387938803881388238833884388538863887388838893890389138923893389438953896389738983899390039013902390339043905390639073908390939103911391239133914391539163917391839193920392139223923392439253926392739283929393039313932393339343935393639373938393939403941394239433944394539463947394839493950395139523953395439553956395739583959396039613962396339643965396639673968396939703971397239733974397539763977397839793980398139823983398439853986398739883989399039913992399339943995399639973998399940004001400240034004400540064007400840094010401140124013401440154016401740184019402040214022402340244025402640274028402940304031403240334034403540364037403840394040404140424043404440454046404740484049405040514052405340544055405640574058405940604061406240634064406540664067406840694070407140724073407440754076407740784079408040814082408340844085408640874088408940904091409240934094409540964097409840994100410141024103410441054106410741084109411041114112411341144115411641174118411941204121412241234124412541264127412841294130413141324133413441354136413741384139414041414142414341444145414641474148414941504151415241534154415541564157415841594160416141624163416441654166416741684169417041714172417341744175417641774178417941804181418241834184418541864187418841894190419141924193419441954196419741984199420042014202420342044205420642074208420942104211421242134214421542164217421842194220422142224223422442254226422742284229423042314232423342344235423642374238423942404241424242434244424542464247424842494250425142524253425442554256425742584259426042614262426342644265426642674268426942704271427242734274427542764277427842794280428142824283428442854286428742884289429042914292429342944295429642974298429943004301430243034304430543064307430843094310431143124313431443154316431743184319432043214322432343244325432643274328432943304331433243334334433543364337433843394340434143424343434443454346434743484349435043514352435343544355435643574358435943604361436243634364436543664367436843694370437143724373437443754376437743784379438043814382438343844385 |
- /*
- * Asterisk -- An open source telephony toolkit.
- *
- * Copyright (C) 1999 - 2018, Digium, Inc.
- *
- * Mark Spencer <markster@digium.com>
- *
- * See http://www.asterisk.org for more information about
- * the Asterisk project. Please do not directly contact
- * any of the maintainers of this project for assistance;
- * the project provides a web site, mailing lists and IRC
- * channels for your use.
- *
- * This program is free software, distributed under the terms of
- * the GNU General Public License Version 2. See the LICENSE file
- * at the top of the source tree.
- */
- /* Doxygenified Copyright Header */
- /*!
- * \mainpage Asterisk -- The Open Source Telephony Project
- *
- * \par Welcome
- *
- * This documentation created by the Doxygen project clearly explains the
- * internals of the Asterisk software. This documentation contains basic
- * examples, developer documentation, support information, and information
- * for upgrading.
- *
- * \section community Community
- * Asterisk is a big project and has a busy community. Look at the
- * resources for questions and stick around to help answer questions.
- * \li \ref asterisk_community_resources
- *
- * \par Developer Documentation for Asterisk
- *
- * This is the main developer documentation for Asterisk. It is
- * generated by running "make progdocs" from the Asterisk source tree.
- *
- * In addition to the information available on the Asterisk source code,
- * please see the appendices for information on coding guidelines,
- * release management, commit policies, and more.
- *
- * \arg \ref AsteriskArchitecture
- *
- * \par Additional documentation
- * \arg \ref Licensing
- * \arg \ref DevDoc
- * \arg \ref configuration_file
- * \arg \ref channel_drivers
- * \arg \ref applications
- *
- * \section copyright Copyright and Author
- *
- * Copyright (C) 1999 - 2021, Sangoma Technologies Corporation.
- * Asterisk is a <a href="https://cdn.sangoma.com/wp-content/uploads/Sangoma-Trademark-Policy.pdf">registered trademark</a>
- * of <a rel="nofollow" href="http://www.sangoma.com">Sangoma Technologies Corporation</a>.
- *
- * \author Mark Spencer <markster@digium.com>
- *
- * See http://www.asterisk.org for more information about
- * the Asterisk project. Please do not directly contact
- * any of the maintainers of this project for assistance;
- * the project provides a web site, mailing lists, and IRC
- * channels for your use.
- *
- */
- /*!
- * \page asterisk_community_resources Asterisk Community Resources
- * \par Websites
- * \li https://www.asterisk.org Asterisk Homepage
- * \li https://docs.asterisk.org Asterisk documentation
- *
- * \par Mailing Lists
- * \par
- * All lists: http://lists.digium.com/mailman/listinfo
- * \li aadk-commits SVN commits to the AADK repository
- * \li asterisk-addons-commits SVN commits to the Asterisk addons project
- * \li asterisk-announce [no description available]
- * \li asterisk-biz Commercial and Business-Oriented Asterisk Discussion
- * \li Asterisk-BSD Asterisk on BSD discussion
- * \li asterisk-bugs [no description available]
- * \li asterisk-commits SVN commits to the Asterisk project
- * \li asterisk-dev Asterisk Developers Mailing List
- * \li asterisk-doc Discussions regarding The Asterisk Documentation Project
- * \li asterisk-embedded Asterisk Embedded Development
- * \li asterisk-gui Asterisk GUI project discussion
- * \li asterisk-gui-commits SVN commits to the Asterisk-GUI project
- * \li asterisk-ha-clustering Asterisk High Availability and Clustering List - Non-Commercial Discussion
- * \li Asterisk-i18n Discussion of Asterisk internationalization
- * \li asterisk-r2 [no description available]
- * \li asterisk-scf-commits Commits to the Asterisk SCF project code repositories
- * \li asterisk-scf-committee Asterisk SCF Steering Committee discussions
- * \li asterisk-scf-dev Asterisk SCF Developers Mailing List
- * \li asterisk-scf-wiki-changes Changes to the Asterisk SCF space on wiki.asterisk.org
- * \li asterisk-security Asterisk Security Discussion
- * \li asterisk-speech-rec Use of speech recognition in Asterisk
- * \li asterisk-ss7 [no description available]
- * \li asterisk-users Asterisk Users Mailing List - Non-Commercial Discussion
- * \li asterisk-video Development discussion of video media support in Asterisk
- * \li asterisk-wiki-changes Changes to the Asterisk space on wiki.asterisk.org
- * \li asterisknow AsteriskNOW Discussion
- * \li dahdi-commits SVN commits to the DAHDI project
- * \li digium-announce Digium Product Announcements
- * \li Dundi Distributed Universal Number Discovery
- * \li libiax2-commits SVN commits to the libiax2 project
- * \li libpri-commits SVN commits to the libpri project
- * \li libss7-commits SVN commits to the libss7 project
- * \li svn-commits SVN commits to the Digium repositories
- * \li Test-results Results from automated testing
- * \li thirdparty-commits SVN commits to the Digium third-party software repository
- * \li zaptel-commits SVN commits to the Zaptel project
- *
- * \par Forums
- * \li Forums are located at http://forums.asterisk.org/
- *
- * \par IRC
- * \par
- * Use https://libera.chat IRC server to connect with Asterisk
- * developers and users in realtime.
- *
- * \li \verbatim #asterisk \endverbatim Asterisk Users Room
- * \li \verbatim #asterisk-dev \endverbatim Asterisk Developers Room
- *
- * \par More
- * \par
- * If you would like to add a resource to this list please create an issue
- * on the issue tracker with a patch.
- */
- /*! \file
- * \brief Top level source file for Asterisk - the Open Source PBX.
- * Implementation of PBX core functions and CLI interface.
- */
- /*! \li \ref asterisk.c uses the configuration file \ref asterisk.conf
- * \addtogroup configuration_file
- */
- /*! \page asterisk.conf asterisk.conf
- * \verbinclude asterisk.conf.sample
- */
- /*** MODULEINFO
- <support_level>core</support_level>
- ***/
- #include "asterisk.h"
- #include "asterisk/_private.h"
- #undef sched_setscheduler
- #undef setpriority
- #include <sys/time.h>
- #include <fcntl.h>
- #include <signal.h>
- #include <sched.h>
- #include <sys/un.h>
- #include <sys/wait.h>
- #include <ctype.h>
- #include <sys/resource.h>
- #include <grp.h>
- #include <pwd.h>
- #include <sys/stat.h>
- #if defined(HAVE_SYSINFO)
- #include <sys/sysinfo.h>
- #elif defined(HAVE_SYSCTL)
- #include <sys/param.h>
- #include <sys/sysctl.h>
- #include <sys/vmmeter.h>
- #if defined(__FreeBSD__) || defined(__DragonFly__)
- #include <vm/vm_param.h>
- #endif
- #if defined(HAVE_SWAPCTL)
- #include <sys/swap.h>
- #endif
- #endif
- #include <regex.h>
- #include <histedit.h>
- #if defined(SOLARIS)
- int daemon(int, int); /* defined in libresolv of all places */
- #include <sys/loadavg.h>
- #endif
- #ifdef linux
- #include <sys/prctl.h>
- #ifdef HAVE_CAP
- #include <sys/capability.h>
- #endif /* HAVE_CAP */
- #endif /* linux */
- /* we define here the variables so to better agree on the prototype */
- #include "asterisk/paths.h"
- #include "asterisk/network.h"
- #include "asterisk/cli.h"
- #include "asterisk/channel.h"
- #include "asterisk/translate.h"
- #include "asterisk/pickup.h"
- #include "asterisk/acl.h"
- #include "asterisk/ulaw.h"
- #include "asterisk/alaw.h"
- #include "asterisk/callerid.h"
- #include "asterisk/image.h"
- #include "asterisk/tdd.h"
- #include "asterisk/term.h"
- #include "asterisk/manager.h"
- #include "asterisk/cdr.h"
- #include "asterisk/pbx.h"
- #include "asterisk/app.h"
- #include "asterisk/mwi.h"
- #include "asterisk/lock.h"
- #include "asterisk/utils.h"
- #include "asterisk/file.h"
- #include "asterisk/io.h"
- #include "asterisk/config.h"
- #include "asterisk/ast_version.h"
- #include "asterisk/linkedlists.h"
- #include "asterisk/devicestate.h"
- #include "asterisk/presencestate.h"
- #include "asterisk/module.h"
- #include "asterisk/buildinfo.h"
- #include "asterisk/xmldoc.h"
- #include "asterisk/poll-compat.h"
- #include "asterisk/test.h"
- #include "asterisk/rtp_engine.h"
- #include "asterisk/format.h"
- #include "asterisk/aoc.h"
- #include "asterisk/uuid.h"
- #include "asterisk/sorcery.h"
- #include "asterisk/bucket.h"
- #include "asterisk/stasis.h"
- #include "asterisk/json.h"
- #include "asterisk/stasis_endpoints.h"
- #include "asterisk/stasis_system.h"
- #include "asterisk/security_events.h"
- #include "asterisk/endpoints.h"
- #include "asterisk/codec.h"
- #include "asterisk/format_cache.h"
- #include "asterisk/media_cache.h"
- #include "asterisk/astdb.h"
- #include "asterisk/options.h"
- #include "asterisk/utf8.h"
- #include "../defaults.h"
- /*** DOCUMENTATION
- <managerEvent language="en_US" name="FullyBooted">
- <managerEventInstance class="EVENT_FLAG_SYSTEM">
- <synopsis>Raised when all Asterisk initialization procedures have finished.</synopsis>
- <syntax>
- <parameter name="Status">
- <para>Informational message</para>
- </parameter>
- <parameter name="Uptime">
- <para>Seconds since start</para>
- </parameter>
- <parameter name="LastReload">
- <para>Seconds since last reload</para>
- </parameter>
- </syntax>
- </managerEventInstance>
- </managerEvent>
- <managerEvent language="en_US" name="Shutdown">
- <managerEventInstance class="EVENT_FLAG_SYSTEM">
- <synopsis>Raised when Asterisk is shutdown or restarted.</synopsis>
- <syntax>
- <parameter name="Shutdown">
- <para>Whether the shutdown is proceeding cleanly (all channels
- were hungup successfully) or uncleanly (channels will be
- terminated)</para>
- <enumlist>
- <enum name="Uncleanly"/>
- <enum name="Cleanly"/>
- </enumlist>
- </parameter>
- <parameter name="Restart">
- <para>Whether or not a restart will occur.</para>
- <enumlist>
- <enum name="True"/>
- <enum name="False"/>
- </enumlist>
- </parameter>
- </syntax>
- </managerEventInstance>
- </managerEvent>
- ***/
- #ifndef AF_LOCAL
- #define AF_LOCAL AF_UNIX
- #define PF_LOCAL PF_UNIX
- #endif
- #define AST_MAX_CONNECTS 128
- #define NUM_MSGS 64
- /*! Displayed copyright tag */
- #define COPYRIGHT_TAG "Copyright (C) 1999 - 2022, Sangoma Technologies Corporation and others."
- /*! \brief Welcome message when starting a CLI interface */
- #define WELCOME_MESSAGE \
- ast_verbose("Asterisk %s, " COPYRIGHT_TAG "\n" \
- "Created by Mark Spencer <markster@digium.com>\n" \
- "Asterisk comes with ABSOLUTELY NO WARRANTY; type 'core show warranty' for details.\n" \
- "This is free software, with components licensed under the GNU General Public\n" \
- "License version 2 and other licenses; you are welcome to redistribute it under\n" \
- "certain conditions. Type 'core show license' for details.\n" \
- "=========================================================================\n", ast_get_version()) \
- static int ast_socket = -1; /*!< UNIX Socket for allowing remote control */
- static int ast_socket_is_sd = 0; /*!< Is socket activation responsible for ast_socket? */
- static int ast_consock = -1; /*!< UNIX Socket for controlling another asterisk */
- pid_t ast_mainpid;
- struct console {
- int fd; /*!< File descriptor */
- int p[2]; /*!< Pipe */
- pthread_t t; /*!< Thread of handler */
- int mute; /*!< Is the console muted for logs */
- int uid; /*!< Remote user ID. */
- int gid; /*!< Remote group ID. */
- int levels[NUMLOGLEVELS]; /*!< Which log levels are enabled for the console */
- /*! Verbosity level of this console. */
- int option_verbose;
- };
- struct ast_atexit {
- void (*func)(void);
- int is_cleanup;
- AST_LIST_ENTRY(ast_atexit) list;
- };
- static AST_LIST_HEAD_STATIC(atexits, ast_atexit);
- struct timeval ast_startuptime;
- struct timeval ast_lastreloadtime;
- static History *el_hist;
- static EditLine *el;
- static char *remotehostname;
- struct console consoles[AST_MAX_CONNECTS];
- static int ast_el_add_history(const char *);
- static int ast_el_read_history(const char *);
- static int ast_el_write_history(const char *);
- static void ast_el_read_default_histfile(void);
- static void ast_el_write_default_histfile(void);
- static void asterisk_daemon(int isroot, const char *runuser, const char *rungroup);
- static char *_argv[256];
- typedef enum {
- /*! Normal operation */
- NOT_SHUTTING_DOWN,
- /*! Committed to shutting down. Final phase */
- SHUTTING_DOWN_FINAL,
- /*! Committed to shutting down. Initial phase */
- SHUTTING_DOWN,
- /*!
- * Valid values for quit_handler() niceness below.
- * These shutdown/restart levels can be cancelled.
- *
- * Remote console exit right now
- */
- SHUTDOWN_FAST,
- /*! core stop/restart now */
- SHUTDOWN_NORMAL,
- /*! core stop/restart gracefully */
- SHUTDOWN_NICE,
- /*! core stop/restart when convenient */
- SHUTDOWN_REALLY_NICE
- } shutdown_nice_t;
- static shutdown_nice_t shuttingdown = NOT_SHUTTING_DOWN;
- /*! Prevent new channel allocation for shutdown. */
- static int shutdown_pending;
- static int restartnow;
- static pthread_t consolethread = AST_PTHREADT_NULL;
- static pthread_t mon_sig_flags;
- static int canary_pid = 0;
- static char canary_filename[128];
- static int multi_thread_safe;
- static char randompool[256];
- #ifdef HAVE_CAP
- static cap_t child_cap;
- #endif
- static int sig_alert_pipe[2] = { -1, -1 };
- static struct {
- unsigned int need_reload:1;
- unsigned int need_quit:1;
- unsigned int need_quit_handler:1;
- unsigned int need_el_end:1;
- } sig_flags;
- #if !defined(LOW_MEMORY)
- struct thread_list_t {
- AST_RWLIST_ENTRY(thread_list_t) list;
- char *name;
- pthread_t id;
- int lwp;
- };
- static AST_RWLIST_HEAD_STATIC(thread_list, thread_list_t);
- void ast_register_thread(char *name)
- {
- struct thread_list_t *new = ast_calloc(1, sizeof(*new));
- if (!new)
- return;
- ast_assert(multi_thread_safe);
- new->id = pthread_self();
- new->lwp = ast_get_tid();
- new->name = name; /* steal the allocated memory for the thread name */
- AST_RWLIST_WRLOCK(&thread_list);
- AST_RWLIST_INSERT_HEAD(&thread_list, new, list);
- AST_RWLIST_UNLOCK(&thread_list);
- }
- void ast_unregister_thread(void *id)
- {
- struct thread_list_t *x;
- AST_RWLIST_WRLOCK(&thread_list);
- AST_RWLIST_TRAVERSE_SAFE_BEGIN(&thread_list, x, list) {
- if ((void *) x->id == id) {
- AST_RWLIST_REMOVE_CURRENT(list);
- break;
- }
- }
- AST_RWLIST_TRAVERSE_SAFE_END;
- AST_RWLIST_UNLOCK(&thread_list);
- if (x) {
- ast_free(x->name);
- ast_free(x);
- }
- }
- /*! \brief Print the contents of a file */
- static int print_file(int fd, char *desc, const char *filename)
- {
- FILE *f;
- char c;
- if (!(f = fopen(filename, "r"))) {
- return -1;
- }
- ast_cli(fd, "%s", desc);
- while ((c = fgetc(f)) != EOF) {
- ast_cli(fd, "%c", c);
- }
- fclose(f);
- /* no need for trailing new line, the file already has one */
- return 0;
- }
- /*! \brief Give an overview of core settings */
- static char *handle_show_settings(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- char buf[BUFSIZ];
- struct ast_tm tm;
- char eid_str[128];
- struct rlimit limits;
- char pbx_uuid[AST_UUID_STR_LEN];
- #if defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS)
- char dir[PATH_MAX];
- #endif
- switch (cmd) {
- case CLI_INIT:
- e->command = "core show settings";
- e->usage = "Usage: core show settings\n"
- " Show core misc settings";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- ast_eid_to_str(eid_str, sizeof(eid_str), &ast_eid_default);
- ast_pbx_uuid_get(pbx_uuid, sizeof(pbx_uuid));
- ast_cli(a->fd, "\nPBX Core settings\n");
- ast_cli(a->fd, "-----------------\n");
- ast_cli(a->fd, " Version: %s\n", ast_get_version());
- ast_cli(a->fd, " ABI related Build Options: %s\n", S_OR(ast_get_build_opts(), "(none)"));
- ast_cli(a->fd, " All Build Options: %s\n", S_OR(ast_get_build_opts_all(), "(none)"));
- if (ast_option_maxcalls)
- ast_cli(a->fd, " Maximum calls: %d (Current %d)\n", ast_option_maxcalls, ast_active_channels());
- else
- ast_cli(a->fd, " Maximum calls: Not set\n");
- if (getrlimit(RLIMIT_NOFILE, &limits)) {
- ast_cli(a->fd, " Maximum open file handles: Error because of %s\n", strerror(errno));
- } else if (limits.rlim_cur == RLIM_INFINITY) {
- ast_cli(a->fd, " Maximum open file handles: Unlimited\n");
- } else if (limits.rlim_cur < ast_option_maxfiles) {
- ast_cli(a->fd, " Maximum open file handles: %d (is) %d (requested)\n", (int) limits.rlim_cur, ast_option_maxfiles);
- } else {
- ast_cli(a->fd, " Maximum open file handles: %d\n", (int) limits.rlim_cur);
- }
- ast_cli(a->fd, " Root console verbosity: %d\n", option_verbose);
- ast_cli(a->fd, " Current console verbosity: %d\n", ast_verb_console_get());
- ast_cli(a->fd, " Debug level: %d\n", option_debug);
- ast_cli(a->fd, " Trace level: %d\n", option_trace);
- ast_cli(a->fd, " Dump core on crash: %s\n", ast_opt_dump_core ? "Yes" : "No");
- print_file(a->fd, " Core dump file: ", "/proc/sys/kernel/core_pattern");
- ast_cli(a->fd, " Maximum load average: %lf\n", ast_option_maxload);
- #if defined(HAVE_SYSINFO)
- ast_cli(a->fd, " Minimum free memory: %ld MB\n", option_minmemfree);
- #endif
- if (ast_localtime(&ast_startuptime, &tm, NULL)) {
- ast_strftime(buf, sizeof(buf), "%H:%M:%S", &tm);
- ast_cli(a->fd, " Startup time: %s\n", buf);
- }
- if (ast_localtime(&ast_lastreloadtime, &tm, NULL)) {
- ast_strftime(buf, sizeof(buf), "%H:%M:%S", &tm);
- ast_cli(a->fd, " Last reload time: %s\n", buf);
- }
- ast_cli(a->fd, " System: %s/%s built by %s on %s %s\n", ast_build_os, ast_build_kernel, ast_build_user, ast_build_machine, ast_build_date);
- ast_cli(a->fd, " System name: %s\n", ast_config_AST_SYSTEM_NAME);
- ast_cli(a->fd, " Entity ID: %s\n", eid_str);
- ast_cli(a->fd, " PBX UUID: %s\n", pbx_uuid);
- ast_cli(a->fd, " Default language: %s\n", ast_defaultlanguage);
- ast_cli(a->fd, " Language prefix: %s\n", ast_language_is_prefix ? "Enabled" : "Disabled");
- ast_cli(a->fd, " User name and group: %s/%s\n", ast_config_AST_RUN_USER, ast_config_AST_RUN_GROUP);
- #if defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS)
- #if defined(HAVE_EUIDACCESS) && !defined(HAVE_EACCESS)
- #define eaccess euidaccess
- #endif
- if (!getcwd(dir, sizeof(dir))) {
- if (eaccess(dir, R_OK | X_OK | F_OK)) {
- ast_cli(a->fd, " Running directory: %s\n", "Unable to access");
- } else {
- ast_cli(a->fd, " Running directory: %s (%s)\n", dir, "Unable to access");
- }
- } else {
- ast_cli(a->fd, " Running directory: %s\n", dir);
- }
- #endif /* defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS) */
- ast_cli(a->fd, " Executable includes: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_EXEC_INCLUDES) ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Transcode via SLIN: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_TRANSCODE_VIA_SLIN) ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Transmit silence during rec: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_TRANSMIT_SILENCE) ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Generic PLC: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_GENERIC_PLC) ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Generic PLC on equal codecs: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_GENERIC_PLC_ON_EQUAL_CODECS) ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Hide Msg Chan AMI events: %s\n", ast_opt_hide_messaging_ami_events ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Sounds search custom dir: %s\n", ast_opt_sounds_search_custom ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Min DTMF duration:: %u\n", option_dtmfminduration);
- #if !defined(LOW_MEMORY)
- ast_cli(a->fd, " Cache media frames: %s\n", ast_opt_cache_media_frames ? "Enabled" : "Disabled");
- #endif
- ast_cli(a->fd, " RTP use dynamic payloads: %u\n", ast_option_rtpusedynamic);
- if (ast_option_rtpptdynamic == AST_RTP_PT_LAST_REASSIGN) {
- ast_cli(a->fd, " RTP dynamic payload types: %u,%u-%u\n",
- ast_option_rtpptdynamic,
- AST_RTP_PT_FIRST_DYNAMIC, AST_RTP_MAX_PT - 1);
- } else if (ast_option_rtpptdynamic < AST_RTP_PT_LAST_REASSIGN) {
- ast_cli(a->fd, " RTP dynamic payload types: %u-%u,%u-%u\n",
- ast_option_rtpptdynamic, AST_RTP_PT_LAST_REASSIGN,
- AST_RTP_PT_FIRST_DYNAMIC, AST_RTP_MAX_PT - 1);
- } else {
- ast_cli(a->fd, " RTP dynamic payload types: %u-%u\n",
- AST_RTP_PT_FIRST_DYNAMIC, AST_RTP_MAX_PT - 1);
- }
- ast_cli(a->fd, "\n* Subsystems\n");
- ast_cli(a->fd, " -------------\n");
- ast_cli(a->fd, " Manager (AMI): %s\n", ast_manager_check_enabled() ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Web Manager (AMI/HTTP): %s\n", ast_webmanager_check_enabled() ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Call data records: %s\n", ast_cdr_is_enabled() ? "Enabled" : "Disabled");
- ast_cli(a->fd, " Realtime Architecture (ARA): %s\n", ast_realtime_enabled() ? "Enabled" : "Disabled");
- /*! \todo we could check musiconhold, voicemail, smdi, adsi, queues */
- ast_cli(a->fd, "\n* Directories\n");
- ast_cli(a->fd, " -------------\n");
- ast_cli(a->fd, " Configuration file: %s\n", ast_config_AST_CONFIG_FILE);
- ast_cli(a->fd, " Configuration directory: %s\n", ast_config_AST_CONFIG_DIR);
- ast_cli(a->fd, " Module directory: %s\n", ast_config_AST_MODULE_DIR);
- ast_cli(a->fd, " Spool directory: %s\n", ast_config_AST_SPOOL_DIR);
- ast_cli(a->fd, " Log directory: %s\n", ast_config_AST_LOG_DIR);
- ast_cli(a->fd, " Run/Sockets directory: %s\n", ast_config_AST_RUN_DIR);
- ast_cli(a->fd, " PID file: %s\n", ast_config_AST_PID);
- ast_cli(a->fd, " VarLib directory: %s\n", ast_config_AST_VAR_DIR);
- ast_cli(a->fd, " Data directory: %s\n", ast_config_AST_DATA_DIR);
- ast_cli(a->fd, " ASTDB: %s\n", ast_config_AST_DB);
- ast_cli(a->fd, " IAX2 Keys directory: %s\n", ast_config_AST_KEY_DIR);
- ast_cli(a->fd, " AGI Scripts directory: %s\n", ast_config_AST_AGI_DIR);
- ast_cli(a->fd, " Cache directory: %s\n", ast_config_AST_CACHE_DIR);
- ast_cli(a->fd, "\n\n");
- return CLI_SUCCESS;
- }
- static char *handle_show_threads(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- int count = 0;
- struct thread_list_t *cur;
- switch (cmd) {
- case CLI_INIT:
- e->command = "core show threads";
- e->usage =
- "Usage: core show threads\n"
- " List threads currently active in the system.\n";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- AST_RWLIST_RDLOCK(&thread_list);
- AST_RWLIST_TRAVERSE(&thread_list, cur, list) {
- ast_cli(a->fd, "%p %d %s\n", (void *)cur->id, cur->lwp, cur->name);
- count++;
- }
- AST_RWLIST_UNLOCK(&thread_list);
- ast_cli(a->fd, "%d threads listed.\n", count);
- return CLI_SUCCESS;
- }
- #if defined (HAVE_SYSCTL) && defined(HAVE_SWAPCTL)
- /*
- * swapmode is rewritten by Tobias Weingartner <weingart@openbsd.org>
- * to be based on the new swapctl(2) system call.
- */
- static int swapmode(int *used, int *total)
- {
- struct swapent *swdev;
- int nswap, rnswap, i;
- nswap = swapctl(SWAP_NSWAP, 0, 0);
- if (nswap == 0)
- return 0;
- swdev = ast_calloc(nswap, sizeof(*swdev));
- if (swdev == NULL)
- return 0;
- rnswap = swapctl(SWAP_STATS, swdev, nswap);
- if (rnswap == -1) {
- ast_free(swdev);
- return 0;
- }
- /* if rnswap != nswap, then what? */
- /* Total things up */
- *total = *used = 0;
- for (i = 0; i < nswap; i++) {
- if (swdev[i].se_flags & SWF_ENABLE) {
- *used += (swdev[i].se_inuse / (1024 / DEV_BSIZE));
- *total += (swdev[i].se_nblks / (1024 / DEV_BSIZE));
- }
- }
- ast_free(swdev);
- return 1;
- }
- #endif
- #if defined(HAVE_SYSINFO) || defined(HAVE_SYSCTL)
- /*! \brief Give an overview of system statistics */
- static char *handle_show_sysinfo(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- uint64_t physmem, freeram;
- #if defined(HAVE_SYSINFO) || defined(HAVE_SWAPCTL)
- int totalswap = 0;
- uint64_t freeswap = 0;
- #endif
- int nprocs = 0;
- long uptime = 0;
- #if defined(HAVE_SYSINFO)
- struct sysinfo sys_info;
- #elif defined(HAVE_SYSCTL)
- static int pageshift;
- struct vmtotal vmtotal;
- struct timeval boottime;
- time_t now;
- int mib[2], pagesize;
- #if defined(HAVE_SWAPCTL)
- int usedswap = 0;
- #endif
- size_t len;
- #endif
- switch (cmd) {
- case CLI_INIT:
- e->command = "core show sysinfo";
- e->usage =
- "Usage: core show sysinfo\n"
- " List current system information.\n";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- #if defined(HAVE_SYSINFO)
- sysinfo(&sys_info);
- uptime = sys_info.uptime / 3600;
- physmem = sys_info.totalram * sys_info.mem_unit;
- freeram = (sys_info.freeram * sys_info.mem_unit) / 1024;
- totalswap = (sys_info.totalswap * sys_info.mem_unit) / 1024;
- freeswap = (sys_info.freeswap * sys_info.mem_unit) / 1024;
- nprocs = sys_info.procs;
- #elif defined(HAVE_SYSCTL)
- /* calculate the uptime by looking at boottime */
- time(&now);
- mib[0] = CTL_KERN;
- mib[1] = KERN_BOOTTIME;
- len = sizeof(boottime);
- if (sysctl(mib, 2, &boottime, &len, NULL, 0) != -1) {
- uptime = now - boottime.tv_sec;
- }
- uptime = uptime/3600;
- /* grab total physical memory */
- mib[0] = CTL_HW;
- #if defined(HW_PHYSMEM64)
- mib[1] = HW_PHYSMEM64;
- #else
- mib[1] = HW_PHYSMEM;
- #endif
- len = sizeof(physmem);
- sysctl(mib, 2, &physmem, &len, NULL, 0);
- pagesize = getpagesize();
- pageshift = 0;
- while (pagesize > 1) {
- pageshift++;
- pagesize >>= 1;
- }
- /* we only need the amount of log(2)1024 for our conversion */
- pageshift -= 10;
- /* grab vm totals */
- mib[0] = CTL_VM;
- mib[1] = VM_METER;
- len = sizeof(vmtotal);
- sysctl(mib, 2, &vmtotal, &len, NULL, 0);
- freeram = (vmtotal.t_free << pageshift);
- /* generate swap usage and totals */
- #if defined(HAVE_SWAPCTL)
- swapmode(&usedswap, &totalswap);
- freeswap = (totalswap - usedswap);
- #endif
- /* grab number of processes */
- #if defined(__OpenBSD__)
- mib[0] = CTL_KERN;
- mib[1] = KERN_NPROCS;
- len = sizeof(nprocs);
- sysctl(mib, 2, &nprocs, &len, NULL, 0);
- #endif
- #endif
- ast_cli(a->fd, "\nSystem Statistics\n");
- ast_cli(a->fd, "-----------------\n");
- ast_cli(a->fd, " System Uptime: %ld hours\n", uptime);
- ast_cli(a->fd, " Total RAM: %" PRIu64 " KiB\n", physmem / 1024);
- ast_cli(a->fd, " Free RAM: %" PRIu64 " KiB\n", freeram);
- #if defined(HAVE_SYSINFO)
- ast_cli(a->fd, " Buffer RAM: %" PRIu64 " KiB\n", ((uint64_t) sys_info.bufferram * sys_info.mem_unit) / 1024);
- #endif
- #if defined(HAVE_SYSINFO) || defined(HAVE_SWAPCTL)
- ast_cli(a->fd, " Total Swap Space: %d KiB\n", totalswap);
- ast_cli(a->fd, " Free Swap Space: %" PRIu64 " KiB\n\n", freeswap);
- #endif
- ast_cli(a->fd, " Number of Processes: %d \n\n", nprocs);
- return CLI_SUCCESS;
- }
- #endif
- struct profile_entry {
- const char *name;
- uint64_t scale; /* if non-zero, values are scaled by this */
- int64_t mark;
- int64_t value;
- int64_t events;
- };
- struct profile_data {
- int entries;
- int max_size;
- struct profile_entry e[0];
- };
- static struct profile_data *prof_data;
- #endif /* ! LOW_MEMORY */
- /*! \brief allocates a counter with a given name and scale.
- * \return Returns the identifier of the counter.
- */
- int ast_add_profile(const char *name, uint64_t scale)
- {
- #if !defined(LOW_MEMORY)
- int l = sizeof(struct profile_data);
- int n = 10; /* default entries */
- if (prof_data == NULL) {
- prof_data = ast_calloc(1, l + n*sizeof(struct profile_entry));
- if (prof_data == NULL)
- return -1;
- prof_data->entries = 0;
- prof_data->max_size = n;
- }
- if (prof_data->entries >= prof_data->max_size) {
- void *p;
- n = prof_data->max_size + 20;
- p = ast_realloc(prof_data, l + n*sizeof(struct profile_entry));
- if (p == NULL)
- return -1;
- prof_data = p;
- prof_data->max_size = n;
- }
- n = prof_data->entries++;
- prof_data->e[n].name = ast_strdup(name);
- prof_data->e[n].value = 0;
- prof_data->e[n].events = 0;
- prof_data->e[n].mark = 0;
- prof_data->e[n].scale = scale;
- return n;
- #else /* if defined(LOW_MEMORY) */
- return 0;
- #endif
- }
- int64_t ast_profile(int i, int64_t delta)
- {
- #if !defined(LOW_MEMORY)
- if (!prof_data || i < 0 || i > prof_data->entries) /* invalid index */
- return 0;
- if (prof_data->e[i].scale > 1)
- delta /= prof_data->e[i].scale;
- prof_data->e[i].value += delta;
- prof_data->e[i].events++;
- return prof_data->e[i].value;
- #else /* if defined(LOW_MEMORY) */
- return 0;
- #endif
- }
- #if !defined(LOW_MEMORY)
- /* The RDTSC instruction was introduced on the Pentium processor and is not
- * implemented on certain clones, like the Cyrix 586. Hence, the previous
- * expectation of __i386__ was in error. */
- #if defined ( __i686__) && (defined(__FreeBSD__) || defined(__NetBSD__) || defined(linux))
- #if defined(__FreeBSD__)
- #include <machine/cpufunc.h>
- #elif defined(__NetBSD__) || defined(linux)
- static __inline uint64_t
- rdtsc(void)
- {
- uint64_t rv;
- __asm __volatile(".byte 0x0f, 0x31" : "=A" (rv));
- return (rv);
- }
- #endif
- #else /* supply a dummy function on other platforms */
- static __inline uint64_t
- rdtsc(void)
- {
- return 0;
- }
- #endif
- #endif /* ! LOW_MEMORY */
- int64_t ast_mark(int i, int startstop)
- {
- #if !defined(LOW_MEMORY)
- if (!prof_data || i < 0 || i > prof_data->entries) /* invalid index */
- return 0;
- if (startstop == 1)
- prof_data->e[i].mark = rdtsc();
- else {
- prof_data->e[i].mark = (rdtsc() - prof_data->e[i].mark);
- if (prof_data->e[i].scale > 1)
- prof_data->e[i].mark /= prof_data->e[i].scale;
- prof_data->e[i].value += prof_data->e[i].mark;
- prof_data->e[i].events++;
- }
- return prof_data->e[i].mark;
- #else /* if defined(LOW_MEMORY) */
- return 0;
- #endif
- }
- #if !defined(LOW_MEMORY)
- #define DEFINE_PROFILE_MIN_MAX_VALUES min = 0; \
- max = prof_data->entries;\
- if (a->argc > 3) { /* specific entries */ \
- if (isdigit(a->argv[3][0])) { \
- min = atoi(a->argv[3]); \
- if (a->argc == 5 && strcmp(a->argv[4], "-")) \
- max = atoi(a->argv[4]); \
- } else \
- search = a->argv[3]; \
- } \
- if (max > prof_data->entries) \
- max = prof_data->entries;
- static char *handle_show_profile(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- int i, min, max;
- const char *search = NULL;
- switch (cmd) {
- case CLI_INIT:
- e->command = "core show profile";
- e->usage = "Usage: core show profile\n"
- " show profile information";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (prof_data == NULL)
- return 0;
- DEFINE_PROFILE_MIN_MAX_VALUES;
- ast_cli(a->fd, "profile values (%d, allocated %d)\n-------------------\n",
- prof_data->entries, prof_data->max_size);
- ast_cli(a->fd, "%6s %8s %10s %12s %12s %s\n", "ID", "Scale", "Events",
- "Value", "Average", "Name");
- for (i = min; i < max; i++) {
- struct profile_entry *entry = &prof_data->e[i];
- if (!search || strstr(entry->name, search))
- ast_cli(a->fd, "%6d: [%8ld] %10ld %12lld %12lld %s\n",
- i,
- (long)entry->scale,
- (long)entry->events, (long long)entry->value,
- (long long)(entry->events ? entry->value / entry->events : entry->value),
- entry->name);
- }
- return CLI_SUCCESS;
- }
- static char *handle_clear_profile(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- int i, min, max;
- const char *search = NULL;
- switch (cmd) {
- case CLI_INIT:
- e->command = "core clear profile";
- e->usage = "Usage: core clear profile\n"
- " clear profile information";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (prof_data == NULL)
- return 0;
- DEFINE_PROFILE_MIN_MAX_VALUES;
- for (i= min; i < max; i++) {
- if (!search || strstr(prof_data->e[i].name, search)) {
- prof_data->e[i].value = 0;
- prof_data->e[i].events = 0;
- }
- }
- return CLI_SUCCESS;
- }
- #undef DEFINE_PROFILE_MIN_MAX_VALUES
- #endif /* ! LOW_MEMORY */
- int ast_pbx_uuid_get(char *pbx_uuid, int length)
- {
- return ast_db_get("pbx", "UUID", pbx_uuid, length);
- }
- static void publish_fully_booted(void)
- {
- struct ast_json *json_object;
- int uptime = 0;
- int lastreloaded = 0;
- struct timeval tmp;
- struct timeval curtime = ast_tvnow();
- if (ast_startuptime.tv_sec) {
- tmp = ast_tvsub(curtime, ast_startuptime);
- uptime = (int) tmp.tv_sec;
- }
- if (ast_lastreloadtime.tv_sec) {
- tmp = ast_tvsub(curtime, ast_lastreloadtime);
- lastreloaded = (int) tmp.tv_sec;
- }
- json_object = ast_json_pack("{s: s, s: i, s: i}",
- "Status", "Fully Booted",
- "Uptime", uptime,
- "LastReload", lastreloaded);
- ast_manager_publish_event("FullyBooted", EVENT_FLAG_SYSTEM, json_object);
- ast_json_unref(json_object);
- }
- static void ast_run_atexits(int run_cleanups)
- {
- struct ast_atexit *ae;
- AST_LIST_LOCK(&atexits);
- while ((ae = AST_LIST_REMOVE_HEAD(&atexits, list))) {
- if (ae->func && (!ae->is_cleanup || run_cleanups)) {
- ae->func();
- }
- ast_free(ae);
- }
- AST_LIST_UNLOCK(&atexits);
- }
- static void __ast_unregister_atexit(void (*func)(void))
- {
- struct ast_atexit *ae;
- AST_LIST_TRAVERSE_SAFE_BEGIN(&atexits, ae, list) {
- if (ae->func == func) {
- AST_LIST_REMOVE_CURRENT(list);
- ast_free(ae);
- break;
- }
- }
- AST_LIST_TRAVERSE_SAFE_END;
- }
- static int register_atexit(void (*func)(void), int is_cleanup)
- {
- struct ast_atexit *ae;
- ae = ast_calloc(1, sizeof(*ae));
- if (!ae) {
- return -1;
- }
- ae->func = func;
- ae->is_cleanup = is_cleanup;
- AST_LIST_LOCK(&atexits);
- __ast_unregister_atexit(func);
- AST_LIST_INSERT_HEAD(&atexits, ae, list);
- AST_LIST_UNLOCK(&atexits);
- return 0;
- }
- int ast_register_atexit(void (*func)(void))
- {
- return register_atexit(func, 0);
- }
- int ast_register_cleanup(void (*func)(void))
- {
- return register_atexit(func, 1);
- }
- void ast_unregister_atexit(void (*func)(void))
- {
- AST_LIST_LOCK(&atexits);
- __ast_unregister_atexit(func);
- AST_LIST_UNLOCK(&atexits);
- }
- /* Sending commands from consoles back to the daemon requires a terminating NULL */
- static int fdsend(int fd, const char *s)
- {
- return write(fd, s, strlen(s) + 1);
- }
- /* Sending messages from the daemon back to the display requires _excluding_ the terminating NULL */
- static int fdprint(int fd, const char *s)
- {
- return write(fd, s, strlen(s));
- }
- /*! \brief NULL handler so we can collect the child exit status */
- static void _null_sig_handler(int sig)
- {
- }
- static struct sigaction null_sig_handler = {
- .sa_handler = _null_sig_handler,
- .sa_flags = SA_RESTART,
- };
- static struct sigaction ignore_sig_handler = {
- .sa_handler = SIG_IGN,
- };
- AST_MUTEX_DEFINE_STATIC(safe_system_lock);
- /*! \brief Keep track of how many threads are currently trying to wait*() on
- * a child process
- */
- static unsigned int safe_system_level = 0;
- static struct sigaction safe_system_prev_handler;
- void ast_replace_sigchld(void)
- {
- unsigned int level;
- ast_mutex_lock(&safe_system_lock);
- level = safe_system_level++;
- /* only replace the handler if it has not already been done */
- if (level == 0) {
- sigaction(SIGCHLD, &null_sig_handler, &safe_system_prev_handler);
- }
- ast_mutex_unlock(&safe_system_lock);
- }
- void ast_unreplace_sigchld(void)
- {
- unsigned int level;
- ast_mutex_lock(&safe_system_lock);
- level = --safe_system_level;
- /* only restore the handler if we are the last one */
- if (level == 0) {
- sigaction(SIGCHLD, &safe_system_prev_handler, NULL);
- }
- ast_mutex_unlock(&safe_system_lock);
- }
- /*! \brief fork and perform other preparations for spawning applications */
- static pid_t safe_exec_prep(int dualfork)
- {
- pid_t pid;
- #if defined(HAVE_WORKING_FORK) || defined(HAVE_WORKING_VFORK)
- ast_replace_sigchld();
- #ifdef HAVE_WORKING_FORK
- pid = fork();
- #else
- pid = vfork();
- #endif
- if (pid == 0) {
- #ifdef HAVE_CAP
- cap_set_proc(child_cap);
- #endif
- #ifdef HAVE_WORKING_FORK
- if (ast_opt_high_priority) {
- ast_set_priority(0);
- }
- /* Close file descriptors and launch system command */
- ast_close_fds_above_n(STDERR_FILENO);
- #endif
- if (dualfork) {
- #ifdef HAVE_WORKING_FORK
- pid = fork();
- #else
- pid = vfork();
- #endif
- if (pid < 0) {
- /* Second fork failed. */
- /* No logger available. */
- _exit(1);
- }
- if (pid > 0) {
- /* This is the first fork, exit so the reaper finishes right away. */
- _exit(0);
- }
- /* This is the second fork. The first fork will exit immediately so
- * Asterisk doesn't have to wait for completion.
- * ast_safe_system("cmd &") would run in the background, but the '&'
- * cannot be added with ast_safe_execvp, so we have to double fork.
- */
- }
- }
- if (pid < 0) {
- ast_log(LOG_WARNING, "Fork failed: %s\n", strerror(errno));
- }
- #else
- ast_log(LOG_WARNING, "Fork failed: %s\n", strerror(ENOTSUP));
- pid = -1;
- #endif
- return pid;
- }
- /*! \brief wait for spawned application to complete and unreplace sigchld */
- static int safe_exec_wait(pid_t pid)
- {
- int res = -1;
- #if defined(HAVE_WORKING_FORK) || defined(HAVE_WORKING_VFORK)
- if (pid > 0) {
- for (;;) {
- int status;
- res = waitpid(pid, &status, 0);
- if (res > -1) {
- res = WIFEXITED(status) ? WEXITSTATUS(status) : -1;
- break;
- }
- if (errno != EINTR) {
- break;
- }
- }
- }
- ast_unreplace_sigchld();
- #endif
- return res;
- }
- int ast_safe_execvp(int dualfork, const char *file, char *const argv[])
- {
- pid_t pid = safe_exec_prep(dualfork);
- if (pid == 0) {
- execvp(file, argv);
- _exit(1);
- /* noreturn from _exit */
- }
- return safe_exec_wait(pid);
- }
- int ast_safe_system(const char *s)
- {
- pid_t pid = safe_exec_prep(0);
- if (pid == 0) {
- execl("/bin/sh", "/bin/sh", "-c", s, (char *) NULL);
- _exit(1);
- /* noreturn from _exit */
- }
- return safe_exec_wait(pid);
- }
- /*!
- * \brief enable or disable a logging level to a specified console
- */
- void ast_console_toggle_loglevel(int fd, int level, int state)
- {
- int x;
- if (level >= NUMLOGLEVELS) {
- level = NUMLOGLEVELS - 1;
- }
- for (x = 0;x < AST_MAX_CONNECTS; x++) {
- if (fd == consoles[x].fd) {
- /*
- * Since the logging occurs when levels are false, set to
- * flipped iinput because this function accepts 0 as off and 1 as on
- */
- consoles[x].levels[level] = state ? 0 : 1;
- return;
- }
- }
- }
- /*!
- * \brief mute or unmute a console from logging
- */
- void ast_console_toggle_mute(int fd, int silent)
- {
- int x;
- for (x = 0;x < AST_MAX_CONNECTS; x++) {
- if (fd == consoles[x].fd) {
- if (consoles[x].mute) {
- consoles[x].mute = 0;
- if (!silent)
- ast_cli(fd, "Console is not muted anymore.\n");
- } else {
- consoles[x].mute = 1;
- if (!silent)
- ast_cli(fd, "Console is muted.\n");
- }
- return;
- }
- }
- ast_cli(fd, "Couldn't find remote console.\n");
- }
- /*!
- * \brief log the string to all attached network console clients
- */
- static void ast_network_puts_mutable(const char *string, int level, int sublevel)
- {
- int x;
- for (x = 0; x < AST_MAX_CONNECTS; ++x) {
- if (consoles[x].fd < 0
- || consoles[x].mute
- || consoles[x].levels[level]
- || (level == __LOG_VERBOSE && consoles[x].option_verbose < sublevel)) {
- continue;
- }
- fdprint(consoles[x].p[1], string);
- }
- }
- /*!
- * \brief log the string to the root console, and all attached
- * network console clients
- */
- void ast_console_puts_mutable(const char *string, int level)
- {
- ast_console_puts_mutable_full(string, level, 0);
- }
- static int console_print(const char *s);
- void ast_console_puts_mutable_full(const char *message, int level, int sublevel)
- {
- /* Send to the root console */
- console_print(message);
- /* Wake up a poll()ing console */
- if (ast_opt_console && consolethread != AST_PTHREADT_NULL) {
- pthread_kill(consolethread, SIGURG);
- }
- /* Send to any network console clients */
- ast_network_puts_mutable(message, level, sublevel);
- }
- /*!
- * \brief write the string to all attached console clients
- */
- static void ast_network_puts(const char *string)
- {
- int x;
- for (x = 0; x < AST_MAX_CONNECTS; ++x) {
- if (consoles[x].fd < 0) {
- continue;
- }
- fdprint(consoles[x].p[1], string);
- }
- }
- /*!
- * \brief write the string to the root console, and all attached
- * network console clients
- */
- void ast_console_puts(const char *string)
- {
- /* Send to the root console */
- fputs(string, stdout);
- fflush(stdout);
- /* Send to any network console clients */
- ast_network_puts(string);
- }
- static pthread_t lthread;
- /*!
- * \brief read() function supporting the reception of user credentials.
- *
- * \param fd Socket file descriptor.
- * \param buffer Receive buffer.
- * \param size 'buffer' size.
- * \param con Console structure to set received credentials
- * \retval -1 on error
- * \retval the number of bytes received on success.
- */
- static int read_credentials(int fd, char *buffer, size_t size, struct console *con)
- {
- #if defined(SO_PEERCRED)
- #ifdef HAVE_STRUCT_SOCKPEERCRED_UID
- #define HAVE_STRUCT_UCRED_UID
- struct sockpeercred cred;
- #else
- struct ucred cred;
- #endif
- socklen_t len = sizeof(cred);
- #endif
- #if defined(HAVE_GETPEEREID)
- uid_t uid;
- gid_t gid;
- #else
- int uid, gid;
- #endif
- int result;
- result = read(fd, buffer, size);
- if (result < 0) {
- return result;
- }
- #if defined(SO_PEERCRED) && (defined(HAVE_STRUCT_UCRED_UID) || defined(HAVE_STRUCT_UCRED_CR_UID))
- if (getsockopt(fd, SOL_SOCKET, SO_PEERCRED, &cred, &len)) {
- return result;
- }
- #if defined(HAVE_STRUCT_UCRED_UID)
- uid = cred.uid;
- gid = cred.gid;
- #else /* defined(HAVE_STRUCT_UCRED_CR_UID) */
- uid = cred.cr_uid;
- gid = cred.cr_gid;
- #endif /* defined(HAVE_STRUCT_UCRED_UID) */
- #elif defined(HAVE_GETPEEREID)
- if (getpeereid(fd, &uid, &gid)) {
- return result;
- }
- #else
- return result;
- #endif
- con->uid = uid;
- con->gid = gid;
- return result;
- }
- /* This is the thread running the remote console on the main process. */
- static void *netconsole(void *vconsole)
- {
- struct console *con = vconsole;
- char hostname[MAXHOSTNAMELEN] = "";
- char inbuf[512];
- char outbuf[512];
- const char * const end_buf = inbuf + sizeof(inbuf);
- char *start_read = inbuf;
- int res;
- struct pollfd fds[2];
- if (gethostname(hostname, sizeof(hostname)-1))
- ast_copy_string(hostname, "<Unknown>", sizeof(hostname));
- snprintf(outbuf, sizeof(outbuf), "%s/%ld/%s\n", hostname, (long)ast_mainpid, ast_get_version());
- fdprint(con->fd, outbuf);
- ast_verb_console_register(&con->option_verbose);
- for (;;) {
- fds[0].fd = con->fd;
- fds[0].events = POLLIN;
- fds[0].revents = 0;
- fds[1].fd = con->p[0];
- fds[1].events = POLLIN;
- fds[1].revents = 0;
- res = ast_poll(fds, 2, -1);
- if (res < 0) {
- if (errno != EINTR)
- ast_log(LOG_WARNING, "poll returned < 0: %s\n", strerror(errno));
- continue;
- }
- if (fds[0].revents) {
- int cmds_read, bytes_read;
- if ((bytes_read = read_credentials(con->fd, start_read, end_buf - start_read, con)) < 1) {
- break;
- }
- /* XXX This will only work if it is the first command, and I'm not sure fixing it is worth the effort. */
- if (strncmp(inbuf, "cli quit after ", 15) == 0) {
- ast_cli_command_multiple_full(con->uid, con->gid, con->fd, bytes_read - 15, inbuf + 15);
- break;
- }
- /* ast_cli_command_multiple_full will only process individual commands terminated by a
- * NULL and not trailing partial commands. */
- if (!(cmds_read = ast_cli_command_multiple_full(con->uid, con->gid, con->fd, bytes_read + start_read - inbuf, inbuf))) {
- /* No commands were read. We either have a short read on the first command
- * with space left, or a command that is too long */
- if (start_read + bytes_read < end_buf) {
- start_read += bytes_read;
- } else {
- ast_log(LOG_ERROR, "Command too long! Skipping\n");
- start_read = inbuf;
- }
- continue;
- }
- if (start_read[bytes_read - 1] == '\0') {
- /* The read ended on a command boundary, start reading again at the head of inbuf */
- start_read = inbuf;
- continue;
- }
- /* If we get this far, we have left over characters that have not been processed.
- * Advance to the character after the last command read by ast_cli_command_multiple_full.
- * We are guaranteed to have at least cmds_read NULLs */
- while (cmds_read-- && (start_read = strchr(start_read, '\0'))) {
- start_read++;
- }
- memmove(inbuf, start_read, end_buf - start_read);
- start_read = end_buf - start_read + inbuf;
- }
- if (fds[1].revents) {
- res = read_credentials(con->p[0], outbuf, sizeof(outbuf), con);
- if (res < 1) {
- ast_log(LOG_ERROR, "read returned %d\n", res);
- break;
- }
- res = write(con->fd, outbuf, res);
- if (res < 1)
- break;
- }
- }
- ast_verb_console_unregister();
- if (!ast_opt_hide_connect) {
- ast_verb(3, "Remote UNIX connection disconnected\n");
- }
- close(con->fd);
- close(con->p[0]);
- close(con->p[1]);
- con->fd = -1;
- return NULL;
- }
- static void *listener(void *unused)
- {
- struct sockaddr_un sunaddr;
- int s;
- socklen_t len;
- int x;
- int poll_result;
- struct pollfd fds[1];
- for (;;) {
- if (ast_socket < 0) {
- return NULL;
- }
- fds[0].fd = ast_socket;
- fds[0].events = POLLIN;
- poll_result = ast_poll(fds, 1, -1);
- pthread_testcancel();
- if (poll_result < 0) {
- if (errno != EINTR) {
- ast_log(LOG_WARNING, "poll returned error: %s\n", strerror(errno));
- }
- continue;
- }
- len = sizeof(sunaddr);
- s = accept(ast_socket, (struct sockaddr *)&sunaddr, &len);
- if (s < 0) {
- if (errno != EINTR)
- ast_log(LOG_WARNING, "Accept returned %d: %s\n", s, strerror(errno));
- } else {
- #if defined(SO_PASSCRED)
- int sckopt = 1;
- /* turn on socket credentials passing. */
- if (setsockopt(s, SOL_SOCKET, SO_PASSCRED, &sckopt, sizeof(sckopt)) < 0) {
- ast_log(LOG_WARNING, "Unable to turn on socket credentials passing\n");
- close(s);
- } else
- #endif
- {
- for (x = 0; x < AST_MAX_CONNECTS; x++) {
- if (consoles[x].fd >= 0) {
- continue;
- }
- if (socketpair(AF_LOCAL, SOCK_STREAM, 0, consoles[x].p)) {
- ast_log(LOG_ERROR, "Unable to create pipe: %s\n", strerror(errno));
- fdprint(s, "Server failed to create pipe\n");
- close(s);
- break;
- }
- ast_fd_set_flags(consoles[x].p[1], O_NONBLOCK);
- consoles[x].mute = 1; /* Default is muted, we will un-mute if necessary */
- /* Default uid and gid to -2, so then in cli.c/cli_has_permissions() we will be able
- to know if the user didn't send the credentials. */
- consoles[x].uid = -2;
- consoles[x].gid = -2;
- /* Server default of remote console verbosity level is OFF. */
- consoles[x].option_verbose = 0;
- consoles[x].fd = s;
- if (ast_pthread_create_detached_background(&consoles[x].t, NULL, netconsole, &consoles[x])) {
- consoles[x].fd = -1;
- ast_log(LOG_ERROR, "Unable to spawn thread to handle connection: %s\n", strerror(errno));
- close(consoles[x].p[0]);
- close(consoles[x].p[1]);
- fdprint(s, "Server failed to spawn thread\n");
- close(s);
- }
- break;
- }
- if (x >= AST_MAX_CONNECTS) {
- fdprint(s, "No more connections allowed\n");
- ast_log(LOG_WARNING, "No more connections allowed\n");
- close(s);
- } else if ((consoles[x].fd > -1) && (!ast_opt_hide_connect)) {
- ast_verb(3, "Remote UNIX connection\n");
- }
- }
- }
- }
- return NULL;
- }
- static int ast_makesocket(void)
- {
- struct sockaddr_un sunaddr;
- int res;
- int x;
- uid_t uid = -1;
- gid_t gid = -1;
- for (x = 0; x < AST_MAX_CONNECTS; x++) {
- consoles[x].fd = -1;
- }
- if (ast_socket_is_sd) {
- ast_socket = ast_sd_get_fd_un(SOCK_STREAM, ast_config_AST_SOCKET);
- goto start_lthread;
- }
- unlink(ast_config_AST_SOCKET);
- ast_socket = socket(PF_LOCAL, SOCK_STREAM, 0);
- if (ast_socket < 0) {
- ast_log(LOG_WARNING, "Unable to create control socket: %s\n", strerror(errno));
- return -1;
- }
- memset(&sunaddr, 0, sizeof(sunaddr));
- sunaddr.sun_family = AF_LOCAL;
- ast_copy_string(sunaddr.sun_path, ast_config_AST_SOCKET, sizeof(sunaddr.sun_path));
- res = bind(ast_socket, (struct sockaddr *)&sunaddr, sizeof(sunaddr));
- if (res) {
- ast_log(LOG_WARNING, "Unable to bind socket to %s: %s\n", ast_config_AST_SOCKET, strerror(errno));
- close(ast_socket);
- ast_socket = -1;
- return -1;
- }
- res = listen(ast_socket, 2);
- if (res < 0) {
- ast_log(LOG_WARNING, "Unable to listen on socket %s: %s\n", ast_config_AST_SOCKET, strerror(errno));
- close(ast_socket);
- ast_socket = -1;
- return -1;
- }
- start_lthread:
- if (ast_pthread_create_background(<hread, NULL, listener, NULL)) {
- ast_log(LOG_WARNING, "Unable to create listener thread.\n");
- close(ast_socket);
- return -1;
- }
- if (ast_socket_is_sd) {
- /* owner/group/permissions are set by systemd, we might not even have access
- * to socket file so leave it alone */
- return 0;
- }
- if (!ast_strlen_zero(ast_config_AST_CTL_OWNER)) {
- struct passwd *pw;
- if ((pw = getpwnam(ast_config_AST_CTL_OWNER)) == NULL)
- ast_log(LOG_WARNING, "Unable to find uid of user %s\n", ast_config_AST_CTL_OWNER);
- else
- uid = pw->pw_uid;
- }
- if (!ast_strlen_zero(ast_config_AST_CTL_GROUP)) {
- struct group *grp;
- if ((grp = getgrnam(ast_config_AST_CTL_GROUP)) == NULL)
- ast_log(LOG_WARNING, "Unable to find gid of group %s\n", ast_config_AST_CTL_GROUP);
- else
- gid = grp->gr_gid;
- }
- if (chown(ast_config_AST_SOCKET, uid, gid) < 0)
- ast_log(LOG_WARNING, "Unable to change ownership of %s: %s\n", ast_config_AST_SOCKET, strerror(errno));
- if (!ast_strlen_zero(ast_config_AST_CTL_PERMISSIONS)) {
- unsigned int p1;
- mode_t p;
- sscanf(ast_config_AST_CTL_PERMISSIONS, "%30o", &p1);
- p = p1;
- if ((chmod(ast_config_AST_SOCKET, p)) < 0)
- ast_log(LOG_WARNING, "Unable to change file permissions of %s: %s\n", ast_config_AST_SOCKET, strerror(errno));
- }
- return 0;
- }
- static int ast_tryconnect(void)
- {
- struct sockaddr_un sunaddr;
- int res;
- ast_consock = socket(PF_LOCAL, SOCK_STREAM, 0);
- if (ast_consock < 0) {
- fprintf(stderr, "Unable to create socket: %s\n", strerror(errno));
- return 0;
- }
- memset(&sunaddr, 0, sizeof(sunaddr));
- sunaddr.sun_family = AF_LOCAL;
- ast_copy_string(sunaddr.sun_path, ast_config_AST_SOCKET, sizeof(sunaddr.sun_path));
- res = connect(ast_consock, (struct sockaddr *)&sunaddr, sizeof(sunaddr));
- if (res) {
- close(ast_consock);
- ast_consock = -1;
- return 0;
- } else
- return 1;
- }
- /*! \brief Urgent handler
- *
- * Called by soft_hangup to interrupt the poll, read, or other
- * system call. We don't actually need to do anything though.
- * Remember: Cannot EVER ast_log from within a signal handler
- */
- static void _urg_handler(int num)
- {
- return;
- }
- static struct sigaction urg_handler = {
- .sa_handler = _urg_handler,
- };
- static void _hup_handler(int num)
- {
- int save_errno = errno;
- if (restartnow) {
- if (el) {
- el_end(el);
- }
- execvp(_argv[0], _argv);
- }
- printf("Received HUP signal -- Reloading configs\n");
- sig_flags.need_reload = 1;
- if (ast_alertpipe_write(sig_alert_pipe)) {
- fprintf(stderr, "hup_handler: write() failed: %s\n", strerror(errno));
- }
- errno = save_errno;
- }
- static struct sigaction hup_handler = {
- .sa_handler = _hup_handler,
- .sa_flags = SA_RESTART,
- };
- static void _child_handler(int sig)
- {
- /* Must not ever ast_log or ast_verbose within signal handler */
- int n, status, save_errno = errno;
- /*
- * Reap all dead children -- not just one
- */
- for (n = 0; waitpid(-1, &status, WNOHANG) > 0; n++)
- ;
- if (n == 0 && option_debug)
- printf("Huh? Child handler, but nobody there?\n");
- errno = save_errno;
- }
- static struct sigaction child_handler = {
- .sa_handler = _child_handler,
- .sa_flags = SA_RESTART,
- };
- /*! \brief Set an X-term or screen title */
- static void set_title(char *text)
- {
- if (getenv("TERM") && strstr(getenv("TERM"), "xterm"))
- fprintf(stdout, "\033]2;%s\007", text);
- }
- static void set_icon(char *text)
- {
- if (getenv("TERM") && strstr(getenv("TERM"), "xterm"))
- fprintf(stdout, "\033]1;%s\007", text);
- }
- /*! \brief Check whether we were set to high(er) priority. */
- static int has_priority(void)
- {
- /* Neither of these calls should fail with these arguments. */
- #ifdef __linux__
- /* For SCHED_OTHER, SCHED_BATCH and SCHED_IDLE, this will return
- * 0. For the realtime priorities SCHED_RR and SCHED_FIFO, it
- * will return something >= 1. */
- return sched_getscheduler(0);
- #else
- /* getpriority() can return a value in -20..19 (or even -INF..20)
- * where negative numbers are high priority. We don't bother
- * checking errno. If the query fails and it returns -1, we'll
- * assume that we're running at high prio; a safe assumption
- * that will enable the resource starvation monitor (canary)
- * just in case. */
- return (getpriority(PRIO_PROCESS, 0) < 0);
- #endif
- }
- /*! \brief Set priority on all known threads. */
- static int set_priority_all(int pri)
- {
- #if !defined(__linux__)
- /* The non-linux version updates the entire process prio. */
- return ast_set_priority(pri);
- #elif defined(LOW_MEMORY)
- ast_log(LOG_WARNING, "Unable to enumerate all threads to update priority\n");
- return ast_set_priority(pri);
- #else
- struct thread_list_t *cur;
- struct sched_param sched;
- char const *policy_str;
- int policy;
- memset(&sched, 0, sizeof(sched));
- if (pri) {
- policy = SCHED_RR;
- policy_str = "realtime";
- sched.sched_priority = 10;
- } else {
- policy = SCHED_OTHER;
- policy_str = "regular";
- sched.sched_priority = 0;
- }
- if (sched_setscheduler(getpid(), policy, &sched)) {
- ast_log(LOG_WARNING, "Unable to set %s thread priority on main thread\n", policy_str);
- return -1;
- }
- ast_verb(1, "Setting %s thread priority on all threads\n", policy_str);
- AST_RWLIST_RDLOCK(&thread_list);
- AST_RWLIST_TRAVERSE(&thread_list, cur, list) {
- /* Don't care about the return value. It should work. */
- sched_setscheduler(cur->lwp, policy, &sched);
- }
- AST_RWLIST_UNLOCK(&thread_list);
- return 0;
- #endif
- }
- /*! \brief We set ourselves to a high priority, that we might pre-empt
- * everything else. If your PBX has heavy activity on it, this is a
- * good thing.
- */
- int ast_set_priority(int pri)
- {
- struct sched_param sched;
- memset(&sched, 0, sizeof(sched));
- #ifdef __linux__
- if (pri) {
- sched.sched_priority = 10;
- if (sched_setscheduler(0, SCHED_RR, &sched)) {
- return -1;
- }
- } else {
- sched.sched_priority = 0;
- /* According to the manpage, these parameters can never fail. */
- sched_setscheduler(0, SCHED_OTHER, &sched);
- }
- #else
- if (pri) {
- if (setpriority(PRIO_PROCESS, 0, -10) == -1) {
- ast_log(LOG_WARNING, "Unable to set high priority\n");
- return -1;
- } else
- ast_verb(1, "Set to high priority\n");
- } else {
- /* According to the manpage, these parameters can never fail. */
- setpriority(PRIO_PROCESS, 0, 0);
- }
- #endif
- return 0;
- }
- int ast_shutdown_final(void)
- {
- return shuttingdown == SHUTTING_DOWN_FINAL;
- }
- int ast_shutting_down(void)
- {
- return shutdown_pending;
- }
- int ast_cancel_shutdown(void)
- {
- int shutdown_aborted = 0;
- ast_mutex_lock(&safe_system_lock);
- if (shuttingdown >= SHUTDOWN_FAST) {
- shuttingdown = NOT_SHUTTING_DOWN;
- shutdown_pending = 0;
- shutdown_aborted = 1;
- }
- ast_mutex_unlock(&safe_system_lock);
- return shutdown_aborted;
- }
- /*!
- * \internal
- * \brief Initiate system shutdown -- prevents new channels from being allocated.
- */
- static void ast_begin_shutdown(void)
- {
- ast_mutex_lock(&safe_system_lock);
- if (shuttingdown != NOT_SHUTTING_DOWN) {
- shutdown_pending = 1;
- }
- ast_mutex_unlock(&safe_system_lock);
- }
- static int can_safely_quit(shutdown_nice_t niceness, int restart);
- static void really_quit(int num, shutdown_nice_t niceness, int restart);
- static void quit_handler(int num, shutdown_nice_t niceness, int restart)
- {
- if (can_safely_quit(niceness, restart)) {
- really_quit(num, niceness, restart);
- /* No one gets here. */
- }
- /* It wasn't our time. */
- }
- #define SHUTDOWN_TIMEOUT 15 /* Seconds */
- /*!
- * \internal
- * \brief Wait for all channels to die, a timeout, or shutdown cancelled.
- * \since 13.3.0
- *
- * \param niceness Shutdown niceness in effect
- * \param seconds Number of seconds to wait or less than zero if indefinitely.
- *
- * \retval zero if waiting wasn't necessary. We were idle.
- * \retval non-zero if we had to wait.
- */
- static int wait_for_channels_to_die(shutdown_nice_t niceness, int seconds)
- {
- time_t start;
- time_t now;
- int waited = 0;
- time(&start);
- for (;;) {
- if (!ast_undestroyed_channels() || shuttingdown != niceness) {
- break;
- }
- if (seconds < 0) {
- /* No timeout so just poll every second */
- sleep(1);
- } else {
- time(&now);
- /* Wait up to the given seconds for all channels to go away */
- if (seconds < (now - start)) {
- break;
- }
- /* Sleep 1/10 of a second */
- usleep(100000);
- }
- waited = 1;
- }
- return waited;
- }
- static int can_safely_quit(shutdown_nice_t niceness, int restart)
- {
- int waited = 0;
- /* Check if someone else isn't already doing this. */
- ast_mutex_lock(&safe_system_lock);
- if (shuttingdown != NOT_SHUTTING_DOWN && niceness >= shuttingdown) {
- /* Already in progress and other request was less nice. */
- ast_mutex_unlock(&safe_system_lock);
- ast_verbose("Ignoring asterisk %s request, already in progress.\n", restart ? "restart" : "shutdown");
- return 0;
- }
- shuttingdown = niceness;
- ast_mutex_unlock(&safe_system_lock);
- /* Try to get as many CDRs as possible submitted to the backend engines
- * (if in batch mode). really_quit happens to call it again when running
- * the atexit handlers, otherwise this would be a bit early. */
- ast_cdr_engine_term();
- /*
- * Shutdown the message queue for the technology agnostic message channel.
- * This has to occur before we pause shutdown pending ast_undestroyed_channels.
- *
- * XXX This is not reversed on shutdown cancel.
- */
- ast_msg_shutdown();
- if (niceness == SHUTDOWN_NORMAL) {
- /* Begin shutdown routine, hanging up active channels */
- ast_begin_shutdown();
- if (ast_opt_console) {
- ast_verb(0, "Beginning asterisk %s....\n", restart ? "restart" : "shutdown");
- }
- ast_softhangup_all();
- waited |= wait_for_channels_to_die(niceness, SHUTDOWN_TIMEOUT);
- } else if (niceness >= SHUTDOWN_NICE) {
- if (niceness != SHUTDOWN_REALLY_NICE) {
- ast_begin_shutdown();
- }
- if (ast_opt_console) {
- ast_verb(0, "Waiting for inactivity to perform %s...\n", restart ? "restart" : "halt");
- }
- waited |= wait_for_channels_to_die(niceness, -1);
- }
- /* Re-acquire lock and check if someone changed the niceness, in which
- * case someone else has taken over the shutdown.
- */
- ast_mutex_lock(&safe_system_lock);
- if (shuttingdown != niceness) {
- if (shuttingdown == NOT_SHUTTING_DOWN && ast_opt_console) {
- ast_verb(0, "Asterisk %s cancelled.\n", restart ? "restart" : "shutdown");
- }
- ast_mutex_unlock(&safe_system_lock);
- return 0;
- }
- if (niceness >= SHUTDOWN_REALLY_NICE) {
- shuttingdown = SHUTTING_DOWN;
- ast_mutex_unlock(&safe_system_lock);
- /* No more Mr. Nice guy. We are committed to shutting down now. */
- ast_begin_shutdown();
- ast_softhangup_all();
- waited |= wait_for_channels_to_die(SHUTTING_DOWN, SHUTDOWN_TIMEOUT);
- ast_mutex_lock(&safe_system_lock);
- }
- shuttingdown = SHUTTING_DOWN_FINAL;
- ast_mutex_unlock(&safe_system_lock);
- if (niceness >= SHUTDOWN_NORMAL && waited) {
- /*
- * We were not idle. Give things in progress a chance to
- * recognize the final shutdown phase.
- */
- sleep(1);
- }
- return 1;
- }
- /*! Called when exiting is certain. */
- static void really_quit(int num, shutdown_nice_t niceness, int restart)
- {
- int active_channels;
- struct ast_json *json_object = NULL;
- int run_cleanups = niceness >= SHUTDOWN_NICE;
- if (run_cleanups && modules_shutdown()) {
- ast_verb(0, "Some modules could not be unloaded, switching to fast shutdown\n");
- run_cleanups = 0;
- }
- if (!restart && !ast_opt_remote) {
- ast_sd_notify("STOPPING=1");
- }
- if (ast_opt_console || (ast_opt_remote && !ast_opt_exec)) {
- ast_el_write_default_histfile();
- if (consolethread == AST_PTHREADT_NULL || consolethread == pthread_self()) {
- /* Only end if we are the consolethread, otherwise there's a race with that thread. */
- if (el != NULL) {
- el_end(el);
- }
- if (el_hist != NULL) {
- history_end(el_hist);
- }
- } else if (!restart) {
- sig_flags.need_el_end = 1;
- pthread_kill(consolethread, SIGURG);
- }
- }
- active_channels = ast_active_channels();
- /* Don't publish messages if we're a remote console - we won't have all of the Stasis
- * topics or message types
- */
- if (!ast_opt_remote) {
- json_object = ast_json_pack("{s: s, s: s}",
- "Shutdown", active_channels ? "Uncleanly" : "Cleanly",
- "Restart", restart ? "True" : "False");
- ast_manager_publish_event("Shutdown", EVENT_FLAG_SYSTEM, json_object);
- ast_json_unref(json_object);
- json_object = NULL;
- }
- ast_verb(0, "Asterisk %s ending (%d).\n",
- active_channels ? "uncleanly" : "cleanly", num);
- ast_verb(0, "Executing last minute cleanups\n");
- ast_run_atexits(run_cleanups);
- ast_debug(1, "Asterisk ending (%d).\n", num);
- if (ast_socket > -1) {
- pthread_cancel(lthread);
- close(ast_socket);
- ast_socket = -1;
- if (!ast_socket_is_sd) {
- unlink(ast_config_AST_SOCKET);
- }
- pthread_kill(lthread, SIGURG);
- pthread_join(lthread, NULL);
- }
- if (ast_consock > -1)
- close(ast_consock);
- if (!ast_opt_remote)
- unlink(ast_config_AST_PID);
- ast_alertpipe_close(sig_alert_pipe);
- printf("%s", term_quit());
- if (restart) {
- int i;
- ast_verb(0, "Preparing for Asterisk restart...\n");
- /* Mark all FD's for closing on exec */
- for (i = 3; i < 32768; i++) {
- fcntl(i, F_SETFD, FD_CLOEXEC);
- }
- ast_verb(0, "Asterisk is now restarting...\n");
- restartnow = 1;
- /* close logger */
- close_logger();
- clean_time_zones();
- /* If there is a consolethread running send it a SIGHUP
- so it can execvp, otherwise we can do it ourselves */
- if ((consolethread != AST_PTHREADT_NULL) && (consolethread != pthread_self())) {
- pthread_kill(consolethread, SIGHUP);
- /* Give the signal handler some time to complete */
- sleep(2);
- } else
- execvp(_argv[0], _argv);
- } else {
- /* close logger */
- close_logger();
- clean_time_zones();
- }
- exit(0);
- }
- static void __quit_handler(int num)
- {
- sig_flags.need_quit = 1;
- if (ast_alertpipe_write(sig_alert_pipe)) {
- fprintf(stderr, "quit_handler: write() failed: %s\n", strerror(errno));
- }
- /* There is no need to restore the signal handler here, since the app
- * is going to exit */
- }
- static void __remote_quit_handler(int num)
- {
- sig_flags.need_quit = 1;
- }
- static void set_header(char *outbuf, int maxout, char level)
- {
- const char *cmp;
- char date[40];
- switch (level) {
- case 0: cmp = NULL;
- break;
- case 1: cmp = VERBOSE_PREFIX_1;
- break;
- case 2: cmp = VERBOSE_PREFIX_2;
- break;
- case 3: cmp = VERBOSE_PREFIX_3;
- break;
- case 4: cmp = VERBOSE_PREFIX_4;
- break;
- case 5: cmp = VERBOSE_PREFIX_5;
- break;
- case 6: cmp = VERBOSE_PREFIX_6;
- break;
- case 7: cmp = VERBOSE_PREFIX_7;
- break;
- case 8: cmp = VERBOSE_PREFIX_8;
- break;
- case 9: cmp = VERBOSE_PREFIX_9;
- break;
- default: cmp = VERBOSE_PREFIX_10;
- break;
- }
- if (ast_opt_timestamp) {
- struct ast_tm tm;
- struct timeval now = ast_tvnow();
- ast_localtime(&now, &tm, NULL);
- ast_strftime(date, sizeof(date), ast_logger_get_dateformat(), &tm);
- }
- snprintf(outbuf, maxout, "%s%s%s%s%s%s",
- ast_opt_timestamp ? "[" : "",
- ast_opt_timestamp ? date : "",
- ast_opt_timestamp ? "] " : "",
- cmp ? ast_term_color(COLOR_GRAY, 0) : "",
- cmp ? cmp : "",
- cmp ? ast_term_reset() : "");
- }
- struct console_state_data {
- char verbose_line_level;
- };
- static int console_state_init(void *ptr)
- {
- struct console_state_data *state = ptr;
- state->verbose_line_level = 0;
- return 0;
- }
- AST_THREADSTORAGE_CUSTOM(console_state, console_state_init, ast_free_ptr);
- static int console_print(const char *s)
- {
- struct console_state_data *state =
- ast_threadstorage_get(&console_state, sizeof(*state));
- char prefix[80];
- const char *c;
- int num, res = 0;
- unsigned int newline;
- do {
- if (VERBOSE_HASMAGIC(s)) {
- /* always use the given line's level, otherwise
- we'll use the last line's level */
- state->verbose_line_level = VERBOSE_MAGIC2LEVEL(s);
- /* move past magic */
- s++;
- set_header(prefix, sizeof(prefix), state->verbose_line_level);
- } else {
- *prefix = '\0';
- }
- c = s;
- /* for a given line separate on verbose magic, newline, and eol */
- if ((s = strchr(c, '\n'))) {
- ++s;
- newline = 1;
- } else {
- s = strchr(c, '\0');
- newline = 0;
- }
- /* check if we should write this line after calculating begin/end
- so we process the case of a higher level line embedded within
- two lower level lines */
- if (state->verbose_line_level > option_verbose) {
- continue;
- }
- if (!ast_strlen_zero(prefix)) {
- fputs(prefix, stdout);
- }
- num = s - c;
- if (fwrite(c, sizeof(char), num, stdout) < num) {
- break;
- }
- if (!res) {
- /* if at least some info has been written
- we'll want to return true */
- res = 1;
- }
- } while (*s);
- if (newline) {
- /* if ending on a newline then reset last level to zero
- since what follows may be not be logging output */
- state->verbose_line_level = 0;
- }
- if (res) {
- fflush(stdout);
- }
- return res;
- }
- static int ast_all_zeros(const char *s)
- {
- while (*s) {
- if (*s > 32)
- return 0;
- s++;
- }
- return 1;
- }
- /* This is the main console CLI command handler. Run by the main() thread. */
- static void consolehandler(const char *s)
- {
- printf("%s", term_end());
- fflush(stdout);
- /* Called when readline data is available */
- if (!ast_all_zeros(s))
- ast_el_add_history(s);
- /* The real handler for bang */
- if (s[0] == '!') {
- if (s[1])
- ast_safe_system(s+1);
- else
- ast_safe_system(getenv("SHELL") ? getenv("SHELL") : "/bin/sh");
- } else
- ast_cli_command(STDOUT_FILENO, s);
- }
- static int remoteconsolehandler(const char *s)
- {
- int ret = 0;
- /* Called when readline data is available */
- if (!ast_all_zeros(s))
- ast_el_add_history(s);
- while (isspace(*s)) {
- s++;
- }
- /* The real handler for bang */
- if (s[0] == '!') {
- if (s[1])
- ast_safe_system(s+1);
- else
- ast_safe_system(getenv("SHELL") ? getenv("SHELL") : "/bin/sh");
- ret = 1;
- } else if ((strncasecmp(s, "quit", 4) == 0 || strncasecmp(s, "exit", 4) == 0) &&
- (s[4] == '\0' || isspace(s[4]))) {
- quit_handler(0, SHUTDOWN_FAST, 0);
- ret = 1;
- }
- return ret;
- }
- static char *handle_version(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core show version";
- e->usage =
- "Usage: core show version\n"
- " Shows Asterisk version information.\n";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != 3)
- return CLI_SHOWUSAGE;
- ast_cli(a->fd, "Asterisk %s built by %s @ %s on a %s running %s on %s\n",
- ast_get_version(), ast_build_user, ast_build_hostname,
- ast_build_machine, ast_build_os, ast_build_date);
- return CLI_SUCCESS;
- }
- static char *handle_stop_now(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core stop now";
- e->usage =
- "Usage: core stop now\n"
- " Shuts down a running Asterisk immediately, hanging up all active calls .\n";
- ast_cli_allow_at_shutdown(e);
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != e->args)
- return CLI_SHOWUSAGE;
- quit_handler(0, SHUTDOWN_NORMAL, 0 /* not restart */);
- return CLI_SUCCESS;
- }
- static char *handle_stop_gracefully(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core stop gracefully";
- e->usage =
- "Usage: core stop gracefully\n"
- " Causes Asterisk to not accept new calls, and exit when all\n"
- " active calls have terminated normally.\n";
- ast_cli_allow_at_shutdown(e);
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != e->args)
- return CLI_SHOWUSAGE;
- quit_handler(0, SHUTDOWN_NICE, 0 /* no restart */);
- return CLI_SUCCESS;
- }
- static char *handle_stop_when_convenient(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core stop when convenient";
- e->usage =
- "Usage: core stop when convenient\n"
- " Causes Asterisk to perform a shutdown when all active calls have ended.\n";
- ast_cli_allow_at_shutdown(e);
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != e->args)
- return CLI_SHOWUSAGE;
- ast_cli(a->fd, "Waiting for inactivity to perform halt\n");
- quit_handler(0, SHUTDOWN_REALLY_NICE, 0 /* don't restart */);
- return CLI_SUCCESS;
- }
- static char *handle_restart_now(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core restart now";
- e->usage =
- "Usage: core restart now\n"
- " Causes Asterisk to hangup all calls and exec() itself performing a cold\n"
- " restart.\n";
- ast_cli_allow_at_shutdown(e);
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != e->args)
- return CLI_SHOWUSAGE;
- quit_handler(0, SHUTDOWN_NORMAL, 1 /* restart */);
- return CLI_SUCCESS;
- }
- static char *handle_restart_gracefully(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core restart gracefully";
- e->usage =
- "Usage: core restart gracefully\n"
- " Causes Asterisk to stop accepting new calls and exec() itself performing a cold\n"
- " restart when all active calls have ended.\n";
- ast_cli_allow_at_shutdown(e);
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != e->args)
- return CLI_SHOWUSAGE;
- quit_handler(0, SHUTDOWN_NICE, 1 /* restart */);
- return CLI_SUCCESS;
- }
- static char *handle_restart_when_convenient(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core restart when convenient";
- e->usage =
- "Usage: core restart when convenient\n"
- " Causes Asterisk to perform a cold restart when all active calls have ended.\n";
- ast_cli_allow_at_shutdown(e);
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != e->args)
- return CLI_SHOWUSAGE;
- ast_cli(a->fd, "Waiting for inactivity to perform restart\n");
- quit_handler(0, SHUTDOWN_REALLY_NICE, 1 /* restart */);
- return CLI_SUCCESS;
- }
- static char *handle_abort_shutdown(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core abort shutdown";
- e->usage =
- "Usage: core abort shutdown\n"
- " Causes Asterisk to abort an executing shutdown or restart, and resume normal\n"
- " call operations.\n";
- ast_cli_allow_at_shutdown(e);
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- if (a->argc != e->args)
- return CLI_SHOWUSAGE;
- ast_cancel_shutdown();
- return CLI_SUCCESS;
- }
- static char *handle_bang(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "!";
- e->usage =
- "Usage: !<command>\n"
- " Executes a given shell command\n";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- return CLI_SUCCESS;
- }
- static const char warranty_lines[] = {
- "\n"
- " NO WARRANTY\n"
- "\n"
- "BECAUSE THE PROGRAM IS LICENSED FREE OF CHARGE, THERE IS NO WARRANTY\n"
- "FOR THE PROGRAM, TO THE EXTENT PERMITTED BY APPLICABLE LAW. EXCEPT WHEN\n"
- "OTHERWISE STATED IN WRITING THE COPYRIGHT HOLDERS AND/OR OTHER PARTIES\n"
- "PROVIDE THE PROGRAM \"AS IS\" WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED\n"
- "OR IMPLIED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF\n"
- "MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. THE ENTIRE RISK AS\n"
- "TO THE QUALITY AND PERFORMANCE OF THE PROGRAM IS WITH YOU. SHOULD THE\n"
- "PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF ALL NECESSARY SERVICING,\n"
- "REPAIR OR CORRECTION.\n"
- "\n"
- "IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING\n"
- "WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MAY MODIFY AND/OR\n"
- "REDISTRIBUTE THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES,\n"
- "INCLUDING ANY GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING\n"
- "OUT OF THE USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED\n"
- "TO LOSS OF DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY\n"
- "YOU OR THIRD PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER\n"
- "PROGRAMS), EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE\n"
- "POSSIBILITY OF SUCH DAMAGES.\n"
- };
- static char *show_warranty(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core show warranty";
- e->usage =
- "Usage: core show warranty\n"
- " Shows the warranty (if any) for this copy of Asterisk.\n";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- ast_cli(a->fd, "%s", warranty_lines);
- return CLI_SUCCESS;
- }
- static const char license_lines[] = {
- "\n"
- "This program is free software; you can redistribute it and/or modify\n"
- "it under the terms of the GNU General Public License version 2 as\n"
- "published by the Free Software Foundation.\n"
- "\n"
- "This program also contains components licensed under other licenses.\n"
- "They include:\n"
- "\n"
- "This program is distributed in the hope that it will be useful,\n"
- "but WITHOUT ANY WARRANTY; without even the implied warranty of\n"
- "MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the\n"
- "GNU General Public License for more details.\n"
- "\n"
- "You should have received a copy of the GNU General Public License\n"
- "along with this program; if not, write to the Free Software\n"
- "Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA\n"
- };
- static char *show_license(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
- {
- switch (cmd) {
- case CLI_INIT:
- e->command = "core show license";
- e->usage =
- "Usage: core show license\n"
- " Shows the license(s) for this copy of Asterisk.\n";
- return NULL;
- case CLI_GENERATE:
- return NULL;
- }
- ast_cli(a->fd, "%s", license_lines);
- return CLI_SUCCESS;
- }
- #define ASTERISK_PROMPT "*CLI> "
- /*!
- * \brief Shutdown Asterisk CLI commands.
- *
- * \note These CLI commands cannot be unregistered at shutdown
- * because one of them is likely the reason for the shutdown.
- * The CLI generates a warning if a command is in-use when it is
- * unregistered.
- */
- static struct ast_cli_entry cli_asterisk_shutdown[] = {
- AST_CLI_DEFINE(handle_stop_now, "Shut down Asterisk immediately"),
- AST_CLI_DEFINE(handle_stop_gracefully, "Gracefully shut down Asterisk"),
- AST_CLI_DEFINE(handle_stop_when_convenient, "Shut down Asterisk at empty call volume"),
- AST_CLI_DEFINE(handle_restart_now, "Restart Asterisk immediately"),
- AST_CLI_DEFINE(handle_restart_gracefully, "Restart Asterisk gracefully"),
- AST_CLI_DEFINE(handle_restart_when_convenient, "Restart Asterisk at empty call volume"),
- };
- static struct ast_cli_entry cli_asterisk[] = {
- AST_CLI_DEFINE(handle_abort_shutdown, "Cancel a running shutdown"),
- AST_CLI_DEFINE(show_warranty, "Show the warranty (if any) for this copy of Asterisk"),
- AST_CLI_DEFINE(show_license, "Show the license(s) for this copy of Asterisk"),
- AST_CLI_DEFINE(handle_version, "Display version info"),
- AST_CLI_DEFINE(handle_bang, "Execute a shell command"),
- #if !defined(LOW_MEMORY)
- AST_CLI_DEFINE(handle_show_threads, "Show running threads"),
- #if defined(HAVE_SYSINFO) || defined(HAVE_SYSCTL)
- AST_CLI_DEFINE(handle_show_sysinfo, "Show System Information"),
- #endif
- AST_CLI_DEFINE(handle_show_profile, "Display profiling info"),
- AST_CLI_DEFINE(handle_show_settings, "Show some core settings"),
- AST_CLI_DEFINE(handle_clear_profile, "Clear profiling info"),
- #endif /* ! LOW_MEMORY */
- };
- static void send_rasterisk_connect_commands(void)
- {
- char buf[80];
- /*
- * Tell the server asterisk instance about the verbose level
- * initially desired.
- */
- if (option_verbose) {
- snprintf(buf, sizeof(buf), "core set verbose atleast %d silent", option_verbose);
- fdsend(ast_consock, buf);
- }
- if (option_debug) {
- snprintf(buf, sizeof(buf), "core set debug atleast %d", option_debug);
- fdsend(ast_consock, buf);
- }
- /* Leave verbose filtering to the server. */
- option_verbose = INT_MAX;
- if (!ast_opt_mute) {
- fdsend(ast_consock, "logger mute silent");
- } else {
- printf("log and verbose output currently muted ('logger mute' to unmute)\n");
- }
- }
- #ifdef HAVE_LIBEDIT_IS_UNICODE
- #define CHAR_T_LIBEDIT wchar_t
- #define CHAR_TO_LIBEDIT(c) btowc(c)
- #else
- #define CHAR_T_LIBEDIT char
- #define CHAR_TO_LIBEDIT(c) c
- #endif
- static int ast_el_read_char(EditLine *editline, CHAR_T_LIBEDIT *cp)
- {
- int num_read = 0;
- int lastpos = 0;
- struct pollfd fds[2];
- int res;
- int max;
- #define EL_BUF_SIZE 512
- char buf[EL_BUF_SIZE];
- for (;;) {
- max = 1;
- fds[0].fd = ast_consock;
- fds[0].events = POLLIN;
- if (!ast_opt_exec) {
- fds[1].fd = STDIN_FILENO;
- fds[1].events = POLLIN;
- max++;
- }
- res = ast_poll(fds, max, -1);
- if (res < 0) {
- if (sig_flags.need_quit || sig_flags.need_quit_handler || sig_flags.need_el_end) {
- break;
- }
- if (errno == EINTR) {
- continue;
- }
- fprintf(stderr, "poll failed: %s\n", strerror(errno));
- break;
- }
- if (!ast_opt_exec && fds[1].revents) {
- char c = '\0';
- num_read = read(STDIN_FILENO, &c, 1);
- if (num_read < 1) {
- break;
- }
- *cp = CHAR_TO_LIBEDIT(c);
- return num_read;
- }
- if (fds[0].revents) {
- res = read(ast_consock, buf, sizeof(buf) - 1);
- /* if the remote side disappears exit */
- if (res < 1) {
- fprintf(stderr, "\nDisconnected from Asterisk server\n");
- if (!ast_opt_reconnect) {
- quit_handler(0, SHUTDOWN_FAST, 0);
- } else {
- int tries;
- int reconnects_per_second = 20;
- fprintf(stderr, "Attempting to reconnect for 30 seconds\n");
- for (tries = 0; tries < 30 * reconnects_per_second; tries++) {
- if (ast_tryconnect()) {
- fprintf(stderr, "Reconnect succeeded after %.3f seconds\n", 1.0 / reconnects_per_second * tries);
- printf("%s", term_quit());
- WELCOME_MESSAGE;
- send_rasterisk_connect_commands();
- break;
- }
- usleep(1000000 / reconnects_per_second);
- }
- if (tries >= 30 * reconnects_per_second) {
- fprintf(stderr, "Failed to reconnect for 30 seconds. Quitting.\n");
- quit_handler(0, SHUTDOWN_FAST, 0);
- }
- }
- continue;
- }
- buf[res] = '\0';
- /* Write over the CLI prompt */
- if (!ast_opt_exec && !lastpos) {
- if (write(STDOUT_FILENO, "\r[0K", 5) < 0) {
- }
- }
- console_print(buf);
- if ((res < EL_BUF_SIZE - 1) && ((buf[res-1] == '\n') || (res >= 2 && buf[res-2] == '\n'))) {
- *cp = CHAR_TO_LIBEDIT(CC_REFRESH);
- return 1;
- }
- lastpos = 1;
- }
- }
- *cp = CHAR_TO_LIBEDIT('\0');
- return 0;
- }
- static struct ast_str *prompt = NULL;
- static char *cli_prompt(EditLine *editline)
- {
- char tmp[100];
- char *pfmt;
- int color_used = 0;
- static int cli_prompt_changes = 0;
- struct passwd *pw;
- struct group *gr;
- if (prompt == NULL) {
- prompt = ast_str_create(100);
- } else if (!cli_prompt_changes) {
- return ast_str_buffer(prompt);
- } else {
- ast_str_reset(prompt);
- }
- if ((pfmt = getenv("ASTERISK_PROMPT"))) {
- char *t = pfmt;
- struct timeval ts = ast_tvnow();
- while (*t != '\0') {
- if (*t == '%') {
- char hostname[MAXHOSTNAMELEN] = "";
- int i, which;
- struct ast_tm tm = { 0, };
- int fgcolor = COLOR_WHITE, bgcolor = COLOR_BLACK;
- t++;
- switch (*t) {
- case 'C': /* color */
- t++;
- if (sscanf(t, "%30d;%30d%n", &fgcolor, &bgcolor, &i) == 2) {
- ast_term_color_code(&prompt, fgcolor, bgcolor);
- t += i - 1;
- } else if (sscanf(t, "%30d%n", &fgcolor, &i) == 1) {
- ast_term_color_code(&prompt, fgcolor, 0);
- t += i - 1;
- }
- /* If the color has been reset correctly, then there's no need to reset it later */
- color_used = ((fgcolor == COLOR_WHITE) && (bgcolor == COLOR_BLACK)) ? 0 : 1;
- break;
- case 'd': /* date */
- if (ast_localtime(&ts, &tm, NULL)) {
- ast_strftime(tmp, sizeof(tmp), "%Y-%m-%d", &tm);
- ast_str_append(&prompt, 0, "%s", tmp);
- cli_prompt_changes++;
- }
- break;
- case 'g': /* group */
- if ((gr = getgrgid(getgid()))) {
- ast_str_append(&prompt, 0, "%s", gr->gr_name);
- }
- break;
- case 'h': /* hostname */
- if (!gethostname(hostname, sizeof(hostname) - 1)) {
- ast_str_append(&prompt, 0, "%s", hostname);
- } else {
- ast_str_append(&prompt, 0, "%s", "localhost");
- }
- break;
- case 'H': /* short hostname */
- if (!gethostname(hostname, sizeof(hostname) - 1)) {
- char *dotptr;
- if ((dotptr = strchr(hostname, '.'))) {
- *dotptr = '\0';
- }
- ast_str_append(&prompt, 0, "%s", hostname);
- } else {
- ast_str_append(&prompt, 0, "%s", "localhost");
- }
- break;
- #ifdef HAVE_GETLOADAVG
- case 'l': /* load avg */
- t++;
- if (sscanf(t, "%30d", &which) == 1 && which > 0 && which <= 3) {
- double list[3];
- getloadavg(list, 3);
- ast_str_append(&prompt, 0, "%.2f", list[which - 1]);
- cli_prompt_changes++;
- }
- break;
- #endif
- case 's': /* Asterisk system name (from asterisk.conf) */
- ast_str_append(&prompt, 0, "%s", ast_config_AST_SYSTEM_NAME);
- break;
- case 't': /* time */
- if (ast_localtime(&ts, &tm, NULL)) {
- ast_strftime(tmp, sizeof(tmp), "%H:%M:%S", &tm);
- ast_str_append(&prompt, 0, "%s", tmp);
- cli_prompt_changes++;
- }
- break;
- case 'u': /* username */
- if ((pw = getpwuid(getuid()))) {
- ast_str_append(&prompt, 0, "%s", pw->pw_name);
- }
- break;
- case '#': /* process console or remote? */
- ast_str_append(&prompt, 0, "%c", ast_opt_remote ? '>' : '#');
- break;
- case '%': /* literal % */
- ast_str_append(&prompt, 0, "%c", '%');
- break;
- case '\0': /* % is last character - prevent bug */
- t--;
- break;
- }
- } else {
- ast_str_append(&prompt, 0, "%c", *t);
- }
- t++;
- }
- if (color_used) {
- /* Force colors back to normal at end */
- ast_term_color_code(&prompt, 0, 0);
- }
- } else {
- ast_str_set(&prompt, 0, "%s%s",
- remotehostname ? remotehostname : "",
- ASTERISK_PROMPT);
- }
- return ast_str_buffer(prompt);
- }
- static struct ast_vector_string *ast_el_strtoarr(char *buf)
- {
- char *retstr;
- struct ast_vector_string *vec = ast_calloc(1, sizeof(*vec));
- if (!vec) {
- return NULL;
- }
- while ((retstr = strsep(&buf, " "))) {
- if (!strcmp(retstr, AST_CLI_COMPLETE_EOF)) {
- break;
- }
- retstr = ast_strdup(retstr);
- if (!retstr || AST_VECTOR_APPEND(vec, retstr)) {
- ast_free(retstr);
- goto vector_cleanup;
- }
- }
- if (!AST_VECTOR_SIZE(vec)) {
- goto vector_cleanup;
- }
- return vec;
- vector_cleanup:
- AST_VECTOR_CALLBACK_VOID(vec, ast_free);
- AST_VECTOR_PTR_FREE(vec);
- return NULL;
- }
- static void ast_cli_display_match_list(struct ast_vector_string *matches, int max)
- {
- int idx = 1;
- /* find out how many entries can be put on one line, with two spaces between strings */
- int limit = ast_get_termcols(STDOUT_FILENO) / (max + 2);
- if (limit == 0) {
- limit = 1;
- }
- for (;;) {
- int numoutputline;
- for (numoutputline = 0; numoutputline < limit && idx < AST_VECTOR_SIZE(matches); idx++) {
- numoutputline++;
- fprintf(stdout, "%-*s ", max, AST_VECTOR_GET(matches, idx));
- }
- if (!numoutputline) {
- break;
- }
- fprintf(stdout, "\n");
- }
- }
- static char *cli_complete(EditLine *editline, int ch)
- {
- int len = 0;
- char *ptr;
- struct ast_vector_string *matches;
- int retval = CC_ERROR;
- char savechr;
- int res;
- LineInfo *lf = (LineInfo *)el_line(editline);
- savechr = *(char *)lf->cursor;
- *(char *)lf->cursor = '\0';
- ptr = (char *)lf->cursor;
- if (ptr) {
- while (ptr > lf->buffer) {
- if (isspace(*ptr)) {
- ptr++;
- break;
- }
- ptr--;
- }
- }
- len = lf->cursor - ptr;
- if (ast_opt_remote) {
- #define CMD_MATCHESARRAY "_COMMAND MATCHESARRAY \"%s\" \"%s\""
- char *mbuf;
- char *new_mbuf;
- int mlen = 0;
- int maxmbuf = ast_asprintf(&mbuf, CMD_MATCHESARRAY, lf->buffer, ptr);
- if (maxmbuf == -1) {
- *((char *) lf->cursor) = savechr;
- return (char *)(CC_ERROR);
- }
- fdsend(ast_consock, mbuf);
- res = 0;
- mlen = 0;
- mbuf[0] = '\0';
- while (!strstr(mbuf, AST_CLI_COMPLETE_EOF) && res != -1) {
- if (mlen + 1024 > maxmbuf) {
- /* Expand buffer to the next 1024 byte increment plus a NULL terminator. */
- maxmbuf = mlen + 1024;
- new_mbuf = ast_realloc(mbuf, maxmbuf + 1);
- if (!new_mbuf) {
- ast_free(mbuf);
- *((char *) lf->cursor) = savechr;
- return (char *)(CC_ERROR);
- }
- mbuf = new_mbuf;
- }
- /* Only read 1024 bytes at a time */
- res = read(ast_consock, mbuf + mlen, 1024);
- if (res > 0) {
- if (!strncmp(mbuf, "Usage:", 6)) {
- /*
- * Abort on malformed tab completes
- * If help (tab complete) follows certain
- * special characters, the main Asterisk process
- * provides usage for the internal tab complete
- * helper command that the remote console processes
- * use.
- * If this happens, the AST_CLI_COMPLETE_EOF sentinel
- * value never gets sent. As a result, we'll just block
- * forever if we don't handle this case.
- * If we get command usage on a tab complete, then
- * we know this scenario just happened and we should
- * just silently ignore and do nothing.
- */
- break;
- }
- mlen += res;
- mbuf[mlen] = '\0';
- }
- }
- mbuf[mlen] = '\0';
- matches = ast_el_strtoarr(mbuf);
- ast_free(mbuf);
- } else {
- matches = ast_cli_completion_vector((char *)lf->buffer, ptr);
- }
- if (matches) {
- int i;
- int maxlen, match_len;
- const char *best_match = AST_VECTOR_GET(matches, 0);
- if (!ast_strlen_zero(best_match)) {
- el_deletestr(editline, (int) len);
- el_insertstr(editline, best_match);
- retval = CC_REFRESH;
- }
- if (AST_VECTOR_SIZE(matches) == 2) {
- /* Found an exact match */
- el_insertstr(editline, " ");
- retval = CC_REFRESH;
- } else {
- /* Must be more than one match */
- for (i = 1, maxlen = 0; i < AST_VECTOR_SIZE(matches); i++) {
- match_len = strlen(AST_VECTOR_GET(matches, i));
- if (match_len > maxlen) {
- maxlen = match_len;
- }
- }
- fprintf(stdout, "\n");
- ast_cli_display_match_list(matches, maxlen);
- retval = CC_REDISPLAY;
- }
- AST_VECTOR_CALLBACK_VOID(matches, ast_free);
- AST_VECTOR_PTR_FREE(matches);
- }
- *((char *) lf->cursor) = savechr;
- return (char *)(long)retval;
- }
- static int ast_el_initialize(void)
- {
- HistEvent ev;
- char *editor, *editrc = getenv("EDITRC");
- if (!(editor = getenv("AST_EDITMODE"))) {
- if (!(editor = getenv("AST_EDITOR"))) {
- editor = "emacs";
- }
- }
- if (el != NULL)
- el_end(el);
- if (el_hist != NULL)
- history_end(el_hist);
- el = el_init("asterisk", stdin, stdout, stderr);
- el_set(el, EL_PROMPT, cli_prompt);
- el_set(el, EL_EDITMODE, 1);
- el_set(el, EL_EDITOR, editor);
- el_hist = history_init();
- if (!el || !el_hist)
- return -1;
- /* setup history with 100 entries */
- history(el_hist, &ev, H_SETSIZE, 100);
- el_set(el, EL_HIST, history, el_hist);
- el_set(el, EL_ADDFN, "ed-complete", "Complete argument", cli_complete);
- /* Bind <tab> to command completion */
- el_set(el, EL_BIND, "^I", "ed-complete", NULL);
- /* Bind ? to command completion */
- el_set(el, EL_BIND, "?", "ed-complete", NULL);
- /* Bind ^D to redisplay */
- el_set(el, EL_BIND, "^D", "ed-redisplay", NULL);
- /* Bind Delete to delete char left */
- el_set(el, EL_BIND, "\\e[3~", "ed-delete-next-char", NULL);
- /* Bind Home and End to move to line start and end */
- el_set(el, EL_BIND, "\\e[1~", "ed-move-to-beg", NULL);
- el_set(el, EL_BIND, "\\e[4~", "ed-move-to-end", NULL);
- /* Bind C-left and C-right to move by word (not all terminals) */
- el_set(el, EL_BIND, "\\eOC", "vi-next-word", NULL);
- el_set(el, EL_BIND, "\\eOD", "vi-prev-word", NULL);
- if (editrc) {
- el_source(el, editrc);
- }
- return 0;
- }
- #define MAX_HISTORY_COMMAND_LENGTH 256
- static int ast_el_add_history(const char *buf)
- {
- HistEvent ev;
- char *stripped_buf;
- if (el_hist == NULL || el == NULL) {
- ast_el_initialize();
- }
- if (strlen(buf) > (MAX_HISTORY_COMMAND_LENGTH - 1)) {
- return 0;
- }
- stripped_buf = ast_strip(ast_strdupa(buf));
- /* HISTCONTROL=ignoredups */
- if (!history(el_hist, &ev, H_FIRST) && strcmp(ev.str, stripped_buf) == 0) {
- return 0;
- }
- return history(el_hist, &ev, H_ENTER, stripped_buf);
- }
- static int ast_el_write_history(const char *filename)
- {
- HistEvent ev;
- if (el_hist == NULL || el == NULL)
- ast_el_initialize();
- return (history(el_hist, &ev, H_SAVE, filename));
- }
- static int ast_el_read_history(const char *filename)
- {
- HistEvent ev;
- if (el_hist == NULL || el == NULL) {
- ast_el_initialize();
- }
- if (access(filename, F_OK) == 0) {
- return history(el_hist, &ev, H_LOAD, filename);
- }
- /* If the history file doesn't exist, failing to read it is unremarkable. */
- return 0;
- }
- static void process_histfile(int (*readwrite)(const char *filename))
- {
- struct passwd *pw = getpwuid(geteuid());
- int ret = 0;
- char *name = NULL;
- if (!pw || ast_strlen_zero(pw->pw_dir)) {
- ast_log(LOG_ERROR, "Unable to determine home directory. History read/write disabled.\n");
- return;
- }
- ret = ast_asprintf(&name, "%s/.asterisk_history", pw->pw_dir);
- if (ret <= 0) {
- ast_log(LOG_ERROR, "Unable to create history file name. History read/write disabled.\n");
- return;
- }
- ret = readwrite(name);
- if (ret < 0) {
- ast_log(LOG_ERROR, "Unable to read or write history file '%s'\n", name);
- }
- ast_free(name);
- return;
- }
- static void ast_el_read_default_histfile(void)
- {
- process_histfile(ast_el_read_history);
- }
- static void ast_el_write_default_histfile(void)
- {
- process_histfile(ast_el_write_history);
- }
- static void ast_remotecontrol(char *data)
- {
- char buf[256] = "";
- int res;
- char *hostname;
- char *cpid;
- char *version;
- int pid;
- char *stringp = NULL;
- char *ebuf;
- int num = 0;
- ast_term_init();
- printf("%s", term_end());
- fflush(stdout);
- memset(&sig_flags, 0, sizeof(sig_flags));
- signal(SIGINT, __remote_quit_handler);
- signal(SIGTERM, __remote_quit_handler);
- signal(SIGHUP, __remote_quit_handler);
- if (read(ast_consock, buf, sizeof(buf) - 1) < 0) {
- ast_log(LOG_ERROR, "read() failed: %s\n", strerror(errno));
- return;
- }
- if (data) {
- char prefix[] = "cli quit after ";
- char *tmp = ast_alloca(strlen(data) + strlen(prefix) + 1);
- sprintf(tmp, "%s%s", prefix, data);
- if (write(ast_consock, tmp, strlen(tmp) + 1) < 0) {
- ast_log(LOG_ERROR, "write() failed: %s\n", strerror(errno));
- if (sig_flags.need_quit || sig_flags.need_quit_handler || sig_flags.need_el_end) {
- return;
- }
- }
- }
- stringp = buf;
- hostname = strsep(&stringp, "/");
- cpid = strsep(&stringp, "/");
- version = strsep(&stringp, "\n");
- if (!version)
- version = "<Version Unknown>";
- stringp = hostname;
- strsep(&stringp, ".");
- if (cpid)
- pid = atoi(cpid);
- else
- pid = -1;
- if (!data) {
- send_rasterisk_connect_commands();
- }
- if (ast_opt_exec && data) { /* hack to print output then exit if asterisk -rx is used */
- int linefull = 1, prev_linefull = 1, prev_line_verbose = 0;
- struct pollfd fds;
- fds.fd = ast_consock;
- fds.events = POLLIN;
- fds.revents = 0;
- while (ast_poll(&fds, 1, 60000) > 0) {
- char buffer[512] = "", *curline = buffer, *nextline;
- int not_written = 1;
- if (sig_flags.need_quit || sig_flags.need_quit_handler || sig_flags.need_el_end) {
- break;
- }
- if (read(ast_consock, buffer, sizeof(buffer) - 1) <= 0) {
- break;
- }
- do {
- prev_linefull = linefull;
- if ((nextline = strchr(curline, '\n'))) {
- linefull = 1;
- nextline++;
- } else {
- linefull = 0;
- nextline = strchr(curline, '\0');
- }
- /* Skip verbose lines */
- /* Prev line full? | Line is verbose | Last line verbose? | Print
- * TRUE | TRUE* | TRUE | FALSE
- * TRUE | TRUE* | FALSE | FALSE
- * TRUE | FALSE* | TRUE | TRUE
- * TRUE | FALSE* | FALSE | TRUE
- * FALSE | TRUE | TRUE* | FALSE
- * FALSE | TRUE | FALSE* | TRUE
- * FALSE | FALSE | TRUE* | FALSE
- * FALSE | FALSE | FALSE* | TRUE
- */
- if ((!prev_linefull && !prev_line_verbose) || (prev_linefull && *curline > 0)) {
- prev_line_verbose = 0;
- not_written = 0;
- if (write(STDOUT_FILENO, curline, nextline - curline) < 0) {
- ast_log(LOG_WARNING, "write() failed: %s\n", strerror(errno));
- }
- } else {
- prev_line_verbose = 1;
- }
- curline = nextline;
- } while (!ast_strlen_zero(curline));
- /* No non-verbose output in 60 seconds. */
- if (not_written) {
- break;
- }
- }
- return;
- }
- ast_verbose("Connected to Asterisk %s currently running on %s (pid = %d)\n", version, hostname, pid);
- ast_init_logger_for_socket_console();
- remotehostname = hostname;
- if (el_hist == NULL || el == NULL)
- ast_el_initialize();
- ast_el_read_default_histfile();
- el_set(el, EL_GETCFN, ast_el_read_char);
- for (;;) {
- ebuf = (char *)el_gets(el, &num);
- if (sig_flags.need_quit || sig_flags.need_quit_handler || sig_flags.need_el_end) {
- break;
- }
- if (!ebuf && write(1, "", 1) < 0)
- break;
- if (!ast_strlen_zero(ebuf)) {
- if (ebuf[strlen(ebuf)-1] == '\n')
- ebuf[strlen(ebuf)-1] = '\0';
- if (!remoteconsolehandler(ebuf)) {
- res = write(ast_consock, ebuf, strlen(ebuf) + 1);
- if (res < 1) {
- ast_log(LOG_WARNING, "Unable to write: %s\n", strerror(errno));
- break;
- }
- }
- }
- }
- printf("\nDisconnected from Asterisk server\n");
- }
- static int show_version(void)
- {
- printf("Asterisk %s\n", ast_get_version());
- return 0;
- }
- static int show_cli_help(void)
- {
- printf("Asterisk %s, " COPYRIGHT_TAG "\n", ast_get_version());
- printf("Usage: asterisk [OPTIONS]\n");
- printf("Valid Options:\n");
- printf(" -V Display version number and exit\n");
- printf(" -C <configfile> Use an alternate configuration file\n");
- printf(" -G <group> Run as a group other than the caller\n");
- printf(" -U <user> Run as a user other than the caller\n");
- printf(" -c Provide console CLI\n");
- printf(" -d Increase debugging (multiple d's = more debugging)\n");
- #if HAVE_WORKING_FORK
- printf(" -f Do not fork\n");
- printf(" -F Always fork\n");
- #endif
- printf(" -g Dump core in case of a crash\n");
- printf(" -h This help screen\n");
- printf(" -i Initialize crypto keys at startup\n");
- printf(" -L <load> Limit the maximum load average before rejecting new calls\n");
- printf(" -M <value> Limit the maximum number of calls to the specified value\n");
- printf(" -m Mute debugging and console output on the console\n");
- printf(" -n Disable console colorization. Can be used only at startup.\n");
- printf(" -p Run as pseudo-realtime thread\n");
- printf(" -q Quiet mode (suppress output)\n");
- printf(" -r Connect to Asterisk on this machine\n");
- printf(" -R Same as -r, except attempt to reconnect if disconnected\n");
- printf(" -s <socket> Connect to Asterisk via socket <socket> (only valid with -r)\n");
- printf(" -t Record soundfiles in /var/tmp and move them where they\n");
- printf(" belong after they are done\n");
- printf(" -T Display the time in [Mmm dd hh:mm:ss] format for each line\n");
- printf(" of output to the CLI. Cannot be used with remote console mode.\n\n");
- printf(" -v Increase verbosity (multiple v's = more verbose)\n");
- printf(" -x <cmd> Execute command <cmd> (implies -r)\n");
- printf(" -X Enable use of #exec in asterisk.conf\n");
- printf(" -W Adjust terminal colors to compensate for a light background\n");
- printf("\n");
- return 0;
- }
- static void read_pjproject_startup_options(void)
- {
- struct ast_config *cfg;
- struct ast_variable *v;
- struct ast_flags config_flags = { CONFIG_FLAG_NOCACHE | CONFIG_FLAG_NOREALTIME };
- ast_option_pjproject_log_level = DEFAULT_PJ_LOG_MAX_LEVEL;
- ast_option_pjproject_cache_pools = DEFAULT_PJPROJECT_CACHE_POOLS;
- cfg = ast_config_load2("pjproject.conf", "" /* core, can't reload */, config_flags);
- if (!cfg
- || cfg == CONFIG_STATUS_FILEUNCHANGED
- || cfg == CONFIG_STATUS_FILEINVALID) {
- /* We'll have to use defaults */
- return;
- }
- for (v = ast_variable_browse(cfg, "startup"); v; v = v->next) {
- if (!strcasecmp(v->name, "log_level")) {
- if (sscanf(v->value, "%30d", &ast_option_pjproject_log_level) != 1) {
- ast_option_pjproject_log_level = DEFAULT_PJ_LOG_MAX_LEVEL;
- } else if (ast_option_pjproject_log_level < 0) {
- ast_option_pjproject_log_level = 0;
- } else if (MAX_PJ_LOG_MAX_LEVEL < ast_option_pjproject_log_level) {
- ast_option_pjproject_log_level = MAX_PJ_LOG_MAX_LEVEL;
- }
- } else if (!strcasecmp(v->name, "cache_pools")) {
- ast_option_pjproject_cache_pools = !ast_false(v->value);
- }
- }
- ast_config_destroy(cfg);
- }
- static void *monitor_sig_flags(void *unused)
- {
- for (;;) {
- struct pollfd p = { sig_alert_pipe[0], POLLIN, 0 };
- ast_poll(&p, 1, -1);
- if (sig_flags.need_reload) {
- sig_flags.need_reload = 0;
- ast_module_reload(NULL);
- }
- if (sig_flags.need_quit) {
- sig_flags.need_quit = 0;
- if ((consolethread != AST_PTHREADT_NULL) && (consolethread != pthread_self())) {
- sig_flags.need_quit_handler = 1;
- pthread_kill(consolethread, SIGURG);
- } else {
- quit_handler(0, SHUTDOWN_NORMAL, 0);
- }
- }
- ast_alertpipe_read(sig_alert_pipe);
- }
- return NULL;
- }
- static void *canary_thread(void *unused)
- {
- struct stat canary_stat;
- struct timeval now;
- /* Give the canary time to sing */
- sleep(120);
- for (;;) {
- now = ast_tvnow();
- if (stat(canary_filename, &canary_stat) || now.tv_sec > canary_stat.st_mtime + 60) {
- ast_log(LOG_WARNING,
- "The canary is no more. He has ceased to be! "
- "He's expired and gone to meet his maker! "
- "He's a stiff! Bereft of life, he rests in peace. "
- "His metabolic processes are now history! He's off the twig! "
- "He's kicked the bucket. He's shuffled off his mortal coil, "
- "run down the curtain, and joined the bleeding choir invisible!! "
- "THIS is an EX-CANARY. (Reducing priority)\n");
- set_priority_all(0);
- pthread_exit(NULL);
- }
- /* Check the canary once a minute */
- sleep(60);
- }
- }
- /* Used by libc's atexit(3) function */
- static void canary_exit(void)
- {
- if (canary_pid > 0) {
- int status;
- kill(canary_pid, SIGKILL);
- waitpid(canary_pid, &status, 0);
- }
- }
- /* Execute CLI commands on startup. Run by main() thread. */
- static void run_startup_commands(void)
- {
- int fd;
- struct ast_config *cfg;
- struct ast_flags cfg_flags = { 0 };
- struct ast_variable *v;
- if (!(cfg = ast_config_load2("cli.conf", "" /* core, can't reload */, cfg_flags)))
- return;
- if (cfg == CONFIG_STATUS_FILEMISSING || cfg == CONFIG_STATUS_FILEUNCHANGED || cfg == CONFIG_STATUS_FILEINVALID) {
- return;
- }
- fd = open("/dev/null", O_RDWR);
- if (fd < 0) {
- ast_config_destroy(cfg);
- return;
- }
- for (v = ast_variable_browse(cfg, "startup_commands"); v; v = v->next) {
- if (ast_true(v->value))
- ast_cli_command(fd, v->name);
- }
- close(fd);
- ast_config_destroy(cfg);
- }
- static void env_init(void)
- {
- setenv("AST_SYSTEMNAME", ast_config_AST_SYSTEM_NAME, 1);
- setenv("AST_BUILD_HOST", ast_build_hostname, 1);
- setenv("AST_BUILD_DATE", ast_build_date, 1);
- setenv("AST_BUILD_KERNEL", ast_build_kernel, 1);
- setenv("AST_BUILD_MACHINE", ast_build_machine, 1);
- setenv("AST_BUILD_OS", ast_build_os, 1);
- setenv("AST_BUILD_USER", ast_build_user, 1);
- setenv("AST_VERSION", ast_get_version(), 1);
- }
- static void print_intro_message(const char *runuser, const char *rungroup)
- {
- if (ast_opt_console || option_verbose || (ast_opt_remote && !ast_opt_exec)) {
- WELCOME_MESSAGE;
- if (runuser) {
- ast_verbose("Running as user '%s'\n", runuser);
- }
- if (rungroup) {
- ast_verbose("Running under group '%s'\n", rungroup);
- }
- }
- }
- static void main_atexit(void)
- {
- ast_cli_unregister_multiple(cli_asterisk, ARRAY_LEN(cli_asterisk));
- }
- int main(int argc, char *argv[])
- {
- int c;
- int x;
- int isroot = 1, rundir_exists = 0;
- RAII_VAR(char *, runuser, NULL, ast_free);
- RAII_VAR(char *, rungroup, NULL, ast_free);
- RAII_VAR(char *, xarg, NULL, ast_free);
- struct rlimit l;
- static const char *getopt_settings = "BC:cde:FfG:ghIiL:M:mnpqRrs:TtU:VvWXx:";
- /* Remember original args for restart */
- if (argc > ARRAY_LEN(_argv) - 1) {
- fprintf(stderr, "Truncating argument size to %d\n", (int)ARRAY_LEN(_argv) - 1);
- argc = ARRAY_LEN(_argv) - 1;
- }
- for (x = 0; x < argc; x++)
- _argv[x] = argv[x];
- _argv[x] = NULL;
- if (geteuid() != 0)
- isroot = 0;
- /* if the progname is rasterisk consider it a remote console */
- if (argv[0] && (strstr(argv[0], "rasterisk")) != NULL) {
- ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_REMOTE);
- }
- ast_mainpid = getpid();
- /* Process command-line options that affect asterisk.conf load. */
- while ((c = getopt(argc, argv, getopt_settings)) != -1) {
- switch (c) {
- case 'X':
- ast_set_flag(&ast_options, AST_OPT_FLAG_EXEC_INCLUDES);
- break;
- case 'C':
- set_asterisk_conf_path(optarg);
- break;
- case 'd':
- option_debug++;
- break;
- case 'h':
- show_cli_help();
- exit(0);
- case 'R':
- case 'r':
- case 'x':
- /* ast_opt_remote is checked during config load. This is only part of what
- * these options do, see the second loop for the rest of the actions. */
- ast_set_flag(&ast_options, AST_OPT_FLAG_REMOTE);
- break;
- case 'V':
- show_version();
- exit(0);
- case 'v':
- option_verbose++;
- break;
- case '?':
- exit(1);
- }
- }
- /* Initialize env so it is available if #exec is used in asterisk.conf. */
- env_init();
- load_asterisk_conf();
- /* Update env to include any systemname that was set. */
- env_init();
- /*! \brief Check for options
- *
- * \todo Document these options
- */
- optind = 1;
- while ((c = getopt(argc, argv, getopt_settings)) != -1) {
- /*!\note Please keep the ordering here to alphabetical, capital letters
- * first. This will make it easier in the future to select unused
- * option flags for new features. */
- switch (c) {
- case 'B': /* Force black background */
- ast_set_flag(&ast_options, AST_OPT_FLAG_FORCE_BLACK_BACKGROUND);
- ast_clear_flag(&ast_options, AST_OPT_FLAG_LIGHT_BACKGROUND);
- break;
- case 'X':
- /* The command-line -X option enables #exec for asterisk.conf only. */
- break;
- case 'C':
- /* already processed. */
- break;
- case 'c':
- ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_CONSOLE);
- break;
- case 'd':
- /* already processed. */
- break;
- #if defined(HAVE_SYSINFO)
- case 'e':
- if ((sscanf(&optarg[1], "%30ld", &option_minmemfree) != 1) || (option_minmemfree < 0)) {
- option_minmemfree = 0;
- }
- break;
- #endif
- #if HAVE_WORKING_FORK
- case 'F':
- ast_set_flag(&ast_options, AST_OPT_FLAG_ALWAYS_FORK);
- break;
- case 'f':
- ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK);
- break;
- #endif
- case 'G':
- rungroup = ast_strdup(optarg);
- break;
- case 'g':
- ast_set_flag(&ast_options, AST_OPT_FLAG_DUMP_CORE);
- break;
- case 'h':
- /* already processed. */
- break;
- case 'I':
- fprintf(stderr,
- "NOTICE: The -I option is no longer needed.\n"
- " It will always be enabled if you have a timing module loaded.\n");
- break;
- case 'i':
- ast_set_flag(&ast_options, AST_OPT_FLAG_INIT_KEYS);
- break;
- case 'L':
- if ((sscanf(optarg, "%30lf", &ast_option_maxload) != 1) || (ast_option_maxload < 0.0)) {
- ast_option_maxload = 0.0;
- }
- break;
- case 'M':
- if ((sscanf(optarg, "%30d", &ast_option_maxcalls) != 1) || (ast_option_maxcalls < 0)) {
- ast_option_maxcalls = 0;
- }
- break;
- case 'm':
- ast_set_flag(&ast_options, AST_OPT_FLAG_MUTE);
- break;
- case 'n':
- ast_set_flag(&ast_options, AST_OPT_FLAG_NO_COLOR);
- break;
- case 'p':
- ast_set_flag(&ast_options, AST_OPT_FLAG_HIGH_PRIORITY);
- break;
- case 'q':
- ast_set_flag(&ast_options, AST_OPT_FLAG_QUIET);
- break;
- case 'R':
- ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_REMOTE | AST_OPT_FLAG_RECONNECT);
- break;
- case 'r':
- ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_REMOTE);
- break;
- case 's':
- if (ast_opt_remote) {
- set_socket_path(optarg);
- }
- break;
- case 'T':
- ast_set_flag(&ast_options, AST_OPT_FLAG_TIMESTAMP);
- break;
- case 't':
- ast_set_flag(&ast_options, AST_OPT_FLAG_CACHE_RECORD_FILES);
- break;
- case 'U':
- runuser = ast_strdup(optarg);
- break;
- case 'V':
- case 'v':
- /* already processed. */
- break;
- case 'W': /* White background */
- ast_set_flag(&ast_options, AST_OPT_FLAG_LIGHT_BACKGROUND);
- ast_clear_flag(&ast_options, AST_OPT_FLAG_FORCE_BLACK_BACKGROUND);
- break;
- case 'x':
- /* -r is implied by -x so set the flags -r sets as well. */
- ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_REMOTE);
- ast_set_flag(&ast_options, AST_OPT_FLAG_EXEC | AST_OPT_FLAG_NO_COLOR);
- xarg = ast_strdup(optarg);
- break;
- case '?':
- /* already processed. */
- break;
- }
- }
- if (ast_opt_remote) {
- int didwarn = 0;
- optind = 1;
- /* Not all options can be used with remote console. Warn if they're used. */
- while ((c = getopt(argc, argv, getopt_settings)) != -1) {
- switch (c) {
- /* okay to run with remote console */
- case 'B': /* force black background */
- case 'C': /* set config path */
- case 'd': /* debug */
- case 'h': /* help */
- case 'I': /* obsolete timing option: warning already thrown if used */
- case 'L': /* max load */
- case 'M': /* max calls */
- case 'm': /* mute */
- /*! \note The q option is never used anywhere, only defined */
- case 'q': /* quiet */
- case 'R': /* reconnect */
- case 'r': /* remote */
- /*! \note Can ONLY be used with remote console */
- case 's': /* set socket path */
- case 'T': /* timestamp */
- case 'V': /* version */
- case 'v': /* verbose */
- case 'W': /* white background */
- case 'x': /* remote execute */
- case '?': /* ? */
- break;
- /* can only be run when Asterisk is starting */
- case 'X': /* enables #exec for asterisk.conf only. */
- case 'c': /* foreground console */
- case 'e': /* minimum memory free */
- case 'F': /* always fork */
- case 'f': /* no fork */
- case 'G': /* run group */
- case 'g': /* dump core */
- case 'i': /* init keys */
- case 'n': /* no color */
- case 'p': /* high priority */
- case 't': /* cache record files */
- case 'U': /* run user */
- fprintf(stderr, "'%c' option is not compatible with remote console mode and has no effect.\n", c);
- didwarn = 1;
- }
- }
- if (didwarn) {
- fprintf(stderr, "\n"); /* if any warnings print out, make them stand out */
- }
- }
- /* For remote connections, change the name of the remote connection.
- * We do this for the benefit of init scripts (which need to know if/when
- * the main asterisk process has died yet). */
- if (ast_opt_remote) {
- strcpy(argv[0], "rasterisk");
- for (x = 1; x < argc; x++) {
- argv[x] = argv[0] + 10;
- }
- }
- if (!ast_language_is_prefix && !ast_opt_remote) {
- fprintf(stderr, "The 'languageprefix' option in asterisk.conf is deprecated; in a future release it will be removed, and your sound files will need to be organized in the 'new style' language layout.\n");
- }
- if (ast_opt_always_fork && (ast_opt_remote || ast_opt_console)) {
- fprintf(stderr, "'alwaysfork' is not compatible with console or remote console mode; ignored\n");
- ast_clear_flag(&ast_options, AST_OPT_FLAG_ALWAYS_FORK);
- }
- if (ast_opt_dump_core) {
- memset(&l, 0, sizeof(l));
- l.rlim_cur = RLIM_INFINITY;
- l.rlim_max = RLIM_INFINITY;
- if (setrlimit(RLIMIT_CORE, &l)) {
- fprintf(stderr, "Unable to disable core size resource limit: %s\n", strerror(errno));
- }
- }
- if (getrlimit(RLIMIT_NOFILE, &l)) {
- fprintf(stderr, "Unable to check file descriptor limit: %s\n", strerror(errno));
- }
- #if !defined(CONFIGURE_RAN_AS_ROOT)
- /* Check if select(2) will run with more file descriptors */
- do {
- int fd, fd2;
- ast_fdset readers;
- struct timeval tv = { 0, };
- if (l.rlim_cur <= FD_SETSIZE) {
- /* The limit of select()able FDs is irrelevant, because we'll never
- * open one that high. */
- break;
- }
- if (!(fd = open("/dev/null", O_RDONLY))) {
- fprintf(stderr, "Cannot open a file descriptor at boot? %s\n", strerror(errno));
- break; /* XXX Should we exit() here? XXX */
- }
- fd2 = ((l.rlim_cur > sizeof(readers) * 8) ? sizeof(readers) * 8 : l.rlim_cur) - 1;
- if (dup2(fd, fd2) < 0) {
- fprintf(stderr, "Cannot open maximum file descriptor %d at boot? %s\n", fd2, strerror(errno));
- close(fd);
- break;
- }
- FD_ZERO(&readers);
- FD_SET(fd2, &readers);
- if (ast_select(fd2 + 1, &readers, NULL, NULL, &tv) < 0) {
- fprintf(stderr, "Maximum select()able file descriptor is %d\n", FD_SETSIZE);
- }
- ast_FD_SETSIZE = l.rlim_cur > ast_FDMAX ? ast_FDMAX : l.rlim_cur;
- close(fd);
- close(fd2);
- } while (0);
- #elif defined(HAVE_VARIABLE_FDSET)
- ast_FD_SETSIZE = l.rlim_cur > ast_FDMAX ? ast_FDMAX : l.rlim_cur;
- #endif /* !defined(CONFIGURE_RAN_AS_ROOT) */
- if ((!rungroup) && !ast_strlen_zero(ast_config_AST_RUN_GROUP))
- rungroup = ast_strdup(ast_config_AST_RUN_GROUP);
- if ((!runuser) && !ast_strlen_zero(ast_config_AST_RUN_USER))
- runuser = ast_strdup(ast_config_AST_RUN_USER);
- /* Must install this signal handler up here to ensure that if the canary
- * fails to execute that it doesn't kill the Asterisk process.
- */
- sigaction(SIGCHLD, &child_handler, NULL);
- /* It's common on some platforms to clear /var/run at boot. Create the
- * socket file directory before we drop privileges. */
- if (mkdir(ast_config_AST_RUN_DIR, 0755)) {
- if (errno == EEXIST) {
- rundir_exists = 1;
- } else {
- fprintf(stderr, "Unable to create socket file directory. Remote consoles will not be able to connect! (%s)\n", strerror(x));
- }
- }
- #ifndef __CYGWIN__
- if (isroot) {
- ast_set_priority(ast_opt_high_priority);
- }
- if (isroot && rungroup) {
- struct group *gr;
- gr = getgrnam(rungroup);
- if (!gr) {
- fprintf(stderr, "No such group '%s'!\n", rungroup);
- exit(1);
- }
- if (!rundir_exists && chown(ast_config_AST_RUN_DIR, -1, gr->gr_gid)) {
- fprintf(stderr, "Unable to chgrp run directory to %d (%s)\n", (int) gr->gr_gid, rungroup);
- }
- if (setgid(gr->gr_gid)) {
- fprintf(stderr, "Unable to setgid to %d (%s)\n", (int)gr->gr_gid, rungroup);
- exit(1);
- }
- if (setgroups(0, NULL)) {
- fprintf(stderr, "Unable to drop unneeded groups\n");
- exit(1);
- }
- }
- if (runuser && !ast_test_flag(&ast_options, AST_OPT_FLAG_REMOTE)) {
- #ifdef HAVE_CAP
- int has_cap = 1;
- #endif /* HAVE_CAP */
- struct passwd *pw;
- pw = getpwnam(runuser);
- if (!pw) {
- fprintf(stderr, "No such user '%s'!\n", runuser);
- exit(1);
- }
- if (chown(ast_config_AST_RUN_DIR, pw->pw_uid, -1)) {
- fprintf(stderr, "Unable to chown run directory to %d (%s)\n", (int) pw->pw_uid, runuser);
- }
- #ifdef HAVE_CAP
- if (prctl(PR_SET_KEEPCAPS, 1, 0, 0, 0)) {
- ast_log(LOG_WARNING, "Unable to keep capabilities.\n");
- has_cap = 0;
- }
- #endif /* HAVE_CAP */
- if (!isroot && pw->pw_uid != geteuid()) {
- fprintf(stderr, "Asterisk started as nonroot, but runuser '%s' requested.\n", runuser);
- exit(1);
- }
- if (!rungroup) {
- if (setgid(pw->pw_gid)) {
- fprintf(stderr, "Unable to setgid to %d!\n", (int)pw->pw_gid);
- exit(1);
- }
- if (isroot && initgroups(pw->pw_name, pw->pw_gid)) {
- fprintf(stderr, "Unable to init groups for '%s'\n", runuser);
- exit(1);
- }
- }
- if (setuid(pw->pw_uid)) {
- fprintf(stderr, "Unable to setuid to %d (%s)\n", (int)pw->pw_uid, runuser);
- exit(1);
- }
- #ifdef HAVE_CAP
- if (has_cap) {
- cap_t cap;
- cap = cap_from_text("cap_net_admin=eip");
- if (cap_set_proc(cap)) {
- fprintf(stderr, "Unable to install capabilities.\n");
- }
- if (cap_free(cap)) {
- fprintf(stderr, "Unable to drop capabilities.\n");
- }
- }
- #endif /* HAVE_CAP */
- }
- #endif /* __CYGWIN__ */
- #ifdef linux
- if (geteuid() && ast_opt_dump_core) {
- if (prctl(PR_SET_DUMPABLE, 1, 0, 0, 0) < 0) {
- fprintf(stderr, "Unable to set the process for core dumps after changing to a non-root user. %s\n", strerror(errno));
- }
- }
- #endif
- {
- #if defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS)
- char dir[PATH_MAX];
- if (!getcwd(dir, sizeof(dir)) || eaccess(dir, R_OK | X_OK | F_OK)) {
- fprintf(stderr, "Unable to access the running directory (%s). Changing to '/' for compatibility.\n", strerror(errno));
- /* If we cannot access the CWD, then we couldn't dump core anyway,
- * so chdir("/") won't break anything. */
- if (chdir("/")) {
- /* chdir(/) should never fail, so this ends up being a no-op */
- fprintf(stderr, "chdir(\"/\") failed?!! %s\n", strerror(errno));
- }
- } else
- #endif /* defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS) */
- if (!ast_opt_no_fork && !ast_opt_dump_core) {
- /* Backgrounding, but no cores, so chdir won't break anything. */
- if (chdir("/")) {
- fprintf(stderr, "Unable to chdir(\"/\") ?!! %s\n", strerror(errno));
- }
- }
- }
- /* Initial value of the maximum active system verbosity level. */
- ast_verb_sys_level = option_verbose;
- if (ast_sd_get_fd_un(SOCK_STREAM, ast_config_AST_SOCKET) > 0) {
- ast_socket_is_sd = 1;
- }
- /* DO NOT perform check for existing daemon if systemd has CLI socket activation */
- if (!ast_socket_is_sd && ast_tryconnect()) {
- /* One is already running */
- if (ast_opt_remote) {
- multi_thread_safe = 1;
- if (ast_opt_exec) {
- ast_remotecontrol(xarg);
- quit_handler(0, SHUTDOWN_FAST, 0);
- exit(0);
- }
- ast_term_init();
- printf("%s", term_end());
- fflush(stdout);
- print_intro_message(runuser, rungroup);
- printf("%s", term_quit());
- ast_remotecontrol(NULL);
- quit_handler(0, SHUTDOWN_FAST, 0);
- exit(0);
- } else {
- fprintf(stderr, "Asterisk already running on %s. Use 'asterisk -r' to connect.\n", ast_config_AST_SOCKET);
- printf("%s", term_quit());
- exit(1);
- }
- } else if (ast_opt_remote || ast_opt_exec) {
- fprintf(stderr, "Unable to connect to remote asterisk (does %s exist?)\n", ast_config_AST_SOCKET);
- printf("%s", term_quit());
- exit(1);
- }
- #ifdef HAVE_CAP
- child_cap = cap_from_text("cap_net_admin-eip");
- #endif
- /* Not a remote console? Start the daemon. */
- asterisk_daemon(isroot, runuser, rungroup);
- #ifdef HAS_CAP
- cap_free(child_cap);
- #endif
- return 0;
- }
- static inline void check_init(int init_result, const char *name)
- {
- if (init_result) {
- if (ast_is_logger_initialized()) {
- ast_log(LOG_ERROR, "%s initialization failed. ASTERISK EXITING!\n%s", name, term_quit());
- } else {
- fprintf(stderr, "%s initialization failed. ASTERISK EXITING!\n%s", name, term_quit());
- }
- ast_run_atexits(0);
- exit(init_result == -2 ? 2 : 1);
- }
- }
- static void asterisk_daemon(int isroot, const char *runuser, const char *rungroup)
- {
- FILE *f;
- sigset_t sigs;
- int num;
- char *buf;
- char pbx_uuid[AST_UUID_STR_LEN];
- /* Set time as soon as possible */
- ast_lastreloadtime = ast_startuptime = ast_tvnow();
- /* This needs to remain as high up in the initial start up as possible.
- * daemon causes a fork to occur, which has all sorts of unintended
- * consequences for things that interact with threads. This call *must*
- * occur before anything in Asterisk spawns or manipulates thread related
- * primitives. */
- #if HAVE_WORKING_FORK
- if (ast_opt_always_fork || !ast_opt_no_fork) {
- #ifndef HAVE_SBIN_LAUNCHD
- if (daemon(1, 0) < 0) {
- fprintf(stderr, "daemon() failed: %s\n", strerror(errno));
- } else {
- ast_mainpid = getpid();
- }
- #else
- fprintf(stderr, "Mac OS X detected. Use 'launchctl load /Library/LaunchDaemon/org.asterisk.asterisk.plist'.\n");
- #endif
- }
- #endif
- /* At this point everything has been forked successfully,
- * we have determined that we aren't attempting to connect to
- * an Asterisk instance, and that there isn't one already running. */
- multi_thread_safe = 1;
- load_astmm_phase_1();
- /* Check whether high prio was successfully set by us or some
- * other incantation. */
- if (has_priority()) {
- ast_set_flag(&ast_options, AST_OPT_FLAG_HIGH_PRIORITY);
- } else {
- ast_clear_flag(&ast_options, AST_OPT_FLAG_HIGH_PRIORITY);
- }
- /* Spawning of astcanary must happen AFTER the call to daemon(3) */
- if (ast_opt_high_priority) {
- snprintf(canary_filename, sizeof(canary_filename), "%s/alt.asterisk.canary.tweet.tweet.tweet", ast_config_AST_RUN_DIR);
- /* Don't let the canary child kill Asterisk, if it dies immediately */
- sigaction(SIGPIPE, &ignore_sig_handler, NULL);
- canary_pid = fork();
- if (canary_pid == 0) {
- char canary_binary[PATH_MAX], ppid[12];
- /* Reset signal handler */
- signal(SIGCHLD, SIG_DFL);
- signal(SIGPIPE, SIG_DFL);
- ast_close_fds_above_n(0);
- ast_set_priority(0);
- snprintf(ppid, sizeof(ppid), "%d", (int) ast_mainpid);
- /* Use the astcanary binary that we installed */
- snprintf(canary_binary, sizeof(canary_binary), "%s/astcanary", ast_config_AST_SBIN_DIR);
- execl(canary_binary, "astcanary", canary_filename, ppid, (char *)NULL);
- /* Should never happen */
- _exit(1);
- } else if (canary_pid > 0) {
- pthread_t dont_care;
- ast_pthread_create_detached(&dont_care, NULL, canary_thread, NULL);
- }
- /* Kill the canary when we exit */
- ast_register_atexit(canary_exit);
- }
- /* Blindly write the PID file. */
- unlink(ast_config_AST_PID);
- f = fopen(ast_config_AST_PID, "w");
- if (f) {
- fprintf(f, "%ld\n", (long)ast_mainpid);
- fclose(f);
- } else {
- fprintf(stderr, "Unable to open pid file '%s': %s\n", ast_config_AST_PID, strerror(errno));
- }
- /* Initialize the terminal. Since all processes have been forked,
- * we can now start using the standard log messages.
- */
- ast_term_init();
- printf("%s", term_end());
- fflush(stdout);
- print_intro_message(runuser, rungroup);
- register_config_cli();
- check_init(astobj2_init(), "AO2");
- check_init(ast_named_locks_init(), "Named Locks");
- if (ast_opt_console) {
- if (el_hist == NULL || el == NULL)
- ast_el_initialize();
- ast_el_read_default_histfile();
- }
- #ifdef AST_XML_DOCS
- /* Load XML documentation. */
- ast_xmldoc_load_documentation();
- #endif
- check_init(astdb_init(), "ASTdb");
- ast_uuid_init();
- if (ast_pbx_uuid_get(pbx_uuid, sizeof(pbx_uuid))) {
- ast_uuid_generate_str(pbx_uuid, sizeof(pbx_uuid));
- ast_db_put("pbx", "UUID", pbx_uuid);
- }
- ast_verb(0, "PBX UUID: %s\n", pbx_uuid);
- check_init(ast_json_init(), "libjansson");
- ast_ulaw_init();
- ast_alaw_init();
- ast_utf8_init();
- tdd_init();
- callerid_init();
- ast_builtins_init();
- check_init(ast_utils_init(), "Utilities");
- check_init(ast_tps_init(), "Task Processor Core");
- check_init(ast_fd_init(), "File Descriptor Debugging");
- check_init(ast_pbx_init(), "ast_pbx_init");
- check_init(aco_init(), "Configuration Option Framework");
- check_init(stasis_init(), "Stasis");
- #ifdef TEST_FRAMEWORK
- check_init(ast_test_init(), "Test Framework");
- #endif
- check_init(ast_translate_init(), "Translator Core");
- ast_aoc_cli_init();
- check_init(ast_sorcery_init(), "Sorcery");
- check_init(ast_codec_init(), "Codecs");
- check_init(ast_format_init(), "Formats");
- check_init(ast_format_cache_init(), "Format Cache");
- check_init(ast_codec_builtin_init(), "Built-in Codecs");
- check_init(ast_bucket_init(), "Bucket API");
- check_init(ast_stasis_system_init(), "Stasis system-level information");
- check_init(ast_endpoint_stasis_init(), "Stasis Endpoint");
- ast_makesocket();
- /* GCC 4.9 gives a bogus "right-hand operand of comma expression has
- * no effect" warning */
- (void) sigemptyset(&sigs);
- (void) sigaddset(&sigs, SIGHUP);
- (void) sigaddset(&sigs, SIGTERM);
- (void) sigaddset(&sigs, SIGINT);
- (void) sigaddset(&sigs, SIGPIPE);
- (void) sigaddset(&sigs, SIGWINCH);
- pthread_sigmask(SIG_BLOCK, &sigs, NULL);
- sigaction(SIGURG, &urg_handler, NULL);
- signal(SIGINT, __quit_handler);
- signal(SIGTERM, __quit_handler);
- sigaction(SIGHUP, &hup_handler, NULL);
- sigaction(SIGPIPE, &ignore_sig_handler, NULL);
- /* ensure that the random number generators are seeded with a different value every time
- Asterisk is started
- */
- srand((unsigned int) getpid() + (unsigned int) time(NULL));
- initstate((unsigned int) getpid() * 65536 + (unsigned int) time(NULL), randompool, sizeof(randompool));
- threadstorage_init();
- check_init(init_logger(), "Logger");
- check_init(ast_rtp_engine_init(), "RTP Engine");
- ast_autoservice_init();
- check_init(ast_timing_init(), "Timing");
- check_init(ast_ssl_init(), "SSL");
- read_pjproject_startup_options();
- check_init(ast_pj_init(), "Embedded PJProject");
- check_init(app_init(), "App Core");
- check_init(mwi_init(), "MWI Core");
- check_init(devstate_init(), "Device State Core");
- check_init(ast_msg_init(), "Messaging API");
- check_init(ast_channels_init(), "Channel");
- check_init(ast_endpoint_init(), "Endpoints");
- check_init(ast_pickup_init(), "Call Pickup");
- check_init(ast_bridging_init(), "Bridging");
- check_init(ast_parking_stasis_init(), "Parking Core");
- check_init(ast_device_state_engine_init(), "Device State Engine");
- check_init(ast_presence_state_engine_init(), "Presence State Engine");
- check_init(dns_core_init(), "DNS Resolver Core");
- check_init(ast_dns_system_resolver_init(), "Default DNS resolver");
- check_init(ast_security_stasis_init(), "Security Stasis Topic and Events");
- check_init(ast_image_init(), "Image");
- check_init(ast_file_init(), "Generic File Format Support");
- check_init(load_pbx(), "load_pbx");
- check_init(load_pbx_builtins(), "Builtin PBX Applications");
- check_init(load_pbx_functions_cli(), "PBX Functions Support");
- check_init(load_pbx_variables(), "PBX Variables Support");
- check_init(load_pbx_switch(), "PBX Switch Support");
- check_init(load_pbx_app(), "PBX Application Support");
- check_init(load_pbx_hangup_handler(), "PBX Hangup Handler Support");
- check_init(ast_local_init(), "Local Proxy Channel Driver");
- check_init(ast_refer_init(), "Refer API");
- /* We should avoid most config loads before this point as they can't use realtime. */
- check_init(load_modules(), "Module");
- /*
- * This has to load after the dynamic modules load, as items in the media
- * cache can't be constructed from items in the AstDB without their
- * bucket backends.
- */
- check_init(ast_media_cache_init(), "Media Cache");
- /* loads the cli_permissions.conf file needed to implement cli restrictions. */
- ast_cli_perms_init(0);
- ast_cli_channels_init(); /* Not always safe to access CLI commands until startup is complete. */
- ast_stun_init();
- dnsmgr_start_refresh();
- if (ast_opt_no_fork) {
- consolethread = pthread_self();
- }
- ast_alertpipe_init(sig_alert_pipe);
- ast_process_pending_reloads();
- ast_set_flag(&ast_options, AST_OPT_FLAG_FULLY_BOOTED);
- publish_fully_booted();
- pthread_sigmask(SIG_UNBLOCK, &sigs, NULL);
- load_astmm_phase_2();
- ast_cli_register_multiple(cli_asterisk_shutdown, ARRAY_LEN(cli_asterisk_shutdown));
- ast_cli_register_multiple(cli_asterisk, ARRAY_LEN(cli_asterisk));
- ast_register_cleanup(main_atexit);
- run_startup_commands();
- ast_sd_notify("READY=1");
- ast_verb(0, COLORIZE_FMT "\n", COLORIZE(COLOR_BRGREEN, 0, "Asterisk Ready."));
- logger_queue_start();
- if (ast_opt_console) {
- /* Console stuff now... */
- /* Register our quit function */
- char title[256];
- char hostname[MAXHOSTNAMELEN] = "";
- if (gethostname(hostname, sizeof(hostname) - 1)) {
- ast_copy_string(hostname, "<Unknown>", sizeof(hostname));
- }
- ast_pthread_create_detached(&mon_sig_flags, NULL, monitor_sig_flags, NULL);
- set_icon("Asterisk");
- snprintf(title, sizeof(title), "Asterisk Console on '%s' (pid %ld)", hostname, (long)ast_mainpid);
- set_title(title);
- el_set(el, EL_GETCFN, ast_el_read_char);
- for (;;) {
- if (sig_flags.need_el_end) {
- el_end(el);
- return;
- }
- if (sig_flags.need_quit || sig_flags.need_quit_handler) {
- quit_handler(0, SHUTDOWN_FAST, 0);
- break;
- }
- buf = (char *) el_gets(el, &num);
- if (!buf && write(1, "", 1) < 0)
- return; /* quit */
- if (buf) {
- if (buf[strlen(buf)-1] == '\n')
- buf[strlen(buf)-1] = '\0';
- consolehandler(buf);
- }
- }
- }
- /* Stall until a quit signal is given */
- monitor_sig_flags(NULL);
- }
|