- struct lu_range *space = &seq->lss_space;
- int rc = 0;
- ENTRY;
-
- LASSERT(range_is_sane(space));
-
- /*
- * This is recovery case. Adjust super range if input range looks like
- * it is allocated from new super.
- */
- if (in != NULL) {
- CDEBUG(D_INFO, "%s: Input seq range: "
- DRANGE"\n", seq->lss_name, PRANGE(in));
-
- if (range_is_exhausted(space)) {
- /*
- * Server cannot send empty range to client, this is why
- * we check here that range from client is "newer" than
- * exhausted super.
- */
- LASSERT(in->lr_end > space->lr_start);
-
- /*
- * Start is set to end of last allocated, because it
- * *is* already allocated so we take that into account
- * and do not use for other allocations.
- */
- space->lr_start = in->lr_end;
-
- /*
- * End is set to in->lr_start + super sequence
- * allocation unit. That is because in->lr_start is
- * first seq in new allocated range from controller
- * before failure.
- */
- space->lr_end = in->lr_start + LUSTRE_SEQ_SUPER_WIDTH;
-
- if (!seq->lss_cli) {
- CERROR("%s: No sequence controller "
- "is attached.\n", seq->lss_name);
- RETURN(-ENODEV);
- }
-
- /*
- * Let controller know that this is recovery and last
- * obtained range from it was @space.
- */
- rc = seq_client_replay_super(seq->lss_cli, space, env);
- if (rc) {
- CERROR("%s: Can't replay super-sequence, "
- "rc %d\n", seq->lss_name, rc);
- RETURN(rc);
- }
- } else {
- /*
- * Update super start by end from client's range. Super
- * end should not be changed if range was not exhausted.
- */
- if (in->lr_end > space->lr_start)
- space->lr_start = in->lr_end;
- }
+ struct lu_seq_range *space = &seq->lss_space;
+ int rc = -ENOSPC;
+ ENTRY;
+
+ /*
+ * In some cases (like recovery after a disaster)
+ * we may need to allocate sequences manually
+ * Notice some sequences can be lost if requested
+ * range doesn't start at the beginning of current
+ * free space. Also notice it's not possible now
+ * to allocate sequences out of natural order.
+ */
+ if (spec->lsr_start >= spec->lsr_end)
+ RETURN(-EINVAL);
+ if (spec->lsr_flags != LU_SEQ_RANGE_MDT &&
+ spec->lsr_flags != LU_SEQ_RANGE_OST)
+ RETURN(-EINVAL);
+
+ mutex_lock(&seq->lss_mutex);
+ if (spec->lsr_start >= space->lsr_start) {
+ space->lsr_start = spec->lsr_end;
+ rc = seq_store_update(env, seq, spec, 1 /* sync */);
+
+ LCONSOLE_INFO("%s: "DRANGE" sequences allocated: rc = %d \n",
+ seq->lss_name, PRANGE(spec), rc);
+ }
+ mutex_unlock(&seq->lss_mutex);