| /dflybsd-src/usr.sbin/makefs/hammer2/ |
| H A D | hammer2_xops.c | 76 checkdirempty(hammer2_chain_t *oparent, hammer2_chain_t *ochain, int clindex) in checkdirempty() argument
100 clindex, 0, in checkdirempty()
162 hammer2_xop_ipcluster(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_ipcluster() argument
168 chain = hammer2_inode_chain(xop->head.ip1, clindex, in hammer2_xop_ipcluster()
176 hammer2_xop_feed(&xop->head, chain, clindex, error); in hammer2_xop_ipcluster()
187 hammer2_xop_readdir(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_readdir() argument
204 parent = hammer2_inode_chain(xop->head.ip1, clindex, in hammer2_xop_readdir()
224 error = hammer2_xop_feed(&xop->head, chain, clindex, 0); in hammer2_xop_readdir()
239 hammer2_xop_feed(&xop->head, NULL, clindex, error); in hammer2_xop_readdir()
246 hammer2_xop_nresolve(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_nresolve() argument
[all …]
|
| H A D | hammer2.h | 861 int clindex; /* cluster element index */ member
908 int clindex);
1541 hammer2_chain_t *hammer2_inode_chain(hammer2_inode_t *ip, int clindex, int how);
1543 int clindex, hammer2_chain_t **parentp, int how);
1585 int clindex, int flags,
1783 const char *id, int clindex, int repidx,
1815 int clindex, int error);
1826 void hammer2_xop_ipcluster(hammer2_xop_t *xop, void *scratch, int clindex);
1827 void hammer2_xop_readdir(hammer2_xop_t *xop, void *scratch, int clindex);
1828 void hammer2_xop_nresolve(hammer2_xop_t *xop, void *scratch, int clindex);
[all …]
|
| H A D | hammer2_admin.c | 225 const char *id, int clindex, int repidx, in hammer2_thr_create() argument
230 thr->clindex = clindex; in hammer2_thr_create()
242 "%s-%s.%02d", id, pmp->pfs_names[clindex], repidx); in hammer2_thr_create()
245 "%s-%s", id, pmp->pfs_names[clindex]); in hammer2_thr_create()
855 int clindex, int error) in hammer2_xop_feed() argument
872 fifo = &xop->collect[clindex]; in hammer2_xop_feed()
1130 int clindex = thr->clindex; in hammer2_xop_next() local
1135 TAILQ_FOREACH(xop, &thr->xopq, collect[clindex].entry) { in hammer2_xop_next()
1157 if (xop->collect[clindex].flags & HAMMER2_XOP_FIFO_RUN) in hammer2_xop_next()
1163 atomic_set_int(&xop->collect[clindex].flags, in hammer2_xop_next()
[all …]
|
| H A D | hammer2_flush.c | 1296 hammer2_xop_inode_flush(hammer2_xop_t *arg, void *scratch __unused, int clindex) in hammer2_xop_inode_flush() argument
1323 chain = hammer2_inode_chain(ip, clindex, HAMMER2_RESOLVE_ALWAYS); in hammer2_xop_inode_flush()
1340 pmp->pfs_iroot_blocksets[clindex] = in hammer2_xop_inode_flush()
1381 for (j = clindex - 1; j >= 0; --j) { in hammer2_xop_inode_flush()
1543 hammer2_xop_feed(&xop->head, NULL, clindex, total_error); in hammer2_xop_inode_flush()
|
| H A D | hammer2_strategy.c | 282 hammer2_xop_strategy_read(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_strategy_read() argument
314 parent = hammer2_inode_chain(xop->head.ip1, clindex, in hammer2_xop_strategy_read()
329 error = hammer2_xop_feed(&xop->head, chain, clindex, error); in hammer2_xop_strategy_read()
560 hammer2_xop_strategy_write(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_strategy_write() argument
606 parent = hammer2_inode_chain(ip, clindex, HAMMER2_RESOLVE_ALWAYS); in hammer2_xop_strategy_write()
615 hammer2_xop_feed(&xop->head, NULL, clindex, error); in hammer2_xop_strategy_write()
|
| H A D | hammer2_inode.c | 412 hammer2_inode_chain(hammer2_inode_t *ip, int clindex, int how) in hammer2_inode_chain() argument
419 if (clindex >= cluster->nchains) in hammer2_inode_chain()
422 chain = cluster->array[clindex].chain; in hammer2_inode_chain()
434 hammer2_inode_chain_and_parent(hammer2_inode_t *ip, int clindex, in hammer2_inode_chain_and_parent() argument
442 if (clindex >= ip->cluster.nchains) in hammer2_inode_chain_and_parent()
445 chain = ip->cluster.array[clindex].chain; in hammer2_inode_chain_and_parent()
464 if (ip->cluster.array[clindex].chain == chain && in hammer2_inode_chain_and_parent()
|
| H A D | hammer2_vfsops.c | 635 hammer2_pfsdealloc(hammer2_pfs_t *pmp, int clindex, int destroying) in hammer2_pfsdealloc() argument
653 hammer2_thr_delete(&pmp->sync_thrs[clindex]); in hammer2_pfsdealloc()
660 chain = iroot->cluster.array[clindex].chain; in hammer2_pfsdealloc()
661 iroot->cluster.array[clindex].chain = NULL; in hammer2_pfsdealloc()
663 switch(pmp->pfs_types[clindex]) { in hammer2_pfsdealloc()
672 pmp->pfs_types[clindex] = HAMMER2_PFSTYPE_NONE; in hammer2_pfsdealloc()
690 &pmp->xop_groups[j].thrs[clindex]); in hammer2_pfsdealloc()
|
| H A D | hammer2_chain.c | 5722 int clindex, int flags, in hammer2_chain_inode_find() argument
5759 *chainp = hammer2_inode_chain_and_parent(ip, clindex, in hammer2_chain_inode_find()
5779 parent = hammer2_inode_chain(pmp->iroot, clindex, resolve_flags); in hammer2_chain_inode_find()
|
| /dflybsd-src/sys/vfs/hammer2/ |
| H A D | hammer2_xops.c | 73 checkdirempty(hammer2_chain_t *oparent, hammer2_chain_t *ochain, int clindex) in checkdirempty() argument
97 clindex, 0, in checkdirempty()
159 hammer2_xop_ipcluster(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_ipcluster() argument
165 chain = hammer2_inode_chain(xop->head.ip1, clindex, in hammer2_xop_ipcluster()
173 hammer2_xop_feed(&xop->head, chain, clindex, error); in hammer2_xop_ipcluster()
184 hammer2_xop_readdir(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_readdir() argument
201 parent = hammer2_inode_chain(xop->head.ip1, clindex, in hammer2_xop_readdir()
221 error = hammer2_xop_feed(&xop->head, chain, clindex, 0); in hammer2_xop_readdir()
236 hammer2_xop_feed(&xop->head, NULL, clindex, error); in hammer2_xop_readdir()
243 hammer2_xop_nresolve(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_nresolve() argument
[all …]
|
| H A D | hammer2.h | 820 int clindex; /* cluster element index */ member
867 int clindex);
1496 hammer2_chain_t *hammer2_inode_chain(hammer2_inode_t *ip, int clindex, int how);
1498 int clindex, hammer2_chain_t **parentp, int how);
1538 int clindex, int flags,
1722 const char *id, int clindex, int repidx,
1754 int clindex, int error);
1765 void hammer2_xop_ipcluster(hammer2_xop_t *xop, void *scratch, int clindex);
1766 void hammer2_xop_readdir(hammer2_xop_t *xop, void *scratch, int clindex);
1767 void hammer2_xop_nresolve(hammer2_xop_t *xop, void *scratch, int clindex);
[all …]
|
| H A D | hammer2_admin.c | 220 const char *id, int clindex, int repidx, in hammer2_thr_create() argument
225 thr->clindex = clindex; in hammer2_thr_create()
236 "%s-%s.%02d", id, pmp->pfs_names[clindex], repidx); in hammer2_thr_create()
239 "%s-%s", id, pmp->pfs_names[clindex]); in hammer2_thr_create()
793 int clindex, int error) in hammer2_xop_feed() argument
810 fifo = &xop->collect[clindex]; in hammer2_xop_feed()
1074 int clindex = thr->clindex; in hammer2_xop_next() local
1079 TAILQ_FOREACH(xop, &thr->xopq, collect[clindex].entry) { in hammer2_xop_next()
1101 if (xop->collect[clindex].flags & HAMMER2_XOP_FIFO_RUN) in hammer2_xop_next()
1107 atomic_set_int(&xop->collect[clindex].flags, in hammer2_xop_next()
[all …]
|
| H A D | hammer2_flush.c | 1292 hammer2_xop_inode_flush(hammer2_xop_t *arg, void *scratch __unused, int clindex) in hammer2_xop_inode_flush() argument
1319 chain = hammer2_inode_chain(ip, clindex, HAMMER2_RESOLVE_ALWAYS); in hammer2_xop_inode_flush()
1336 pmp->pfs_iroot_blocksets[clindex] = in hammer2_xop_inode_flush()
1377 for (j = clindex - 1; j >= 0; --j) { in hammer2_xop_inode_flush()
1537 hammer2_xop_feed(&xop->head, NULL, clindex, total_error); in hammer2_xop_inode_flush()
|
| H A D | hammer2_strategy.c | 270 hammer2_xop_strategy_read(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_strategy_read() argument
302 parent = hammer2_inode_chain(xop->head.ip1, clindex, in hammer2_xop_strategy_read()
317 error = hammer2_xop_feed(&xop->head, chain, clindex, error); in hammer2_xop_strategy_read()
539 hammer2_xop_strategy_write(hammer2_xop_t *arg, void *scratch, int clindex) in hammer2_xop_strategy_write() argument
585 parent = hammer2_inode_chain(ip, clindex, HAMMER2_RESOLVE_ALWAYS); in hammer2_xop_strategy_write()
594 hammer2_xop_feed(&xop->head, NULL, clindex, error); in hammer2_xop_strategy_write()
|
| H A D | hammer2_inode.c | 408 hammer2_inode_chain(hammer2_inode_t *ip, int clindex, int how) in hammer2_inode_chain() argument
415 if (clindex >= cluster->nchains) in hammer2_inode_chain()
418 chain = cluster->array[clindex].chain; in hammer2_inode_chain()
430 hammer2_inode_chain_and_parent(hammer2_inode_t *ip, int clindex, in hammer2_inode_chain_and_parent() argument
438 if (clindex >= ip->cluster.nchains) in hammer2_inode_chain_and_parent()
441 chain = ip->cluster.array[clindex].chain; in hammer2_inode_chain_and_parent()
460 if (ip->cluster.array[clindex].chain == chain && in hammer2_inode_chain_and_parent()
|
| H A D | hammer2_synchro.c | 177 pmp->pfs_names[thr->clindex], thr->clindex); in hammer2_primary_sync_thread()
377 idx = thr->clindex; /* cluster node we are responsible for */ in hammer2_sync_slaves()
|
| H A D | hammer2_vfsops.c | 605 hammer2_pfsdealloc(hammer2_pfs_t *pmp, int clindex, int destroying) in hammer2_pfsdealloc() argument
623 hammer2_thr_delete(&pmp->sync_thrs[clindex]); in hammer2_pfsdealloc()
630 chain = iroot->cluster.array[clindex].chain; in hammer2_pfsdealloc()
631 iroot->cluster.array[clindex].chain = NULL; in hammer2_pfsdealloc()
633 switch(pmp->pfs_types[clindex]) { in hammer2_pfsdealloc()
642 pmp->pfs_types[clindex] = HAMMER2_PFSTYPE_NONE; in hammer2_pfsdealloc()
660 &pmp->xop_groups[j].thrs[clindex]); in hammer2_pfsdealloc()
|
| H A D | hammer2_chain.c | 5710 int clindex, int flags, in hammer2_chain_inode_find() argument
5747 *chainp = hammer2_inode_chain_and_parent(ip, clindex, in hammer2_chain_inode_find()
5767 parent = hammer2_inode_chain(pmp->iroot, clindex, resolve_flags); in hammer2_chain_inode_find()
|