File: [Development] / xfs-cmds / xfsdump / inventory / inv_api.c (download)
Revision 1.12, Wed May 24 06:08:55 2006 UTC (11 years, 5 months ago) by nathans.longdrop.melbourne.sgi.com
Branch: MAIN
CVS Tags: HEAD
Changes since 1.11: +2 -2
lines
Update xfsdump build to use xfs.h instead of libxfs.h, fixing a recent namespace collision on list symbols.
Merge of master-melb:xfs-cmds:26007a by kenmcd.
|
/*
* Copyright (c) 2000-2002 Silicon Graphics, Inc.
* All Rights Reserved.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License as
* published by the Free Software Foundation.
*
* This program is distributed in the hope that it would be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#include <xfs/xfs.h>
#include <xfs/jdm.h>
#include <fcntl.h>
#include <time.h>
#include <stdlib.h>
#include <errno.h>
#include <unistd.h>
#include <stdio.h>
#include <sys/stat.h>
#include "types.h"
#include "mlog.h"
#include "inv_priv.h"
#include "getopt.h"
/*----------------------------------------------------------------------*/
/* inventory_open */
/* */
/* INV_BY_MOUNTPT, INV_BY_UUID or INV_BY_DEVPATH */
/*----------------------------------------------------------------------*/
inv_idbtoken_t
inv_open( inv_predicate_t bywhat, inv_oflag_t forwhat, void *pred )
{
int fd, stobjfd, num, retval;
inv_idbtoken_t tok = INV_TOKEN_NULL;
invt_sescounter_t *sescnt = 0;
int index = 0;
ASSERT ( pred );
fd = retval = init_idb ( pred, bywhat, forwhat, &tok );
if ( retval == I_DONE )
return tok;
/* if we just want to search the db, all we need is the invidx.
at this point, we know that a tok wasnt created in init_idb() */
if ( forwhat == INV_SEARCH_ONLY ) {
/* fd == I_EMPTYINV or fd == valid fd */
tok = get_token( fd, -1);
tok->d_oflag = forwhat;
return tok;
}
/* XXX also, see if it is too full. if so, make another and leave a
reference to the new file in the old one */
stobjfd = idx_get_stobj( fd, forwhat, &index );
if ( stobjfd < 0 ) {
close( fd );
return INV_TOKEN_NULL;
}
ASSERT ( index > 0 );
/* Now we need to make sure that this has enough space */
INVLOCK( stobjfd, LOCK_SH );
num = GET_SESCOUNTERS( stobjfd, &sescnt );
if ( num < 0 ) {
close( fd );
INVLOCK( stobjfd, LOCK_UN );
close( stobjfd );
return INV_TOKEN_NULL;
}
/* create another storage object ( and, an inv_index entry for it
too ) if we've filled this one up */
if ( (u_int) num >= sescnt->ic_maxnum ) {
mlog( MLOG_DEBUG | MLOG_INV, "$ INV: creating a new storage obj & "
"index entry. \n" );
INVLOCK( stobjfd, LOCK_UN );
close (stobjfd);
INVLOCK( fd, LOCK_EX );
stobjfd = idx_create_entry( &tok, fd, BOOL_FALSE );
INVLOCK( fd, LOCK_UN );
free ( sescnt );
if ( stobjfd < 0 ) {
close( fd );
return INV_TOKEN_NULL;
}
return tok;
}
INVLOCK( stobjfd, LOCK_UN );
free ( sescnt );
tok = get_token( fd, stobjfd );
tok->d_invindex_off = IDX_HDR_OFFSET( index - 1 );
tok->d_oflag = forwhat;
return tok;
}
/*----------------------------------------------------------------------*/
/* */
/* */
/* */
/*----------------------------------------------------------------------*/
bool_t
inv_close( inv_idbtoken_t tok )
{
close ( tok->d_invindex_fd );
if ( tok->d_stobj_fd >= 0 )
close ( tok->d_stobj_fd );
destroy_token( tok );
return BOOL_TRUE;
}
/*----------------------------------------------------------------------*/
/* */
/* */
/* */
/*----------------------------------------------------------------------*/
inv_sestoken_t
inv_writesession_open(
inv_idbtoken_t tok, /* token obtained by inventory_open() */
uuid_t *fsid,
uuid_t *sesid,
char *label,
bool_t ispartial,
bool_t isresumed,
u_char level,
u_int nstreams,
time32_t time,
char *mntpt,
char *devpath )
{
invt_session_t ses;
int fd;
intgen_t rval;
invt_sescounter_t *sescnt = NULL;
invt_seshdr_t hdr;
inv_sestoken_t sestok;
inv_oflag_t forwhat;
ASSERT ( tok != INV_TOKEN_NULL );
ASSERT ( sesid && fsid && mntpt && devpath );
forwhat = tok->d_oflag;
fd = tok->d_stobj_fd;
ASSERT ( forwhat != INV_SEARCH_ONLY );
ASSERT ( fd > 0 );
if ( ! ( tok->d_update_flag & FSTAB_UPDATED ) ) {
if ( fstab_put_entry( fsid, mntpt, devpath, forwhat ) < 0 ) {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: put_fstab_entry failed.\n") );
return INV_TOKEN_NULL;
}
tok->d_update_flag |= FSTAB_UPDATED;
}
/* copy the session information to store */
memset( (void *)&ses, 0, sizeof( ses ) ); /* paranoia */
memcpy( &ses.s_sesid, sesid, sizeof( uuid_t ) );
memcpy( &ses.s_fsid, fsid, sizeof( uuid_t ) );
strcpy( ses.s_label, label );
strcpy( ses.s_mountpt, mntpt );
strcpy( ses.s_devpath, devpath );
ses.s_max_nstreams = nstreams;
hdr.sh_pruned = 0; /* session is not pruned by invutil */
hdr.sh_time = time;
hdr.sh_level = level;
hdr.sh_flag = (ispartial) ? INVT_PARTIAL: 0;
hdr.sh_flag |= (isresumed) ? INVT_RESUMED : 0;
/* sh_streams_off and sh_sess_off will be set in create_session() */
sestok = get_sesstoken( tok );
/* we need to put the new session in the appropriate place in
storage object. So first find out howmany sessions are there */
INVLOCK( fd, LOCK_EX );
if ( GET_SESCOUNTERS( fd, &sescnt) < 0 ) {
free ( sestok );
INVLOCK( fd, LOCK_UN );
return INV_TOKEN_NULL;
}
/* create the writesession, and get ready for the streams to come
afterwards */
rval = stobj_create_session( sestok, fd, sescnt, &ses, &hdr );
ASSERT (rval > 0);
INVLOCK( fd, LOCK_UN );
sestok->sd_sesstime = time;
if ( tok->d_update_flag & NEW_INVINDEX ) {
if ( idx_put_sesstime( sestok, INVT_STARTTIME ) < 0 ) {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: put_starttime failed.\n") );
return INV_TOKEN_NULL;
}
tok->d_update_flag &= ~(NEW_INVINDEX);
}
free ( sescnt );
return ( rval < 0 )? INV_TOKEN_NULL: sestok;
}
/*----------------------------------------------------------------------*/
/* */
/* */
/* */
/*----------------------------------------------------------------------*/
bool_t
inv_writesession_close( inv_sestoken_t tok )
{
int rval;
ASSERT ( tok != INV_TOKEN_NULL );
/* now update end_time in the inv index header */
rval = idx_put_sesstime( tok, INVT_ENDTIME );
memset( tok, 0, sizeof( invt_sesdesc_entry_t ) );
free ( tok );
return ( rval < 0 ) ? BOOL_FALSE: BOOL_TRUE;
}
/*----------------------------------------------------------------------*/
/* inventory_stream_open */
/* */
/* Opens a stream for mediafiles to be put in. */
/*----------------------------------------------------------------------*/
inv_stmtoken_t
inv_stream_open(
inv_sestoken_t tok,
char *cmdarg )
{
inv_stmtoken_t stok;
invt_stream_t stream;
invt_session_t ses;
invt_seshdr_t seshdr;
int fd;
bool_t err = BOOL_FALSE;
ASSERT ( tok != INV_TOKEN_NULL );
/* this memset is needed as a dump interrupted/crashed very soon
* after starting results in an inventory with exteremely large
* starting/ending inodes or offsets. This can be misleading.
* See bug #463702 for an example.
*/
memset( (void *)&stream, 0 , sizeof(invt_stream_t) );
stream.st_nmediafiles = 0;
stream.st_interrupted = BOOL_TRUE; /* fix for 353197 */
strcpy( stream.st_cmdarg, cmdarg );
/* XXX yukk... make the token descriptors not pointers */
stok = ( inv_stmtoken_t ) malloc( sizeof( invt_strdesc_entry_t ) );
stok->md_sesstok = tok;
stok->md_lastmfile = 0;
/* get the session to find out where the stream is going to go */
fd = tok->sd_invtok->d_stobj_fd;
INVLOCK( fd, LOCK_EX );
/* get the session header and the session */
if ( stobj_get_sessinfo( tok, &seshdr, &ses ) <= 0 )
err = BOOL_TRUE;
if ( ( ! err ) && ses.s_cur_nstreams < ses.s_max_nstreams ) {
/* this is where this stream header will be written to */
stok->md_stream_off = (off64_t) (sizeof( invt_stream_t ) *
ses.s_cur_nstreams )
+ seshdr.sh_streams_off;
ses.s_cur_nstreams++;
/* write it back. */
if ( PUT_REC_NOLOCK( fd, &ses, sizeof( ses ),
tok->sd_session_off ) < 0 )
err = BOOL_TRUE;
} else if ( ! err ) {
mlog ( MLOG_NORMAL, _(
"INV: cant create more than %d streams."
" Max'd out..\n"), ses.s_cur_nstreams );
err = BOOL_TRUE;
}
if ( ! err ) {
stream.st_firstmfile = stream.st_lastmfile =
stok->md_stream_off;
/* now write the stream header on to the disk */
if ( PUT_REC_NOLOCK( fd, &stream, sizeof( invt_stream_t ),
stok->md_stream_off ) > 0 ) {
/* we're all set */
INVLOCK( fd, LOCK_UN );
return stok;
}
}
/* error occured somewhere */
free ( stok );
INVLOCK( fd, LOCK_UN );
return INV_TOKEN_NULL;
}
/*----------------------------------------------------------------------*/
/* */
/* */
/* */
/*----------------------------------------------------------------------*/
bool_t
inv_stream_close(
inv_stmtoken_t tok,
bool_t wasinterrupted )
{
invt_stream_t strm;
int fd = tok->md_sesstok->sd_invtok->d_stobj_fd;
int rval;
bool_t dowrite = BOOL_FALSE;
rval = idx_put_sesstime( tok->md_sesstok, INVT_ENDTIME );
if (rval < 0)
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: idx_put_sesstime failed in "
"inv_stream_close() \n") );
INVLOCK( fd, LOCK_EX );
if ((rval = GET_REC_NOLOCK( fd, &strm, sizeof( invt_stream_t ),
tok->md_stream_off )) > 0 ) {
if ( strm.st_interrupted != wasinterrupted ) {
strm.st_interrupted = wasinterrupted;
dowrite = BOOL_TRUE;
}
/* get the last media file to figure out what our last
ino was. we have a pointer to that in the stream token */
if ( tok->md_lastmfile ){
if ( strm.st_endino.ino !=
tok->md_lastmfile->mf_endino.ino ||
strm.st_endino.offset !=
tok->md_lastmfile->mf_endino.offset) {
mlog( MLOG_DEBUG | MLOG_INV, "INV: stream_close() "
" - endinos dont match ! \n");
dowrite = BOOL_TRUE;
strm.st_endino = tok->md_lastmfile->mf_endino;
}
}
if (dowrite) {
rval = PUT_REC_NOLOCK_SEEKCUR( fd, &strm,
sizeof( invt_stream_t ),
-(off64_t)(sizeof( invt_stream_t )) );
}
}
INVLOCK( fd, LOCK_UN );
if ( tok->md_lastmfile ) {
free ( tok->md_lastmfile );
}
memset( tok, 0, sizeof( invt_strdesc_entry_t ) );
free ( tok );
return ( rval < 0 ) ? BOOL_FALSE: BOOL_TRUE;
}
/*----------------------------------------------------------------------*/
/* */
/* */
/* */
/*----------------------------------------------------------------------*/
bool_t
inv_put_mediafile(
inv_stmtoken_t tok,
uuid_t *moid,
char *label,
u_int mfileindex,
xfs_ino_t startino,
off64_t startino_offset,
xfs_ino_t endino,
off64_t endino_offset,
off64_t size,
bool_t isgood,
bool_t isinvdump)
{
invt_mediafile_t *mf;
int rval;
ASSERT ( tok != INV_TOKEN_NULL );
ASSERT ( tok->md_sesstok->sd_invtok->d_update_flag & FSTAB_UPDATED );
ASSERT ( tok->md_sesstok->sd_invtok->d_stobj_fd >= 0 );
mf = (invt_mediafile_t *) calloc( 1, sizeof( invt_mediafile_t ) );
/* copy the media file information */
memcpy( &mf->mf_moid, moid, sizeof( uuid_t ) );
strcpy( mf->mf_label, label );
mf->mf_mfileidx = mfileindex;
mf->mf_startino.ino = startino;
mf->mf_startino.offset = startino_offset;
mf->mf_endino.ino = endino;
mf->mf_endino.offset = endino_offset;
mf->mf_size = size;
mf->mf_flag = 0;
if ( isgood )
mf->mf_flag |= INVT_MFILE_GOOD;
/* This flag is used to indicate the media file that contains the
dump of the sessioninfo structure that contains all but this
media file */
if ( isinvdump )
mf->mf_flag |= INVT_MFILE_INVDUMP;
INVLOCK( tok->md_sesstok->sd_invtok->d_stobj_fd, LOCK_EX );
rval = stobj_put_mediafile( tok, mf );
INVLOCK( tok->md_sesstok->sd_invtok->d_stobj_fd, LOCK_UN );
/* we dont free the mfile here. we always keep the last mfile
around, inside the inv_stmtoken, and when we add a new mfile,
we free the previous one. The last one is freed in stream_close()
*/
return ( rval < 0 ) ? BOOL_FALSE: BOOL_TRUE;
}
/*----------------------------------------------------------------------*/
/* inv_get_sessioninfo */
/* */
/* This is to be called after a write-session is complete, but before it*/
/* is closed. ie. the token must still be valid, and all the streams */
/* and their mediafiles put in the inventory. */
/* */
/* On return, the buffer will be filled with all the data pertinent to */
/* the session referred to by the session token. The application of this*/
/* is to dump the inventory of a session to a media object. */
/*----------------------------------------------------------------------*/
bool_t
inv_get_sessioninfo(
inv_sestoken_t tok,
void **bufpp, /* buf to fill */
size_t *bufszp )/* size of that buffer */
{
invt_session_t ses;
invt_seshdr_t hdr;
bool_t rval;
int fd;
ASSERT( tok != INV_TOKEN_NULL );
ASSERT( tok->sd_invtok );
*bufpp = NULL;
*bufszp = 0;
fd = tok->sd_invtok->d_stobj_fd;
INVLOCK( fd, LOCK_SH );
/* Next we get the session header, and the session information. Then
we can figure out how much space to allocate */
if ( stobj_get_sessinfo( tok, &hdr, &ses ) <= 0 ) {
INVLOCK( fd, LOCK_UN );
return BOOL_FALSE;
}
rval = stobj_pack_sessinfo( fd, &ses, &hdr, bufpp, bufszp );
INVLOCK( fd, LOCK_UN );
return rval;
}
/*----------------------------------------------------------------------*/
/* inv_put_sessioninfo */
/* */
/* This is used in reconstructing an inventory from dumped media objects*/
/* */
/* Most importantly, note that this is not in anyway an alternative to */
/* inv_open_writesession() - that is called while the dump is in progr- */
/* ess. This is really inv_put_dumpedsession(); We just didn't want to */
/* be *that* dump-specific :) */
/*----------------------------------------------------------------------*/
bool_t
inv_put_sessioninfo( invt_sessinfo_t *s )
{
static bool_t invdir_ok = BOOL_FALSE;
if ( !invdir_ok ) {
if ( make_invdirectory( INV_SEARCH_N_MOD ) < 0 )
return BOOL_FALSE;
else
invdir_ok = BOOL_TRUE;
}
return insert_session( s );
}
/*----------------------------------------------------------------------*/
/* inv_free_session */
/* */
/* free the inv_session structure allocated as a result of calls to */
/* inv_get_session_byuuid, etc. */
/*----------------------------------------------------------------------*/
void
inv_free_session(
inv_session_t **ses)
{
uint i;
ASSERT(ses);
ASSERT(*ses);
for ( i = 0; i < (*ses)->s_nstreams; i++ ) {
/* the array of mediafiles is contiguous */
free ((*ses)->s_streams[i].st_mediafiles);
}
/* all streams are contiguous too */
free ((*ses)->s_streams);
free (*ses);
*ses = NULL;
}
/*----------------------------------------------------------------------*/
/* inventory_lasttime_level_lessthan */
/* */
/* Given a token that refers to a file system, and a level, this returns*/
/* the last time when a session of a lesser level was done. */
/* */
/* returns -1 on error. */
/*----------------------------------------------------------------------*/
bool_t
inv_lasttime_level_lessthan(
inv_idbtoken_t tok,
u_char level,
time32_t **tm )
{
int rval;
if ( tok != INV_TOKEN_NULL ) {
rval = search_invt( tok->d_invindex_fd, &level, (void **) tm,
(search_callback_t) tm_level_lessthan );
return ( rval < 0) ? BOOL_FALSE: BOOL_TRUE;
}
return invmgr_query_all_sessions((void *) &level, /* in */
(void **) tm, /* out */
(search_callback_t) tm_level_lessthan);
}
/*----------------------------------------------------------------------*/
/* */
/* */
/* */
/*----------------------------------------------------------------------*/
bool_t
inv_lastsession_level_lessthan(
inv_idbtoken_t tok,
u_char level,
inv_session_t **ses )
{
int rval;
if ( tok != INV_TOKEN_NULL ) {
rval = search_invt( tok->d_invindex_fd, &level, (void **) ses,
(search_callback_t) lastsess_level_lessthan );
return ( rval < 0) ? BOOL_FALSE: BOOL_TRUE;
}
return invmgr_query_all_sessions((void *) &level, /* in */
(void **) ses, /* out */
(search_callback_t) lastsess_level_lessthan);
}
/*----------------------------------------------------------------------*/
/* */
/* */
/* Return FALSE on an error, TRUE if not. If (*ses) is NULL, then the */
/* search failed. */
/*----------------------------------------------------------------------*/
bool_t
inv_lastsession_level_equalto(
inv_idbtoken_t tok,
u_char level,
inv_session_t **ses )
{
int rval;
if ( tok != INV_TOKEN_NULL ) {
rval = search_invt( tok->d_invindex_fd, &level, (void **) ses,
(search_callback_t) lastsess_level_equalto );
return ( rval < 0) ? BOOL_FALSE: BOOL_TRUE;
}
return invmgr_query_all_sessions((void *) &level, /* in */
(void **) ses, /* out */
(search_callback_t) lastsess_level_equalto);
}
/*----------------------------------------------------------------------*/
/* inv_getsession_byuuid */
/* */
/*----------------------------------------------------------------------*/
bool_t
inv_get_session_byuuid(
uuid_t *sesid,
inv_session_t **ses)
{
return (invmgr_query_all_sessions((void *)sesid, /* in */
(void **) ses, /* out */
(search_callback_t) stobj_getsession_byuuid));
}
/*----------------------------------------------------------------------*/
/* inv_getsession_byuuid */
/* */
/*----------------------------------------------------------------------*/
bool_t
inv_get_session_bylabel(
char *session_label,
inv_session_t **ses)
{
return (invmgr_query_all_sessions((void *)session_label, /* in */
(void **) ses, /* out */
(search_callback_t) stobj_getsession_bylabel));
}
/*----------------------------------------------------------------------*/
/* inv_delete_mediaobj */
/* */
/* We delete all the media files that are stored in the given mobj, and */
/* delete them one by one. We delete the session information only when */
/* all its mediafiles are deleted. This is because a single session can */
/* be striped across multiple mediaobjects. */
/*----------------------------------------------------------------------*/
bool_t
inv_delete_mediaobj( uuid_t *moid )
{
inv_oflag_t forwhat = INV_SEARCH_N_MOD;
/* forall fsids (fs) in fstab {
open invindex table (t)
forall indices (i) in t {
open stobj (st)
forall sessions (s) in st {
forall streams (strm) in s {
forall mediafiles (m) in strm {
if (m.mediaobj == moid) {
// delete m
if ( --strm.nmediafiles == 0 )
if ( --s.nstreams == 0 )
delete-session (s)
}
}
}
}
}
*/
invt_counter_t *cnt;
invt_fstab_t *arr;
int numfs, i, fd, invfd;
char fname[INV_STRLEN];
fd = fstab_getall( &arr, &cnt, &numfs, forwhat );
if ( fd < 0 || numfs <= 0 ) {
mlog( MLOG_NORMAL | MLOG_INV, _("INV: Error in fstab\n") );
return BOOL_FALSE;
}
close( fd );
for ( i = 0; i < numfs; i++) {
if ( fstab_get_fname( &arr[i].ft_uuid,
fname,
(inv_predicate_t)INV_BY_UUID,
forwhat
)
< 0 ) {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: Cant get inv-name for uuid\n") );
return BOOL_FALSE;
}
strcat( fname, INV_INVINDEX_PREFIX );
invfd = open( fname, INV_OFLAG(forwhat));
if ( invfd < 0 ) {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: Open failed on %s\n"),
fname );
return BOOL_FALSE;
}
if ( search_invt( invfd, NULL, (void **)&moid,
(search_callback_t) stobj_delete_mobj )
< 0 )
return BOOL_FALSE;
/* we have to delete the session, etc */
close( invfd );
}
return BOOL_TRUE;
}
#define I_IFOUND 0x01
#define I_IDONE 0x02
#define I_IERR 0x04
static const char *myopts[] = {
#define OPT_MNT 0
"mnt",
#define OPT_FSID 1
"fsid",
#define OPT_DEV 2
"dev",
#define OPT_DEPTH 3
"depth",
#define OPT_MOBJID 4
"mobjid",
#define OPT_MOBJLABEL 5
"mobjlabel",
#define OPT_FSTAB 6
"fstab",
#define OPT_INVIDX 7
"invidx",
#define OPT_INVCHECK 8
"check",
#define OPT_INVLEVEL 9
"level",
NULL
};
intgen_t
inv_getopt(int argc, char **argv, invt_pr_ctx_t *prctx)
{
intgen_t rval = 0;
void *fs = 0;
char *options, *value;
extern char *optarg;
extern int optind, opterr;
inv_predicate_t bywhat = -1;
int c, d;
uuid_t fsid;
int npreds = 0;
int npreds2 = 0;
char invoptstring[128], *rptr, *wptr;
optind = 1;
opterr = 0;
/*
* getopt doesn't handle both '-I' and '-I w/subopts' so...
* First set I_IFOUND if -I is set at all (with or without
* any suboptions). Do this by taking out the ':' so getopt
* accepts it. Later, reset opts and go through again to
* pick off any subopts.
*/
strcpy(invoptstring, GETOPT_CMDSTRING);
wptr = strchr(invoptstring, 'I');
if (wptr != NULL) {
wptr++;
rptr = wptr + 1;
while (*wptr != '\0')
*wptr++ = *rptr++;
while ( ( c = getopt( argc, argv, invoptstring)) != EOF ) {
switch ( c ) {
case GETOPT_INVPRINT:
prctx->depth = 0;
rval |= I_IFOUND ;
break;
}
}
optind = 1;
opterr = 0;
optarg = NULL;
}
while ( ( c = getopt( argc, argv, GETOPT_CMDSTRING )) != EOF ) {
switch ( c ) {
case GETOPT_INVPRINT:
rval |= I_IFOUND ;
if ((options = optarg) == NULL)
break;
while (*options != '\0') {
d = getsubopt(&options,(constpp)myopts,&value);
if (value == NULL && d != OPT_FSTAB &&
d != OPT_INVIDX && d != OPT_INVCHECK)
continue;
switch( d ) {
/* process mntpt option */
case OPT_MNT:
bywhat = (inv_predicate_t) INV_BY_MOUNTPT;
fs = value;
npreds++;
break;
/* process fsid option */
case OPT_FSID:
bywhat = (inv_predicate_t) INV_BY_UUID;
npreds++;
uuid_parse(value, fsid);
fs = fsid;
break;
case OPT_DEV: /* process dev option */
bywhat = (inv_predicate_t) INV_BY_DEVPATH;
fs = value;
npreds++;
break;
case OPT_DEPTH:
prctx->depth = atoi(value);
if (prctx->depth < 0 ||
prctx->depth > 4 )
prctx->depth = 0;
break;
case OPT_MOBJID:
{
uuid_t *u;
u = malloc ( sizeof( uuid_t ) );
uuid_parse(value, *u);
prctx->mobj.type = INVT_MOID;
prctx->mobj.value = (void *)u;
}
npreds2++;
break;
case OPT_MOBJLABEL:
prctx->mobj.type = INVT_LABEL;
prctx->mobj.value = (void *)value;
npreds2++;
break;
case OPT_FSTAB:
prctx->fstab = BOOL_TRUE;
break;
case OPT_INVIDX:
prctx->invidx = BOOL_TRUE;
break;
case OPT_INVCHECK:
prctx->invcheck = BOOL_TRUE;
break;
case OPT_INVLEVEL:
prctx->level = atoi(value);
break;
default:
if ( strlen(value) == 1 &&
atoi(value) < PR_MAXDEPTH )
prctx->depth = atoi(value);
else {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: invalid sub-option %s"
" for -I option\n"), value );
rval |= I_IERR;
}
break;
}
}
break; /* case GETOPT_INVPRINT */
}
}
if (npreds > 1) {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: Only one of mnt=,dev= and fsid=value can be used.\n")
);
rval |= I_IERR;
}
else if (npreds2 > 1) {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: Only one of mobjid= and mobjlabel= can be used.\n")
);
rval |= I_IERR;
}
else if ( (rval & I_IFOUND) && !(rval & I_IERR) && fs
&& ! prctx->fstab && ! prctx->invcheck) {
inv_idbtoken_t tok;
/* A filesystem could be backed up, mkfs'ed then restored
* to a new UUID value. Therefore, we can't simply stop
* when we find the first matching mount point (pv564234).
* This code loops through all filesystems and does the
* comparison by hand. */
if (bywhat == INV_BY_MOUNTPT) {
int fd, numfs, i;
invt_fstab_t *arr = NULL;
invt_counter_t *cnt = NULL;
inv_oflag_t forwhat = INV_SEARCH_ONLY;
fd = fstab_getall( &arr, &cnt, &numfs, forwhat );
free( cnt );
rval |= I_IERR; /* Cleared if successful */
if ( fd >= 0 ) {
for ( i = 0; i < numfs; i++ ) {
tok = inv_open(
(inv_predicate_t )INV_BY_UUID,
INV_SEARCH_ONLY,
&arr[i].ft_uuid );
if ( tok == INV_TOKEN_NULL )
break;
if ( STREQL( arr[i].ft_mountpt, fs) ) {
prctx->index = i;
invmgr_inv_print(
tok->d_invindex_fd,
prctx );
rval &= ~(I_IERR);
}
inv_close( tok );
}
free ( arr );
rval |= I_IDONE;
}
if ( (rval&I_IERR) ) {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: open failed on mount point \"%s\"\n"),
fs);
}
return rval;
}
/* We have to print only one file system to print by UUID */
tok = inv_open( bywhat, INV_SEARCH_ONLY, fs);
if ( tok != INV_TOKEN_NULL ) {
prctx->index = 0;
invmgr_inv_print(tok->d_invindex_fd, prctx);
inv_close( tok );
rval |= I_IDONE;
} else {
mlog( MLOG_NORMAL | MLOG_INV, _(
"INV: open failed on file system id \"%s\"\n"),
fs);
rval |= I_IERR;
}
}
return rval;
}
/* This prints out all the sessions of a filesystem that are in the inventory */
bool_t
inv_DEBUG_print( int argc, char **argv )
{
invt_counter_t *cnt = NULL;
invt_fstab_t *arr = NULL;
int fd, numfs, i;
inv_idbtoken_t tok;
int rval;
invt_pr_ctx_t prctx;
inv_oflag_t forwhat = INV_SEARCH_ONLY;
prctx.mobj.type = INVT_NULLTYPE;
prctx.fstab = prctx.invidx = prctx.invcheck = BOOL_FALSE;
prctx.level = PR_MAXLEVEL;
/* If user didnt indicate -i option, we can't do anything */
rval = inv_getopt( argc, argv, &prctx );
if (!prctx.invcheck && ! prctx.fstab) {
if (! (rval & I_IFOUND)) {
return BOOL_TRUE;
} else if ( rval & I_IERR || rval & I_IDONE ) {
return BOOL_FALSE;
}
}
fd = fstab_getall( &arr, &cnt, &numfs, forwhat );
free( cnt );
if ( fd >= 0 ) {
if (prctx.fstab) {
fstab_DEBUG_print( arr, numfs );
if (! prctx.invidx)
return BOOL_FALSE;
}
for ( i = 0; i < numfs; i++ ) {
tok = inv_open( ( inv_predicate_t )INV_BY_UUID,
forwhat,
&arr[i].ft_uuid );
if ( tok == INV_TOKEN_NULL ) {
free ( arr );
return BOOL_FALSE;
}
if (prctx.invcheck) {
mlog( MLOG_VERBOSE | MLOG_INV, _(
"INV: checking fs \"%s\"\n"),
&arr[i].ft_mountpt
);
invmgr_inv_check(tok->d_invindex_fd);
}
else {
prctx.index = i;
invmgr_inv_print( tok->d_invindex_fd,
&prctx );
}
inv_close( tok );
}
}
return BOOL_FALSE;
}
#undef I_IFOUND
#undef I_IDONE
#undef I_IERR
![[BACK]](/icons/back.gif){kind=icon}
Return to inv_api.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [Development] / xfs-cmds / xfsdump / inventory