Whamcloud - gitweb
50d402d9132fcd584a7e8e2414f1f31725b907bb
[fs/lustre-release.git] / lustre / llite / dir.c
1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2  * vim:expandtab:shiftwidth=8:tabstop=8:
3  *
4  * Copyright (C) 1992, 1993, 1994, 1995
5  * Remy Card (card@masi.ibp.fr)
6  * Laboratoire MASI - Institut Blaise Pascal
7  * Universite Pierre et Marie Curie (Paris VI)
8  *
9  *  from
10  *
11  *  linux/fs/minix/dir.c
12  *  linux/fs/ext2/dir.c
13  *
14  *  Copyright (C) 1991, 1992  Linus Torvalds
15  *
16  *  ext2 directory handling functions
17  *
18  *  Big-endian to little-endian byte-swapping/bitmaps by
19  *        David S. Miller (davem@caip.rutgers.edu), 1995
20  *
21  *  All code that works with directory layout had been switched to pagecache
22  *  and moved here. AV
23  *
24  *  Adapted for Lustre Light
25  *  Copyright (C) 2002-2003, Cluster File Systems, Inc.
26  *
27  */
28
29 #include <linux/fs.h>
30 #include <linux/ext2_fs.h>
31 #include <linux/pagemap.h>
32 #include <linux/mm.h>
33 #include <linux/version.h>
34 #include <linux/smp_lock.h>
35 #include <asm/uaccess.h>
36 #include <linux/file.h>
37 #include <linux/kmod.h>
38 #if (LINUX_VERSION_CODE < KERNEL_VERSION(2,5,0))
39 # include <linux/locks.h>   // for wait_on_buffer
40 #else
41 # include <linux/buffer_head.h>   // for wait_on_buffer
42 #endif
43
44 #define DEBUG_SUBSYSTEM S_LLITE
45
46 #include <linux/obd_support.h>
47 #include <linux/obd_class.h>
48 #include <linux/lustre_lib.h>
49 #include <linux/lustre_idl.h>
50 #include <linux/lustre_mds.h>
51 #include <linux/lustre_lite.h>
52 #include <linux/lustre_dlm.h>
53 #include "llite_internal.h"
54
55 typedef struct ext2_dir_entry_2 ext2_dirent;
56
57 #define PageChecked(page)        test_bit(PG_checked, &(page)->flags)
58 #define SetPageChecked(page)     set_bit(PG_checked, &(page)->flags)
59
60 /* returns the page unlocked, but with a reference */
61 static int ll_dir_readpage(struct file *file, struct page *page)
62 {
63         struct inode *inode = page->mapping->host;
64         struct ptlrpc_request *request;
65         struct mds_body *body;
66         struct lustre_id id;
67         __u64 offset;
68         int rc = 0;
69         ENTRY;
70
71         CDEBUG(D_VFSTRACE, "VFS Op:inode=%lu/%u(%p)\n", inode->i_ino,
72                inode->i_generation, inode);
73
74         mdc_pack_id(&id, inode->i_ino, inode->i_generation, 
75                     S_IFDIR, id_group(&ll_i2info(inode)->lli_id),
76                     id_fid(&ll_i2info(inode)->lli_id));
77
78         offset = page->index << PAGE_SHIFT;
79         rc = md_readpage(ll_i2sbi(inode)->ll_lmv_exp, &id, offset,
80                          page, &request);
81         if (!rc) {
82                 body = lustre_msg_buf(request->rq_repmsg, 0, sizeof(*body));
83                 LASSERT (body != NULL);          /* checked by md_readpage() */
84                 LASSERT_REPSWABBED (request, 0); /* swabbed by md_readpage() */
85
86 #warning "FIXME ASAP!"
87                 //inode->i_size = body->size;
88                 SetPageUptodate(page);
89         }
90         ptlrpc_req_finished(request);
91
92         unlock_page(page);
93         RETURN(rc);
94 }
95
96 struct address_space_operations ll_dir_aops = {
97         .readpage  = ll_dir_readpage,
98 };
99
100 /*
101  * ext2 uses block-sized chunks. Arguably, sector-sized ones would be
102  * more robust, but we have what we have
103  */
104 static inline unsigned ext2_chunk_size(struct inode *inode)
105 {
106         return inode->i_sb->s_blocksize;
107 }
108
109 static inline void ext2_put_page(struct page *page)
110 {
111         kunmap(page);
112         page_cache_release(page);
113 }
114
115 static inline unsigned long dir_pages(struct inode *inode)
116 {
117         return (inode->i_size+PAGE_CACHE_SIZE-1)>>PAGE_CACHE_SHIFT;
118 }
119
120 static void ext2_check_page(struct page *page)
121 {
122         struct inode *dir = page->mapping->host;
123         unsigned chunk_size = ext2_chunk_size(dir);
124         char *kaddr = page_address(page);
125         //      u32 max_inumber = le32_to_cpu(sb->u.ext2_sb.s_es->s_inodes_count);
126         unsigned offs, rec_len;
127         unsigned limit = PAGE_CACHE_SIZE;
128         ext2_dirent *p;
129         char *error;
130
131         if ((dir->i_size >> PAGE_CACHE_SHIFT) == page->index) {
132                 limit = dir->i_size & ~PAGE_CACHE_MASK;
133                 if (limit & (chunk_size - 1)) {
134                         CERROR("limit %d dir size %lld index %ld\n",
135                                limit, dir->i_size, page->index);
136                         goto Ebadsize;
137                 }
138                 for (offs = limit; offs<PAGE_CACHE_SIZE; offs += chunk_size) {
139                         ext2_dirent *p = (ext2_dirent*)(kaddr + offs);
140                         p->rec_len = cpu_to_le16(chunk_size);
141                         p->name_len = 0;
142                         p->inode = 0;
143                 }
144                 if (!limit)
145                         goto out;
146         }
147         for (offs = 0; offs <= limit - EXT2_DIR_REC_LEN(1); offs += rec_len) {
148                 p = (ext2_dirent *)(kaddr + offs);
149                 rec_len = le16_to_cpu(p->rec_len);
150
151                 if (rec_len < EXT2_DIR_REC_LEN(1))
152                         goto Eshort;
153                 if (rec_len & 3)
154                         goto Ealign;
155                 if (rec_len < EXT2_DIR_REC_LEN(p->name_len))
156                         goto Enamelen;
157                 if (((offs + rec_len - 1) ^ offs) & ~(chunk_size-1))
158                         goto Espan;
159                 //              if (le32_to_cpu(p->inode) > max_inumber)
160                 //goto Einumber;
161         }
162         if (offs != limit)
163                 goto Eend;
164 out:
165         SetPageChecked(page);
166         return;
167
168         /* Too bad, we had an error */
169
170 Ebadsize:
171         CERROR("ext2_check_page"
172                 "size of directory #%lu is not a multiple of chunk size\n",
173                 dir->i_ino
174         );
175         goto fail;
176 Eshort:
177         error = "rec_len is smaller than minimal";
178         goto bad_entry;
179 Ealign:
180         error = "unaligned directory entry";
181         goto bad_entry;
182 Enamelen:
183         error = "rec_len is too small for name_len";
184         goto bad_entry;
185 Espan:
186         error = "directory entry across blocks";
187         goto bad_entry;
188         //Einumber:
189         // error = "inode out of bounds";
190 bad_entry:
191         CERROR("ext2_check_page: bad entry in directory #%lu: %s - "
192                 "offset=%lu+%u, inode=%lu, rec_len=%d, name_len=%d",
193                 dir->i_ino, error, (page->index<<PAGE_CACHE_SHIFT), offs,
194                 (unsigned long) le32_to_cpu(p->inode),
195                 rec_len, p->name_len);
196         goto fail;
197 Eend:
198         p = (ext2_dirent *)(kaddr + offs);
199         CERROR("ext2_check_page"
200                 "entry in directory #%lu spans the page boundary"
201                 "offset=%lu, inode=%lu",
202                 dir->i_ino, (page->index<<PAGE_CACHE_SHIFT)+offs,
203                 (unsigned long) le32_to_cpu(p->inode));
204 fail:
205         SetPageChecked(page);
206         SetPageError(page);
207 }
208
209 static struct page *ll_get_dir_page(struct inode *dir, unsigned long n)
210 {
211         struct ll_inode_info *li = ll_i2info(dir);
212         struct ldlm_res_id res_id =
213                 { .name = { id_fid(&li->lli_id), id_group(&li->lli_id)} };
214         struct lustre_handle lockh;
215         struct obd_device *obddev = class_exp2obd(ll_i2sbi(dir)->ll_lmv_exp);
216         struct address_space *mapping = dir->i_mapping;
217         struct page *page;
218         ldlm_policy_data_t policy = { .l_inodebits = { MDS_INODELOCK_UPDATE } };
219         int rc;
220
221         obddev = md_get_real_obd(ll_i2sbi(dir)->ll_lmv_exp, NULL, 0);
222         rc = ldlm_lock_match(obddev->obd_namespace, LDLM_FL_BLOCK_GRANTED,
223                              &res_id, LDLM_IBITS, &policy, LCK_PR, &lockh);
224         if (!rc) {
225                 struct lookup_intent it = { .it_op = IT_READDIR };
226                 struct ptlrpc_request *request;
227                 struct mdc_op_data data;
228
229                 ll_prepare_mdc_data(&data, dir, NULL, NULL, 0, 0);
230
231                 rc = md_enqueue(ll_i2sbi(dir)->ll_lmv_exp, LDLM_IBITS, &it,
232                                 LCK_PR, &data, &lockh, NULL, 0,
233                                 ldlm_completion_ast, ll_mdc_blocking_ast, dir);
234
235                 request = (struct ptlrpc_request *)it.d.lustre.it_data;
236                 if (request)
237                         ptlrpc_req_finished(request);
238                 if (rc < 0) {
239                         CERROR("lock enqueue: rc: %d\n", rc);
240                         return ERR_PTR(rc);
241                 }
242         }
243         ldlm_lock_dump_handle(D_OTHER, &lockh);
244
245         page = read_cache_page(mapping, n,
246                                (filler_t*)mapping->a_ops->readpage, NULL);
247         if (!IS_ERR(page)) {
248                 wait_on_page(page);
249                 (void)kmap(page);
250                 if (!PageUptodate(page))
251                         goto fail;
252                 if (!PageChecked(page))
253                         ext2_check_page(page);
254                 if (PageError(page))
255                         goto fail;
256         }
257
258 out_unlock:
259         ldlm_lock_decref(&lockh, LCK_PR);
260         return page;
261
262 fail:
263         ext2_put_page(page);
264         page = ERR_PTR(-EIO);
265         goto out_unlock;
266 }
267
268 /*
269  * p is at least 6 bytes before the end of page
270  */
271 static inline ext2_dirent *ext2_next_entry(ext2_dirent *p)
272 {
273         return (ext2_dirent *)((char*)p + le16_to_cpu(p->rec_len));
274 }
275
276 static inline unsigned
277 ext2_validate_entry(char *base, unsigned offset, unsigned mask)
278 {
279         ext2_dirent *de = (ext2_dirent*)(base + offset);
280         ext2_dirent *p = (ext2_dirent*)(base + (offset&mask));
281         while ((char*)p < (char*)de)
282                 p = ext2_next_entry(p);
283         return (char *)p - base;
284 }
285
286 static unsigned char ext2_filetype_table[EXT2_FT_MAX] = {
287         [EXT2_FT_UNKNOWN]       DT_UNKNOWN,
288         [EXT2_FT_REG_FILE]      DT_REG,
289         [EXT2_FT_DIR]           DT_DIR,
290         [EXT2_FT_CHRDEV]        DT_CHR,
291         [EXT2_FT_BLKDEV]        DT_BLK,
292         [EXT2_FT_FIFO]          DT_FIFO,
293         [EXT2_FT_SOCK]          DT_SOCK,
294         [EXT2_FT_SYMLINK]       DT_LNK,
295 };
296
297
298 int ll_readdir(struct file * filp, void * dirent, filldir_t filldir)
299 {
300         struct inode *inode = filp->f_dentry->d_inode;
301         loff_t pos = filp->f_pos;
302         // XXX struct super_block *sb = inode->i_sb;
303         unsigned offset = pos & ~PAGE_CACHE_MASK;
304         unsigned long n = pos >> PAGE_CACHE_SHIFT;
305         unsigned long npages = dir_pages(inode);
306         unsigned chunk_mask = ~(ext2_chunk_size(inode)-1);
307         unsigned char *types = ext2_filetype_table;
308         int need_revalidate = (filp->f_version != inode->i_version);
309         int rc = 0;
310         ENTRY;
311
312         CDEBUG(D_VFSTRACE, "VFS Op:inode=%lu/%u(%p) pos %llu/%llu\n",
313                inode->i_ino, inode->i_generation, inode, pos, inode->i_size);
314
315         if (pos > inode->i_size - EXT2_DIR_REC_LEN(1))
316                 RETURN(0);
317
318         for ( ; n < npages; n++, offset = 0) {
319                 char *kaddr, *limit;
320                 ext2_dirent *de;
321                 struct page *page;
322
323                 CDEBUG(D_EXT2,"read %lu of dir %lu/%u page %lu/%lu size %llu\n",
324                        PAGE_CACHE_SIZE, inode->i_ino, inode->i_generation,
325                        n, npages, inode->i_size);
326                 page = ll_get_dir_page(inode, n);
327
328                 /* size might have been updated by md_readpage() */
329                 npages = dir_pages(inode);
330
331                 if (IS_ERR(page)) {
332                         rc = PTR_ERR(page);
333                         CERROR("error reading dir %lu/%u page %lu: rc %d\n",
334                                inode->i_ino, inode->i_generation, n, rc);
335                         continue;
336                 }
337
338                 kaddr = page_address(page);
339                 if (need_revalidate) {
340                         offset = ext2_validate_entry(kaddr, offset, chunk_mask);
341                         need_revalidate = 0;
342                 }
343                 de = (ext2_dirent *)(kaddr+offset);
344                 limit = kaddr + PAGE_CACHE_SIZE - EXT2_DIR_REC_LEN(1);
345                 for ( ;(char*)de <= limit; de = ext2_next_entry(de)) {
346                         if (de->inode) {
347                                 int over;
348                                 
349                                 rc = 0; /* no error if we return something */
350                                 
351                                 offset = (char *)de - kaddr;
352                                 over = filldir(dirent, de->name, de->name_len,
353                                                (n<<PAGE_CACHE_SHIFT) | offset,
354                                                le32_to_cpu(de->inode),
355                                                types[de->file_type &
356                                                      (EXT2_FT_MAX - 1)]);
357
358                                 if (over) {
359                                         ext2_put_page(page);
360                                         GOTO(done, rc);
361                                 }
362                         }
363                 }
364                 ext2_put_page(page);
365         }
366
367 done:
368         filp->f_pos = (n << PAGE_CACHE_SHIFT) | offset;
369         filp->f_version = inode->i_version;
370         update_atime(inode);
371         RETURN(rc);
372 }
373
374 static int ll_mkdir_stripe(struct inode *inode, unsigned long arg)
375 {
376         char *name;
377         struct ll_user_mkdir_stripe lums;
378         struct ptlrpc_request *request = NULL;
379         struct ll_sb_info *sbi = ll_i2sbi(inode);
380         struct mdc_op_data op_data;
381         u16 nstripes;
382         mode_t mode;
383         int err = 0;
384         ENTRY;
385
386         if (copy_from_user(&lums, (void *)arg, sizeof(lums)))
387                 RETURN(-EFAULT);
388
389         if (lums.lums_namelen <= 0)
390                 RETURN(-EINVAL);
391         OBD_ALLOC(name, lums.lums_namelen);
392         if (!name)
393                 RETURN(-ENOMEM);
394
395         if (copy_from_user(name, lums.lums_name, lums.lums_namelen))
396                 GOTO(out, err=-EFAULT);
397
398         CDEBUG(D_VFSTRACE, "ioctl Op:name=%s,dir=%lu/%u(%p)\n",
399                name, inode->i_ino, inode->i_generation, inode);
400         nstripes = lums.lums_nstripes;
401
402         mode = lums.lums_mode;
403         mode = (mode & (S_IRWXUGO|S_ISVTX) & ~current->fs->umask) | S_IFDIR;
404         ll_prepare_mdc_data(&op_data, inode, NULL, name,lums.lums_namelen,0);
405         err = md_create(sbi->ll_lmv_exp, &op_data, &nstripes, sizeof(nstripes),
406                         mode, current->fsuid, current->fsgid, 0, &request);
407         ptlrpc_req_finished(request);
408
409 out:
410         OBD_FREE(name, lums.lums_namelen);
411         RETURN(err);
412 }
413
414 static int ll_dir_ioctl(struct inode *inode, struct file *file,
415                         unsigned int cmd, unsigned long arg)
416 {
417         struct ll_sb_info *sbi = ll_i2sbi(inode);
418         struct obd_ioctl_data *data;
419         ENTRY;
420
421         CDEBUG(D_VFSTRACE, "VFS Op:inode=%lu/%u(%p), cmd=%#x\n",
422                inode->i_ino, inode->i_generation, inode, cmd);
423
424         if (_IOC_TYPE(cmd) == 'T') /* tty ioctls */
425                 return -ENOTTY;
426
427         lprocfs_counter_incr(ll_i2sbi(inode)->ll_stats, LPROC_LL_IOCTL);
428         switch(cmd) {
429         case EXT3_IOC_GETFLAGS:
430         case EXT3_IOC_SETFLAGS:
431                 RETURN(ll_iocontrol(inode, file, cmd, arg));
432         case IOC_MDC_LOOKUP: {
433                 struct ptlrpc_request *request = NULL;
434                 struct lustre_id id;
435                 char *buf = NULL;
436                 char *filename;
437                 int namelen, rc, len = 0;
438                 unsigned long valid;
439
440                 rc = obd_ioctl_getdata(&buf, &len, (void *)arg);
441                 if (rc)
442                         RETURN(rc);
443                 data = (void *)buf;
444
445                 filename = data->ioc_inlbuf1;
446                 namelen = data->ioc_inllen1;
447
448                 if (namelen < 1) {
449                         CDEBUG(D_INFO, "IOC_MDC_LOOKUP missing filename\n");
450                         GOTO(out, rc = -EINVAL);
451                 }
452
453                 valid = OBD_MD_FLID;
454                 ll_inode2id(&id, inode);
455                 rc = md_getattr_name(sbi->ll_lmv_exp, &id,
456                                      filename, namelen, valid, 0, &request);
457                 if (rc < 0) {
458                         CDEBUG(D_INFO, "md_getattr_name: %d\n", rc);
459                         GOTO(out, rc);
460                 }
461
462                 ptlrpc_req_finished(request);
463
464                 EXIT;
465         out:
466                 obd_ioctl_freedata(buf, len);
467                 return rc;
468         }
469         case LL_IOC_MDC_MKDIRSTRIPE:
470                 RETURN(ll_mkdir_stripe(inode, arg));
471         case IOC_MDC_FINISH_GNS:
472                 RETURN(ll_finish_gns(sbi));
473         case LL_IOC_LOV_SETSTRIPE: {
474                 struct ptlrpc_request *request = NULL;
475                 struct mdc_op_data op_data;
476                 struct iattr attr = { 0 };
477                 struct lov_user_md lum, *lump = (struct lov_user_md *)arg;
478                 int rc = 0;
479
480                 ll_prepare_mdc_data(&op_data, inode, NULL, NULL, 0, 0);
481
482                 LASSERT(sizeof(lum) == sizeof(*lump));
483                 LASSERT(sizeof(lum.lmm_objects[0]) ==
484                         sizeof(lump->lmm_objects[0]));
485                 rc = copy_from_user(&lum, lump, sizeof(lum));
486                 if (rc)
487                         return(-EFAULT);
488
489                 if (lum.lmm_magic != LOV_USER_MAGIC)
490                         RETURN(-EINVAL);
491
492                 rc = md_setattr(sbi->ll_lmv_exp, &op_data,
493                                 &attr, &lum, sizeof(lum), NULL, 0, &request);
494                 if (rc) {
495                         ptlrpc_req_finished(request);
496                         if (rc != -EPERM && rc != -EACCES)
497                                 CERROR("md_setattr fails: rc = %d\n", rc);
498                         return rc;
499                 }
500                 ptlrpc_req_finished(request);
501
502                 return rc;
503         }
504         case LL_IOC_LOV_GETSTRIPE: {
505                 struct ptlrpc_request *request = NULL;
506                 struct lov_user_md *lump = (struct lov_user_md *)arg;
507                 struct lov_mds_md *lmm;
508                 struct lustre_id id;
509                 struct mds_body *body;
510                 unsigned long valid = 0;
511                 int rc, lmmsize;
512
513                 valid |= OBD_MD_FLDIREA;
514
515                 ll_inode2id(&id, inode);
516                 rc = md_getattr(sbi->ll_lmv_exp, &id, valid,
517                                 obd_size_diskmd(sbi->ll_lov_exp, NULL),
518                                 &request);
519                 if (rc < 0) {
520                         CDEBUG(D_INFO, "md_getattr failed: rc = %d\n", rc);
521                         RETURN(rc);
522                 }
523
524                 body = lustre_msg_buf(request->rq_repmsg, 0, sizeof(*body));
525                 LASSERT(body != NULL);         /* checked by md_getattr_name */
526                 LASSERT_REPSWABBED(request, 0);/* swabbed by md_getattr_name */
527
528                 lmmsize = body->eadatasize;
529                 if (lmmsize == 0)
530                         GOTO(out_get, rc = -ENODATA);
531
532                 lmm = lustre_msg_buf(request->rq_repmsg, 1, lmmsize);
533                 LASSERT(lmm != NULL);
534                 LASSERT_REPSWABBED(request, 1);
535                 rc = copy_to_user(lump, lmm, lmmsize);
536                 if (rc)
537                         GOTO(out_get, rc = -EFAULT);
538
539                 EXIT;
540         out_get:
541                 ptlrpc_req_finished(request);
542                 RETURN(rc);
543         }
544         case IOC_MDC_GETSTRIPE: {
545                 struct ptlrpc_request *request = NULL;
546                 struct lustre_id id;
547                 struct mds_body *body;
548                 struct lov_user_md *lump = (struct lov_user_md *)arg;
549                 struct lov_mds_md *lmm;
550                 char *filename;
551                 int rc, lmmsize;
552
553                 filename = getname((const char *)arg);
554                 if (IS_ERR(filename))
555                         RETURN(PTR_ERR(filename));
556
557                 ll_inode2id(&id, inode);
558                 rc = md_getattr_name(sbi->ll_lmv_exp, &id, filename,
559                                      strlen(filename) + 1, OBD_MD_FLEASIZE,
560                                      obd_size_diskmd(sbi->ll_lov_exp, NULL),
561                                      &request);
562                 if (rc < 0) {
563                         CDEBUG(D_INFO, "md_getattr_name failed on %s: rc %d\n",
564                                filename, rc);
565                         GOTO(out_name, rc);
566                 }
567
568                 body = lustre_msg_buf(request->rq_repmsg, 0, sizeof (*body));
569                 LASSERT(body != NULL);         /* checked by md_getattr_name */
570                 LASSERT_REPSWABBED(request, 0);/* swabbed by md_getattr_name */
571
572                 lmmsize = body->eadatasize;
573
574                 if (!(body->valid & OBD_MD_FLEASIZE) || lmmsize == 0)
575                         GOTO(out_req, rc = -ENODATA);
576
577                 if (lmmsize > 4096)
578                         GOTO(out_req, rc = -EFBIG);
579
580                 lmm = lustre_msg_buf(request->rq_repmsg, 1, lmmsize);
581                 LASSERT(lmm != NULL);
582                 LASSERT_REPSWABBED(request, 1);
583
584                 rc = copy_to_user(lump, lmm, lmmsize);
585                 if (rc)
586                         GOTO(out_req, rc = -EFAULT);
587
588                 EXIT;
589         out_req:
590                 ptlrpc_req_finished(request);
591         out_name:
592                 putname(filename);
593                 return rc;
594         }
595         case OBD_IOC_PING: {
596                 struct ptlrpc_request *req = NULL;
597                 char *buf = NULL;
598                 int rc, len=0;
599                 struct client_obd *cli;
600                 struct obd_device *obd;
601
602                 rc = obd_ioctl_getdata(&buf, &len, (void *)arg);
603                 if (rc)
604                         RETURN(rc);
605                 data = (void *)buf;
606
607                 obd = class_name2obd(data->ioc_inlbuf1);
608
609                 if (!obd )
610                         GOTO(out_ping, rc = -ENODEV);
611
612                 if (!obd->obd_attached) {
613                         CERROR("Device %d not attached\n", obd->obd_minor);
614                         GOTO(out_ping, rc = -ENODEV);
615                 }
616                 if (!obd->obd_set_up) {
617                         CERROR("Device %d still not setup\n", obd->obd_minor);
618                         GOTO(out_ping, rc = -ENODEV);
619                 }
620                 cli = &obd->u.cli;
621                 req = ptlrpc_prep_req(cli->cl_import, LUSTRE_OBD_VERSION,
622                                       OBD_PING, 0, NULL, NULL);
623                 if (!req)
624                         GOTO(out_ping, rc = -ENOMEM);
625
626                 req->rq_replen = lustre_msg_size(0, NULL);
627                 req->rq_send_state = LUSTRE_IMP_FULL;
628
629                 rc = ptlrpc_queue_wait(req);
630
631                 ptlrpc_req_finished(req);
632         out_ping:
633                 obd_ioctl_freedata(buf, len);
634                 return rc;
635         }
636         case OBD_IOC_LLOG_CATINFO: {
637                 struct ptlrpc_request *req = NULL;
638                 char *buf = NULL;
639                 int rc, len = 0;
640                 char *bufs[2], *str;
641                 int lens[2], size;
642
643                 rc = obd_ioctl_getdata(&buf, &len, (void *)arg);
644                 if (rc)
645                         RETURN(rc);
646                 data = (void *)buf;
647
648                 if (!data->ioc_inlbuf1) {
649                         obd_ioctl_freedata(buf, len);
650                         RETURN(-EINVAL);
651                 }
652
653                 lens[0] = data->ioc_inllen1;
654                 bufs[0] = data->ioc_inlbuf1;
655                 if (data->ioc_inllen2) {
656                         lens[1] = data->ioc_inllen2;
657                         bufs[1] = data->ioc_inlbuf2;
658                 } else {
659                         lens[1] = 0;
660                         bufs[1] = NULL;
661                 }
662                 size = data->ioc_plen1;
663                 req = ptlrpc_prep_req(sbi2lmv(sbi)->cl_import,
664                                       LUSTRE_LOG_VERSION, LLOG_CATINFO,
665                                       2, lens, bufs);
666                 if (!req)
667                         GOTO(out_catinfo, rc = -ENOMEM);
668
669                 req->rq_replen = lustre_msg_size(1, &size);
670
671                 rc = ptlrpc_queue_wait(req);
672                 str = lustre_msg_string(req->rq_repmsg, 0, data->ioc_plen1);
673                 if (!rc)
674                         rc = copy_to_user(data->ioc_pbuf1, str,
675                                           data->ioc_plen1);
676                 ptlrpc_req_finished(req);
677         out_catinfo:
678                 obd_ioctl_freedata(buf, len);
679                 RETURN(rc);
680         }
681         default:
682                 return obd_iocontrol(cmd, sbi->ll_lov_exp, 0,
683                                      NULL, (void *)arg);
684         }
685 }
686
687 int ll_dir_open(struct inode *inode, struct file *file)
688 {
689         ENTRY;
690         RETURN(ll_file_open(inode, file));
691 }
692
693 int ll_dir_release(struct inode *inode, struct file *file)
694 {
695         ENTRY;
696         RETURN(ll_file_release(inode, file));
697 }
698
699 struct file_operations ll_dir_operations = {
700         .open     = ll_dir_open,
701         .release  = ll_dir_release,
702         .read     = generic_read_dir,
703         .readdir  = ll_readdir,
704         .ioctl    = ll_dir_ioctl
705 };
706