diff options
| author |  Nathaniel Manista <nathaniel@google.com> | 2015-02-24 00:53:45 +0000 |
|---|---|---|
| committer | Nathaniel Manista <nathaniel@google.com> | 2015-02-24 00:53:45 +0000 |
| commit | 4ad01246e3af14306598b9a8f1ea65ef194c4bad (patch) | |
| tree | 9ae18a9ebf85af0a01979bc386cfdb0fdd605e96 /src/python | |
| parent | ebda87a9a77d6cb358d992f17c129f34c5871a58 (diff) | |
Propagate ForeLink-joining to the inner RearLink.
rear._ActivatedRearLink's inner RearLink should of
course send its tickets to whatever ForeLink was joined
to the rear._ActivatedRearLink.
Diffstat (limited to 'src/python')
| -rw-r--r-- | src/python/src/grpc/_adapter/rear.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/python/src/grpc/_adapter/rear.py b/src/python/src/grpc/_adapter/rear.py index 3fbcb24094..d16fbeecf7 100644 --- a/src/python/src/grpc/_adapter/rear.py +++ b/src/python/src/grpc/_adapter/rear.py @@ -382,6 +382,8 @@ class _ActivatedRearLink(ticket_interfaces.RearLink, activated.Activated): def join_fore_link(self, fore_link): with self._lock: self._fore_link = null.NULL_FORE_LINK if fore_link is None else fore_link + if self._rear_link is not None: + self._rear_link.join_fore_link(self._fore_link) def _start(self): with self._lock: |