GNU Linux-libre 4.14.251-gnu1
[releases.git] / fs / f2fs / recovery.c
1 /*
2  * fs/f2fs/recovery.c
3  *
4  * Copyright (c) 2012 Samsung Electronics Co., Ltd.
5  *             http://www.samsung.com/
6  *
7  * This program is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU General Public License version 2 as
9  * published by the Free Software Foundation.
10  */
11 #include <linux/fs.h>
12 #include <linux/f2fs_fs.h>
13 #include "f2fs.h"
14 #include "node.h"
15 #include "segment.h"
16
17 /*
18  * Roll forward recovery scenarios.
19  *
20  * [Term] F: fsync_mark, D: dentry_mark
21  *
22  * 1. inode(x) | CP | inode(x) | dnode(F)
23  * -> Update the latest inode(x).
24  *
25  * 2. inode(x) | CP | inode(F) | dnode(F)
26  * -> No problem.
27  *
28  * 3. inode(x) | CP | dnode(F) | inode(x)
29  * -> Recover to the latest dnode(F), and drop the last inode(x)
30  *
31  * 4. inode(x) | CP | dnode(F) | inode(F)
32  * -> No problem.
33  *
34  * 5. CP | inode(x) | dnode(F)
35  * -> The inode(DF) was missing. Should drop this dnode(F).
36  *
37  * 6. CP | inode(DF) | dnode(F)
38  * -> No problem.
39  *
40  * 7. CP | dnode(F) | inode(DF)
41  * -> If f2fs_iget fails, then goto next to find inode(DF).
42  *
43  * 8. CP | dnode(F) | inode(x)
44  * -> If f2fs_iget fails, then goto next to find inode(DF).
45  *    But it will fail due to no inode(DF).
46  */
47
48 static struct kmem_cache *fsync_entry_slab;
49
50 bool space_for_roll_forward(struct f2fs_sb_info *sbi)
51 {
52         s64 nalloc = percpu_counter_sum_positive(&sbi->alloc_valid_block_count);
53
54         if (sbi->last_valid_block_count + nalloc > sbi->user_block_count)
55                 return false;
56         return true;
57 }
58
59 static struct fsync_inode_entry *get_fsync_inode(struct list_head *head,
60                                                                 nid_t ino)
61 {
62         struct fsync_inode_entry *entry;
63
64         list_for_each_entry(entry, head, list)
65                 if (entry->inode->i_ino == ino)
66                         return entry;
67
68         return NULL;
69 }
70
71 static struct fsync_inode_entry *add_fsync_inode(struct f2fs_sb_info *sbi,
72                         struct list_head *head, nid_t ino, bool quota_inode)
73 {
74         struct inode *inode;
75         struct fsync_inode_entry *entry;
76         int err;
77
78         inode = f2fs_iget_retry(sbi->sb, ino);
79         if (IS_ERR(inode))
80                 return ERR_CAST(inode);
81
82         err = dquot_initialize(inode);
83         if (err)
84                 goto err_out;
85
86         if (quota_inode) {
87                 err = dquot_alloc_inode(inode);
88                 if (err)
89                         goto err_out;
90         }
91
92         entry = f2fs_kmem_cache_alloc(fsync_entry_slab, GFP_F2FS_ZERO);
93         entry->inode = inode;
94         list_add_tail(&entry->list, head);
95
96         return entry;
97 err_out:
98         iput(inode);
99         return ERR_PTR(err);
100 }
101
102 static void del_fsync_inode(struct fsync_inode_entry *entry)
103 {
104         iput(entry->inode);
105         list_del(&entry->list);
106         kmem_cache_free(fsync_entry_slab, entry);
107 }
108
109 static int recover_dentry(struct inode *inode, struct page *ipage,
110                                                 struct list_head *dir_list)
111 {
112         struct f2fs_inode *raw_inode = F2FS_INODE(ipage);
113         nid_t pino = le32_to_cpu(raw_inode->i_pino);
114         struct f2fs_dir_entry *de;
115         struct fscrypt_name fname;
116         struct page *page;
117         struct inode *dir, *einode;
118         struct fsync_inode_entry *entry;
119         int err = 0;
120         char *name;
121
122         entry = get_fsync_inode(dir_list, pino);
123         if (!entry) {
124                 entry = add_fsync_inode(F2FS_I_SB(inode), dir_list,
125                                                         pino, false);
126                 if (IS_ERR(entry)) {
127                         dir = ERR_CAST(entry);
128                         err = PTR_ERR(entry);
129                         goto out;
130                 }
131         }
132
133         dir = entry->inode;
134
135         memset(&fname, 0, sizeof(struct fscrypt_name));
136         fname.disk_name.len = le32_to_cpu(raw_inode->i_namelen);
137         fname.disk_name.name = raw_inode->i_name;
138
139         if (unlikely(fname.disk_name.len > F2FS_NAME_LEN)) {
140                 WARN_ON(1);
141                 err = -ENAMETOOLONG;
142                 goto out;
143         }
144 retry:
145         de = __f2fs_find_entry(dir, &fname, &page);
146         if (de && inode->i_ino == le32_to_cpu(de->ino))
147                 goto out_unmap_put;
148
149         if (de) {
150                 einode = f2fs_iget_retry(inode->i_sb, le32_to_cpu(de->ino));
151                 if (IS_ERR(einode)) {
152                         WARN_ON(1);
153                         err = PTR_ERR(einode);
154                         if (err == -ENOENT)
155                                 err = -EEXIST;
156                         goto out_unmap_put;
157                 }
158
159                 err = dquot_initialize(einode);
160                 if (err) {
161                         iput(einode);
162                         goto out_unmap_put;
163                 }
164
165                 err = acquire_orphan_inode(F2FS_I_SB(inode));
166                 if (err) {
167                         iput(einode);
168                         goto out_unmap_put;
169                 }
170                 f2fs_delete_entry(de, page, dir, einode);
171                 iput(einode);
172                 goto retry;
173         } else if (IS_ERR(page)) {
174                 err = PTR_ERR(page);
175         } else {
176                 err = __f2fs_do_add_link(dir, &fname, inode,
177                                         inode->i_ino, inode->i_mode);
178         }
179         if (err == -ENOMEM)
180                 goto retry;
181         goto out;
182
183 out_unmap_put:
184         f2fs_dentry_kunmap(dir, page);
185         f2fs_put_page(page, 0);
186 out:
187         if (file_enc_name(inode))
188                 name = "<encrypted>";
189         else
190                 name = raw_inode->i_name;
191         f2fs_msg(inode->i_sb, KERN_NOTICE,
192                         "%s: ino = %x, name = %s, dir = %lx, err = %d",
193                         __func__, ino_of_node(ipage), name,
194                         IS_ERR(dir) ? 0 : dir->i_ino, err);
195         return err;
196 }
197
198 static void recover_inode(struct inode *inode, struct page *page)
199 {
200         struct f2fs_inode *raw = F2FS_INODE(page);
201         char *name;
202
203         inode->i_mode = le16_to_cpu(raw->i_mode);
204         i_uid_write(inode, le32_to_cpu(raw->i_uid));
205         i_gid_write(inode, le32_to_cpu(raw->i_gid));
206
207         if (raw->i_inline & F2FS_EXTRA_ATTR) {
208                 if (f2fs_sb_has_project_quota(F2FS_I_SB(inode)->sb) &&
209                         F2FS_FITS_IN_INODE(raw, le16_to_cpu(raw->i_extra_isize),
210                                                                 i_projid)) {
211                         projid_t i_projid;
212
213                         i_projid = (projid_t)le32_to_cpu(raw->i_projid);
214                         F2FS_I(inode)->i_projid =
215                                 make_kprojid(&init_user_ns, i_projid);
216                 }
217         }
218
219         f2fs_i_size_write(inode, le64_to_cpu(raw->i_size));
220         inode->i_atime.tv_sec = le64_to_cpu(raw->i_atime);
221         inode->i_ctime.tv_sec = le64_to_cpu(raw->i_ctime);
222         inode->i_mtime.tv_sec = le64_to_cpu(raw->i_mtime);
223         inode->i_atime.tv_nsec = le32_to_cpu(raw->i_atime_nsec);
224         inode->i_ctime.tv_nsec = le32_to_cpu(raw->i_ctime_nsec);
225         inode->i_mtime.tv_nsec = le32_to_cpu(raw->i_mtime_nsec);
226
227         F2FS_I(inode)->i_advise = raw->i_advise;
228         F2FS_I(inode)->i_flags = le32_to_cpu(raw->i_flags);
229
230         f2fs_mark_inode_dirty_sync(inode, true);
231
232         if (file_enc_name(inode))
233                 name = "<encrypted>";
234         else
235                 name = F2FS_INODE(page)->i_name;
236
237         f2fs_msg(inode->i_sb, KERN_NOTICE, "recover_inode: ino = %x, name = %s",
238                         ino_of_node(page), name);
239 }
240
241 static int find_fsync_dnodes(struct f2fs_sb_info *sbi, struct list_head *head,
242                                 bool check_only)
243 {
244         struct curseg_info *curseg;
245         struct page *page = NULL;
246         block_t blkaddr;
247         int err = 0;
248
249         /* get node pages in the current segment */
250         curseg = CURSEG_I(sbi, CURSEG_WARM_NODE);
251         blkaddr = NEXT_FREE_BLKADDR(sbi, curseg);
252
253         while (1) {
254                 struct fsync_inode_entry *entry;
255
256                 if (!f2fs_is_valid_blkaddr(sbi, blkaddr, META_POR))
257                         return 0;
258
259                 page = get_tmp_page(sbi, blkaddr);
260
261                 if (!is_recoverable_dnode(page))
262                         break;
263
264                 if (!is_fsync_dnode(page))
265                         goto next;
266
267                 entry = get_fsync_inode(head, ino_of_node(page));
268                 if (!entry) {
269                         bool quota_inode = false;
270
271                         if (!check_only &&
272                                         IS_INODE(page) && is_dent_dnode(page)) {
273                                 err = recover_inode_page(sbi, page);
274                                 if (err)
275                                         break;
276                                 quota_inode = true;
277                         }
278
279                         /*
280                          * CP | dnode(F) | inode(DF)
281                          * For this case, we should not give up now.
282                          */
283                         entry = add_fsync_inode(sbi, head, ino_of_node(page),
284                                                                 quota_inode);
285                         if (IS_ERR(entry)) {
286                                 err = PTR_ERR(entry);
287                                 if (err == -ENOENT) {
288                                         err = 0;
289                                         goto next;
290                                 }
291                                 break;
292                         }
293                 }
294                 entry->blkaddr = blkaddr;
295
296                 if (IS_INODE(page) && is_dent_dnode(page))
297                         entry->last_dentry = blkaddr;
298 next:
299                 /* check next segment */
300                 blkaddr = next_blkaddr_of_node(page);
301                 f2fs_put_page(page, 1);
302
303                 ra_meta_pages_cond(sbi, blkaddr);
304         }
305         f2fs_put_page(page, 1);
306         return err;
307 }
308
309 static void destroy_fsync_dnodes(struct list_head *head)
310 {
311         struct fsync_inode_entry *entry, *tmp;
312
313         list_for_each_entry_safe(entry, tmp, head, list)
314                 del_fsync_inode(entry);
315 }
316
317 static int check_index_in_prev_nodes(struct f2fs_sb_info *sbi,
318                         block_t blkaddr, struct dnode_of_data *dn)
319 {
320         struct seg_entry *sentry;
321         unsigned int segno = GET_SEGNO(sbi, blkaddr);
322         unsigned short blkoff = GET_BLKOFF_FROM_SEG0(sbi, blkaddr);
323         struct f2fs_summary_block *sum_node;
324         struct f2fs_summary sum;
325         struct page *sum_page, *node_page;
326         struct dnode_of_data tdn = *dn;
327         nid_t ino, nid;
328         struct inode *inode;
329         unsigned int offset;
330         block_t bidx;
331         int i;
332
333         sentry = get_seg_entry(sbi, segno);
334         if (!f2fs_test_bit(blkoff, sentry->cur_valid_map))
335                 return 0;
336
337         /* Get the previous summary */
338         for (i = CURSEG_HOT_DATA; i <= CURSEG_COLD_DATA; i++) {
339                 struct curseg_info *curseg = CURSEG_I(sbi, i);
340                 if (curseg->segno == segno) {
341                         sum = curseg->sum_blk->entries[blkoff];
342                         goto got_it;
343                 }
344         }
345
346         sum_page = get_sum_page(sbi, segno);
347         sum_node = (struct f2fs_summary_block *)page_address(sum_page);
348         sum = sum_node->entries[blkoff];
349         f2fs_put_page(sum_page, 1);
350 got_it:
351         /* Use the locked dnode page and inode */
352         nid = le32_to_cpu(sum.nid);
353         if (dn->inode->i_ino == nid) {
354                 tdn.nid = nid;
355                 if (!dn->inode_page_locked)
356                         lock_page(dn->inode_page);
357                 tdn.node_page = dn->inode_page;
358                 tdn.ofs_in_node = le16_to_cpu(sum.ofs_in_node);
359                 goto truncate_out;
360         } else if (dn->nid == nid) {
361                 tdn.ofs_in_node = le16_to_cpu(sum.ofs_in_node);
362                 goto truncate_out;
363         }
364
365         /* Get the node page */
366         node_page = get_node_page(sbi, nid);
367         if (IS_ERR(node_page))
368                 return PTR_ERR(node_page);
369
370         offset = ofs_of_node(node_page);
371         ino = ino_of_node(node_page);
372         f2fs_put_page(node_page, 1);
373
374         if (ino != dn->inode->i_ino) {
375                 int ret;
376
377                 /* Deallocate previous index in the node page */
378                 inode = f2fs_iget_retry(sbi->sb, ino);
379                 if (IS_ERR(inode))
380                         return PTR_ERR(inode);
381
382                 ret = dquot_initialize(inode);
383                 if (ret) {
384                         iput(inode);
385                         return ret;
386                 }
387         } else {
388                 inode = dn->inode;
389         }
390
391         bidx = start_bidx_of_node(offset, inode) + le16_to_cpu(sum.ofs_in_node);
392
393         /*
394          * if inode page is locked, unlock temporarily, but its reference
395          * count keeps alive.
396          */
397         if (ino == dn->inode->i_ino && dn->inode_page_locked)
398                 unlock_page(dn->inode_page);
399
400         set_new_dnode(&tdn, inode, NULL, NULL, 0);
401         if (get_dnode_of_data(&tdn, bidx, LOOKUP_NODE))
402                 goto out;
403
404         if (tdn.data_blkaddr == blkaddr)
405                 truncate_data_blocks_range(&tdn, 1);
406
407         f2fs_put_dnode(&tdn);
408 out:
409         if (ino != dn->inode->i_ino)
410                 iput(inode);
411         else if (dn->inode_page_locked)
412                 lock_page(dn->inode_page);
413         return 0;
414
415 truncate_out:
416         if (datablock_addr(tdn.inode, tdn.node_page,
417                                         tdn.ofs_in_node) == blkaddr)
418                 truncate_data_blocks_range(&tdn, 1);
419         if (dn->inode->i_ino == nid && !dn->inode_page_locked)
420                 unlock_page(dn->inode_page);
421         return 0;
422 }
423
424 static int do_recover_data(struct f2fs_sb_info *sbi, struct inode *inode,
425                                         struct page *page, block_t blkaddr)
426 {
427         struct dnode_of_data dn;
428         struct node_info ni;
429         unsigned int start, end;
430         int err = 0, recovered = 0;
431
432         /* step 1: recover xattr */
433         if (IS_INODE(page)) {
434                 recover_inline_xattr(inode, page);
435         } else if (f2fs_has_xattr_block(ofs_of_node(page))) {
436                 err = recover_xattr_data(inode, page, blkaddr);
437                 if (!err)
438                         recovered++;
439                 goto out;
440         }
441
442         /* step 2: recover inline data */
443         if (recover_inline_data(inode, page))
444                 goto out;
445
446         /* step 3: recover data indices */
447         start = start_bidx_of_node(ofs_of_node(page), inode);
448         end = start + ADDRS_PER_PAGE(page, inode);
449
450         set_new_dnode(&dn, inode, NULL, NULL, 0);
451 retry_dn:
452         err = get_dnode_of_data(&dn, start, ALLOC_NODE);
453         if (err) {
454                 if (err == -ENOMEM) {
455                         congestion_wait(BLK_RW_ASYNC, HZ/50);
456                         goto retry_dn;
457                 }
458                 goto out;
459         }
460
461         f2fs_wait_on_page_writeback(dn.node_page, NODE, true);
462
463         get_node_info(sbi, dn.nid, &ni);
464         f2fs_bug_on(sbi, ni.ino != ino_of_node(page));
465
466         if (ofs_of_node(dn.node_page) != ofs_of_node(page)) {
467                 f2fs_msg(sbi->sb, KERN_WARNING,
468                         "Inconsistent ofs_of_node, ino:%lu, ofs:%u, %u",
469                         inode->i_ino, ofs_of_node(dn.node_page),
470                         ofs_of_node(page));
471                 err = -EFSCORRUPTED;
472                 goto err;
473         }
474
475         for (; start < end; start++, dn.ofs_in_node++) {
476                 block_t src, dest;
477
478                 src = datablock_addr(dn.inode, dn.node_page, dn.ofs_in_node);
479                 dest = datablock_addr(dn.inode, page, dn.ofs_in_node);
480
481                 /* skip recovering if dest is the same as src */
482                 if (src == dest)
483                         continue;
484
485                 /* dest is invalid, just invalidate src block */
486                 if (dest == NULL_ADDR) {
487                         truncate_data_blocks_range(&dn, 1);
488                         continue;
489                 }
490
491                 if (!file_keep_isize(inode) &&
492                         (i_size_read(inode) <= ((loff_t)start << PAGE_SHIFT)))
493                         f2fs_i_size_write(inode,
494                                 (loff_t)(start + 1) << PAGE_SHIFT);
495
496                 /*
497                  * dest is reserved block, invalidate src block
498                  * and then reserve one new block in dnode page.
499                  */
500                 if (dest == NEW_ADDR) {
501                         truncate_data_blocks_range(&dn, 1);
502                         reserve_new_block(&dn);
503                         continue;
504                 }
505
506                 /* dest is valid block, try to recover from src to dest */
507                 if (f2fs_is_valid_blkaddr(sbi, dest, META_POR)) {
508
509                         if (src == NULL_ADDR) {
510                                 err = reserve_new_block(&dn);
511 #ifdef CONFIG_F2FS_FAULT_INJECTION
512                                 while (err)
513                                         err = reserve_new_block(&dn);
514 #endif
515                                 /* We should not get -ENOSPC */
516                                 f2fs_bug_on(sbi, err);
517                                 if (err)
518                                         goto err;
519                         }
520 retry_prev:
521                         /* Check the previous node page having this index */
522                         err = check_index_in_prev_nodes(sbi, dest, &dn);
523                         if (err) {
524                                 if (err == -ENOMEM) {
525                                         congestion_wait(BLK_RW_ASYNC, HZ/50);
526                                         goto retry_prev;
527                                 }
528                                 goto err;
529                         }
530
531                         /* write dummy data page */
532                         f2fs_replace_block(sbi, &dn, src, dest,
533                                                 ni.version, false, false);
534                         recovered++;
535                 }
536         }
537
538         copy_node_footer(dn.node_page, page);
539         fill_node_footer(dn.node_page, dn.nid, ni.ino,
540                                         ofs_of_node(page), false);
541         set_page_dirty(dn.node_page);
542 err:
543         f2fs_put_dnode(&dn);
544 out:
545         f2fs_msg(sbi->sb, KERN_NOTICE,
546                 "recover_data: ino = %lx (i_size: %s) recovered = %d, err = %d",
547                 inode->i_ino,
548                 file_keep_isize(inode) ? "keep" : "recover",
549                 recovered, err);
550         return err;
551 }
552
553 static int recover_data(struct f2fs_sb_info *sbi, struct list_head *inode_list,
554                                                 struct list_head *dir_list)
555 {
556         struct curseg_info *curseg;
557         struct page *page = NULL;
558         int err = 0;
559         block_t blkaddr;
560
561         /* get node pages in the current segment */
562         curseg = CURSEG_I(sbi, CURSEG_WARM_NODE);
563         blkaddr = NEXT_FREE_BLKADDR(sbi, curseg);
564
565         while (1) {
566                 struct fsync_inode_entry *entry;
567
568                 if (!f2fs_is_valid_blkaddr(sbi, blkaddr, META_POR))
569                         break;
570
571                 ra_meta_pages_cond(sbi, blkaddr);
572
573                 page = get_tmp_page(sbi, blkaddr);
574
575                 if (!is_recoverable_dnode(page)) {
576                         f2fs_put_page(page, 1);
577                         break;
578                 }
579
580                 entry = get_fsync_inode(inode_list, ino_of_node(page));
581                 if (!entry)
582                         goto next;
583                 /*
584                  * inode(x) | CP | inode(x) | dnode(F)
585                  * In this case, we can lose the latest inode(x).
586                  * So, call recover_inode for the inode update.
587                  */
588                 if (IS_INODE(page))
589                         recover_inode(entry->inode, page);
590                 if (entry->last_dentry == blkaddr) {
591                         err = recover_dentry(entry->inode, page, dir_list);
592                         if (err) {
593                                 f2fs_put_page(page, 1);
594                                 break;
595                         }
596                 }
597                 err = do_recover_data(sbi, entry->inode, page, blkaddr);
598                 if (err) {
599                         f2fs_put_page(page, 1);
600                         break;
601                 }
602
603                 if (entry->blkaddr == blkaddr)
604                         del_fsync_inode(entry);
605 next:
606                 /* check next segment */
607                 blkaddr = next_blkaddr_of_node(page);
608                 f2fs_put_page(page, 1);
609         }
610         if (!err)
611                 allocate_new_segments(sbi);
612         return err;
613 }
614
615 int recover_fsync_data(struct f2fs_sb_info *sbi, bool check_only)
616 {
617         struct list_head inode_list;
618         struct list_head dir_list;
619         int err;
620         int ret = 0;
621         unsigned long s_flags = sbi->sb->s_flags;
622         bool need_writecp = false;
623
624         if (s_flags & MS_RDONLY) {
625                 f2fs_msg(sbi->sb, KERN_INFO, "orphan cleanup on readonly fs");
626                 sbi->sb->s_flags &= ~MS_RDONLY;
627         }
628
629 #ifdef CONFIG_QUOTA
630         /* Needed for iput() to work correctly and not trash data */
631         sbi->sb->s_flags |= MS_ACTIVE;
632         /* Turn on quotas so that they are updated correctly */
633         f2fs_enable_quota_files(sbi);
634 #endif
635
636         fsync_entry_slab = f2fs_kmem_cache_create("f2fs_fsync_inode_entry",
637                         sizeof(struct fsync_inode_entry));
638         if (!fsync_entry_slab) {
639                 err = -ENOMEM;
640                 goto out;
641         }
642
643         INIT_LIST_HEAD(&inode_list);
644         INIT_LIST_HEAD(&dir_list);
645
646         /* prevent checkpoint */
647         mutex_lock(&sbi->cp_mutex);
648
649         /* step #1: find fsynced inode numbers */
650         err = find_fsync_dnodes(sbi, &inode_list, check_only);
651         if (err || list_empty(&inode_list))
652                 goto skip;
653
654         if (check_only) {
655                 ret = 1;
656                 goto skip;
657         }
658
659         need_writecp = true;
660
661         /* step #2: recover data */
662         err = recover_data(sbi, &inode_list, &dir_list);
663         if (!err)
664                 f2fs_bug_on(sbi, !list_empty(&inode_list));
665 skip:
666         destroy_fsync_dnodes(&inode_list);
667
668         /* truncate meta pages to be used by the recovery */
669         truncate_inode_pages_range(META_MAPPING(sbi),
670                         (loff_t)MAIN_BLKADDR(sbi) << PAGE_SHIFT, -1);
671
672         if (err) {
673                 truncate_inode_pages_final(NODE_MAPPING(sbi));
674                 truncate_inode_pages_final(META_MAPPING(sbi));
675         }
676
677         clear_sbi_flag(sbi, SBI_POR_DOING);
678         mutex_unlock(&sbi->cp_mutex);
679
680         /* let's drop all the directory inodes for clean checkpoint */
681         destroy_fsync_dnodes(&dir_list);
682
683         if (!err && need_writecp) {
684                 struct cp_control cpc = {
685                         .reason = CP_RECOVERY,
686                 };
687                 err = write_checkpoint(sbi, &cpc);
688         }
689
690         kmem_cache_destroy(fsync_entry_slab);
691 out:
692 #ifdef CONFIG_QUOTA
693         /* Turn quotas off */
694         f2fs_quota_off_umount(sbi->sb);
695 #endif
696         sbi->sb->s_flags = s_flags; /* Restore MS_RDONLY status */
697
698         return ret ? ret: err;
699 }