MCPcopy Create free account
hub / github.com/apache/qpid-proton / flow

Method flow

cpp/examples/broker.cpp:174–178  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

172 tryToSend();
173 }
174 void flow(Sender* s, int c) {
175 DOUT(std::cerr << "Queue: " << this << "(" << name_ << ") flow: " << c << " to " << s << "\n";);
176 subscriptions_[s] = c;
177 tryToSend();
178 }
179 void subscribe(Sender* s) {
180 DOUT(std::cerr << "Queue: " << this << "(" << name_ << ") subscribe Sender: " << s << "\n";);
181 subscriptions_[s] = 0;

Callers 2

on_sendableMethod · 0.45
boundQueueMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected