MCPcopy Create free account
hub / github.com/ceph/ceph / queue_refused

Method queue_refused

src/msg/DispatchQueue.h:190–199  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

188 cond.notify_all();
189 }
190 void queue_refused(Connection *con) {
191 std::lock_guard l{lock};
192 if (stop)
193 return;
194 mqueue.enqueue_strict(
195 0,
196 CEPH_MSG_PRIO_HIGHEST,
197 QueueItem(D_CONN_REFUSED, con));
198 cond.notify_all();
199 }
200
201 bool can_fast_dispatch(const ceph::cref_t<Message> &m) const;
202 void fast_dispatch(const ceph::ref_t<Message>& m);

Callers 1

processMethod · 0.80

Calls 3

QueueItemClass · 0.70
enqueue_strictMethod · 0.45
notify_allMethod · 0.45

Tested by

no test coverage detected