ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/libstatgrab/src/libstatgrab/tools.c
(Generate patch)

Comparing projects/libstatgrab/src/libstatgrab/tools.c (file contents):
Revision 1.5 by tdb, Wed Apr 9 21:01:53 2003 UTC vs.
Revision 1.26 by pajs, Tue Feb 10 16:16:22 2004 UTC

# Line 1 | Line 1
1 < /*
1 > /*
2   * i-scream central monitoring system
3 < * http://www.i-scream.org.uk
4 < * Copyright (C) 2000-2002 i-scream
3 > * http://www.i-scream.org
4 > * Copyright (C) 2000-2004 i-scream
5   *
6 < * This program is free software; you can redistribute it and/or
7 < * modify it under the terms of the GNU General Public License
8 < * as published by the Free Software Foundation; either version 2
9 < * of the License, or (at your option) any later version.
6 > * This library is free software; you can redistribute it and/or
7 > * modify it under the terms of the GNU Lesser General Public
8 > * License as published by the Free Software Foundation; either
9 > * version 2.1 of the License, or (at your option) any later version.
10   *
11 < * This program is distributed in the hope that it will be useful,
11 > * This library is distributed in the hope that it will be useful,
12   * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 < * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 < * GNU General Public License for more details.
13 > * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14 > * Lesser General Public License for more details.
15   *
16 < * You should have received a copy of the GNU General Public License
17 < * along with this program; if not, write to the Free Software
18 < * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
16 > * You should have received a copy of the GNU Lesser General Public
17 > * License along with this library; if not, write to the Free Software
18 > * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
19 > * 02111-1307 USA
20 > *
21 > * $Id$
22   */
23  
24   #ifdef HAVE_CONFIG_H
# Line 25 | Line 28
28   #include <stdio.h>
29   #include <string.h>
30   #include <stdlib.h>
31 + #include <unistd.h>
32   #include <sys/types.h>
33   #include <regex.h>
34 + #ifdef ALLBSD
35 + #include <fcntl.h>
36 + #include <kvm.h>
37 + #endif
38 + #ifdef NETBSD
39 + #include <uvm/uvm_extern.h>
40 + #endif
41  
42 + #include "tools.h"
43 +
44 + #ifdef SOLARIS
45 + #include <libdevinfo.h>
46 + #include <kstat.h>
47 + #include <unistd.h>
48 + #include <ctype.h>
49 + #include <sys/types.h>
50 + #include <sys/dkio.h>
51 + #include <sys/stat.h>
52 + #include <fcntl.h>
53 + #include <sys/fcntl.h>
54 + #include <dirent.h>
55 + #endif
56 +
57 + #if defined(SOLARIS) && defined(HAVE_LIBDEVINFO_H)
58 + struct map{
59 +        char *bsd;
60 +        char *svr;
61 +
62 +        struct map *next;
63 + };
64 + typedef struct map mapping_t;
65 +
66 + static mapping_t *mapping = NULL;
67 + #endif
68 +
69 + #ifdef SOLARIS
70 + char *get_svr_from_bsd(char *bsd){
71 + #ifdef HAVE_LIBDEVINFO_H
72 +        mapping_t *map_ptr;
73 +        for(map_ptr = mapping; map_ptr != NULL; map_ptr = map_ptr->next)
74 +                if(!strcmp(map_ptr->bsd, bsd)) return map_ptr->svr;
75 + #endif
76 +        return bsd;
77 + }
78 + #endif
79 +
80 + #if defined(SOLARIS) && defined(HAVE_LIBDEVINFO_H)
81 + void add_mapping(char *bsd, char *svr){
82 +        mapping_t *map_ptr;
83 +        mapping_t *map_end_ptr;
84 +
85 +        bsd = strdup(bsd);
86 +        svr = strdup(svr);
87 +
88 +        if (mapping == NULL){
89 +                mapping = malloc(sizeof(mapping_t));
90 +                if (mapping == NULL) return;
91 +                map_ptr = mapping;
92 +        }else{
93 +                /* See if its already been added */
94 +                for(map_ptr = mapping; map_ptr != NULL; map_ptr = map_ptr->next){
95 +                        if( (!strcmp(map_ptr->bsd, bsd)) || (!strcmp(map_ptr->svr, svr)) ){
96 +                                return;
97 +                        }
98 +                        map_end_ptr = map_ptr;
99 +                }
100 +
101 +                /* We've reached end of list and not found the entry.. So we need to malloc
102 +                 * new mapping_t
103 +                 */
104 +                map_end_ptr->next = malloc(sizeof(mapping_t));
105 +                if (map_end_ptr->next == NULL) return;
106 +                map_ptr = map_end_ptr->next;
107 +        }
108 +
109 +        map_ptr->next = NULL;
110 +        map_ptr->bsd = bsd;
111 +        map_ptr->svr = svr;
112 +
113 +        return;
114 + }
115 +
116 + char *read_dir(char *disk_path){
117 +        DIR *dirp;
118 +        struct dirent *dp;
119 +        struct stat stbuf;
120 +        char *svr_name;
121 +        char current_dir[MAXPATHLEN];
122 +        char file_name[MAXPATHLEN];
123 +        char temp_name[MAXPATHLEN];
124 +        char dir_dname[MAXPATHLEN];
125 +        char *dsk_dir;
126 +        int x;
127 +
128 +        dsk_dir = "/dev/osa/dev/dsk";
129 +        strncpy(current_dir, dsk_dir, sizeof current_dir);
130 +        if ((dirp = opendir(current_dir)) == NULL){
131 +                dsk_dir = "/dev/dsk";
132 +                snprintf(current_dir, sizeof current_dir, "%s", dsk_dir);
133 +                if ((dirp = opendir(current_dir)) == NULL){
134 +                        return NULL;
135 +                }
136 +        }
137 +
138 +        while ((dp = readdir(dirp)) != NULL){
139 +                snprintf(temp_name, sizeof temp_name, "../..%s", disk_path);
140 +                snprintf(dir_dname, sizeof dir_dname, "%s/%s", dsk_dir, dp->d_name);
141 +                stat(dir_dname,&stbuf);
142 +
143 +                if (S_ISBLK(stbuf.st_mode)){
144 +                        x = readlink(dir_dname, file_name, sizeof(file_name));
145 +                        file_name[x] = '\0';
146 +                        if (strcmp(file_name, temp_name) == 0) {
147 +                                svr_name = strdup(dp->d_name);
148 +                                closedir(dirp);
149 +                                return svr_name;
150 +                        }
151 +                }
152 +        }
153 +        closedir(dirp);
154 +        return NULL;
155 + }
156 +
157 +
158 +
159 + int get_alias(char *alias){
160 +        char file[MAXPATHLEN];
161 +        di_node_t root_node;
162 +        di_node_t node;
163 +        di_minor_t minor = DI_MINOR_NIL;
164 +        char tmpnode[MAXPATHLEN];
165 +        char *phys_path;
166 +        char *minor_name;
167 +        char *value;
168 +        int instance;
169 +        if ((root_node = di_init("/", DINFOCPYALL)) == DI_NODE_NIL) {
170 +                return 1;
171 +        }
172 +        node = di_drv_first_node(alias, root_node);
173 +        while (node != DI_NODE_NIL) {
174 +                if ((minor = di_minor_next(node, DI_MINOR_NIL)) != DI_MINOR_NIL) {
175 +                        instance = di_instance(node);
176 +                        phys_path = di_devfs_path(node);
177 +                        minor_name = di_minor_name(minor);
178 +                        strcpy(tmpnode, alias);
179 +                        sprintf(tmpnode, "%s%d", tmpnode, instance);
180 +                        strlcpy(file, "/devices", sizeof file);
181 +                        strlcat(file, phys_path, sizeof file);
182 +                        strlcat(file, ":", sizeof file);
183 +                        strlcat(file, minor_name, sizeof file);
184 +                        value = read_dir(file);
185 +                        if (value != NULL){
186 +                                add_mapping(tmpnode, value);
187 +                        }
188 +                        di_devfs_path_free(phys_path);
189 +                        node = di_drv_next_node(node);
190 +                }else{
191 +                        node = di_drv_next_node(node);
192 +                }
193 +        }
194 +        di_fini(root_node);
195 +        return 0;
196 + }
197 +
198 +
199 + #define BIG_ENOUGH 512
200 + int build_mapping(){
201 +        char device_name[BIG_ENOUGH];
202 +        int x;
203 +        kstat_ctl_t *kc;
204 +        kstat_t *ksp;
205 +        kstat_io_t kios;
206 +
207 +        char driver_list[BIG_ENOUGH][BIG_ENOUGH];
208 +        int list_entries = 0;
209 +        int found;
210 +
211 +        if ((kc = kstat_open()) == NULL) {
212 +                return;
213 +        }
214 +
215 +        for (ksp = kc->kc_chain; ksp; ksp = ksp->ks_next) {
216 +                if (!strcmp(ksp->ks_class, "disk")) {
217 +                        if(ksp->ks_type != KSTAT_TYPE_IO) continue;
218 +                        /* We dont want metadevices appearing as num_diskio */
219 +                        if(strcmp(ksp->ks_module, "md")==0) continue;
220 +                        if((kstat_read(kc, ksp, &kios))==-1) continue;
221 +                        strncpy(device_name, ksp->ks_name, sizeof device_name);
222 +                        for(x=0;x<(sizeof device_name);x++){
223 +                                if( isdigit((int)device_name[x]) ) break;
224 +                        }
225 +                        if(x == sizeof device_name) x--;
226 +                        device_name[x] = '\0';
227 +
228 +                        /* Check if we've not already looked it up */
229 +                        found = 0;
230 +                        for(x=0;x<list_entries;x++){
231 +                                if (x>=BIG_ENOUGH){
232 +                                        /* We've got bigger than we thought was massive */
233 +                                        /* If we hit this.. Make big enough bigger */
234 +                                        return 1;
235 +                                }
236 +                                if( !strncmp(driver_list[x], device_name, BIG_ENOUGH)){
237 +                                        found = 1;
238 +                                        break;
239 +                                }
240 +                        }
241 +
242 +                        if(!found){
243 +                                if((get_alias(device_name)) != 0){
244 +                                        return 1;
245 +                                }
246 +                                strncpy(driver_list[x], device_name, BIG_ENOUGH);
247 +                                list_entries++;
248 +                        }
249 +                }
250 +        }
251 +
252 +        return 0;
253 + }
254 +
255 + #endif
256 +
257 +
258 +
259   char *f_read_line(FILE *f, const char *string){
260          /* Max line length. 8k should be more than enough */
261          static char line[8192];
# Line 50 | Line 278 | char *get_string_match(char *line, regmatch_t *match){
278  
279          return match_string;
280   }
281 < #ifdef HAVE_ATOLL
281 >
282 >
283 >
284 > #ifndef HAVE_ATOLL
285 > static long long atoll(const char *s) {
286 >        long long value = 0;
287 >        int isneg = 0;
288 >
289 >        while (*s == ' ' || *s == '\t') {
290 >                s++;
291 >        }
292 >        if (*s == '-') {
293 >                isneg = 1;
294 >                s++;
295 >        }
296 >        while (*s >= '0' && *s <= '9') {
297 >                value = (10 * value) + (*s - '0');
298 >                s++;
299 >        }
300 >        return (isneg ? -value : value);
301 > }
302 > #endif
303 >
304 > #ifndef HAVE_STRLCPY
305 > /*      $OpenBSD: strlcpy.c,v 1.8 2003/06/17 21:56:24 millert Exp $     */
306 >
307 > /*
308 > * Copyright (c) 1998 Todd C. Miller <Todd.Miller@courtesan.com>
309 > *
310 > * Permission to use, copy, modify, and distribute this software for any
311 > * purpose with or without fee is hereby granted, provided that the above
312 > * copyright notice and this permission notice appear in all copies.
313 > *
314 > * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
315 > * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
316 > * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
317 > * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
318 > * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
319 > * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
320 > * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
321 > */
322 >
323 > /*
324 > * Copy src to string dst of size siz.  At most siz-1 characters
325 > * will be copied.  Always NUL terminates (unless siz == 0).
326 > * Returns strlen(src); if retval >= siz, truncation occurred.
327 > */
328 > size_t strlcpy(char *dst, const char *src, size_t siz){
329 >        register char *d = dst;
330 >        register const char *s = src;
331 >        register size_t n = siz;
332 >
333 >        /* Copy as many bytes as will fit */
334 >        if (n != 0 && --n != 0) {
335 >                do {
336 >                        if ((*d++ = *s++) == 0)
337 >                                break;
338 >                } while (--n != 0);
339 >        }
340 >
341 >        /* Not enough room in dst, add NUL and traverse rest of src */
342 >        if (n == 0) {
343 >                if (siz != 0)
344 >                        *d = '\0';              /* NUL-terminate dst */
345 >                while (*s++)
346 >                        ;
347 >        }
348 >
349 >        return(s - src - 1);    /* count does not include NUL */
350 > }
351 > #endif
352 >
353 > #ifndef HAVE_STRLCAT
354 > /*      $OpenBSD: strlcat.c,v 1.11 2003/06/17 21:56:24 millert Exp $    */
355 >
356 > /*
357 > * Copyright (c) 1998 Todd C. Miller <Todd.Miller@courtesan.com>
358 > *
359 > * Permission to use, copy, modify, and distribute this software for any
360 > * purpose with or without fee is hereby granted, provided that the above
361 > * copyright notice and this permission notice appear in all copies.
362 > *
363 > * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
364 > * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
365 > * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
366 > * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
367 > * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
368 > * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
369 > * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
370 > */
371 >
372 > /*
373 > * Appends src to string dst of size siz (unlike strncat, siz is the
374 > * full size of dst, not space left).  At most siz-1 characters
375 > * will be copied.  Always NUL terminates (unless siz <= strlen(dst)).
376 > * Returns strlen(src) + MIN(siz, strlen(initial dst)).
377 > * If retval >= siz, truncation occurred.
378 > */
379 > size_t strlcat(char *dst, const char *src, size_t siz){
380 >        register char *d = dst;
381 >        register const char *s = src;
382 >        register size_t n = siz;
383 >        size_t dlen;
384 >
385 >        /* Find the end of dst and adjust bytes left but don't go past end */
386 >        while (n-- != 0 && *d != '\0')
387 >                d++;
388 >        dlen = d - dst;
389 >        n = siz - dlen;
390 >
391 >        if (n == 0)
392 >                return(dlen + strlen(s));
393 >        while (*s != '\0') {
394 >                if (n != 1) {
395 >                        *d++ = *s;
396 >                        n--;
397 >                }
398 >                s++;
399 >        }
400 >        *d = '\0';
401 >
402 >        return(dlen + (s - src));       /* count does not include NUL */
403 > }
404 >
405 > #endif
406 >
407   long long get_ll_match(char *line, regmatch_t *match){
408          char *ptr;
409          long long num;
# Line 60 | Line 413 | long long get_ll_match(char *line, regmatch_t *match){
413  
414          return num;
415   }
416 +
417 + #ifdef ALLBSD
418 + kvm_t *get_kvm() {
419 +        static kvm_t *kvmd = NULL;
420 +
421 +        if (kvmd != NULL) {
422 +                return kvmd;
423 +        }
424 +
425 +        kvmd = kvm_openfiles(NULL, NULL, NULL, O_RDONLY, NULL);
426 +        return kvmd;
427 + }
428   #endif
429 +
430 + #ifdef NETBSD
431 + struct uvmexp *get_uvmexp() {
432 +        static u_long addr = 0;
433 +        static struct uvmexp uvm;
434 +        kvm_t *kvmd = get_kvm();
435 +
436 +        if (kvmd == NULL) {
437 +                return NULL;
438 +        }
439 +
440 +        if (addr == 0) {
441 +                struct nlist symbols[] = {
442 +                        { "_uvmexp" },
443 +                        { NULL }
444 +                };
445 +
446 +                if (kvm_nlist(kvmd, symbols) != 0) {
447 +                        return NULL;
448 +                }
449 +                addr = symbols[0].n_value;
450 +        }
451 +
452 +        if (kvm_read(kvmd, addr, &uvm, sizeof uvm) != sizeof uvm) {
453 +                return NULL;
454 +        }
455 +        return &uvm;
456 + }
457 + #endif
458 +
459 + int statgrab_init(){
460 + #ifdef ALLBSD
461 +        {
462 +                kvm_t *kvmd = get_kvm();
463 +                if (kvmd == NULL) return 1;
464 +        }
465 + #endif
466 + #ifdef NETBSD
467 +        {
468 +                struct uvmexp *uvm = get_uvmexp();
469 +                if (uvm == NULL) return 1;
470 +        }
471 + #endif
472 + #ifdef SOLARIS
473 +        /* On solaris 7, this will fail if you are not root. But, everything
474 +         * will still work, just no disk mappings. So we will ignore the exit
475 +         * status of this, and carry on merrily.
476 +         */
477 + #ifdef HAVE_LIBDEVINFO_H
478 +        build_mapping();
479 + #endif
480 + #endif
481 +        return 0;
482 + }
483 +
484 + int statgrab_drop_privileges() {
485 +        if (setegid(getgid()) != 0) return -1;
486 +        if (seteuid(getuid()) != 0) return -1;
487 +        return 0;
488 + }
489 +

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines