/*
 * 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