← Back to branch summary

~ubuntu-branches/ubuntu/quantal/ceph/quantal

« back to all changes in this revision

Viewing changes to src/osdc/Objecter.h

  • Committer: Package Import Robot
  • Author(s): James Page
  • Date: 2012-08-27 08:23:21 UTC
  • mto: This revision was merged to the branch mainline in revision 21.
  • Revision ID: package-import@ubuntu.com-20120827082321-2cfej6ddvk63vsqq
Tags: upstream-0.48.1
Import upstream version 0.48.1

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/osdc/Objecter.h
602
602
 
603
603
    bool budgeted;
604
604
 
 
605
    /// true if we should resend this message on failure
 
606
    bool should_resend;
 
607
 
605
608
    Op(const object_t& o, const object_locator_t& ol, vector<OSDOp>& op,
606
609
       int f, Context *ac, Context *co, eversion_t *ov) :
607
610
      session(NULL), session_item(this), incarnation(0),
612
615
      flags(f), priority(0), onack(ac), oncommit(co),
613
616
      tid(0), attempts(0),
614
617
      paused(false), objver(ov), reply_epoch(NULL), precalc_pgid(false),
615
 
      budgeted(false) {
 
618
      budgeted(false),
 
619
      should_resend(true) {
616
620
      ops.swap(op);
617
621
      
618
622
      /* initialize out_* to match op vector */
779
783
    OSDSession *session;
780
784
    xlist<LingerOp*>::item session_item;
781
785
 
 
786
    tid_t register_tid;
 
787
 
782
788
    LingerOp() : linger_id(0), flags(0), poutbl(NULL), pobjver(NULL),
783
789
                 registering(false), registered(false),
784
790
                 on_reg_ack(NULL), on_reg_commit(NULL),
785
 
                 session(NULL), session_item(this) {}
 
791
                 session(NULL), session_item(this),
 
792
                 register_tid(0) {}
786
793
 
787
794
    // no copy!
788
795
    const LingerOp &operator=(const LingerOp& r);
857
864
  map<epoch_t,list< pair<Context*, int> > > waiting_for_map;
858
865
 
859
866
  void send_op(Op *op);
 
867
  void cancel_op(Op *op);
 
868
  void finish_op(Op *op);
860
869
  bool is_pg_changed(vector<int>& a, vector<int>& b, bool any_change=false);
861
870
  enum recalc_op_target_result {
862
871
    RECALC_OP_TARGET_NO_ACTION = 0,
866
875
  int recalc_op_target(Op *op);
867
876
  bool recalc_linger_op_target(LingerOp *op);
868
877
 
869
 
  void send_linger(LingerOp *info, bool first_send);
 
878
  void send_linger(LingerOp *info);
870
879
  void _linger_ack(LingerOp *info, int r);
871
880
  void _linger_commit(LingerOp *info, int r);
872
881