subr.c revision 1.7
1 /* $NetBSD: subr.c,v 1.7 2010/09/29 08:01:10 manu Exp $ */ 2 3 /*- 4 * Copyright (c) 2010 Emmanuel Dreyfus. All rights reserved. 5 * 6 * Redistribution and use in source and binary forms, with or without 7 * modification, are permitted provided that the following conditions 8 * are met: 9 * 1. Redistributions of source code must retain the above copyright 10 * notice, this list of conditions and the following disclaimer. 11 * 2. Redistributions in binary form must reproduce the above copyright 12 * notice, this list of conditions and the following disclaimer in the 13 * documentation and/or other materials provided with the distribution. 14 * 15 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS 16 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 17 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 18 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS 19 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 20 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 21 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 22 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 23 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 24 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 25 * POSSIBILITY OF SUCH DAMAGE. 26 */ 27 28 #include <stdio.h> 29 #include <stdlib.h> 30 #include <err.h> 31 #include <errno.h> 32 #include <sysexits.h> 33 #include <syslog.h> 34 #include <puffs.h> 35 #include <paths.h> 36 37 #include "perfuse_priv.h" 38 39 struct puffs_node * 40 perfuse_new_pn(pu, parent) 41 struct puffs_usermount *pu; 42 struct puffs_node *parent; 43 { 44 struct perfuse_state *ps; 45 struct puffs_node *pn; 46 struct perfuse_node_data *pnd; 47 48 ps = puffs_getspecific(pu); 49 50 if ((pnd = malloc(sizeof(*pnd))) == NULL) 51 DERR(EX_OSERR, "malloc failed"); 52 53 if ((pn = puffs_pn_new(pu, pnd)) == NULL) 54 DERR(EX_SOFTWARE, "puffs_pn_new failed"); 55 56 (void)memset(pnd, 0, sizeof(*pnd)); 57 pnd->pnd_rfh = FUSE_UNKNOWN_FH; 58 pnd->pnd_wfh = FUSE_UNKNOWN_FH; 59 pnd->pnd_ino = PERFUSE_UNKNOWN_INO; 60 pnd->pnd_nlookup = 1; 61 pnd->pnd_parent = parent; 62 pnd->pnd_timestamp = time(NULL); 63 pnd->pnd_pn = (puffs_cookie_t)pn; 64 TAILQ_INIT(&pnd->pnd_pcq); 65 66 TAILQ_INSERT_TAIL(&ps->ps_pnd, pnd, pnd_next); 67 ps->ps_pnd_count++; 68 69 if (parent != NULL) 70 PERFUSE_NODE_DATA(parent)->pnd_childcount++; 71 72 return pn; 73 } 74 75 void 76 perfuse_destroy_pn(pu, pn) 77 struct puffs_usermount *pu; 78 struct puffs_node *pn; 79 { 80 struct perfuse_state *ps; 81 struct perfuse_node_data *pnd; 82 83 ps = puffs_getspecific(pu); 84 pnd = PERFUSE_NODE_DATA(pn); 85 86 TAILQ_REMOVE(&ps->ps_pnd, pnd, pnd_next); 87 ps->ps_pnd_count--; 88 89 if ((pnd = puffs_pn_getpriv(pn)) != NULL) { 90 if (pnd->pnd_parent != NULL) 91 PERFUSE_NODE_DATA(pnd->pnd_parent)->pnd_childcount--; 92 93 if (pnd->pnd_dirent != NULL) 94 free(pnd->pnd_dirent); 95 96 if (pnd->pnd_all_fd != NULL) 97 free(pnd->pnd_all_fd); 98 #ifdef PERFUSE_DEBUG 99 if (pnd->pnd_flags & PND_OPEN) 100 DERRX(EX_SOFTWARE, "%s: file open", __func__); 101 102 if (!TAILQ_EMPTY(&pnd->pnd_pcq)) 103 DERRX(EX_SOFTWARE, "%s: non empty pnd_pcq", __func__); 104 #endif /* PERFUSE_DEBUG */ 105 106 free(pnd); 107 } 108 109 puffs_pn_put(pn); 110 111 return; 112 } 113 114 115 void 116 perfuse_new_fh(opc, fh, mode) 117 puffs_cookie_t opc; 118 uint64_t fh; 119 int mode; 120 { 121 struct perfuse_node_data *pnd; 122 123 pnd = PERFUSE_NODE_DATA(opc); 124 125 if (mode & FWRITE) { 126 if (pnd->pnd_flags & PND_WFH) 127 DERRX(EX_SOFTWARE, "%s: opc = %p, write fh already set", 128 __func__, (void *)opc); 129 pnd->pnd_wfh = fh; 130 pnd->pnd_flags |= PND_WFH; 131 } 132 133 if (mode & FREAD) { 134 if (pnd->pnd_flags & PND_RFH) 135 DERRX(EX_SOFTWARE, "%s: opc = %p, read fh already set", 136 __func__, (void *)opc); 137 pnd->pnd_rfh = fh; 138 pnd->pnd_flags |= PND_RFH; 139 } 140 141 return; 142 } 143 144 void 145 perfuse_destroy_fh(opc, fh) 146 puffs_cookie_t opc; 147 uint64_t fh; 148 { 149 struct perfuse_node_data *pnd; 150 151 pnd = PERFUSE_NODE_DATA(opc); 152 153 if (fh == pnd->pnd_rfh) { 154 if (!(pnd->pnd_flags & PND_RFH) && (fh != FUSE_UNKNOWN_FH)) 155 DERRX(EX_SOFTWARE, 156 "%s: opc = %p, unset rfh = %"PRIx64"", 157 __func__, (void *)opc, fh); 158 pnd->pnd_rfh = FUSE_UNKNOWN_FH; 159 pnd->pnd_flags &= ~PND_RFH; 160 } 161 162 if (fh == pnd->pnd_wfh) { 163 if (!(pnd->pnd_flags & PND_WFH) && (fh != FUSE_UNKNOWN_FH)) 164 DERRX(EX_SOFTWARE, 165 "%s: opc = %p, unset wfh = %"PRIx64"", 166 __func__, (void *)opc, fh); 167 pnd->pnd_wfh = FUSE_UNKNOWN_FH; 168 pnd->pnd_flags &= ~PND_WFH; 169 } 170 171 return; 172 } 173 174 uint64_t 175 perfuse_get_fh(opc, mode) 176 puffs_cookie_t opc; 177 int mode; 178 { 179 struct perfuse_node_data *pnd; 180 181 pnd = PERFUSE_NODE_DATA(opc); 182 183 if (mode & FWRITE) { 184 if (pnd->pnd_flags & PND_WFH) 185 return pnd->pnd_wfh; 186 } 187 188 if (mode & FREAD) { 189 if (pnd->pnd_flags & PND_RFH) 190 return pnd->pnd_rfh; 191 192 if (pnd->pnd_flags & PND_WFH) 193 return pnd->pnd_wfh; 194 195 } 196 197 return FUSE_UNKNOWN_FH; 198 } 199 200
Indexes created Sun Sep 21 16:09:51 GMT 2025