4 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License version 2 only,
8 * as published by the Free Software Foundation.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License version 2 for more details (a copy is included
14 * in the LICENSE file that accompanied this code).
16 * You should have received a copy of the GNU General Public License
17 * version 2 along with this program; If not, see
18 * http://www.gnu.org/licenses/gpl-2.0.html
23 * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
24 * Use is subject to license terms.
26 * Copyright (c) 2013, Intel Corporation.
29 * This file is part of Lustre, http://www.lustre.org/
31 * lustre/utils/lr_reader.c
33 * Author: Nathan Rutman <nathan@clusterfs.com>
35 /* Safely read the last_rcvd file from a device */
39 #endif /* HAVE_CONFIG_H */
54 #include <sys/types.h>
56 #include <sys/mount.h>
61 #include <asm/byteorder.h>
62 #include <linux/lustre/lustre_disk.h>
63 #include <linux/lustre/lustre_ver.h>
66 static struct option const long_opts[] = {
67 { .val = 'c', .name = "client", .has_arg = no_argument },
68 { .val = 'h', .name = "help", .has_arg = no_argument },
69 { .val = 'r', .name = "reply", .has_arg = no_argument },
72 /* Executes the command \a cmd and returns command status.
74 int run_command(char *cmd, size_t cmdsz)
76 char log[] = "/tmp/run_command_logXXXXXX";
79 if (strlen(cmd) + strlen(log) + 8 > cmdsz) {
80 fprintf(stderr, "Command buffer overflow: %.*s...\n",
88 strncat(cmd, " >", cmdsz);
89 strncat(cmd, log, cmdsz);
91 strncat(cmd, " 2>&1", cmdsz - strlen(cmd));
93 /* Can't use popen because we need the rv of the command */
100 while (fgets(buf, sizeof(buf), fp) != NULL) {
113 void display_usage(void)
115 printf("Usage: %s [OPTIONS] devicename\n", progname);
116 printf("Read and print the last_rcvd file from a device\n");
117 printf("(safe for mounted devices)\n");
118 printf("\t-c, --client, display client information\n");
119 printf("\t-h, --help, display this help and exit\n");
120 printf("\t-r, --reply, display reply data information\n");
124 int main(int argc, char *const argv[])
126 char tmpdir[] = "/tmp/dirXXXXXX";
128 char filepnm[128] = "";
130 struct lr_server_data lsd;
138 while ((c = getopt_long(argc, argv, "chr", long_opts, NULL)) != -1) {
158 /* Make a temporary directory to hold Lustre data files. */
159 if (!mkdtemp(tmpdir)) {
160 fprintf(stderr, "%s: Can't create temporary directory %s: %s\n",
161 progname, tmpdir, strerror(errno));
165 memset(cmd, 0, sizeof(cmd));
166 snprintf(cmd, sizeof(cmd),
167 "%s -c -R 'dump /%s %s/%s' %s",
168 DEBUGFS, LAST_RCVD, tmpdir, LAST_RCVD, dev);
170 ret = run_command(cmd, sizeof(cmd));
172 fprintf(stderr, "%s: Unable to dump %s file\n",
173 progname, LAST_RCVD);
177 snprintf(filepnm, 128, "%s/%s", tmpdir, LAST_RCVD);
178 filep = fopen(filepnm, "r");
180 fprintf(stderr, "%s: Unable to read old data\n",
187 /* read lr_server_data structure */
188 printf("%s:\n", LAST_RCVD);
189 ret = fread(&lsd, 1, sizeof(lsd), filep);
190 if (ret < sizeof(lsd)) {
191 fprintf(stderr, "%s: Short read (%d of %d)\n",
192 progname, ret, (int)sizeof(lsd));
193 ret = -ferror(filep);
198 /* swab structure fields of interest */
199 lsd.lsd_feature_compat = __le32_to_cpu(lsd.lsd_feature_compat);
200 lsd.lsd_feature_incompat = __le32_to_cpu(lsd.lsd_feature_incompat);
201 lsd.lsd_feature_rocompat = __le32_to_cpu(lsd.lsd_feature_rocompat);
202 lsd.lsd_last_transno = __le64_to_cpu(lsd.lsd_last_transno);
203 lsd.lsd_osd_index = __le32_to_cpu(lsd.lsd_osd_index);
204 lsd.lsd_mount_count = __le64_to_cpu(lsd.lsd_mount_count);
207 printf(" uuid: %.40s\n", lsd.lsd_uuid);
208 printf(" feature_compat: %#x\n", lsd.lsd_feature_compat);
209 printf(" feature_incompat: %#x\n", lsd.lsd_feature_incompat);
210 printf(" feature_rocompat: %#x\n", lsd.lsd_feature_rocompat);
211 printf(" last_transaction: %llu\n",
212 (unsigned long long)lsd.lsd_last_transno);
213 printf(" target_index: %u\n", lsd.lsd_osd_index);
214 printf(" mount_count: %llu\n",
215 (unsigned long long)lsd.lsd_mount_count);
217 /* read client information */
219 lsd.lsd_client_start = __le32_to_cpu(lsd.lsd_client_start);
220 lsd.lsd_client_size = __le16_to_cpu(lsd.lsd_client_size);
221 printf(" client_area_start: %u\n", lsd.lsd_client_start);
222 printf(" client_area_size: %hu\n", lsd.lsd_client_size);
224 /* seek to per-client data area */
225 ret = fseek(filep, lsd.lsd_client_start, SEEK_SET);
227 fprintf(stderr, "%s: seek failed. %s\n",
228 progname, strerror(errno));
233 /* walk throuh the per-client data area */
235 struct lsd_client_data lcd;
237 /* read a per-client data area */
238 ret = fread(&lcd, 1, sizeof(lcd), filep);
239 if (ret < sizeof(lcd)) {
242 fprintf(stderr, "%s: Short read (%d of %d)\n",
243 progname, ret, (int)sizeof(lcd));
244 ret = -ferror(filep);
248 if (lcd.lcd_uuid[0] == '\0')
251 /* swab structure fields */
252 lcd.lcd_last_transno =
253 __le64_to_cpu(lcd.lcd_last_transno);
254 lcd.lcd_last_xid = __le64_to_cpu(lcd.lcd_last_xid);
255 lcd.lcd_last_result = __le32_to_cpu(lcd.lcd_last_result);
256 lcd.lcd_last_data = __le32_to_cpu(lcd.lcd_last_data);
257 lcd.lcd_generation = __le32_to_cpu(lcd.lcd_generation);
259 /* display per-client data area */
260 printf("\n %.40s:\n", lcd.lcd_uuid);
261 printf(" generation: %u\n", lcd.lcd_generation);
262 printf(" last_transaction: %llu\n",
263 (unsigned long long)lcd.lcd_last_transno);
264 printf(" last_xid: %llu\n",
265 (unsigned long long)lcd.lcd_last_xid);
266 printf(" last_result: %u\n", lcd.lcd_last_result);
267 printf(" last_data: %u\n", lcd.lcd_last_data);
269 if (lcd.lcd_last_close_transno != 0 &&
270 lcd.lcd_last_close_xid != 0) {
271 lcd.lcd_last_close_transno =
272 __le64_to_cpu(lcd.lcd_last_close_transno);
273 lcd.lcd_last_close_xid =
274 __le64_to_cpu(lcd.lcd_last_close_xid);
275 lcd.lcd_last_close_result =
276 __le32_to_cpu(lcd.lcd_last_close_result);
277 lcd.lcd_last_close_data =
278 __le32_to_cpu(lcd.lcd_last_close_data);
279 printf(" last_close_transation: %llu\n",
280 (unsigned long long)lcd.lcd_last_close_transno);
281 printf(" last_close_xid: %llu\n",
282 (unsigned long long)lcd.lcd_last_close_xid);
283 printf(" last_close_result: %u\n",
284 lcd.lcd_last_close_result);
285 printf(" last_close_data: %u\n",
286 lcd.lcd_last_close_data);
293 /* read reply data information */
295 struct lsd_reply_header lrh;
296 struct lsd_reply_data lrd;
297 unsigned long long slot;
299 snprintf(cmd, sizeof(cmd),
300 "%s -c -R 'dump /%s %s/%s' %s",
301 DEBUGFS, REPLY_DATA, tmpdir, REPLY_DATA, dev);
303 ret = run_command(cmd, sizeof(cmd));
305 fprintf(stderr, "%s: Unable to dump %s file\n",
306 progname, REPLY_DATA);
310 snprintf(filepnm, sizeof(filepnm),
311 "%s/%s", tmpdir, REPLY_DATA);
312 filep = fopen(filepnm, "r");
314 fprintf(stderr, "%s: Unable to read reply data\n",
321 /* read reply_data header */
322 printf("\n%s:\n", REPLY_DATA);
323 ret = fread(&lrh, 1, sizeof(lrh), filep);
324 if (ret < sizeof(lrh)) {
325 fprintf(stderr, "%s: Short read (%d of %d)\n",
326 progname, ret, (int)sizeof(lrh));
327 ret = -ferror(filep);
333 lrh.lrh_magic = __le32_to_cpu(lrh.lrh_magic);
334 lrh.lrh_header_size = __le32_to_cpu(lrh.lrh_header_size);
335 lrh.lrh_reply_size = __le32_to_cpu(lrh.lrh_reply_size);
336 if (lrh.lrh_magic != LRH_MAGIC) {
337 fprintf(stderr, "%s: invalid %s header: "
338 "lrh_magic=%08x expected %08x\n",
339 progname, REPLY_DATA, lrh.lrh_magic, LRH_MAGIC);
342 if (lrh.lrh_header_size != sizeof(struct lsd_reply_header)) {
343 fprintf(stderr, "%s: invalid %s header: "
344 "lrh_header_size=%08x expected %08x\n",
345 progname, REPLY_DATA, lrh.lrh_header_size,
346 (unsigned int)sizeof(struct lsd_reply_header));
349 if (lrh.lrh_reply_size != sizeof(struct lsd_reply_data)) {
350 fprintf(stderr, "%s: invalid %s header: "
351 "lrh_reply_size=%08x expected %08x\n",
352 progname, REPLY_DATA, lrh.lrh_reply_size,
353 (unsigned int)sizeof(struct lsd_reply_data));
357 /* walk throuh the reply data */
358 for (slot = 0; ; slot++) {
359 /* read a reply data */
360 ret = fread(&lrd, 1, sizeof(lrd), filep);
361 if (ret < sizeof(lrd)) {
364 fprintf(stderr, "%s: Short read (%d of %d)\n",
365 progname, ret, (int)sizeof(lrd));
366 ret = -ferror(filep);
370 /* display reply data */
371 lrd.lrd_transno = __le64_to_cpu(lrd.lrd_transno);
372 lrd.lrd_xid = __le64_to_cpu(lrd.lrd_xid);
373 lrd.lrd_data = __le64_to_cpu(lrd.lrd_data);
374 lrd.lrd_result = __le32_to_cpu(lrd.lrd_result);
375 lrd.lrd_client_gen = __le32_to_cpu(lrd.lrd_client_gen);
377 printf(" %lld:\n", slot);
378 printf(" client_generation: %u\n",
380 printf(" last_transaction: %lluu\n",
381 (unsigned long long)lrd.lrd_transno);
382 printf(" last_xid: %llu\n",
383 (unsigned long long)lrd.lrd_xid);
384 printf(" last_result: %u\n", lrd.lrd_result);
385 printf(" last_data: %llu\n\n",
386 (unsigned long long)lrd.lrd_data);