This is an archive of the discontinued Mercurial Phabricator instance.

Differential D12329

keepalive: remove pycompat.iteritems()
ClosedPublic

Authored by indygreg on Mar 3 2022, 4:21 PM.

Details

Reviewers
Alphare
Group Reviewers
hg-reviewers
Commits
rHGdea766fca7e1: keepalive: remove pycompat.iteritems()

Diff Detail

Repository
rHG Mercurial
Lint
Automatic diff as part of commit; lint not applicable.
Unit
Automatic diff as part of commit; unit tests not applicable.

Event Timeline

indygreg created this revision.Mar 3 2022, 4:21 PM
Alphare accepted this revision.Mar 8 2022, 4:29 AM
This revision is now accepted and ready to land.Mar 8 2022, 4:29 AM
indygreg added a commit: rHGdea766fca7e1: keepalive: remove pycompat.iteritems().Mar 8 2022, 5:58 AM
Closed by commit rHGdea766fca7e1: keepalive: remove pycompat.iteritems() (authored by indygreg). · Explain Why
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

PathPackages
Mmercurial/keepalive.py (2 lines)

Diff 32581

mercurial/keepalive.py

host is the host:port spec, as in 'www.cnn.com:8080' as passed in. host is the host:port spec, as in 'www.cnn.com:8080' as passed in.
no error occurs if there is no connection to that host.""" no error occurs if there is no connection to that host."""
for h in self._cm.get_all(host): for h in self._cm.get_all(host):
self._cm.remove(h) self._cm.remove(h)
h.close() h.close()
def close_all(self): def close_all(self):
"""close all open connections""" """close all open connections"""
for host, conns in pycompat.iteritems(self._cm.get_all()): for host, conns in self._cm.get_all().items():
for h in conns: for h in conns:
self._cm.remove(h) self._cm.remove(h)
h.close() h.close()
def _request_closed(self, request, host, connection): def _request_closed(self, request, host, connection):
"""tells us that this request is now closed and that the """tells us that this request is now closed and that the
connection is ready for another request""" connection is ready for another request"""
self._cm.set_ready(connection, True) self._cm.set_ready(connection, True)