o ]V @sdZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZed gd ed ZejejfZGd d d eZejejejejejejejejejejiZddZddZddZ ddZ!ddZ"ddZ#dS)z*Represent a deployment of MongoDB servers.) namedtuple)common)ConfigurationError)ReadPreferenceServerDescription) Selection) SERVER_TYPE TopologyType)SingleReplicaSetNoPrimaryReplicaSetWithPrimaryShardedUnknownc@seZdZddZddZddZddZd d Zd d Ze d dZ e ddZ e ddZ e ddZ e ddZe ddZe ddZe ddZe ddZe dd Ze d!d"Zd*d$d%Zejfd&d'Zd(d)Zd#S)+TopologyDescriptionc Cs ||_||_||_||_||_||_d|_|jD]G}|js q|j duo*|j t j k}|j duo5|j t j k} |rJd|jd|jd|j t j f|_q| rad|jd|jd|j t j t jf|_nq|j} | sld|_dStdd| Drzd|_dStdd| D|_dS) aRepresentation of a deployment of MongoDB servers. :Parameters: - `topology_type`: initial type - `server_descriptions`: dict of (address, ServerDescription) for all seeds - `replica_set_name`: replica set name or None - `max_set_version`: greatest setVersion seen from a primary, or None - `max_election_id`: greatest electionId seen from a primary, or None - `topology_settings`: a TopologySettings Nz]Server at %s:%d requires wire version %d, but this version of PyMongo only supports up to %d.rzgServer at %s:%d reports wire version %d, but this version of PyMongo requires at least %d (MongoDB %s).css|]}|jduVqdSNlogical_session_timeout_minutes.0srN/var/www/html/env/lib/python3.10/site-packages/pymongo/topology_description.py osz/TopologyDescription.__init__..cs|]}|jVqdSrrrrrrrss)_topology_type_replica_set_name_server_descriptions_max_set_version_max_election_id_topology_settings_incompatible_errvaluesis_server_type_knownmin_wire_versionrMAX_SUPPORTED_WIRE_VERSIONmax_wire_versionMIN_SUPPORTED_WIRE_VERSIONaddressMIN_SUPPORTED_SERVER_VERSIONreadable_servers_ls_timeout_minutesanymin) self topology_typeserver_descriptionsreplica_set_namemax_set_versionmax_election_idtopology_settingsrserver_too_newserver_too_oldr,rrr__init__%sX      zTopologyDescription.__init__cCs|jrt|jdS)zRaise ConfigurationError if any server is incompatible. A server is incompatible if its wire protocol version range does not overlap with PyMongo's. N)r#rr0rrrcheck_compatiblevs z$TopologyDescription.check_compatiblecCs ||jvSr)rr0r*rrr has_servers zTopologyDescription.has_servercCst|t|S)z;A copy of this description, with one server marked Unknown.)updated_topology_descriptionrr<rrr reset_serversz TopologyDescription.reset_servercCsH|jtjkr tj}n|j}tdd|jD}t|||j|j|j |j S)z.) r TOPOLOGY_TYPEr r dictrrrr r!r")r0r1sdsrrrresets zTopologyDescription.resetcCs |jS)zRDict of (address, :class:`~pymongo.server_description.ServerDescription`).)rcopyr:rrrr2s z'TopologyDescription.server_descriptionscC|jS)zThe type of this topology.)rr:rrrr1z!TopologyDescription.topology_typecCs tj|jS)zUThe topology type as a human readable string. .. versionadded:: 3.4 )r@_fieldsrr:rrrtopology_type_names z&TopologyDescription.topology_type_namecCrE)zThe replica set name.)rr:rrrr3rFz$TopologyDescription.replica_set_namecCrE)z1Greatest setVersion seen from a primary, or None.)r r:rrrr4rFz#TopologyDescription.max_set_versioncCrE)z1Greatest electionId seen from a primary, or None.)r!r:rrrr5rFz#TopologyDescription.max_election_idcCrE)z)Minimum logical session timeout, or None.)r-r:rrrrrFz3TopologyDescription.logical_session_timeout_minutescCdd|jDS)z)List of Servers of types besides Unknown.cSg|]}|jr|qSrr%rrrr s z5TopologyDescription.known_servers..rr$r:rrr known_serversz!TopologyDescription.known_serverscCstdd|jDS)z7Whether there are any Servers of types besides Unknown.css|]}|jr|VqdSrrKrrrrrsz8TopologyDescription.has_known_servers..)r.rr$r:rrrhas_known_serverssz%TopologyDescription.has_known_serverscCrI)zList of readable Servers.cSrJr) is_readablerrrrrLsz8TopologyDescription.readable_servers..rMr:rrrr,rOz$TopologyDescription.readable_serverscCs"|j}|rtdd|jDSdS)z3Minimum of all servers' max wire versions, or None.csrr)r(rrrrrsz:TopologyDescription.common_wire_version..N)rNr/)r0serversrrrcommon_wire_versionsz'TopologyDescription.common_wire_versioncCs|jjSr)r"heartbeat_frequencyr:rrrrTsz'TopologyDescription.heartbeat_frequencyNcsfdd}t|ddr j}|r ||jkr td||j|fjtjkr)jS|r9 |}|r7|gSgSjtj krEt }n|t }|durZ|rZ| ||j}||S)NcsB|sgSj}tdd|jD|jdfdd|jDS)Ncsrrround_trip_timerrrrrs zTTopologyDescription.apply_selector..apply_local_threshold..g@@csg|] }|jkr|qSrrUrfastest thresholdrrrLszUTopologyDescription.apply_selector..apply_local_threshold..)r"r/r2local_threshold_ms) selectionsettingsr:rWrapply_local_thresholds zATopologyDescription.apply_selector..apply_local_thresholdr&rzF%s requires min wire version %d, but topology's min wire version is %d)getattrrSr&rr1r@r rNr2getrrfrom_topology_descriptionwith_server_descriptions)r0selectorr*custom_selectorr] common_wv descriptionr[rr:rapply_selectors2      z"TopologyDescription.apply_selectorcCstd|t||dS)aDoes this topology have any readable servers available matching the given read preference? :Parameters: - `read_preference`: an instance of a read preference from :mod:`~pymongo.read_preferences`. Defaults to :attr:`~pymongo.read_preferences.ReadPreference.PRIMARY`. .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 read_preferenceN)rvalidate_read_preferencer.rf)r0rgrrrhas_readable_servers z'TopologyDescription.has_readable_servercCs |tjS)zDoes this topology have a writable server available? .. note:: When connected directly to a single server this method always returns ``True``. .. versionadded:: 3.4 )rirPRIMARYr:rrrhas_writable_servers z'TopologyDescription.has_writable_serverr)__name__ __module__ __qualname__r9r;r=r?rCr2propertyr1rHr3r4r5rrNrPr,rSrTrfrrjrirkrrrrr$s@Q             + rc Cs|j}|j}|j}|j}|j}|j}|}|||<|tjkr*t tj|||||j S|tj krF|t j kr:||n |t j t jfvrFt|}|tjkrY|t jt j fvrX||nv|tjkr|t j t jfvrl||nc|t jkr~t|||||\}}}}nQ|t jt jt jfvrt|||\}}n>|tjkr|t j t jfvr||t|}n'|t jkrt|||||\}}}}n|t jt jt jfvrt|||}nt|}t ||||||j S)aReturn an updated copy of a TopologyDescription. :Parameters: - `topology_description`: the current TopologyDescription - `server_description`: a new ServerDescription that resulted from an ismaster call Called after attempting (successfully or not) to call ismaster on the server at server_description.address. Does not modify topology_description. )r*r1r3r4r5 server_typer2r@r rr"rr StandalonepopRSGhost_SERVER_TYPE_TO_TOPOLOGY_TYPErMongosr RSPrimary_update_rs_from_primary RSSecondary RSArbiterRSOther!_update_rs_no_primary_from_memberr _check_has_primary#_update_rs_with_primary_from_member) topology_descriptionserver_descriptionr*r1set_namer4r5rprBrrrr>/s              r>cCs~|}t|t|kr|S|D] }||vrt|||<qt|D] }||vr0||q%t|j||j|j |j |j S)zReturn an updated copy of a TopologyDescription. :Parameters: - `topology_description`: the current TopologyDescription - `seedlist`: a list of new seeds new ServerDescription that resulted from an ismaster call ) r2setkeysrlistrrrr1r3r4r5r")r~seedlistrBr*rrr)_updated_topology_description_srv_pollings&   rc Cs,|dur|j}n||jkr||jt||||fS||f}d|jvrAd|vr>||jkr>|j}t|||<t||||fS|j}|jdurR|dusO|j|krR|j}|D]}|j t j urn|j|jkrnt|j||j<nqV|j D] }||vr~t|||<qrt ||j D]} || qt||||fS)ajUpdate topology description from a primary's ismaster response. Pass in a dict of ServerDescriptions, current replica set name, the ServerDescription we are processing, and the TopologyDescription's max_set_version and max_election_id if any. Returns (new topology type, new replica_set_name, new max_set_version, new max_election_id). N)r3rrr*r|election_tupler election_id set_versionr$rpr rv all_hostsr) rBr3rr4r5max_election_tupler*server new_addressaddrrrrrwsT             rwcCsP|dusJ||jkr||jt|S|jr$|j|jkr$||jt|S)zRS with known primary. Process a response from a non-primary. Pass in a dict of ServerDescriptions, current replica set name, and the ServerDescription we are processing. Returns new topology type. N)r3rrr*mer|)rBr3rrrrr}s    r}cCsztj}|dur |j}n||jkr||j||fS|jD] }||vr)t|||<q|jr9|j|jkr9||j||fS)zRS without known primary. Update from a non-primary's response. Pass in a dict of ServerDescriptions, current replica set name, and the ServerDescription we are processing. Returns (new topology type, new replica_set_name). N)r@r r3rrr*rrr)rBr3rr1r*rrrr{s       r{cCs*|D] }|jtjkrtjSqtjS)zCurrent topology type is ReplicaSetWithPrimary. Is primary still known? Pass in a dict of ServerDescriptions. Returns new topology type. )r$rpr rvr@r r )rBrrrrr|<s   r|N)$__doc__ collectionsrpymongorpymongo.errorsrpymongo.read_preferencesrpymongo.server_descriptionrpymongo.server_selectorsrpymongo.server_typer ranger@rrSRV_POLLING_TOPOLOGIESobjectrrurvr rxr ryrzrtr>rrwr}r{r|rrrrs6          h"L