gddlZddlZddlmZmZmZmZdZdZdZ dZ GddZ Gdd eZ Gd d eZ Gd d eZGddeZy)N)HTTPSConnectionPoolHTTPConnectionPool PoolManager ProxyManager<c"eZdZdZeddZy)TCPKeepAliveValidationMethodsa< This class contains a single method whose sole purpose is to set up TCP Keep Alive probes on the socket for a connection. This is necessary for long-running requests which will be silently terminated by the AWS Network Load Balancer which kills a connection if it is idle for more than 350 seconds. c|dk(rytj}|dk(rKt|jdr4ttdr#ttdrttdrttdr|jj tj tjd |jj tjtjt|jj tjtjt|jj tjtjty|d k(rdttd rTt|jd d <|jj!tj"d td ztd zfy|dk(rt|jddm|jj tj tjd |jj tjt$tyyy)a Adjusts the socket settings so that the client sends a TCP keep alive probe over the connection. This is only applied where possible, if the ability to set the socket options is not available, for example using Anaconda, then the settings will be left as is. :param conn: The connection to update the socket settings for :param str protocol: The protocol of the connection :return: None httpNlinux setsockopt SO_KEEPALIVE TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNTwin32SIO_KEEPALIVE_VALSioctlidarwin)sysplatformhasattrsocksocketr SOL_SOCKETr IPPROTO_TCPr TCP_KEEP_IDLErTCP_KEEPALIVE_INTERVALr TCP_KEEP_CNTgetattrrr TCP_KEEPALIVE)connprotocolrs A/opt/Tautulli/lib/cloudinary/api_client/tcp_keep_alive_manager.pyadjust_connection_socketz6TCPKeepAliveValidationMethods.adjust_connection_sockets v  <<  GDII|$DQWYgIh/GFO4TY`aganZp II !2!2F4G4G K II !3!3V5H5H- X II !3!3V5I5IKa b II !3!3V5G5G V WV5I%JwW[W`W`biW[P]dhPi IIOOF55=4;OQgjnQn7o p !gdiit&L&X II !2!2F4G4G K II !3!3]DZ ['Y !N)https)__name__ __module__ __qualname____doc__ staticmethodr(r)r'r r s !\!\r)r c"eZdZdZfdZxZS)TCPKeepAliveHTTPSConnectionPoolz This class overrides the _validate_conn method in the HTTPSConnectionPool class. This is the entry point to use for modifying the socket as it is called after the socket is created and before the request is made. cXtt| |tj |dy)U Called right before a request is made, after the socket is created. r*N)superr2_validate_connr r(selfr% __class__s r'r6z.TCPKeepAliveHTTPSConnectionPool._validate_connEs' -tCDI &>>tWMr)r+r,r-r.r6 __classcell__r9s@r'r2r2?s NNr)r2c"eZdZdZfdZxZS)TCPKeepAliveHTTPConnectionPoola This class overrides the _validate_conn method in the HTTPSConnectionPool class. This is the entry point to use for modifying the socket as it is called after the socket is created and before the request is made. In the base class this method is passed completely. cXtt| |tj |dy)r4r N)r5r>r6r r(r7s r'r6z-TCPKeepAliveHTTPConnectionPool._validate_connWs' ,dB4H &>>tVLr)r:r<s@r'r>r>Ps MMr)r>c$eZdZdZdfd ZxZS)TCPKeepAlivePoolManagerz This Pool Manager has only had the pool_classes_by_scheme variable changed. This now points at the TCPKeepAlive connection pools rather than the default connection pools. c Vtt| d||d|ttd|_y)N) num_poolsheadersr r*r0)r5rA__init__r>r2pool_classes_by_scheme)r8rCrDconnection_pool_kwr9s r'rFz TCPKeepAlivePoolManager.__init__hs- %t5q SZq^pq/MXw&x#r)) Nr+r,r-r.rFr;r<s@r'rArAbs yyr)rAc$eZdZdZdfd ZxZS)TCPKeepAliveProxyManagerz This Proxy Manager has only had the pool_classes_by_scheme variable changed. This now points at the TCPKeepAlive connection pools rather than the default connection pools. c Ztt| d||||d|ttd|_y)N) proxy_urlrCrD proxy_headersrEr0)r5rLrFr>r2rG)r8rNrCrDrOrHr9s r'rFz!TCPKeepAliveProxyManager.__init__ss? &6 MV_ipER M9K M0NXw&x#r))rINNrJr<s@r'rLrLms yyr)rL)rrurllib3rrrrr$r r!r"r r2r>rArLr0r)r'rQso VV    )\)\XN&9N"M%7M$yky y| yr)