*
* Copyright (C) 2002 Cluster File Systems, Inc.
*
- * This file is part of Lustre, http://www.lustre.org.
+ * This file is part of the Lustre file system, http://www.lustre.org
+ * Lustre is a trademark of Cluster File Systems, Inc.
*
- * Lustre is free software; you can redistribute it and/or
- * modify it under the terms of version 2 of the GNU General Public
- * License as published by the Free Software Foundation.
+ * You may have signed or agreed to another license before downloading
+ * this software. If so, you are bound by the terms and conditions
+ * of that agreement, and the following does not apply to you. See the
+ * LICENSE file included with this distribution for more information.
*
- * Lustre is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
+ * If you did not agree to a different license, then this copy of Lustre
+ * is open source software; you can redistribute it and/or modify it
+ * under the terms of version 2 of the GNU General Public License as
+ * published by the Free Software Foundation.
*
- * You should have received a copy of the GNU General Public License
- * along with Lustre; if not, write to the Free Software
- * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ * In either case, Lustre is distributed in the hope that it will be
+ * useful, but WITHOUT ANY WARRANTY; without even the implied warranty
+ * of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * license text for more details.
*
*/
#define DEBUG_SUBSYSTEM S_CLASS
{ MDS_SET_INFO, "mds_set_info" },
{ MDS_QUOTACHECK, "mds_quotacheck" },
{ MDS_QUOTACTL, "mds_quotactl" },
+ { MDS_GETXATTR, "mds_getxattr" },
+ { MDS_SETXATTR, "mds_setxattr" },
{ LDLM_ENQUEUE, "ldlm_enqueue" },
{ LDLM_CONVERT, "ldlm_convert" },
{ LDLM_CANCEL, "ldlm_cancel" },
{ LDLM_BL_CALLBACK, "ldlm_bl_callback" },
{ LDLM_CP_CALLBACK, "ldlm_cp_callback" },
{ LDLM_GL_CALLBACK, "ldlm_gl_callback" },
- { PTLBD_QUERY, "ptlbd_query" },
- { PTLBD_READ, "ptlbd_read" },
- { PTLBD_WRITE, "ptlbd_write" },
- { PTLBD_FLUSH, "ptlbd_flush" },
- { PTLBD_CONNECT, "ptlbd_connect" },
- { PTLBD_DISCONNECT, "ptlbd_disconnect" },
{ OBD_PING, "obd_ping" },
{ OBD_LOG_CANCEL, "llog_origin_handle_cancel"},
};
return ll_rpc_opcode_table[offset].opname;
}
-#ifndef LPROCFS
-void ptlrpc_lprocfs_register_service(struct obd_device *obddev,
- struct ptlrpc_service *svc) { return ; }
-void ptlrpc_lprocfs_unregister_service(struct ptlrpc_service *svc) { return; }
-#else
-
+#ifdef LPROCFS
void ptlrpc_lprocfs_register(struct proc_dir_entry *root, char *dir,
char *name, struct proc_dir_entry **procroot_ret,
struct lprocfs_stats **stats_ret)
int count, int *eof, void *data)
{
struct ptlrpc_service *svc = data;
-
+
*eof = 1;
return snprintf(page, count, "%d\n", svc->srv_n_history_rqbds);
}
int count, int *eof, void *data)
{
struct ptlrpc_service *svc = data;
-
+
*eof = 1;
return snprintf(page, count, "%d\n", svc->srv_max_history_rqbds);
}
unsigned long flags;
int val;
int rc = lprocfs_write_helper(buffer, count, &val);
-
+
if (rc < 0)
return rc;
bufpages = (svc->srv_buf_size + PAGE_SIZE - 1)/PAGE_SIZE;
if (val > num_physpages/(2*bufpages))
return -ERANGE;
-
+
spin_lock_irqsave(&svc->srv_lock, flags);
svc->srv_max_history_rqbds = val;
spin_unlock_irqrestore(&svc->srv_lock, flags);
-
+
return count;
}
srhi->srhi_seq <= seq) {
/* If srhi_req was set previously, hasn't been culled and
* we're searching for a seq on or after it (i.e. more
- * recent), search from it onwards.
+ * recent), search from it onwards.
* Since the service history is LRU (i.e. culled reqs will
* be near the head), we shouldn't have to do long
* re-scans */
while (e != &svc->srv_request_history) {
req = list_entry(e, struct ptlrpc_request, rq_history_list);
-
+
if (req->rq_history_seq >= seq) {
srhi->srhi_seq = req->rq_history_seq;
srhi->srhi_req = req;
}
e = e->next;
}
-
+
return -ENOENT;
}
srhi->srhi_seq = 0;
srhi->srhi_req = NULL;
-
+
spin_lock_irqsave(&svc->srv_lock, flags);
rc = ptlrpc_lprocfs_svc_req_history_seek(svc, srhi, *pos);
spin_unlock_irqrestore(&svc->srv_lock, flags);
-
+
if (rc == 0) {
*pos = srhi->srhi_seq;
return srhi;
}
-
+
OBD_FREE(srhi, sizeof(*srhi));
return NULL;
}
}
static void *
-ptlrpc_lprocfs_svc_req_history_next(struct seq_file *s,
+ptlrpc_lprocfs_svc_req_history_next(struct seq_file *s,
void *iter, loff_t *pos)
{
struct ptlrpc_service *svc = s->private;
* parser. Currently I only print stuff here I know is OK
* to look at coz it was set up in request_in_callback()!!! */
seq_printf(s, LPD64":%s:%s:"LPD64":%d:%s ",
- req->rq_history_seq,
- req->rq_peer.peer_ni->pni_name, req->rq_peerstr,
- req->rq_xid, req->rq_reqlen,ptlrpc_rqphase2str(req));
+ req->rq_history_seq, libcfs_nid2str(req->rq_self),
+ libcfs_id2str(req->rq_peer), req->rq_xid,
+ req->rq_reqlen,ptlrpc_rqphase2str(req));
if (svc->srv_request_history_print_fn == NULL)
seq_printf(s, "\n");
struct ptlrpc_service *svc)
{
struct lprocfs_vars lproc_vars[] = {
- {.name = "req_buffer_history_len",
+ {.name = "req_buffer_history_len",
.write_fptr = NULL,
- .read_fptr = ptlrpc_lprocfs_read_req_history_len,
+ .read_fptr = ptlrpc_lprocfs_read_req_history_len,
.data = svc},
{.name = "req_buffer_history_max",
.write_fptr = ptlrpc_lprocfs_write_req_history_max,
- .read_fptr = ptlrpc_lprocfs_read_req_history_max,
+ .read_fptr = ptlrpc_lprocfs_read_req_history_max,
.data = svc},
{NULL}
};
ptlrpc_lprocfs_register(entry, svc->srv_name,
"stats", &svc->srv_procroot,
&svc->srv_stats);
-
+
if (svc->srv_procroot == NULL)
return;
lprocfs_add_vars(svc->srv_procroot, lproc_vars, NULL);
- req_history = create_proc_entry("req_history", 0400,
+ req_history = create_proc_entry("req_history", 0400,
svc->srv_procroot);
if (req_history != NULL) {
req_history->data = svc;
&obddev->obd_svc_procroot,
&obddev->obd_svc_stats);
}
+EXPORT_SYMBOL(ptlrpc_lprocfs_register_obd);
void ptlrpc_lprocfs_rpc_sent(struct ptlrpc_request *req)
{
obd->obd_svc_stats = NULL;
}
}
+EXPORT_SYMBOL(ptlrpc_lprocfs_unregister_obd);
+
int lprocfs_wr_evict_client(struct file *file, const char *buffer,
unsigned long count, void *data)
{
struct obd_device *obd = data;
- struct obd_export *doomed_exp = NULL;
- struct obd_uuid doomed;
- struct list_head *p;
- char tmpbuf[sizeof(doomed)];
+ char tmpbuf[sizeof(struct obd_uuid)];
sscanf(buffer, "%40s", tmpbuf);
- obd_str2uuid(&doomed, tmpbuf);
-
- spin_lock(&obd->obd_dev_lock);
- list_for_each(p, &obd->obd_exports) {
- doomed_exp = list_entry(p, struct obd_export, exp_obd_chain);
- if (obd_uuid_equals(&doomed, &doomed_exp->exp_client_uuid)) {
- class_export_get(doomed_exp);
- break;
- }
- doomed_exp = NULL;
- }
- spin_unlock(&obd->obd_dev_lock);
- if (doomed_exp == NULL) {
- CERROR("can't disconnect %s: no export found\n", doomed.uuid);
- } else {
- CERROR("evicting %s at adminstrative request\n", doomed.uuid);
- ptlrpc_fail_export(doomed_exp);
- class_export_put(doomed_exp);
- }
+ obd_export_evict_by_uuid(obd, tmpbuf);
+
return count;
}
EXPORT_SYMBOL(lprocfs_wr_evict_client);
int rc;
ENTRY;
- req = ptlrpc_prep_req(obd->u.cli.cl_import, OBD_PING, 0, NULL, NULL);
+ req = ptlrpc_prep_req(obd->u.cli.cl_import, LUSTRE_OBD_VERSION,
+ OBD_PING, 0, NULL, NULL);
if (req == NULL)
RETURN(-ENOMEM);
git://git.whamcloud.com / fs / lustre-release.git / blobdiff