SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSK J!r! SSK J"r" SSK#r#SSK$r$SSK%J&r& \"RNRQ5(dSSK)r)OSSKJ*r* Sr+"SS\RX5r-"SS\RX5r.Sr/Sr0S5Sjr1Sr2Sr3S r4S!r5S"r6S#r7"S$S%\85r9S6S&jr:S'r;S(r"S+S,\85r?"S-S.\85r@"S/S0\85rA"S1S25rB"S3S45rCg)7z7Tunnel TCP traffic over Cloud IAP WebSocket connection.)absolute_import)division)unicode_literalsN)iap_tunnel_websocket)iap_tunnel_websocket_utils) sg_tunnel)sg_tunnel_utils) exceptions)execution_utils) http_proxy)log) properties) transport)creds)store)files) platforms)queue)wintypesc\rSrSrSrg)LocalPortUnavailableError<N__name__ __module__ __qualname____firstlineno____static_attributes__r4lib/googlecloudsdk/command_lib/compute/iap_tunnel.pyrr<r!rc\rSrSrSrg)UnableToOpenPortError@rNrrr!r"r%r%@r#r!r%cLURSSSS9 URSSSSSS 9 g) Nz--iap-tunnel-url-overrideTzFAllows for overriding the connection endpoint for integration testing.)hiddenhelp2--iap-tunnel-insecure-disable-websocket-cert-checkF store_truez;Disables checking certificates on the WebSocket connection.)defaultactionr(r) add_argumentparsers r" _AddBaseArgsr2DsE!    :   H Jr!c<[U5 URSSSS9 g)Nz--tunnel-through-iapr+z Tunnel the ssh connection through Cloud Identity-Aware Proxy for TCP forwarding. To learn more, see the [IAP for TCP forwarding documentation](https://cloud.google.com/iap/docs/tcp-forwarding-overview). )r-r))r2r/)r1tunnel_through_iap_scopes r"AddSshTunnelArgsr5Rs(v''  (  r!cUR5nURSSSSS9 U(a7URSS9n[URSS95 UR5n[U5 g)z8Add the arguments for supporting host-based connections.z--regionNTzDConfigures the region to use when connecting via IP address or FQDN.r,requiredr))mutex)r()add_argument_groupr/AddSecurityGatewayTunnelArgsAddOnPremTunnelArgs)r1support_security_gatewaygroup group_mutexs r"AddHostBasedTunnelArgsr@`sw  # # %%  ***6K !?!?t!?!LM  * * ,Eer!cLURSSSSS9 URSSSSS9 g) z7Add the arguments for supporting IP/FQDN-based tunnels.z --networkNTzIConfigures the VPC network to use when connecting via IP address or FQDN.r7z --dest-groupFOConfigures the destination group to use when connecting via IP address or FQDN.r.r0s r"r<r<rsF     !r!cNURSSSSS9 URSSSSS S 9 g) z,Add arguments for the Security Gateway path.z--security-gatewayNTz7Configure the security gateway resource for connecting.r7z--use-dest-groupFr+rB)r,r-r8r)r.r0s r"r;r;sH D F     !r!c[U5 gN)r2r0s r"AddProxyServerHelperArgsrFs vr!c[US5(dg[USS5(agURS5(aUR(dgO'U(ag[R R S5 [5nURUl URUl URUl URUl [X5 U$)aConstruct an SshTunnelArgs from command line args and values. Args: args: The parsed commandline arguments. May or may not have had AddSshTunnelArgs called. track: ReleaseTrack, The currently running release track. instance_ref: The target instance reference object. external_interface: The external interface of target resource object, if available, otherwise None. Returns: SshTunnelArgs or None if IAP Tunnel is disabled. tunnel_through_iapN internal_ipFzEExternal IP address was not found; defaulting to using IAP tunneling.)hasattrgetattr IsSpecifiedrHr statusPrint SshTunnelArgsprefixtrackprojectzoneinstance_AddPassThroughArgs)argsrQ instance_refexternal_interfaceress r"CreateSshTunnelArgsrZs + , ,  T=%((  *++  " "  #  JJ&' #ll#)$$#+   #(&&#,d *r!c[5nURUl[RR R R5UlURUlURUl X#l [X5 U$)a-Construct an SshTunnelArgs from command line args and values for on-prem. Args: args: The parsed commandline arguments. May or may not have had AddSshTunnelArgs called. track: ReleaseTrack, The currently running release track. host: The target IP address or FQDN. Returns: SshTunnelArgs. ) rOrPrQrVALUEScorerR GetOrFailregionnetworkrTrU)rVrQhostrYs r"CreateOnPremSshTunnelArgsrbs` #ll#)!!&&..88:#+{{#* #+,d *r!cVURS5(a(URRSUR-5 UR(aURRS5 UR S5(a)URRSUR -5 gg)zAdds any passthrough args to the SshTunnelArgs. Args: args: The parsed commandline arguments. May or may not have had AddSshTunnelArgs called. ssh_tunnel_args: SshTunnelArgs, The SSH tunnel args to update. iap_tunnel_url_overridez--iap-tunnel-url-override=r* dest_groupz --dest-group=N)rLpass_through_argsappendrd0iap_tunnel_insecure_disable_websocket_cert_checkIsKnownAndSpecifiedre)rVssh_tunnel_argss r"rUrUs /00%%,,$t'C'CCE ::%%,,<> l++%%,,_t-NO,r!c6\rSrSrSrSrSrSrSrSr Sr g ) rOaA class to hold some options for IAP Tunnel SSH/SCP. Attributes: track: str/None, the prefix of the track for the inner gcloud. project: str, the project id (string with dashes). zone: str, the zone name. instance: str, the instance name (or IP or FQDN for on-prem). region: str, the region name (on-prem only). network: str, the network name (on-prem only). cloud_run_args: dict, The fields required to construct Cloud Run SshTunnelArgs. If present, this field should contain fields for 'deployment_name', 'workload_type', and 'project_number'. Optionally can contain 'instance_id' and 'container_id'. pass_through_args: [str], additional args to be passed to the inner gcloud. ctSUlSUlSUlSUlSUlSUlSUl/Ulg)N)rQrRrSrTr_r`cloud_run_argsrfselfs r"__init__SshTunnelArgs.__init__s<DJDLDIDMDKDLDDr!cURURURURURUR UR UR4$rE)rQrRrSrTr_r`rfrorps r"_MembersSshTunnelArgs._Members sH          r!cDUR5UR5:H$rErurqothers r"__eq__SshTunnelArgs.__eq__s ==?enn. ..r!c X:X+$rErrys r"__ne__SshTunnelArgs.__ne__s  r!c,SUR5<S3$)NzSshTunnelArgs<>rxrps r"__repr__SshTunnelArgs.__repr__s"&--/ 33r!)rorTr`rfrRr_rQrSN) rrrr__doc__rrrur{r~rr rr!r"rOrOs    /4r!rOcU(d[R"5n[R"U5(d[SU-5eU$)Nz!Local port [%d] is not available.) portpickerpick_unused_port is_port_freer)port_args r"DetermineLocalPortr"sA **,H   * * #$G$,%- .. /r!cU(a2UR[R5 UR 5 gg![a Nf=f![a gf=f)z8Callback function to close the local connection, if any.N)shutdownsocket SHUT_RDWREnvironmentErrorclose) local_conns r"_CloseLocalConnectionCallbackr+s_ &**+         s ;A AA AAcFU(dg[R"S[R"U55 U [R "U5 [ R"U5(aURsSSS5 $URsSSS5 $!,(df  g=f)zACallback function to refresh credentials and return access token.Nz5credentials type for _GetAccessTokenCallback is [%s].) r debugsix text_typerRefreshIfAlmostExpirerIsGoogleAuthCredentialstoken access_token) credentialslocks r"_GetAccessTokenCallbackr=sl  )) C MM+ &(   , $$[11     t  % %  tts=B= B B c6U(aURU5 ggrE)send)rdatas r"_SendLocalDataCallbackrMsOODr!c/n[R"X[R[RS[R5HnUupEpgn[R"XEU5n [ RR5(d/U R[R[RS5 U RU5 U RS5 URU 5 M U(aU$[#SU-5e![R a Mf=f![a2 U R!5 M![R a GMf=ff=f)zGAttempt to open a local socket(s) listening on specified host and port.rz#Unable to open socket on port [%d].)r getaddrinfo AF_UNSPEC SOCK_STREAM AI_PASSIVEerrorrOperatingSystem IsWindows setsockopt SOL_SOCKET SO_REUSEADDRbindlistenrgrrr%) local_host local_port open_socketsrYafsocktypeprotounused_canonname sock_addrss r"_OpenLocalTcpSocketsrSs',   f..0B0BA c8;4B%9 --e ,a   & & 0 0 2 2 V&&(;(;Q?ffYhhsm!, C() **' <<     \\    s=D )BD$ D! D!$ E /EEE EE c\rSrSrSr"SS\5r"SS\5r"SS5r "S S 5r "S S 5r S r Sr SrSrSrSrSrSrSrSrSrg) _StdinSocketiszA wrapper around stdin/out that allows it to be treated like a socket. Does not implement all socket functions. And of the ones implemented, not all arguments/flags are supported. Once created, stdin should never be accessed by anything else. c*\rSrSrSrSrSrSrSrg) _StdinSocket._StdinSocketMessagei{zHA class to wrap messages coming to the stdin socket for windows systems.cXlX lgrE)_type_data)rq message_typers r"rr)_StdinSocket._StdinSocketMessage.__init__~s jjr!cUR$rE)rrps r"GetData(_StdinSocket._StdinSocketMessage.GetData ZZr!cUR$rE)rrps r"GetType(_StdinSocket._StdinSocketMessage.GetTyperr!)rrN) rrrrrrrrrr rr!r"_StdinSocketMessager{sRr!rc\rSrSrSrg)_StdinSocket._EOFErrorirNrrr!r" _EOFErrorrr!rc\rSrSrSrg)$_StdinSocket._StdinClosedMessageTypeirNrrr!r"_StdinClosedMessageTyperrr!rc\rSrSrSrg)"_StdinSocket._ExceptionMessageTypeirNrrr!r"_ExceptionMessageTyperrr!rc\rSrSrSrg)_StdinSocket._DataMessageTypeirNrrr!r"_DataMessageTyperrr!rcbSUl[RUl[R R 5(ai[R"5Ul [R"URS9Ul SURlURR5 g[ R "["R$[ R&5Ul[ R "["R$[ R*UR([,R.-5 g)NF)targetT) _stdin_closedutilsSUBPROTOCOL_MAX_DATA_FRAME_SIZE_bufsizerrrrQueue_message_queue threadingThread&_ReadFromStdinAndEnqueueMessageWindows_reading_threaddaemonstartfcntlsysstdinF_GETFL _old_flagsF_SETFLos O_NONBLOCKrps r"rr_StdinSocket.__init__sD99DM  **,,"KKMd&--<<>d$(d!   " CIIu}}=do kk#))U]]DOObmm,KLr!c[RR5(d?[R"[R [R UR5 ggrE)rrrrrrrrrps r"__del___StdinSocket.__del__s:  $ $ . . 0 0 kk#))U]]DOO< 1r!c[R"[RU5 [R (d([RR R5 [U5$rE) rWriteStreamBytesrstdoutrPY2bufferflushlen)rqrs r"r_StdinSocket.sends? 3::t, 77 jj t9r!c[RR5(aURU5$UR U5$)aReceives data from stdin. Blocks until at least 1 byte is available. On Unix (but not Windows) this is unblocked by close() and shutdown(RD). On all platforms a signal handler triggering an exception will unblock this. This cannot be called by multiple threads at the same time. This function performs cleanups before returning, so killing gcloud while this is running should be avoided. Specifically RaisesKeyboardInterrupt should be in effect so that ctrl-c causes a clean exit with an exception instead of triggering gcloud's default os.kill(). Args: bufsize: The maximum number of bytes to receive. Must be positive. Returns: The bytes received. EOF is indicated by b''. Raises: IOError: On low level errors. )rrr _RecvWindows _RecvUnix)rqbufsizes r"recv_StdinSocket.recvs9(  **,,   w '' ^^G $$r!cBUR[R5 grE)rrSHUT_RDrps r"r_StdinSocket.closes MM&..!r!cU[R[R4;acSUl[R R 5(a8URURS5nURRU5 ggg)NTr!) rrrrrrrrrrput)rqhowmsgs r"r_StdinSocket.shutdownsn v00d  " " , , . .&&t'C'CSI $ / 1r!cHUR(Gd7[RRR S5n[R "UR 5n[R"5n[RRRXUR [R"U5S5nU(d%[R"[RS5eURSUR nUR"R%UR'UR(U55 UR(dGM6gg![*aK UR"R%UR'UR,[.R0"555 gf=f)zReads data from stdin on Windows. This method will loop until stdin is closed. Should be executed in a separate thread to avoid blocking the main thread. iNzstdin ReadFile failed)rctypeswindllkernel32 GetStdHandlecreate_string_bufferrrDWORDReadFilebyrefrrerrnoEIOrawvaluerrrr Exceptionrrexc_info)rqhbufnumber_of_bytes_readokrs r"r3_StdinSocket._ReadFromStdinAndEnqueueMessageWindowss/4""" MM " " / / 4))$--8'~~/ ]] # # , , DMM6<<0D#EtM UYY(?@ @gg1+112  8 89N9N9<!> ?""" 4   " "4#=#=#&<<> 344sEE AF! F!cU[R:wa[R"SU5 UR(dUR R SS9nUR5nUR5nX0RLa![R"USUSUS5 X0RLaSUlU$g![Ra Mf=f)zReads data from stdin on Windows. Args: bufsize: The maximum number of bytes to receive. Must be positive. Returns: The bytes received. EOF is indicated by b''. Raises: socket.error: On low level errors. 'bufsize [%s] is not max_data_frame_sizer)timeoutrTr!)rrr inforrgetrEmptyrrrrreraiser)rqrrmsg_typemsg_datas r"r_StdinSocket._RecvWindowss%777 hh8'B   !!%%a%0 hh // / HQK!hqk: 11 1! o ![[sB>>CCcU[R:wa[R"SU5 UR(agUR(dS[ R "[ R/SS[5nUS(dMIURUR5$g![Ra SUlgf=f)aReads data from stdin on Unix. Args: bufsize: The maximum number of bytes to receive. Must be positive. Returns: The bytes received. EOF is indicated by b''. Once EOF has been indicated, will always indicate EOF. Raises: IOError: On low level errors. rr!rrT) rrr r!rselectrrREAD_FROM_STDIN_TIMEOUT_SECS_ReadUnixNonBlockingrrr)rqr stdin_readys r"r_StdinSocket._RecvUnix!s%777 hh8'B    ""mmSYYKR$@B 1~ ((77 #   ! ! d  sA#B%%CCc[R(a [RR U5nO*[RR R U5nUS:Xa[ReUcSnU$![ aHnUR[R:Xd[U[R5(aSnAgeSnAff=f)a Reads from stdin on Unix in a nonblocking manner. Args: bufsize: The maximum number of bytes to receive. Must be positive. Returns: The bytes read. b'' means no data is available. Raises: _StdinSocket._EOFError: to indicate EOF. IOError: On low level errors. Nr!)rrrrreadrIOErrorrEAGAIN isinstanceioBlockingIOErrorrr)rqrbes r"r+!_StdinSocket._ReadUnixNonBlockingBs  IINN7 # II   ! !' * Cx  " ""y a H%   ELL Jq"2D2D$E$E   s"4A>)A>> C=C  C  C)rrrrrN)rrrrrobjectrrrrrrrrrrrrrrrrr+r rr!r"rrssr F  )       M$=%2" %42$LB% r!rcB\rSrSrSrS SjrSrSrS SjrSr Sr g ) SecurityGatewayTunnelHelperijz5Helper class for starting a Security Gateaway tunnel.cURUlURUlX lX0lX@lXPlX`lXpl SUl [R"SS9Ul [R"5UlgNFT)use_google_auth)rd_tunnel_url_overriderh _ignore_certs_project_region_security_gateway_host_port_use_dest_group _shutdownr LoadIfEnabled _credentialrLock_credential_lock)rqrVrRr_security_gatewayraportuse_dest_groups r"rr$SecurityGatewayTunnelHelper.__init__msi!% < rErqr`s r"rP*SecurityGatewayTunnelHelper._GetTargetInfosr,,.J W-j  - - ||// ZZ ZZ..++  r!c2ASnURU[R"[URUR 5U5nUR (dUR5(dwUR[R5nU(d[R"SU5 O9URU5 UR (dUR5(dMw[R "SU5 U(a/UR#[R$5 UR'5 U(a(UR)5 [R*"SU5 gg![Ra!n[R"SX'5 SnANSnAff=f![R "SU5 U(a/UR#[R$5 UR'5 U(a(UR)5 [R*"SU5 ff=f)aEReceive data from provided local connection and send over HTTP CONNECT. Args: local_conn: A socket or _StdinSocket representing the local connection. socket_address: A verbose loggable string describing where conn is connected to. user_agent: The user_agent of this connection conn_id: The id of the connection. Nz!Local connection [%s] has closed.z3Error while transmitting local connection [%s]: %s z2Terminating connection from local connection: [%s]zConnection [%s] closed.)rYrRrSrrHrJrF ShouldStoprrrr warningSendrrr!rrrCloser)rqrsocket_addressrVconn_idsg_connrr6s r"RunReceiveLocalData/SecurityGatewayTunnelHelper.RunReceiveLocalDatas G=((    %t'7'79N9N   g7#5#5#7#7uDDE ++9> J  T 7#5#5#7#7 hhC FNN+   +^<  <<# iiE### hhC FNN+   +^< s7B$E )F*7E F4F FFFA>HcSUlgNTrFrps r"rk!SecurityGatewayTunnelHelper.Closes DNr!) rHrJrCr?rDr@rArBrFr>rENF) rrrrrrrrYrProrkr rr!r"r:r:js)=$-&   #%&=Pr!r:cH\rSrSrSrS SjrSrS SjrSrS Sjr S r g) IAPWebsocketTunnelHelperiz2Helper class for starting an IAP WebSocket tunnel.Nc (X lURUlURUlX0lX@lXPlX`lXpl Xl Xl Xl SUl [R"SS9Ul["R$"5Ulgr<)r@rd_iap_tunnel_url_overriderhr?_zone _instance _interfacerDrA_networkrC _dest_grouprFrrGrHrrIrJ) rqrVrRrSrT interfacerLr_r`rares r"rr!IAPWebsocketTunnelHelper.__init__swM$($@$@D!NNDJNOJLMJ!DN**4@D%NN,Dr!cSUlgrrrsrps r"rkIAPWebsocketTunnelHelper.Closes DNr!c UR5n[R"XR[R"[ U5[R"[ U5X0RUS9nUR5 U$)N) ignore_certsrm) _GetTunnelTargetInforIapTunnelWebSocketrRrSrrr?rT)rqrrUrVrm tunnel_target new_websockets r"rY,IAPWebsocketTunnelHelper._InitiateConnectionse--/M(;;0*=7D!3!3 M $$& r!c^[R"5n[U5(aU"SS9n[R"UR UR URURURURUURURURURSS9 $)Nr\r]) rRrSrTrrLr_r`r_r`rarero)r rarbrIapTunnelTargetInfor@r|r}r~rDr{rArrCrres r"r-IAPWebsocketTunnelHelper._GetTunnelTargetInfos,,.J W-j  $ $ ZZ// ZZ22|| ZZ##  r!cSnURU[R"[URUR 5UUS9nUR (dUR[R5nU(dTUR5 [R"SU5 UR5(d[R"SXB5 O$URU5 UR (dMUR (a[R("SXB5 O[R("SXB5 UR+5 U(aUR/5 gg![ ["R$4a"n[R&"SUX'5 SnANSnAff=f![,a Nef=f![,["R$4a gf=f!UR (a[R("SXB5 O[R("SXB5 UR+5 O![,a Of=fU(aUR/5 ff![,["R$4a ff=f=f)a8Receive data from provided local connection and send over WebSocket. Args: conn: A socket or _StdinSocket representing the local connection. socket_address: A verbose loggable string describing where conn is connected to. user_agent: The user_agent of this connection conn_id: Id of the connection. Nrmz+[%d] Received local EOF, closing connectionz'[%d] Failed to send all data from [%s].z.[%d] Error during local connection to [%s]: %sz$[%d] Terminating connection to [%s].z([%d] Client closed connection from [%s].)rYrRrSrrHrJrFrrrLocalEOFr rWaitForAllSentrirjrr Error exceptionr!rrrk)rqconnrlrVrmwebsocket_connrr6s r"ro,IAPWebsocketTunnelHelper.RunReceiveLocalDatas N' //    %t'7'79N9N   0nyy>>?  ! ! # ))A7 K..00 KKA 1 D!  7 * ; *         z'' (' mmDg"'''    0 0 1     7 * ; *            0 0 1   sC EG "E4FF-F8FG FG  F*)F*-G  G  AI*H I* H-*I*,H--I*1I I* I'$I*&I''I*)rHrJrrCr{r?r}r~rrDr@rArFr|)NNNNNNNNrvr) rrrrrrrrkrYrror rr!r"ryrys,:?C@D-*/1 &2 r!rycN\rSrSrSrSrSrSrSrSr Sr S r S r S r S rg )IapTunnelProxyServerHelperi9z@Proxy server helper listens on a port for new local connections.c^X@lXlX lX0l/Ul/UlSUlg)Nr) _tunneler _local_host _local_port_should_test_connection_server_sockets _connections_total_connections)rqrrshould_test_connectiontunnelers r"rr#IapTunnelProxyServerHelper.__init__<s1N!!#9 DDDr!c$UR5 grE)_CloseServerSocketsrps r"r"IapTunnelProxyServerHelper.__del__Fsr!cnUR(aUR5 [ URUR5Ul [RRSUR-5 [R"5 URR!UR#55 UR%5 M;![Ra2n[R"S[R "U5-5eSnAff=f!,(df  O)=f![&a [R("S5 Of=fUR+5 O!UR+5 f=fUR,R/5 UR15 [R2RS5 g)zStart accepting connections.z.While checking if a connection can be made: %sNzListening on port [%d].Keyboard interrupt received.zServer shutdown complete.)r_TestConnectionrConnectionCreationErrorrrrrrrr outrNr RaisesKeyboardInterruptrrg_AcceptNewConnection_CleanDeadClientConnectionsKeyboardInterruptr!rrrk_CloseClientConnectionsrM)rqr6s r"RunIapTunnelProxyServerHelper.RunIsN ##Q 00@0@040@0@BDGGMM+d.>.>>? !  2 2 4    " "4#<#<#> ?  * * , " 9 9Q":: > - -  # NN & & NN   D JJLr!cbS/nUS(d/[R"URSSS5nUS(dM/USnUSR5up4[R"UR X4UR 4S9nSUlUR5 U=R S- slXS4$)z@Accept a new socket connection and start a new WebSocket tunnel.rrg?)rrVTr) r)racceptrr_HandleNewConnectionrrr)rq ready_socketsready_read_socketsrrl new_threads r"r/IapTunnelProxyServerHelper._AcceptNewConnectionvs DMAmmD$8$8"b#FmA'q)-a0779D!!)B)B(,(,(?(?(ABJJq   r!c[R"S5 URHnUR5 M g![a gf=f)NzStopping server.)r rrrr)rq server_sockets r"r.IapTunnelProxyServerHelper._CloseServerSocketssBII ! //-0    s#< A A c&UR(aoSnURH2up#UR5(dMUS- nUR5 M4 U(a#[R R SU-5 ggg![a Mof=f)z4Close client connections that seem to still be open.rrz Closed [%d] local connection(s).N)ris_aliverrr rMrN)rq close_count client_threadrs r"r2IapTunnelProxyServerHelper._CloseClientConnectionss k!%!2!2 -  ! ! # #  +  JJL "3  ;kIJ "   sB BBc/nUR(aSnURHFup4UR5(dUS- nUR5 AAM4UR X4/5 MH U(a[ R "SU-5 Xl[R"S5 [ R "S[UR5-5 gg![a Nf=f)zEErase reference to dead connections so they can be garbage collected.rrz Cleaned [%d] dead connection(s).r zconnections alive: [%d]N) rrrrrgr rgccollectr)rqconn_still_alivedead_connectionsrrs r"r6IapTunnelProxyServerHelper._CleanDeadClientConnectionss !%!2!2 -%%'' a    JJL  ! !="7 8"3  47GGH, jjm ii)C0A0A,BBC)"   sC C#"C#c,[R"5nURRU[ U5XCS9 g![ a5n[ R"S[R"U55 SnAgSnAf [ R"S5 g=f)Nrz.Socket error [%s] while receiving from client.z"Error while receiving from client.) rrrroreprrr r!rrr)rqrrlrmrVr6s r"r/IapTunnelProxyServerHelper._HandleNewConnectionsv:002j nn((tN/C)3)F ! hh?}}Q!!: mm89s9< B+A66B)rrrrrrrN)rrrrrrrrrrrrrrrr rr!r"rr9s4H 28"*  KD2 :r!rc$\rSrSrSrSrSrSrg)IapTunnelStdinHelperiz9Facilitates a connection that gets local data from stdin.cXlgrEr)rqrs r"rrIapTunnelStdinHelper.__init__sNr!c$[R"5 [R"5nURR [ 5SU5 SSS5 g!,(df  g=f![a [R"S5 gf=f)zExecutes the tunneling of data.rNr) r rrrrrorrr r!)rqrVs r"rIapTunnelStdinHelper.Runsd /  2 2 4 224  **<>7JO 5 4 4 / hh-./s.A,;AA, A)%A,)A,, BBrN)rrrrrrrrr rr!r"rrsA /r!rrur)Dr __future__rrrr rrRrr3rr)rrrgooglecloudsdk.api_lib.computerrrrr rcgooglecloudsdk.corer r r r rrgooglecloudsdk.core.credentialsrrgooglecloudsdk.core.utilrrrr six.movesrrrrrr*rrr%r2r5r@r<r;rFrZrbrUr8rOrrrrrrr:ryrrrr!r"rsF >&'  ?N4F*/*#*)11*.   **,,  0 0J,, J  $!$!"* Z 0P$/4F/4d $ &  *@t 6t n]&]@l vl ^J:J:Z//r!