Skip to content

Instantly share code, notes, and snippets.

@oberstet
Created November 27, 2021 06:44
Show Gist options
  • Save oberstet/d270630c3f635ed27f986d0101a5b817 to your computer and use it in GitHub Desktop.
Save oberstet/d270630c3f635ed27f986d0101a5b817 to your computer and use it in GitHub Desktop.
(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