ivhSrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK J r SSKJr SSKJrJr SSKrSSKJr SS KJrJrJrJr SS KJrJr SS KJrJ r SS K!J"r" SS K#J$r$J%r%J&r& SSK'J(r( SSK)J*r*J+r+J,r,J-r-J.r.J/r/ SSK0J1r1 SSK2J3r3J4r4 Sr5Sr6Sr7Sr8Sr9Sr:Sr;SrSr?Sr@SrA"SS\B5rCS/S jrDS0S1S!jjrE\"S"S#9"S$S%55rF\"S"S#9"S&S'55rG"S(S)\R5rI"S*S+\ R\%5rK"S,S-\5rLS2S.jrMg)3a Module to interact with the ChromeCast via protobuf-over-socket. Big thanks goes out to Fred Clift who build the first version of this code: https://github.com/minektur/chromecast-python-poc. Without him this would not have been possible. ) annotationsN) defaultdict) dataclass)packunpack) APP_AUDIBLE) MESSAGE_TYPEPLATFORM_DESTINATION_ID REQUEST_ID SESSION_ID)BaseController CallbackType) NS_HEARTBEATHeartbeatController)MediaController) CastStatusCastStatusListenerReceiverController)get_host_from_service)ChromecastConnectionErrorChromecastConnectionClosedControllerNotRegistered NotConnectedPyChromecastStoppedUnsupportedNamespace) CastMessage)HostServiceInfoMDNSServiceInfoz(urn:x-cast:com.google.cast.tp.connectionCONNECTCLOSELOAD CONNECTING CONNECTED DISCONNECTEDFAILEDFAILED_RESOLVELOSTg@g>@c\rSrSrSrSrg) InterruptLoopGz)The chromecast has been manually stopped.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r,Q/home/sebas/venvs/catt/lib/python3.13/site-packages/pychromecast/socket_client.pyr*r*Gs3r3r*c[R"UR5n[U[5(dC[ R "[5nURSURUR5 0$U$![aF [ R "[5nURSURUR5 0s$f=f)z$Parses a PB2 message as a JSON dict.z#Non dict json in namespace %s: '%s'z"Invalid json in namespace %s: '%s') jsonloads payload_utf8 isinstancedictlogging getLoggerr-debug namespace ValueError)messagedataloggers r4_dict_from_message_payloadrCKszz'../$%%&&x0F LL5!!$$  I ""8, 0       sA7A<:A< source_iddestination_idr8)r@rAs r4_message_to_stringrGbs[  |)'2 7$$%VG,=,=+>d  ! ! ""T%AW-A-A$B Dr3T)frozenc.\rSrSr%SrS\S'S\S'Srg) NetworkAddresspzNetwork address container.straddress int | Noneportr,Nr-r.r/r0r1__annotations__r2r,r3r4rJrJps$ L r3rJc8\rSrSr%SrS\S'S\S'S\S'S rg ) ConnectionStatusxzConnection status container.rLstatuszNetworkAddress | NonerMz(HostServiceInfo | MDNSServiceInfo | Noneservicer,NrPr,r3r4rSrSxs& K "" 55r3rSc@\rSrSrSr\R SSj5rSrg)ConnectionStatusListenerz0Listener for receiving connection status events.cg)zUpdated connection status.Nr,)selfrUs r4new_connection_status.ConnectionStatusListener.new_connection_statussr3r,NrUrSreturnNone) r-r.r/r0r1abcabstractmethodr\r2r,r3r4rXrXs:))r3rXc^\rSrSrSrS U4SjjrS!SjrS!SjrS"SjrS"Sjr S#Sjr S$S jr \ S%S j5r \ S%S j5rS!S jrS$S jrS%SjrS&SjrS!SjrS'SjrS(SjrS)SjrSSSSS.S*SjjrSSSS.S+SjjrSSSS.S+SjjrS,SjrS-SjrS-SjrS!SjrSrU=r$). SocketClienta Class to interact with a Chromecast through a socket. :param host: The host to connect to. :param port: The port to use when connecting to the device, set to None to use the default of 8009. Special devices such as Cast Groups may return a different port number so we need to use that. :param cast_type: The type of chromecast to connect to, see dial.CAST_TYPE_* for types. :param tries: Number of retries to perform if the connection fails. None for infinite retries. :param timeout: A floating point number specifying the socket timeout in seconds. None means to use the default which is 30 seconds. :param retry_wait: A floating point number specifying how many seconds to wait between each retry. None means to use the default which is 5 seconds. :param services: A list of mDNS services to try to connect to. If present, parameters host and port are ignored and host and port are instead resolved through mDNS. The list of services may be modified, for example if speaker group leadership is handed over. SocketClient will catch modifications to the list when attempting reconnect. :param zconf: A zeroconf instance, needed if a list of services is passed. The zeroconf instance may be obtained from the browser returned by pychromecast.start_discovery(). cp>[TU]5 SUl[R"[ 5UlSUlXlSUl X l U=(d [Ul U=(d [UlXPlX`lSUlSUlSUl[(R*"5Ul[.R0"5Ul/UlSUlSUlSUl0Ul/UlSUlSUl SUl[BRD"5Ul#URFRIUR0S[BRJ5Ul&SUl'[Q[R5Ul*/Ul+[YU5Ul-[]5Ul/[a5Ul1UReURb5 URe[g55 UReURZ5 UReUR^5 URZRiU5 g)NTFunknowniIzsender-0r)5super__init__daemonr;r<r-rB _force_recon cast_typefntries TIMEOUT_TIMEtimeout RETRY_TIME retry_waitserviceszconfhostrOrE threadingEventstopsocket socketpairapp_namespacesrF session_id _request_id_request_callbacks_open_channels connectingfirst_connection selectorsDefaultSelectorselectorregister EVENT_READwakeup_selector_keyremote_selector_keyrset _handlers_connection_listenersrreceiver_controllerrmedia_controllerrheartbeat_controllerregister_handlerConnectionControllerregister_status_listener)r[rlrnrprrrsrt __class__s r4riSocketClient.__init__s  ''1 !"" ., $2     #OO%  ++-)+*.&*;=)+ $<@ !113 #'==#9#9 OOA  4 4$  BF :ES9IEG"#5i#@ / 1$7$9! d778 245 d667 d334   99$?r3c ^URnURbMURRUR5 URR 5 SUlSUlUR R5H nU"SS5 M /UlSUl SUl SUl 0Ul/Ul SUl URRn0mSU4SjjnUR R#5(GdUbUS:GaUR$R'5Vs0sHnUcMUT;dMUTU_M snmUR$R'5GHn[(R("5nTR+X`R,US.5nXxS:aMAURbMURRUR5 URR 5 SUlSUl[/5UlURR1UR[2R45UlURR7UR85 UR;[=[>[AURBURD5S55 Sn Sn [GX`RH5upn U (aU (aU (a$U RJSRMS 5Ul'URRWS URN=(d S URBURDUU U 5 Xl!Xl"OqURRWS URN=(d S URBURDU5 UR;[=[XSU55 U"Xh5 GMbURRWS URN=(d S URBURDURBURD5 URR[URBURD45 [\R^"[\R`5n SU l1[\RdU l3U RiUR5UlSUl SUl5UR;[=[l[AURBURD5S55 URnRq5 URrRu5 URrRw5 URx(aMSUl<URRWSURN=(d S URBURD5 OEURR{SURN=(d S URBURD5 g UbUS:a{URRWSURN=(d S URBURDUR,UR$5 [(R"UR,5 U(aUS-nUR R#5(dUcGMUS:aGMUR R5 URRSURN=(d S URBURD5 [S5es snf![P[R[T4a GN8f=f![|[~4Gan SUl UR R#5(aRURRSURN=(d S URBURDU 5 [S5U eUR;[=[[AURBURD5S55 U"SURN=(d S URBURDUUS5 U"Xh5 URRVnSn A GMSn A ff=f)z;Initialize a socket to a Chromecast, retrying as necessary.NFrTcx>[R"5nX!S-US'[USS-S5US'UTU'g)z4Exponentional backoff for service name mdns lookups.delay next_retryi,N)timemin)rVretrynowretriess r4 mdns_backoff8SocketClient.initialize_connection..mdns_backoffsD ))+C"%g"6E,  w!!3S9E'N$GG r3)rrrsfnzutf-8z([%s(%s):%s] Resolved service %s to %s:%sz([%s(%s):%s] Failed to resolve service %sz[%s(%s):%s] Connecting to %s:%sz[%s(%s):%s] Connected!z%[%s(%s):%s] Connection reestablished!z?[%s(%s):%s] Failed to connect: %s. aborting due to stop signal.zFailed to connectz>[%s(%s):%s] Failed to connect to service %s, retrying in %.1fsrrz;[%s(%s):%s] Not connected, sleeping for %.1fs. Services: %sz*[%s(%s):%s] Failed to connect. No retries.)rVz!HostServiceInfo | MDNSServiceInforzdict[str, float]r_r`)Drnryr unregistercloserr~valuesr{rFr|r}rrrBerrorrxis_setrscopyrgetrr new_socketrrr settimeoutrp_report_connection_statusrSCONNECTION_STATUS_CONNECTINGrJrurOrrt propertiesdecodermAttributeErrorKeyError UnicodeErrorr= CONNECTION_STATUS_FAILED_RESOLVEconnectssl SSLContextPROTOCOL_TLS_CLIENTcheck_hostname CERT_NONE verify_mode wrap_socketrkCONNECTION_STATUS_CONNECTEDr update_statusrpingresetrinfoOSErrorrrCONNECTION_STATUS_FAILEDsleepr)r[rncallback_function retry_log_funrkeyrVrrrurO service_infocontexterrrs @r4initialize_connection"SocketClient.initialize_connections  ;; " MM $ $T[[ 1 KK   DK'+D $"&!8!8!?!?!A  eT *"B!""$  )) NP %6 %# % %))""$$%-519 ==--//C"(+w"WS\!/G  ==--/iik cJ|,,J6{{. 00= ))+&* 370",,DK/3}}/E/E Y%9%90D,KK**4<<822(8*499dii@  DD/D0,D '%*6*A*A%*H*O*OPW*X ))F GGMr II II#  %) $(  ))F GGMr II II# 66, @ $ '%W4!KK%%9 2    KK''DII(>?!nnS-D-DEG-2G**---G'")"5"5dkk"BDK&+DO(-D%22(7*499dii@ ,,::<--224--335,,05- ))4 GGMr II II  ((C GGMr II II  a0h}  !!QGGMrIIIIOOMM  4??+ Q))""$$%-519T   8 GGMr II II  ((;<<_X%3Hl#K% $%^ .6&*DOyy'')) ))] GGMr II II 88KLRUU22(4*499dii@ "X 2  g !0$(KK$5$5M96sX/\ :\  \ +D6]"#\%C] H)]%\>:]=\>>]a)D a$$a)cURR5 URSRS5 g![R a gf=f)z1Disconnect socket connection to Chromecast devicerxN)rxrrzsendryrr[s r4 disconnectSocketClient.disconnectsA   OOA  # #D )||   s;AAcvURURRU5 URU5 gz!Register a new namespace handler.N)rr>add registeredr[handlers r4rSocketClient.register_handlers- w(()--g64 r3cURUR;aDXRUR;a(URURRU5 UR5 gr)r>rremove unregisteredrs r4unregister_handlerSocketClient.unregister_handlersT    />>'*;*;<< NN7,, - 4 4W =r3c^TRUR:gnU(a(TRbTRTR5 URTlURTlUR TlU(GaTRb[ U4SjTR55(a_TRTR;aEUR[:Xa1TRRS5 [R"S5 TRH_nUTR;dMTRTR5 [!TRU5HnUR#5 M Ma ggg)z0Called when a new cast status has been received.Nc3@># UHoTR;v M g7fN)r).0r>r[s r4 /SocketClient.new_cast_status..sUATI/ATsz,Detected Audible connection. Sleeping for 1sr)rF transport_iddisconnect_channel namespacesr{r|anyrapp_idr rBr=rrr_ensure_channel_connectedrchannel_connected)r[rU new_channelr>rs` r4new_cast_statusSocketClient.new_cast_statuss'))V-@-@@ 4..:  # #D$7$7 8$//$11 ++ 4..: UATATUUU''t/B/BBMM[0 !!"PQ 1 "00 .2243F3FG#&t~~i'@#A113$B1;;r3cDU=RS- slUR$)zGenerates a unique request id.r)r}rs r4_gen_request_idSocketClient._gen_request_ids Ar3c$UR(+$)zY Returns True if the client is connected, False if it is stopped (or trying to connect). )rrs r4 is_connectedSocketClient.is_connecteds ??""r3c6URR5$)zJ Returns True if the connection has been stopped, False if it is running. )rxrrs r4 is_stoppedSocketClient.is_stopped s yy!!r3c UR5 URR5 URRS5 URR5(d8UR5S:XaO"URR5(dM8URRS5 UR'5 g![aA UR[[[ UR UR5S55 gf=f![aO SUlURR#SUR$=(d SUR UR5 Nf=f)z1Connect to the cast and start polling the socket.NzThread started...rTzF[%s(%s):%s] Unhandled exception in worker thread, attempting reconnectrzThread done...)rrrrSCONNECTION_STATUS_DISCONNECTEDrJrurOrrrBr=rxr _run_once Exceptionrk exceptionrm_cleanuprs r4runSocketClient.runs&   & & ( !!'') -.))""$$ >>#q()))""$$ *+ 7)   * * 2"499dii8     $(! %%\GGMrIIII  s%C 'D ADDAE10E1cjUR5(dgURceURR [ 5nUVVs1sHup4UiM nnnSnURU;a"UR(dUR5nUR4U;aUR6SR9S 5 UR"R%5(agU(dg[;U5nUR=Xg5 [>U;a@U[>UR@;a)UR@RCU[>5"SU5 g![a gf=f![ [4aWnURRSUR=(d SURURU5 SUl SnAgSnAff=fs snnf![ anUR"R%5(aFURR'SUR=(d SURUR5 OFURRSUR=(d SURURU5 SnAgSnAf[(R*aHnUR,[(R.:Xa$UR"R%5(aSnAgeSnAf[0aXnSUl URR3S UR=(d SURURU5 SnAGNSnAf[RaXnSUl URRS UR=(d SURURU5 SnAGNSnAff=f) z(Receive from the socket and handle data.rrNz$[%s(%s):%s] Error in select call: %srTz9[%s(%s):%s] Stopped while reading message, disconnecting.z9[%s(%s):%s] Interruption caught without being stopped: %sz[%s(%s):%s] %sz)[%s(%s):%s] Error reading from socket: %s)"_check_connectionrryrselectSELECT_TIMEOUTr?rrBrrmrurOrkr _read_messager*rxrrrSSLErrorerrno SSL_ERROR_EOFrr=rrzrecvrC_route_messager r~pop)r[readyexcr_can_readr@rAs r4rSocketClient._run_once2s ))++, {{&&& MM((8E',,eFCCe,  # #x /8I8I) ,,.T  # #x / OOA  # #C ( 99    *'2 G*  $z"2d6M6M"M  # # ' 'Z(8 9$ Eu)  G$  KK  6 2    !%D  - ! 99##%%KK$$S 2  KK%%S 2   << 99 1 11yy'')) - $(! !!$GGMrIIII << $(! !!?GGMrIIII  stEE G G EEG/A GG N2B+J  N2 =K#"K## N20A MN2A N--N2c SnUR(aHURRSUR=(d SURUR 5 SnOfUR R5(aGURRSUR=(d SURUR 5 SnU(aURR5 URHnURU5 M UR[[[!URUR 5S55 UR#5 gg![$a UR&R)5 gf=f)z Checks if the connection is active, and if not reconnect :return: True if the connection is active, False if the connection was reset. Fz[%s(%s):%s] Forced reconnectionrTz3[%s(%s):%s] Heartbeat timeout, resetting connectionN)rkrBr=rmrurOr is_expiredrr disconnectedrrrrSCONNECTION_STATUS_LOSTrJrrrxr)r[rchannels r4rSocketClient._check_connections+    KK  1 2    E  & & 1 1 3 3 KK  E 2    E   $ $ 1 1 3..''0/  * * *N499dii,PRV   **,-   sE$E?>E?c jURUR;GaTUR[:wd8URRR [ R5(aOURRSUR=(d SURUR[X55 [URUR5HnURX5nU(dvUR[ 5UR";aQURRSUR=(d SURUR[X55 MMM gURRSUR=(d SURUR[X55 g![$ah URR'SUR=(d SURUR[)U5R*[X55 GMXf=f)z6Route message to any handlers on the message namespacez[%s(%s):%s] Received: %srz![%s(%s):%s] Message unhandled: %szG[%s(%s):%s] Exception caught while sending message to controller %s: %sz*[%s(%s):%s] Received unknown namespace: %sN)r>rrrrB isEnabledForr;DEBUGr=rmrurOrGrreceive_messagerr r~rrtyper-)r[r@rArhandleds r4rSocketClient._route_messages    .!!\1,,33@@OO !!.GGMrIIII&w5 t~~g.?.?@A%55gDG"88J/t7N7NN KK-- C $ 2 $ $ 27 A O# B6 KK  < 2  "71  ! KK))0 2  W ..*79   sB GA-H21H2c JURHnURU5 M URR 5H&n[ U5HnUR 5 M M( URbURR5 UR[[ [#URUR5S55 UR$SR5 UR$SR5 UR&R5 SUlg![a GM-f=f![a Mf=f![aI URRSUR=(d SURUR5 GNf=f)z"Cleanup open channels and handlersNz[%s(%s):%s] _cleanuprrrT)rrrrrr tear_downryrrBrrmrurOrrSrrJrzrr)r[rhandlersrs r4rSocketClient._cleanupsS**G ''0+ --/Hx=%%')0 ;; "  !!# && .tyy$))4     "   " ;  !   %%*DGGMr499dii s6D,D>8E, D;:D;> E  E AF"!F"c URHynURRSUR=(d SURUR [ U5[U5RU5 URU5 M{ g![aI URRSUR=(d SURUR 5 Mf=f)z9Report a change in the connection status to any listenersz+[%s(%s):%s] connection listener: %x (%s) %srz=[%s(%s):%s] Exception thrown when calling connection listenerN) rrBr=rmrurOidrr-r\rr)r[rUlisteners r4r&SocketClient._report_connection_statuss22H  !!AGGMrIIIIxLN++..v63  %%SGGMrIIII  sA5B  ACCcURce/nSnX1:aURR5(a [S5eURR [ X- S55nUS:Xa [ S5eURU5 U[U5- nX1:aMSRU5$![aI URRSUR=(d SURUR5 Mf=f)zRead bytes from the socket.rz!Stopped while reading from socketir3zConnection was closed by remotez0[%s(%s):%s] timeout in : _read_bytes_from_socketr)ryrxrr*rrrappendlen TimeoutErrorrBr=rmrurOjoin)r[msglenchunks bytes_recdchunks r4_read_bytes_from_socket$SocketClient._read_bytes_from_socket/s{{&&& !yy!!#$GHH  ((V-@$)GHC<45VWW e$c%j( !"xx   !!FGGMrIIII   sAB33ADDcURS5n[SU5SnURU5n[5nURU5 U$)z=Reads a message from the socket and converts it to a message.>Ir)r,rrParseFromString)r[ payload_inforead_lenpayloadr@s r4rSocketClient._read_messageIsQ33A6 $ -a0..x8-(r3FN)inc_session_idrno_add_request_idforcec URU5 U(dUR5nX['U(aURU['[ 5n U R U lURU lXl [ RU l X)l [R"USS9U l[!SU R#55n U R[$:wd8UR&R(R+[,R.5(aOUR(R1SUR2=(d SUR4UR6[9X55 U(d:UR:R=5(aU(a U"SS5 [?S5eUR@(dsURB(dbURDceU(aU(dXPRFW'O U"SS5 URDRIXRK5-5 gU(a U"SS5 [SS UR4S UR6S 35e![DRLan U(a U"SS5 U(dURFROWS5 SUl!UR(RQS UR2=(d SUR4UR6U 5 Sn A gSn A ff=f) z!Send a message to the Chromecast.F) ensure_asciir0z[%s(%s):%s] Sending: %srNz"Socket client's thread is stopped.Tz'[%s(%s):%s] Error writing to socket: %sz Chromecast :z is connecting...)*rrr r|r r CASTV2_1_0protocol_versionrErFSTRING payload_typer>r6dumpsr8rByteSizerrrBrr;rr=rmrurOrGrxrrrrkryr~sendallSerializeToStringrrwarningr) r[rFr>rAr6rr7r8 request_idmsgbe_sizer s r4 send_messageSocketClient.send_messageXs;$ &&~6 --/J)  #D m"~~ +&--! ::d?tS\\^, MM\ )((//<O// ;)$5 ##G.C.C.E$EF!!%.TYYKq CTUV V!<< $%eT2(++// DA$(! ##=GGMrIIII  sAI""L6BK;;Lr6rr7c 2UR[UUUUUS9$)z0Helper method to send a message to the platform.rJ)rHr r[r>r@r6rr7s r4send_platform_message"SocketClient.send_platform_messages.  #  )// !  r3c  XR;a:U(a U"SS5 [SUSSRUR535eURcU(a U"SS5 [ S5eUR URUUUUUS9$)z7Helper method to send a message to current running app.FNz Namespace z0 is not supported by current app. Supported are z, z8Attempting send a message when destination_id is not setrJ)r{rr'rFrrHrLs r4send_app_messageSocketClient.send_app_messages // / !%.&YK(!!%4+>+>!? @B     & !%.J       )// !  r3c:URRU5 g)zRegister a connection listener for when the socket connection changes. Listeners will be called with listener.new_connection_status(status)N)rr$)r[r!s r4register_connection_listener)SocketClient.register_connection_listeners ""))(3r3cXR;aIURRU5 URU[[[ S0SSSSSSSS S S .0S S 9 gg)z-Ensure we opened a channel to destination_id.origin userAgent PyChromecast senderInforz 15.605.1.3z 44.0.2403.30r/z Macintosh; Intel Mac OS X10_10_3r)sdkTypeversionbrowserVersionplatform systemVersionconnectionTypeT)r7N)rr$rH NS_CONNECTIONr TYPE_CONNECTr[rFs r4r&SocketClient._ensure_channel_connectedss !4!4 4    & &~ 6    ,b #$#/*8$%)K*+ # #'!   5r3cXR;aPURU[[[S00SSS9 URRU5 UR5 gg![ a N9[ aH URRSUR=(d SURUR5 Nf=f)z)Disconnect a channel with destination_id.rVT)r7r8z[%s(%s):%s] ExceptionrN)rrHr`r TYPE_CLOSErrrBrrmrurOrhandle_channel_disconnectedrbs r4rSocketClient.disconnect_channels 00 0 !!"!!:x<&* "    & &~ 6  , , .% 1    %%+TWW]DIItyy s#A!! B>-AB>=B>cURHCnXR;dM[URU5HnUR5 M ME /UlSUlSUlg)z%Handles a channel being disconnected.N)r{rrchannel_disconnectedrFr|)r[r>rs r4rf(SocketClient.handle_channel_disconnectedsY,,INN*"4>>)#<=G002 >- !"r3) rrkrrr~r}r{rlrrjrFrrmrrurBrrOrrrrrrsr|ryrzrErxrprnrrt)rlrLrnrNrp float | Nonerrrkrsz&set[HostServiceInfo | MDNSServiceInfo]rtzzeroconf.Zeroconf | Noner_r`r_r`)rrr_r`)rUrr_r`)r_int)r_bool)r@rrAr:r_r`r^)r(rmr_bytes)r_r)rFrLr>rLrAr:r6rnrCallbackType | Noner7rnr8rnr_r`) r>rLr@r:r6rnrrpr7rnr_r`)r!rXr_r`)rFrLr_r`) r-r.r/r0r1rirrrrrrpropertyrrrrrrrrr,rrHrMrPrSrrrfr2 __classcell__rs@r4rdrds8?@?@ ?@  ?@ ! ?@9?@(?@ ?@BX= X=t! 4> ##""BaF)V3j"H, 4 * %15"'SWSWSW SW  SW/SW SWSW SWt %15"'     /      0 %15"'        /        D4 0/,  r3rdc:^\rSrSrSrSU4SjjrSSjrSrU=r$)ri"z-Controller to respond to connection messages.c,>[TU][5 gr)rhrir`)r[rs r4riConnectionController.__init__%s 'r3cURc[eURR(agU[[:XaJURR UR 5 URRR5 gg)z^ Called when a message is received. data is message.payload_utf8 interpreted as a JSON dict. TF) _socket_clientrrr rerrErr)r[r@rAs r4r$ConnectionController.receive_message(so    &) )    ) )   +    2 273D3D E    3 3 A A Cr3r,rl)r@rrAr:r_rn) r-r.r/r0r1rirr2rrrss@r4rr"s7(r3rc[R"[R[R5nUR[R[R S5 [R nUR[RUS5 U$![[R4a*nUR[R:waeSnAU$SnAff=f![a U$f=f)z Create a new socket with OS-specific parameters Try to set SO_REUSEPORT for BSD-flavored systems if it's an option. Catches errors if not. rN) ryAF_INET SOCK_STREAM setsockopt SOL_SOCKET SO_REUSEADDR SO_REUSEPORTrrr ENOPROTOOPTr)new_sock reuseportrs r4rr@s}}V^^V-?-?@H ))6+>+>B ''      1 19a @ O & yyE---. O      O s*$C5!BC2CC C-,C-)r@rr_r:r)r@rrAz dict | Noner_rL)r_z socket.socket)Nr1 __future__rrarr6r;rryrrvr collectionsr dataclassesrstructrrzeroconfconfigr constr r r r controllersrrcontrollers.heartbeatrrcontrollers.mediarcontrollers.receiverrrrdialrrrrrrrrgenerated.cast_channel_pb2rmodelsrrr`rare TYPE_LOADrrrrrrrrorqrr*rCrGrJrSABCrXThreadrdrrr,r3r4rsV#   #!PP5D.TT'44:     ,)!/##3   4I42        $ $666)sww)U9##%7Up><r3