-/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
- * vim:expandtab:shiftwidth=8:tabstop=8:
- *
+/*
* GPL HEADER START
*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
/*
* Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
* Use is subject to license terms.
+ *
+ * Copyright (c) 2011, 2012, Whamcloud, Inc.
*/
/*
* This file is part of Lustre, http://www.lustre.org/
* Author: Yury Umanets <umka@clusterfs.com>
*/
-#ifndef EXPORT_SYMTAB
-# define EXPORT_SYMTAB
-#endif
#define DEBUG_SUBSYSTEM S_FID
#ifdef __KERNEL__
struct lu_seq_range *output, __u32 opc,
const char *opcname)
{
- struct obd_export *exp = seq->lcs_exp;
- struct ptlrpc_request *req;
- struct lu_seq_range *out, *in;
- __u32 *op;
- int rc;
- ENTRY;
-
- req = ptlrpc_request_alloc_pack(class_exp2cliimp(exp), &RQF_SEQ_QUERY,
- LUSTRE_MDS_VERSION, SEQ_QUERY);
- if (req == NULL)
- RETURN(-ENOMEM);
-
- /* Init operation code */
- op = req_capsule_client_get(&req->rq_pill, &RMF_SEQ_OPC);
- *op = opc;
-
- /* Zero out input range, this is not recovery yet. */
- in = req_capsule_client_get(&req->rq_pill, &RMF_SEQ_RANGE);
- range_init(in);
-
- ptlrpc_request_set_replen(req);
-
- if (seq->lcs_type == LUSTRE_SEQ_METADATA) {
- req->rq_request_portal = SEQ_METADATA_PORTAL;
- in->lsr_flags = LU_SEQ_RANGE_MDT;
- } else {
- LASSERTF(seq->lcs_type == LUSTRE_SEQ_DATA,
- "unknown lcs_type %u\n", seq->lcs_type);
- req->rq_request_portal = SEQ_DATA_PORTAL;
- in->lsr_flags = LU_SEQ_RANGE_OST;
- }
-
- if (opc == SEQ_ALLOC_SUPER) {
- /* Update index field of *in, it is required for
- * FLD update on super sequence allocator node. */
- in->lsr_index = seq->lcs_space.lsr_index;
- req->rq_request_portal = SEQ_CONTROLLER_PORTAL;
- } else {
- LASSERTF(opc == SEQ_ALLOC_META,
- "unknown opcode %u\n, opc", opc);
- }
-
- ptlrpc_at_set_req_timeout(req);
-
- mdc_get_rpc_lock(exp->exp_obd->u.cli.cl_rpc_lock, NULL);
- rc = ptlrpc_queue_wait(req);
- mdc_put_rpc_lock(exp->exp_obd->u.cli.cl_rpc_lock, NULL);
-
- if (rc)
- GOTO(out_req, rc);
-
- out = req_capsule_server_get(&req->rq_pill, &RMF_SEQ_RANGE);
- *output = *out;
-
- if (!range_is_sane(output)) {
- CERROR("%s: Invalid range received from server: "
- DRANGE"\n", seq->lcs_name, PRANGE(output));
- GOTO(out_req, rc = -EINVAL);
- }
-
- if (range_is_exhausted(output)) {
- CERROR("%s: Range received from server is exhausted: "
- DRANGE"]\n", seq->lcs_name, PRANGE(output));
- GOTO(out_req, rc = -EINVAL);
- }
-
- CDEBUG(D_INFO, "%s: Allocated %s-sequence "DRANGE"]\n",
- seq->lcs_name, opcname, PRANGE(output));
-
- EXIT;
+ struct obd_export *exp = seq->lcs_exp;
+ struct ptlrpc_request *req;
+ struct lu_seq_range *out, *in;
+ __u32 *op;
+ unsigned int debug_mask;
+ int rc;
+ ENTRY;
+
+ req = ptlrpc_request_alloc_pack(class_exp2cliimp(exp), &RQF_SEQ_QUERY,
+ LUSTRE_MDS_VERSION, SEQ_QUERY);
+ if (req == NULL)
+ RETURN(-ENOMEM);
+
+ /* Init operation code */
+ op = req_capsule_client_get(&req->rq_pill, &RMF_SEQ_OPC);
+ *op = opc;
+
+ /* Zero out input range, this is not recovery yet. */
+ in = req_capsule_client_get(&req->rq_pill, &RMF_SEQ_RANGE);
+ range_init(in);
+
+ ptlrpc_request_set_replen(req);
+
+ if (seq->lcs_type == LUSTRE_SEQ_METADATA) {
+ req->rq_request_portal = SEQ_METADATA_PORTAL;
+ in->lsr_flags = LU_SEQ_RANGE_MDT;
+ } else {
+ LASSERTF(seq->lcs_type == LUSTRE_SEQ_DATA,
+ "unknown lcs_type %u\n", seq->lcs_type);
+ req->rq_request_portal = SEQ_DATA_PORTAL;
+ in->lsr_flags = LU_SEQ_RANGE_OST;
+ }
+
+ if (opc == SEQ_ALLOC_SUPER) {
+ /* Update index field of *in, it is required for
+ * FLD update on super sequence allocator node. */
+ in->lsr_index = seq->lcs_space.lsr_index;
+ req->rq_request_portal = SEQ_CONTROLLER_PORTAL;
+ debug_mask = D_CONSOLE;
+ } else {
+ debug_mask = D_INFO;
+ LASSERTF(opc == SEQ_ALLOC_META,
+ "unknown opcode %u\n, opc", opc);
+ }
+
+ ptlrpc_at_set_req_timeout(req);
+
+ mdc_get_rpc_lock(exp->exp_obd->u.cli.cl_rpc_lock, NULL);
+ rc = ptlrpc_queue_wait(req);
+ mdc_put_rpc_lock(exp->exp_obd->u.cli.cl_rpc_lock, NULL);
+
+ if (rc)
+ GOTO(out_req, rc);
+
+ out = req_capsule_server_get(&req->rq_pill, &RMF_SEQ_RANGE);
+ *output = *out;
+
+ if (!range_is_sane(output)) {
+ CERROR("%s: Invalid range received from server: "
+ DRANGE"\n", seq->lcs_name, PRANGE(output));
+ GOTO(out_req, rc = -EINVAL);
+ }
+
+ if (range_is_exhausted(output)) {
+ CERROR("%s: Range received from server is exhausted: "
+ DRANGE"]\n", seq->lcs_name, PRANGE(output));
+ GOTO(out_req, rc = -EINVAL);
+ }
+
+ CDEBUG_LIMIT(debug_mask, "%s: Allocated %s-sequence "DRANGE"]\n",
+ seq->lcs_name, opcname, PRANGE(output));
+
+ EXIT;
out_req:
- ptlrpc_req_finished(req);
- return rc;
+ ptlrpc_req_finished(req);
+ return rc;
}
/* Request sequence-controller node to allocate new super-sequence. */
int rc;
ENTRY;
- cfs_down(&seq->lcs_sem);
+ cfs_mutex_lock(&seq->lcs_mutex);
#ifdef __KERNEL__
if (seq->lcs_srv) {
#ifdef __KERNEL__
}
#endif
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
RETURN(rc);
}
if (seq->lcs_update) {
cfs_waitq_add(&seq->lcs_waitq, link);
cfs_set_current_state(CFS_TASK_UNINT);
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
cfs_waitq_wait(link, CFS_TASK_UNINT);
- cfs_down(&seq->lcs_sem);
+ cfs_mutex_lock(&seq->lcs_mutex);
cfs_waitq_del(&seq->lcs_waitq, link);
cfs_set_current_state(CFS_TASK_RUNNING);
return -EAGAIN;
}
++seq->lcs_update;
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
return 0;
}
static void seq_fid_alloc_fini(struct lu_client_seq *seq)
{
LASSERT(seq->lcs_update == 1);
- cfs_down(&seq->lcs_sem);
+ cfs_mutex_lock(&seq->lcs_mutex);
--seq->lcs_update;
cfs_waitq_signal(&seq->lcs_waitq);
}
int rc;
LASSERT(seqnr != NULL);
- cfs_down(&seq->lcs_sem);
+ cfs_mutex_lock(&seq->lcs_mutex);
cfs_waitlink_init(&link);
while (1) {
CERROR("%s: Can't allocate new sequence, "
"rc %d\n", seq->lcs_name, rc);
seq_fid_alloc_fini(seq);
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
return rc;
}
* to setup FLD for it.
*/
seq_fid_alloc_fini(seq);
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
return rc;
}
LASSERT(fid != NULL);
cfs_waitlink_init(&link);
- cfs_down(&seq->lcs_sem);
+ cfs_mutex_lock(&seq->lcs_mutex);
+
+ if (OBD_FAIL_CHECK(OBD_FAIL_SEQ_EXHAUST))
+ seq->lcs_fid.f_oid = seq->lcs_width;
while (1) {
seqno_t seqnr;
CERROR("%s: Can't allocate new sequence, "
"rc %d\n", seq->lcs_name, rc);
seq_fid_alloc_fini(seq);
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
RETURN(rc);
}
}
*fid = seq->lcs_fid;
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
CDEBUG(D_INFO, "%s: Allocated FID "DFID"\n", seq->lcs_name, PFID(fid));
RETURN(rc);
LASSERT(seq != NULL);
cfs_waitlink_init(&link);
- cfs_down(&seq->lcs_sem);
+ cfs_mutex_lock(&seq->lcs_mutex);
while (seq->lcs_update) {
cfs_waitq_add(&seq->lcs_waitq, &link);
cfs_set_current_state(CFS_TASK_UNINT);
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
cfs_waitq_wait(&link, CFS_TASK_UNINT);
- cfs_down(&seq->lcs_sem);
+ cfs_mutex_lock(&seq->lcs_mutex);
cfs_waitq_del(&seq->lcs_waitq, &link);
cfs_set_current_state(CFS_TASK_RUNNING);
}
seq->lcs_space.lsr_index = -1;
range_init(&seq->lcs_space);
- cfs_up(&seq->lcs_sem);
+ cfs_mutex_unlock(&seq->lcs_mutex);
}
EXPORT_SYMBOL(seq_client_flush);
seq->lcs_exp = exp;
seq->lcs_srv = srv;
seq->lcs_type = type;
- cfs_sema_init(&seq->lcs_sem, 1);
+ cfs_mutex_init(&seq->lcs_mutex);
seq->lcs_width = LUSTRE_SEQ_MAX_WIDTH;
cfs_waitq_init(&seq->lcs_waitq);
git://git.whamcloud.com / fs / lustre-release.git / blobdiff