#include <lustre_mdc.h>
#include "fid_internal.h"
-static int seq_client_rpc(struct lu_client_seq *seq, struct lu_range *input,
- struct lu_range *output, __u32 opc,
+static int seq_client_rpc(struct lu_client_seq *seq, struct lu_seq_range *input,
+ struct lu_seq_range *output, __u32 opc,
const char *opcname)
{
struct obd_export *exp = seq->lcs_exp;
struct ptlrpc_request *req;
- struct lu_range *out, *in;
+ struct lu_seq_range *out, *in;
__u32 *op;
int rc;
ENTRY;
if (seq->lcs_type == LUSTRE_SEQ_METADATA) {
req->rq_request_portal = (opc == SEQ_ALLOC_SUPER) ?
SEQ_CONTROLLER_PORTAL : SEQ_METADATA_PORTAL;
+ /* update mdt field of *in, it is required for fld update
+ * on super sequence allocator node. */
+ if (opc == SEQ_ALLOC_SUPER)
+ in->lsr_mdt = seq->lcs_space.lsr_mdt;
} else {
- req->rq_request_portal = (opc == SEQ_ALLOC_SUPER) ?
- SEQ_CONTROLLER_PORTAL : SEQ_DATA_PORTAL;
+ LASSERT(opc == SEQ_ALLOC_META);
+ req->rq_request_portal = SEQ_DATA_PORTAL;
}
ptlrpc_at_set_req_timeout(req);
/* Request sequence-controller node to allocate new super-sequence. */
int seq_client_replay_super(struct lu_client_seq *seq,
- struct lu_range *range,
+ struct lu_seq_range *range,
const struct lu_env *env)
{
int rc;
}
LASSERT(!range_is_exhausted(&seq->lcs_space));
- *seqnr = seq->lcs_space.lr_start;
- seq->lcs_space.lr_start += 1;
+ *seqnr = seq->lcs_space.lsr_start;
+ seq->lcs_space.lsr_start += 1;
CDEBUG(D_INFO, "%s: Allocated sequence ["LPX64"]\n", seq->lcs_name,
*seqnr);
LASSERT(seq != NULL);
down(&seq->lcs_sem);
fid_zero(&seq->lcs_fid);
+ /**
+ * this id shld not be used for seq range allocation.
+ * set to -1 for dgb check.
+ */
+
+ seq->lcs_space.lsr_mdt = -1;
+
range_init(&seq->lcs_space);
up(&seq->lcs_sem);
}