Class QueueItem

src/msg/DispatchQueue.h:45–74

  ArrivalSet marrival;

  class QueueItem {
    int type;
    ConnectionRef con;
    ceph::ref_t<Message> m;
  public:
    explicit QueueItem(const ceph::ref_t<Message>& m) : type(-1), con(0), m(m) {}
    QueueItem(int type, Connection *con) : type(type), con(con), m(0) {}
    bool is_code() const {
      return type != -1;
    }
    int get_code () const {
      ceph_assert(is_code());
      return type;
    }
    const ceph::ref_t<Message>& get_message() {
      ceph_assert(!is_code());
      return m;
    }
    Connection *get_connection() {
      ceph_assert(is_code());
      return con.get();
    }

    /**
     * An iterator into #marrival.  This field is only initialized if
     * `!is_code()`.  It is set by add_arrival() and used by
     * remove_arrival().
     */
    ArrivalSet::iterator arrival;
  };

  CephContext *cct;
  Messenger *msgr;