o B]7E@sddlZddlmZddlmZddlmZddlmZddl m Z ddlm Z m Z ddl mZmZdd lmZdd lmZed ZGd d d eZddZdddedfddZee_dS)N)null)config)rfc2576)rfc3411)v2c)errinderror)viewrfc1902)nextid)debugic@s@eZdZdZddZddZ dddZd d Z dd d ZdS)NotificationOriginatorcKs$i|_i|_|dd|_||_dS)N snmpContext)$_NotificationOriginator__pendingReqs-_NotificationOriginator__pendingNotificationspopr _NotificationOriginator__options)selfoptionsr>/usr/lib/python3/dist-packages/pysnmp/entity/rfc3413/ntforg.py__init__s zNotificationOriginator.__init__c Cs| \} }}| |jvrtd| |j| \ }}}}}}}}}}}}}|jt|| rtd| | | f| d}|t j t j fvrR|d7}d}nd}|d7}||kse||j ddkrtjtj @otd| | |f||| |d|dS||| |d|dSt|d |j}|dkrt|}d}n|}d}z|j|||||||||||d ||j| ||f} Wn8tjytd} tjtj @otd | | f||| | dd|YdS||| | dd|YdSw|jt|tjtj @o'td | | |||f|||||||||||||f |j| <dS|||||||||||||f |j| <dS|dkrGt| |} ||| d| |dS) NzMissing sendPduHandle %szOprocessResponsePdu: sendRequestHandle %s, sendPduHandle %s statusInformation %serrorIndicationrZdiscoveryRetrieszRprocessResponsePdu: sendRequestHandle %s, sendPduHandle %s retry count %d exceededdTzCprocessResponsePdu: sendRequestHandle %s: sendPdu() failed with %r zVprocessResponsePdu: sendRequestHandle %s, sendPduHandle %s, timeout %d, retry %d of %d)rr ProtocolErrorrtransportDispatcherZ jobFinishedidr loggerflagApprZnotInTimeWindowZunknownEngineIDrgetfloatgetTimerResolutionrv2ToV1 msgAndPduDspsendPduprocessResponsePduStatusInformationsysexc_info jobStartedZv1ToV2) r snmpEnginemessageProcessingModel securityModel securityName securityLevelcontextEngineId contextName pduVersionZPDUstatusInformation sendPduHandleZcbInfosendRequestHandlecbFuncbCtxZorigTransportDomainZorigTransportAddressZorigMessageProcessingModelZorigSecurityModelZorigSecurityNameZorigSecurityLevelZorigContextEngineIdZorigContextNameZorigPduZ origTimeoutZorigRetryCountZ origRetriesZorigDiscoveryRetriesrtimeoutInTicksreqPDUrrrr(s              z)NotificationOriginator.processResponsePduNcCsrt||\}} } } } t|| \} }}}| dkr!t|}d}n|}d}|jtjvrt| d|j }t }|j ||| | |||||||d||j|||f}tjtj@o|td|| f|| | ||||||| | ddf |j|<|j t||S|| | ||||||| | ddf |j|<|j t||S|j ||| | |||||||d d}tjtj@otd|S)NrrrTz%sendPdu: sendPduHandle %s, timeout %dFzsendPdu: message sent)r getTargetAddrgetTargetParamsrr%ZtagSetrZconfirmedClassPDUsr#rr$ getNextHandler&r'r(r r r!rr,r)rr-Z targetNamer2r3pdur8r9transportDomaintransportAddresstimeout retryCountparamsr.r/r0r1r;r4r:r7r6rrrr'zs^            zNotificationOriginator.sendPduc Cs|\}}}|j||tjtj@o td||||j|f|j|s_tjtj@o4td||f|j|=|||||rEtj|pFd|rPtjj|ddpQd|rYtj |pZd|dSdS)NzmprocessResponseVarBinds: notificationHandle %s, sendRequestHandle %s, errorIndication %s, pending requests %szQprocessResponseVarBinds: notificationHandle %s, sendRequestHandle %s -- completedrT)Z muteErrorsr) rremover r r!rapiPDUZgetErrorStatusZ getErrorIndexZ getVarBinds)rr-r7rr?r9notificationHandler8rrrprocessResponseVarBindss.  z.NotificationOriginator.processResponseVarBindsrc Cs2tjtj@otd||p d||f|r#|jjjdd\}||}t||\} } t } tjtj@o=td| | | fdd|D}|jjjdd d \} } t t |D]E}|r||d | kr|d d | krv|||d <n | d ||||=|d d | kr| d t| | fqWt |d ks|d d | kr| d t| | fd}tjtj@otd|ft|| D]0}t||\}}}}}t||\}}}}tjtj@otd| | |||||f|D]U\}}|| j| jfvrqz"|j|j||||d||tjtj@o.td||fWqtjyUtjtj@oOtd||fYdSYdSw| d kr`t}n| d krjt}ntd| tj|tj ||z|!||||||j"| ||f}WnJtjyt#$d }tjtj@otd||f| |j%vs|j%| s| |j%vr|j%| =|r||| |dd d d|| YSwtjtj@otd| ||f| d kr| |j%vrt&|j%| <|j%| '|qtjtj@otd| |f| S| S)NzVsendVarBinds: notificationTarget %s, contextEngineId %s, contextName "%s", varBinds %sz zSNMP-FRAMEWORK-MIBZSnmpAdminStringz@sendVarBinds: notificationHandle %s, notifyTag %s, notifyType %scSsg|] \}}t||fqSr)rObjectIdentifier).0xyrrr sz7NotificationOriginator.sendVarBinds..z __SNMPv2-MIB snmpTrapOID sysUpTimerrzsendVarBinds: final varBinds %szsendVarBinds: notificationHandle %s, notifyTag %s yields: transportDomain %s, transportAddress %r, securityModel %s, securityName %s, securityLevel %sZnotifyz6sendVarBinds: ACL succeeded for OID %s securityName %szRsendVarBinds: ACL denied access for OID %s securityName %s, droppping notificationzUnknown notify-type %rzrangelenZgetNameinsertrrIZ getSyntaxZcloneZgetTargetNamesr<r=nameZaccessControlModelacmIDZisAccessAllowedrr)Z SNMPv2TrapPDUZInformRequestPDUrrFZ setDefaultsZ setVarBindsr'rHr*r+rsetadd)rr-notificationTargetr2r3varBindsr8r9Z(_NotificationOriginator__SnmpAdminStringZ notifyTagZ notifyTyperGrNrOidxr7ZtargetAddrNamer@rArBrCrDr.r/r0r1ZvarNameZvarValr?r5rrr sendVarBindss                           z#NotificationOriginator.sendVarBinds)NN)rNN) __name__ __module__ __qualname__rWrr(r'rHr]rrrrr s] 8r cCsB|\}}z |||||||WdSty ||||YdSw)N) TypeError)r-r7rZ errorStatusZ errorIndexr[r9r8rrr_sendNotificationCbFunUs rbrc Cs|jdur td|d} | st|} |j| dt|t t fr4|r4t|dt r4t j |}nt |}t j||d} | | |j|} | dd| | dd} ||||jj|| t |t||fS)NzSNMP context not specifiedmibViewController)rcr) instanceIndexr)rrrZgetUserContextr ZMibViewControllerZ getMibBuilderZsetUserContext isinstancetupleliststrr ZObjectIdentityZNotificationTypeZresolveWithMibZ getMibInstrumZreadVarsr]r2rb) rr-rZZnotificationNameZadditionalVarBindsr8r9r3rdrcr[rRrrr_sendNotificationbs0          ri)r*Zpyasn1.compat.octetsrZpysnmp.entity.rfc3413rZpysnmp.proto.proxyrZ pysnmp.protorZpysnmp.proto.apirrrZ pysnmp.smir r Zpysnmpr r ZIntegerr>objectr rbriZsendNotificationrrrrs&        B )