1 /*
2 * Copyright (c) 1999, 2007, Oracle and/or its affiliates. All rights reserved.
3 * Copyright (c) 2014 Racktop Systems.
4 */
5 /*
6 * Project.xs contains XS wrappers for the project database maniplulation
7 * functions as provided by libproject and described in getprojent(3EXACCT).
8 */
9
10 /* Solaris includes. */
11 #include <zone.h>
12 #include <project.h>
13 #include <pool.h>
14 #include <sys/pool_impl.h>
15 #include <rctl.h>
16 #include <stdio.h>
17
18 /* Perl includes. */
19 #include "EXTERN.h"
20 #include "perl.h"
21 #include "XSUB.h"
22
23 /*
24 * Convert and save a struct project on the perl XS return stack.
25 * In a void context it returns nothing, in a scalar context it returns just
26 * the name of the project and in a list context it returns a 6-element list
27 * consisting of (name, projid, comment, users, groups, attr), where users and
28 * groups are references to arrays containing the appropriate lists.
29 */
30 static int
31 pushret_project(const struct project *proj)
32 {
33 char **cp;
34 AV *ary;
35
36 dSP;
37 if (GIMME_V == G_SCALAR) {
38 EXTEND(SP, 1);
39 PUSHs(sv_2mortal(newSVpv(proj->pj_name, 0)));
40 PUTBACK;
41 return (1);
42 } else if (GIMME_V == G_ARRAY) {
43 EXTEND(SP, 6);
44 PUSHs(sv_2mortal(newSVpv(proj->pj_name, 0)));
45 PUSHs(sv_2mortal(newSViv(proj->pj_projid)));
46 PUSHs(sv_2mortal(newSVpv(proj->pj_comment, 0)));
47 ary = newAV();
48 for (cp = proj->pj_users; *cp != NULL; cp++) {
49 av_push(ary, newSVpv(*cp, 0));
50 }
51 PUSHs(sv_2mortal(newRV_noinc((SV *)ary)));
52 ary = newAV();
53 for (cp = proj->pj_groups; *cp != NULL; cp++) {
54 av_push(ary, newSVpv(*cp, 0));
55 }
56 PUSHs(sv_2mortal(newRV_noinc((SV *)ary)));
57 PUSHs(sv_2mortal(newSVpv(proj->pj_attr, 0)));
58 PUTBACK;
59 return (6);
60 } else {
61 return (0);
62 }
63 }
64
65 static int
66 pwalk_cb(const projid_t project, void *walk_data)
67 {
68 int *nitemsp;
69
70 dSP;
71 nitemsp = (int *) walk_data;
72 EXTEND(SP, 1);
73 PUSHs(sv_2mortal(newSViv(project)));
74 (*nitemsp)++;
75 PUTBACK;
76 return (0);
77 }
78
79 /*
80 * The XS code exported to perl is below here. Note that the XS preprocessor
81 * has its own commenting syntax, so all comments from this point on are in
82 * that form. Note also that the PUTBACK; lines are necessary to synchronise
83 * the local and global views of the perl stack before calling pushret_project,
84 * as the code generated by the perl XS compiler twiddles with the stack on
85 * entry to an XSUB.
86 */
87
88 MODULE = Sun::Solaris::Project PACKAGE = Sun::Solaris::Project
89 PROTOTYPES: ENABLE
90
91 #
92 # Define any constants that need to be exported. By doing it this way we can
93 # avoid the overhead of using the DynaLoader package, and in addition constants
94 # defined using this mechanism are eligible for inlining by the perl
95 # interpreter at compile time.
96 #
97 BOOT:
98 {
99 HV *stash;
100 char buf[128];
101 stash = gv_stashpv("Sun::Solaris::Project", TRUE);
102 newCONSTSUB(stash, "MAXPROJID", newSViv(MAXPROJID));
103 newCONSTSUB(stash, "PROJNAME_MAX", newSViv(PROJNAME_MAX));
104 newCONSTSUB(stash, "PROJF_PATH",
105 newSVpv(PROJF_PATH, sizeof (PROJF_PATH) - 1));
106 newCONSTSUB(stash, "PROJECT_BUFSZ", newSViv(PROJECT_BUFSZ));
107 newCONSTSUB(stash, "SETPROJ_ERR_TASK", newSViv(SETPROJ_ERR_TASK));
108 newCONSTSUB(stash, "SETPROJ_ERR_POOL", newSViv(SETPROJ_ERR_POOL));
109 newCONSTSUB(stash, "RCTL_GLOBAL_NOBASIC",
110 newSViv(RCTL_GLOBAL_NOBASIC));
111 newCONSTSUB(stash, "RCTL_GLOBAL_LOWERABLE",
112 newSViv(RCTL_GLOBAL_LOWERABLE));
113 newCONSTSUB(stash, "RCTL_GLOBAL_DENY_ALWAYS",
114 newSViv(RCTL_GLOBAL_DENY_ALWAYS));
115 newCONSTSUB(stash, "RCTL_GLOBAL_DENY_NEVER",
116 newSViv(RCTL_GLOBAL_DENY_NEVER));
117 newCONSTSUB(stash, "RCTL_GLOBAL_FILE_SIZE",
118 newSViv(RCTL_GLOBAL_FILE_SIZE));
119 newCONSTSUB(stash, "RCTL_GLOBAL_CPU_TIME",
120 newSViv(RCTL_GLOBAL_CPU_TIME));
121 newCONSTSUB(stash, "RCTL_GLOBAL_SIGNAL_NEVER",
122 newSViv(RCTL_GLOBAL_SIGNAL_NEVER));
123 newCONSTSUB(stash, "RCTL_GLOBAL_INFINITE",
124 newSViv(RCTL_GLOBAL_INFINITE));
125 newCONSTSUB(stash, "RCTL_GLOBAL_UNOBSERVABLE",
126 newSViv(RCTL_GLOBAL_UNOBSERVABLE));
127 newCONSTSUB(stash, "RCTL_GLOBAL_BYTES",
128 newSViv(RCTL_GLOBAL_BYTES));
129 newCONSTSUB(stash, "RCTL_GLOBAL_SECONDS",
130 newSViv(RCTL_GLOBAL_SECONDS));
131 newCONSTSUB(stash, "RCTL_GLOBAL_COUNT",
132 newSViv(RCTL_GLOBAL_COUNT));
133 sprintf(buf, "%llu", UINT64_MAX);
134 newCONSTSUB(stash, "RCTL_MAX_VALUE",
135 newSVpv(buf, strlen(buf)));
136 }
137
138 projid_t
139 getprojid()
140
141 int
142 setproject(name, user_name, flags)
143 const char *name;
144 const char *user_name
145 uint_t flags
146
147 void
148 activeprojects()
149 PREINIT:
150 int nitems;
151 PPCODE:
152 PUTBACK;
153 nitems = 0;
154 project_walk(&pwalk_cb, (void*)&nitems);
155 XSRETURN(nitems);
156
157 void
158 getprojent()
159 PREINIT:
160 struct project proj, *projp;
161 char buf[PROJECT_BUFSZ];
162 PPCODE:
163 PUTBACK;
164 if ((projp = getprojent(&proj, buf, sizeof (buf)))) {
165 XSRETURN(pushret_project(projp));
166 } else {
167 XSRETURN_EMPTY;
168 }
169
170 void
171 setprojent()
172
173 void
174 endprojent()
175
176 void
177 getprojbyname(name)
178 char *name
179 PREINIT:
180 struct project proj, *projp;
181 char buf[PROJECT_BUFSZ];
182 PPCODE:
183 PUTBACK;
184 if ((projp = getprojbyname(name, &proj, buf, sizeof (buf)))) {
185 XSRETURN(pushret_project(projp));
186 } else {
187 XSRETURN_EMPTY;
188 }
189
190 void
191 getprojbyid(id)
192 projid_t id
193 PREINIT:
194 struct project proj, *projp;
195 char buf[PROJECT_BUFSZ];
196 PPCODE:
197 PUTBACK;
198 if ((projp = getprojbyid(id, &proj, buf, sizeof (buf)))) {
199 XSRETURN(pushret_project(projp));
200 } else {
201 XSRETURN_EMPTY;
202 }
203
204 void
205 getdefaultproj(user)
206 char *user
207 PREINIT:
208 struct project proj, *projp;
209 char buf[PROJECT_BUFSZ];
210 PPCODE:
211 PUTBACK;
212 if ((projp = getdefaultproj(user, &proj, buf, sizeof (buf)))) {
213 XSRETURN(pushret_project(projp));
214 } else {
215 XSRETURN_EMPTY;
216 }
217
218 void
219 fgetprojent(fh)
220 FILE *fh
221 PREINIT:
222 struct project proj, *projp;
223 char buf[PROJECT_BUFSZ];
224 PPCODE:
225 PUTBACK;
226 if ((projp = fgetprojent(fh, &proj, buf, sizeof (buf)))) {
227 XSRETURN(pushret_project(projp));
228 } else {
229 XSRETURN_EMPTY;
230 }
231
232 bool
233 inproj(user, proj)
234 char *user
235 char *proj
236 PREINIT:
237 char buf[PROJECT_BUFSZ];
238 CODE:
239 RETVAL = inproj(user, proj, buf, sizeof (buf));
240 OUTPUT:
241 RETVAL
242
243
244 int
245 getprojidbyname(proj)
246 char *proj
247 PREINIT:
248 int id;
249 PPCODE:
250 if ((id = getprojidbyname(proj)) == -1) {
251 XSRETURN_UNDEF;
252 } else {
253 XSRETURN_IV(id);
254 }
255
256
257 # rctl_get_info(name)
258 #
259 # For the given rctl name, returns the list
260 # ($max, $flags), where $max is the integer value
261 # of the system rctl, and $flags are the rctl's
262 # global flags, as returned by rctlblk_get_global_flags
263 #
264 # This function is private to Project.pm
265 void
266 rctl_get_info(name)
267 char *name
268 PREINIT:
269 rctlblk_t *blk1 = NULL;
270 rctlblk_t *blk2 = NULL;
271 rctlblk_t *tmp = NULL;
272 rctl_priv_t priv;
273 rctl_qty_t value;
274 int flags = 0;
275 int ret;
276 int err = 0;
277 char string[24]; /* 24 will always hold a uint64_t */
278 PPCODE:
279 Newc(0, blk1, rctlblk_size(), char, rctlblk_t);
280 if (blk1 == NULL) {
281 err = 1;
282 goto out;
283 }
284 Newc(1, blk2, rctlblk_size(), char, rctlblk_t);
285 if (blk2 == NULL) {
286 err = 1;
287 goto out;
288 }
289 ret = getrctl(name, NULL, blk1, RCTL_FIRST);
290 if (ret != 0) {
291 err = 1;
292 goto out;
293 }
294 priv = rctlblk_get_privilege(blk1);
295 while (priv != RCPRIV_SYSTEM) {
296 tmp = blk2;
297 blk2 = blk1;
298 blk1 = tmp;
299 ret = getrctl(name, blk2, blk1, RCTL_NEXT);
300 if (ret != 0) {
301 err = 1;
302 goto out;
303 }
304 priv = rctlblk_get_privilege(blk1);
305 }
306 value = rctlblk_get_value(blk1);
307 flags = rctlblk_get_global_flags(blk1);
308 ret = sprintf(string, "%llu", value);
309 if (ret <= 0) {
310 err = 1;
311 }
312 out:
313 if (blk1)
314 Safefree(blk1);
315 if (blk2)
316 Safefree(blk2);
317 if (err)
318 XSRETURN(0);
319
320 XPUSHs(sv_2mortal(newSVpv(string, 0)));
321 XPUSHs(sv_2mortal(newSViv(flags)));
322 XSRETURN(2);
323
324 #
325 # pool_exists(name)
326 #
327 # Returns 0 a pool with the given name exists on the current system.
328 # Returns 1 if pools are disabled or the pool does not exist
329 #
330 # Used internally by project.pm to validate the project.pool attribute
331 #
332 # This function is private to Project.pm
333 void
334 pool_exists(name)
335 char *name
336 PREINIT:
337 pool_conf_t *conf;
338 pool_t *pool;
339 pool_status_t status;
340 int fd;
341 PPCODE:
342
343 /*
344 * Determine if pools are enabled using /dev/pool directly, as
345 * libpool may not be present.
346 */
347 if (getzoneid() != GLOBAL_ZONEID) {
348 XSRETURN_IV(1);
349 }
350 if ((fd = open("/dev/pool", O_RDONLY)) < 0) {
351 XSRETURN_IV(1);
352 }
353 if (ioctl(fd, POOL_STATUSQ, &status) < 0) {
354 (void) close(fd);
355 XSRETURN_IV(1);
356 }
357 close(fd);
358 if (status.ps_io_state != 1) {
359 XSRETURN_IV(1);
360 }
361
362 /*
363 * If pools are enabled, assume libpool is present.
364 */
365 conf = pool_conf_alloc();
366 if (conf == NULL) {
367 XSRETURN_IV(1);
368 }
369 if (pool_conf_open(conf, pool_dynamic_location(), PO_RDONLY)) {
370 pool_conf_free(conf);
371 XSRETURN_IV(1);
372 }
373 pool = pool_get_pool(conf, name);
374 if (pool == NULL) {
375 pool_conf_close(conf);
376 pool_conf_free(conf);
377 XSRETURN_IV(1);
378 }
379 pool_conf_close(conf);
380 pool_conf_free(conf);
381 XSRETURN_IV(0);
382