B 9-eÏã@sxdZddlZddlZddlZddlZddlmZddlmZddlm Z ddl Z ddl m Z e  e¡ZGdd„dƒZdS) zÊ Copyright (C) 2019 Interactive Brokers LLC. All rights reserved. This code is subject to the terms and conditions of the IB API Non-Commercial License or the IB API Commercial License, as applicable. éN)ÚFAIL_CREATE_SOCK)Ú CONNECT_FAIL)Ú NO_VALID_ID)Úexitc@sLeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dS)Ú ConnectioncCsN||_||_d|_d|_t ¡|_|js6tt›dƒ|jsJtt›dƒdS)Nz::connection host=Nonez::connection port=None) ÚhostÚportÚsocketÚwrapperÚ threadingÚLockÚlockrÚ__name__)Úselfrr©rú²G:\My Drive\STUDY\EPAT\09 TBP - Trading & Back-testing Platforms\TBP04 - Backtesting & Live Trading\IB IBridgePy API\02 Python 3.7 IBridgePy_Win_Anaconda37_64\ibapi\connection.pyÚ__init__s zConnection.__init__c CsÄyt ¡|_WnTtjk rb}z4t d|›¡|jrR|j tt ¡t ¡d¡Wdd}~XYnXy|j  |j |j f¡Wn6tjk r²|jr®|j tt  ¡t  ¡d¡YnX|j  d¡dS)Nzconnect failed. err=Úé)r ÚerrorÚloggerÚdebugr rrÚcodeÚmsgÚconnectrrrÚ settimeout)rÚerrrrrr(s, zConnection.connectcCs^|j ¡zB|jdk rJt d¡|j ¡d|_t d¡|jrJ|j ¡Wd|j ¡XdS)NÚ disconnectingÚ disconnected) r Úacquirer rrÚcloser ÚconnectionClosedÚrelease)rrrrÚ disconnect9s     zConnection.disconnectcCs |jdk S)N)r )rrrrÚ isConnectedFszConnection.isConnectedc Cs°t d¡|j ¡t d¡| ¡s>t d¡|j ¡dSz@y|j |¡}Wn*tjk rzt dt   ¡¡d}YnXWdt d¡|j ¡t d¡Xt d|¡|S) Nzacquiring lockz acquired lockz5sendMsg attempted while not connected, releasing lockrzexception from sendMsg %szreleasing lockz release lockzsendMsg: sent: %d) rrr rr$r"r ÚsendrÚ tracebackÚ format_exc)rrZnSentrrrÚsendMsgIs"         zConnection.sendMsgc Cs°| ¡st d¡dSy| ¡}t|ƒdkr,Wn|tjk rXt dt ¡¡d}YnTtj k rzt  d¡d}Yn2t k rª}zt  d|›¡Wdd}~XYnX|S)Nz5recvMsg attempted while not connected, releasing lockórzsocket timeout from recvMsg %szsocket broken, reconnectedz Socket is broken or closed. err=) r$rrÚ _recvAllMsgÚlenr Útimeoutr&r'rÚinfoÚOSError)rÚbufrrrrÚrecvMsg_s    "zConnection.recvMsgcCs t d¡t d¡| ¡dS)NézTry to reconnect socket)ÚtimeÚsleeprr-r)rrrrÚ _reconnect{s  zConnection._reconnectcCsTd}d}xF|rN| ¡rN|j d¡}||7}t dt|ƒ|¡t|ƒdkr d}q W|S)NTr)izlen %d raw:%s|F)r$r Úrecvrrr+)rÚcontZallbufr/rrrr*€s  zConnection._recvAllMsgN) rÚ __module__Ú __qualname__rrr#r$r(r0r4r*rrrrrs  r)Ú__doc__r&r r ÚloggingÚ ibapi.errorsrrÚ ibapi.commonrr2ÚsysrÚ getLoggerrrrrrrrÚs