Created
November 27, 2021 06:44
-
-
Save oberstet/d270630c3f635ed27f986d0101a5b817 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(cpy310_1) oberstet@intel-nuci7:~/scm/crossbario/crossbar$ find crossbar -name "*.py" -exec grep -Hi "forward_for" {} \; | |
crossbar/worker/rlink.py: 'Received event on uri={uri}, options={options} (publisher={publisher}, publisher_authid={publisher_authid}, publisher_authrole={publisher_authrole}, forward_for={forward_for})', | |
crossbar/worker/rlink.py: forward_for=details.forward_for) | |
crossbar/worker/rlink.py: if details.forward_for: | |
crossbar/worker/rlink.py: if len(details.forward_for) >= 0: | |
crossbar/worker/rlink.py: forward_for = copy.deepcopy(details.forward_for) | |
crossbar/worker/rlink.py: forward_for.append(this_forward) | |
crossbar/worker/rlink.py: forward_for = [this_forward] | |
crossbar/worker/rlink.py: forward_for=forward_for) | |
crossbar/worker/rlink.py: 'Received invocation on uri={uri}, options={options} (caller={caller}, caller_authid={caller_authid}, caller_authrole={caller_authrole}, forward_for={forward_for})', | |
crossbar/worker/rlink.py: forward_for=details.forward_for) | |
crossbar/worker/rlink.py: if details.forward_for: | |
crossbar/worker/rlink.py: if len(details.forward_for) >= 0: | |
crossbar/worker/rlink.py: forward_for = copy.deepcopy(details.forward_for) | |
crossbar/worker/rlink.py: forward_for.append(this_forward) | |
crossbar/worker/rlink.py: forward_for = [this_forward] | |
crossbar/worker/rlink.py: options = CallOptions(forward_for=forward_for) | |
crossbar/router/dealer.py: 'forward_for', | |
crossbar/router/dealer.py: def __init__(self, id, registration, caller, call, callee, forward_for): | |
crossbar/router/dealer.py: self.forward_for = forward_for | |
crossbar/router/dealer.py: # FIXME: what about exclude_authid as collected from forward_for? like we do elsewhere in this file! | |
crossbar/router/dealer.py: if register.forward_for: | |
crossbar/router/dealer.py: exclude_authid = [ff['authid'] for ff in register.forward_for] | |
crossbar/router/dealer.py: 'WAMP meta event will be published excluding these authids (from forward_for): {exclude_authid}', | |
crossbar/router/dealer.py: if unregister.forward_for: | |
crossbar/router/dealer.py: exclude_authid = [ff['authid'] for ff in unregister.forward_for] | |
crossbar/router/dealer.py: 'WAMP meta event will be published excluding these authids (from forward_for): {exclude_authid}', | |
crossbar/router/dealer.py: # set the disclosed caller and forward_for | |
crossbar/router/dealer.py: forward_for = None | |
crossbar/router/dealer.py: if call.forward_for: | |
crossbar/router/dealer.py: # forwarded call: ultimate caller is the first in forward_for | |
crossbar/router/dealer.py: caller = call.forward_for[0]['session'] | |
crossbar/router/dealer.py: caller_authid = call.forward_for[0]['authid'] | |
crossbar/router/dealer.py: caller_authrole = call.forward_for[0]['authrole'] | |
crossbar/router/dealer.py: # append this session (a r2r link) to forward_for | |
crossbar/router/dealer.py: forward_for = call.forward_for + [{ | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: forward_for, | |
crossbar/router/dealer.py: forward_for, | |
crossbar/router/dealer.py: invoke_request = InvocationRequest(invocation_request_id, registration, session, call, callee, forward_for) | |
crossbar/router/dealer.py: forward_for = None | |
crossbar/router/dealer.py: if cancel.forward_for: | |
crossbar/router/dealer.py: # append this calling session (a r2r link) to forward_for | |
crossbar/router/dealer.py: forward_for = cancel.forward_for + [{ | |
crossbar/router/dealer.py: interrupt = message.Interrupt(invocation_request.id, interrupt_mode, forward_for=forward_for) | |
crossbar/router/dealer.py: # set the disclosed callee and forward_for | |
crossbar/router/dealer.py: forward_for = None | |
crossbar/router/dealer.py: if yield_.forward_for: | |
crossbar/router/dealer.py: # forwarded call result: ultimate callee is the first in forward_for | |
crossbar/router/dealer.py: callee = yield_.forward_for[0]['session'] | |
crossbar/router/dealer.py: callee_authid = yield_.forward_for[0]['authid'] | |
crossbar/router/dealer.py: callee_authrole = yield_.forward_for[0]['authrole'] | |
crossbar/router/dealer.py: # append this session (a r2r link) to forward_for | |
crossbar/router/dealer.py: forward_for = yield_.forward_for + [{ | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: # set the disclosed callee and forward_for | |
crossbar/router/dealer.py: forward_for = None | |
crossbar/router/dealer.py: if error.forward_for: | |
crossbar/router/dealer.py: # forwarded call: ultimate caller is the first in forward_for | |
crossbar/router/dealer.py: callee = invocation_request.forward_for[0]['session'] | |
crossbar/router/dealer.py: callee_authid = invocation_request.forward_for[0]['authid'] | |
crossbar/router/dealer.py: callee_authrole = invocation_request.forward_for[0]['authrole'] | |
crossbar/router/dealer.py: # append this session (a r2r link) to forward_for | |
crossbar/router/dealer.py: forward_for = error.forward_for + [{ | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/dealer.py: forward_for=forward_for) | |
crossbar/router/broker.py: # FIXME: what about exclude_authid as colleced from forward_for? like we do elsewhere in this file! | |
crossbar/router/broker.py: forward_for = None | |
crossbar/router/broker.py: if publish.forward_for: | |
crossbar/router/broker.py: publisher = publish.forward_for[0]['session'] | |
crossbar/router/broker.py: publisher_authid = publish.forward_for[0]['authid'] | |
crossbar/router/broker.py: publisher_authrole = publish.forward_for[0]['authrole'] | |
crossbar/router/broker.py: forward_for = publish.forward_for + [{ | |
crossbar/router/broker.py: forward_for=forward_for) | |
crossbar/router/broker.py: forward_for=forward_for) | |
crossbar/router/broker.py: if subscribe.forward_for: | |
crossbar/router/broker.py: exclude_authid = [ff['authid'] for ff in subscribe.forward_for] | |
crossbar/router/broker.py: if unsubscribe and unsubscribe.forward_for: | |
crossbar/router/broker.py: exclude_authid = [ff['authid'] for ff in unsubscribe.forward_for] | |
(cpy310_1) oberstet@intel-nuci7:~/scm/crossbario/crossbar$ | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment