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

Method queue_reset

src/msg/DispatchQueue.h:180–189  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

178 cond.notify_all();
179 }
180 void queue_reset(Connection *con) {
181 std::lock_guard l{lock};
182 if (stop)
183 return;
184 mqueue.enqueue_strict(
185 0,
186 CEPH_MSG_PRIO_HIGHEST,
187 QueueItem(D_BAD_RESET, con));
188 cond.notify_all();
189 }
190 void queue_refused(Connection *con) {
191 std::lock_guard l{lock};
192 if (stop)

Callers 9

stopMethod · 0.80
_faultMethod · 0.80
handle_helloMethod · 0.80
send_auth_requestMethod · 0.80
reuse_connectionMethod · 0.80
faultMethod · 0.80
replaceMethod · 0.80

Calls 3

QueueItemClass · 0.70
enqueue_strictMethod · 0.45
notify_allMethod · 0.45

Tested by

no test coverage detected