// apply new object state.
ctx->obc->obs = ctx->new_obs;
ctx->obc->ssc->snapset = ctx->new_snapset;
- info.stats.stats.add(ctx->delta_stats, ctx->obc->obs.oi.category);
+ info.stats.stats.add(ctx->delta_stats, ctx->obs->oi.category);
+ int backfill_target = get_backfill_target();
if (backfill_target >= 0) {
pg_info_t& pinfo = peer_info[backfill_target];
if (soid <= pinfo.last_backfill)
void cancel_copy(CopyOpRef cop, bool requeue);
void cancel_copy_ops(bool requeue);
- friend class C_Copyfrom;
+ friend struct C_Copyfrom;
+ // -- flush --
+ map<hobject_t, FlushOpRef> flush_ops;
+
+ int start_flush(OpContext *ctx, bool blocking);
+ void finish_flush(hobject_t oid, tid_t tid, int r);
+ int try_flush_mark_clean(FlushOpRef fop);
+ void cancel_flush(FlushOpRef fop, bool requeue);
+ void cancel_flush_ops(bool requeue);
+
+ friend class C_Flush;
+
// -- scrub --
virtual void _scrub(ScrubMap& map);
virtual void _scrub_clear_state();
void set_honor_osdmap_full() { honor_osdmap_full = true; }
void unset_honor_osdmap_full() { honor_osdmap_full = false; }
- void scan_requests(bool skipped_map,
- void set_honor_cache_redirects() { honor_cache_redirects = true; }
- void unset_honor_cache_redirects() { honor_cache_redirects = false; }
-
+ void scan_requests(bool force_resend,
+ bool force_resend_writes,
map<tid_t, Op*>& need_resend,
list<LingerOp*>& need_resend_linger,
map<tid_t, CommandOp*>& need_resend_command);
hitset=""
overwrite_conf=1
cephx=1 #turn cephx on by default
+cache=""
+ memstore=0
MON_ADDR=""