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.sun.com/software/products/lustre/docs/GPLv2.pdf
20 * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
21 * CA 95054 USA or visit www.sun.com if you need additional information or
27 * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
28 * Use is subject to license terms.
30 * Copyright (c) 2013, Intel Corporation.
33 * This file is part of Lustre, http://www.lustre.org/
34 * Lustre is a trademark of Sun Microsystems, Inc.
36 * lustre/utils/lr_reader.c
38 * Author: Nathan Rutman <nathan@clusterfs.com>
40 /* Safely read the last_rcvd file from a device */
44 #endif /* HAVE_CONFIG_H */
57 #include <sys/types.h>
59 #include <sys/mount.h>
64 #include <lustre_disk.h>
65 #include <lustre_ver.h>
68 static struct option const longopts[] = {
69 { "help", no_argument, 0, 'h' },
70 { "client", no_argument, 0, 'c' },
71 { "reply", no_argument, 0, 'r' },
75 /* Executes the command \a cmd and returns command status.
77 int run_command(char *cmd, size_t cmdsz)
79 char log[] = "/tmp/run_command_logXXXXXX";
82 if (strlen(cmd) + strlen(log) + 8 > cmdsz) {
83 fprintf(stderr, "Command buffer overflow: %.*s...\n",
91 strncat(cmd, " >", 2);
92 strncat(cmd, log, strlen(log));
94 strncat(cmd, " 2>&1", 5);
96 /* Can't use popen because we need the rv of the command */
101 fp = fopen(log, "r");
103 while (fgets(buf, sizeof(buf), fp) != NULL) {
116 void display_usage(void)
118 printf("Usage: %s [OPTIONS] devicename\n", progname);
119 printf("Read and print the last_rcvd file from a device\n");
120 printf("(safe for mounted devices)\n");
121 printf("\t-c, --client, display client information\n");
122 printf("\t-h, --help, display this help and exit\n");
123 printf("\t-r, --reply, display reply data information\n");
127 int main(int argc, char *const argv[])
129 char tmpdir[] = "/tmp/dirXXXXXX";
131 char filepnm[128] = "";
133 struct lr_server_data lsd;
141 while ((c = getopt_long(argc, argv, "chr", longopts, NULL)) != -1) {
161 /* Make a temporary directory to hold Lustre data files. */
162 if (!mkdtemp(tmpdir)) {
163 fprintf(stderr, "%s: Can't create temporary directory %s: %s\n",
164 progname, tmpdir, strerror(errno));
168 memset(cmd, 0, sizeof(cmd));
169 snprintf(cmd, sizeof(cmd),
170 "%s -c -R 'dump /%s %s/%s' %s",
171 DEBUGFS, LAST_RCVD, tmpdir, LAST_RCVD, dev);
173 ret = run_command(cmd, sizeof(cmd));
175 fprintf(stderr, "%s: Unable to dump %s file\n",
176 progname, LAST_RCVD);
180 snprintf(filepnm, 128, "%s/%s", tmpdir, LAST_RCVD);
181 filep = fopen(filepnm, "r");
183 fprintf(stderr, "%s: Unable to read old data\n",
190 /* read lr_server_data structure */
191 printf("%s:\n", LAST_RCVD);
192 ret = fread(&lsd, 1, sizeof(lsd), filep);
193 if (ret < sizeof(lsd)) {
194 fprintf(stderr, "%s: Short read (%d of %d)\n",
195 progname, ret, (int)sizeof(lsd));
196 ret = -ferror(filep);
201 /* swab structure fields of interest */
202 lsd.lsd_feature_compat = le32_to_cpu(lsd.lsd_feature_compat);
203 lsd.lsd_feature_incompat = le32_to_cpu(lsd.lsd_feature_incompat);
204 lsd.lsd_feature_rocompat = le32_to_cpu(lsd.lsd_feature_rocompat);
205 lsd.lsd_last_transno = le64_to_cpu(lsd.lsd_last_transno);
206 lsd.lsd_osd_index = le32_to_cpu(lsd.lsd_osd_index);
207 lsd.lsd_mount_count = le64_to_cpu(lsd.lsd_mount_count);
210 printf(" uuid: %.40s\n", lsd.lsd_uuid);
211 printf(" feature_compat: %#x\n", lsd.lsd_feature_compat);
212 printf(" feature_incompat: %#x\n", lsd.lsd_feature_incompat);
213 printf(" feature_rocompat: %#x\n", lsd.lsd_feature_rocompat);
214 printf(" last_transaction: %llu\n", lsd.lsd_last_transno);
215 printf(" target_index: %u\n", lsd.lsd_osd_index);
216 printf(" mount_count: %llu\n", lsd.lsd_mount_count);
218 /* read client information */
220 lsd.lsd_client_start = le32_to_cpu(lsd.lsd_client_start);
221 lsd.lsd_client_size = le16_to_cpu(lsd.lsd_client_size);
222 printf(" client_area_start: %u\n", lsd.lsd_client_start);
223 printf(" client_area_size: %hu\n", lsd.lsd_client_size);
225 /* seek to per-client data area */
226 ret = fseek(filep, lsd.lsd_client_start, SEEK_SET);
228 fprintf(stderr, "%s: seek failed. %s\n",
229 progname, strerror(errno));
234 /* walk throuh the per-client data area */
236 struct lsd_client_data lcd;
238 /* read a per-client data area */
239 ret = fread(&lcd, 1, sizeof(lcd), filep);
240 if (ret < sizeof(lcd)) {
243 fprintf(stderr, "%s: Short read (%d of %d)\n",
244 progname, ret, (int)sizeof(lcd));
245 ret = -ferror(filep);
249 if (lcd.lcd_uuid[0] == '\0')
252 /* swab structure fields */
253 lcd.lcd_last_transno =
254 le64_to_cpu(lcd.lcd_last_transno);
255 lcd.lcd_last_xid = le64_to_cpu(lcd.lcd_last_xid);
256 lcd.lcd_last_result = le32_to_cpu(lcd.lcd_last_result);
257 lcd.lcd_last_data = le32_to_cpu(lcd.lcd_last_data);
258 lcd.lcd_generation = le32_to_cpu(lcd.lcd_generation);
260 /* display per-client data area */
261 printf("\n %.40s:\n", lcd.lcd_uuid);
262 printf(" generation: %u\n", lcd.lcd_generation);
263 printf(" last_transaction: %llu\n",
264 lcd.lcd_last_transno);
265 printf(" last_xid: %llu\n", 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 lcd.lcd_last_close_transno);
281 printf(" last_close_xid: %llu\n",
282 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: %llu\n", lrd.lrd_transno);
381 printf(" last_xid: %llu\n", lrd.lrd_xid);
382 printf(" last_result: %u\n", lrd.lrd_result);
383 printf(" last_data: %llu\n\n", lrd.lrd_data);