From bbdae98115f6ffe324fe36846789c24eb4f530db Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Tue, 2 Oct 2012 16:34:50 -0700 Subject: [PATCH] Pipe: we don't queue DispatchQueue codes on an actual pipe The dispatch queue event codes are now queued directly and won't end up in a real Pipe. Signed-off-by: Samuel Just --- src/msg/Pipe.cc | 6 ------ 1 file changed, 6 deletions(-) diff --git a/src/msg/Pipe.cc b/src/msg/Pipe.cc index c7d549a673575..9c198104a7383 100644 --- a/src/msg/Pipe.cc +++ b/src/msg/Pipe.cc @@ -1007,18 +1007,12 @@ void Pipe::discard_out_queue() ldout(msgr->cct,10) << "discard_queue" << dendl; for (list::iterator p = sent.begin(); p != sent.end(); p++) { - if (*p < (void *) DispatchQueue::D_NUM_CODES) { - continue; // skip non-Message dispatch codes - } ldout(msgr->cct,20) << " discard " << *p << dendl; (*p)->put(); } sent.clear(); for (map >::iterator p = out_q.begin(); p != out_q.end(); p++) for (list::iterator r = p->second.begin(); r != p->second.end(); r++) { - if (*r < (void *) DispatchQueue::D_NUM_CODES) { - continue; // skip non-Message dispatch codes - } ldout(msgr->cct,20) << " discard " << *r << dendl; (*r)->put(); } -- 2.39.5