@@ -49,67 +49,67 @@
/* storage object whether or not it has reached its maximum. */
/*----------------------------------------------------------------------*/
int
-stobj_insert_session( invt_idxinfo_t *idx,
+stobj_insert_session(invt_idxinfo_t *idx,
int fd, /* kept locked EX by caller */
- invt_sessinfo_t *s )
+ invt_sessinfo_t *s)
{
invt_sescounter_t *sescnt = NULL;
- if ( GET_SESCOUNTERS( fd, &sescnt ) < 0 ) {
- INVLOCK( fd, LOCK_UN );
+ if (GET_SESCOUNTERS(fd, &sescnt) < 0) {
+ INVLOCK(fd, LOCK_UN);
return -1;
}
/* Check the existing sessions to make sure that we're not
duplicating this session */
- if ( sescnt->ic_curnum > 0 ) {
+ if (sescnt->ic_curnum > 0) {
uint i;
- invt_session_t *sessions = calloc( sescnt->ic_curnum,
- sizeof( invt_session_t ) );
- if ( GET_REC_NOLOCK( fd, sessions, sescnt->ic_curnum *
- sizeof( invt_session_t ),
- (off64_t) ( sizeof( *sescnt ) +
- sescnt->ic_maxnum * sizeof( invt_seshdr_t ))) < 0 ) {
- free ( sescnt );
- free ( sessions );
+ invt_session_t *sessions = calloc(sescnt->ic_curnum,
+ sizeof(invt_session_t));
+ if (GET_REC_NOLOCK(fd, sessions, sescnt->ic_curnum *
+ sizeof(invt_session_t),
+ (off64_t) (sizeof(*sescnt) +
+ sescnt->ic_maxnum * sizeof(invt_seshdr_t))) < 0) {
+ free (sescnt);
+ free (sessions);
return -1;
}
- for( i = 0; i < sescnt->ic_curnum; i++ ) {
- if ( uuid_compare( sessions[i].s_sesid,
- s->ses->s_sesid ) == 0 )
+ for(i = 0; i < sescnt->ic_curnum; i++) {
+ if (uuid_compare(sessions[i].s_sesid,
+ s->ses->s_sesid) == 0)
break;
}
- free ( sessions );
- if ( i < sescnt->ic_curnum ) {
- mlog( MLOG_DEBUG | MLOG_INV,
+ free (sessions);
+ if (i < sescnt->ic_curnum) {
+ mlog(MLOG_DEBUG | MLOG_INV,
"INV: attempt to insert an "
"existing session.\n"
);
- free ( sescnt );
+ free (sescnt);
return 1;
}
}
- if ( sescnt->ic_curnum >= sescnt->ic_maxnum ) {
- if ( stobj_split( idx, fd, sescnt, s ) < 0 ) {
- free( sescnt );
+ if (sescnt->ic_curnum >= sescnt->ic_maxnum) {
+ if (stobj_split(idx, fd, sescnt, s) < 0) {
+ free(sescnt);
return -1;
}
- free( sescnt );
+ free(sescnt);
return 1;
}
- if ( stobj_put_session( fd, sescnt, s->ses, s->seshdr, s->strms,
- s->mfiles ) < 0 ){
- free ( sescnt);
+ if (stobj_put_session(fd, sescnt, s->ses, s->seshdr, s->strms,
+ s->mfiles) < 0){
+ free (sescnt);
return -1;
}
- free ( sescnt);
+ free (sescnt);
return 1;
}
@@ -125,16 +125,16 @@ stobj_insert_session( invt_idxinfo_t *idx,
/* ARGSUSED */
uint
-stobj_find_splitpoint( int fd, invt_seshdr_t *harr, uint ns, time32_t tm )
+stobj_find_splitpoint(int fd, invt_seshdr_t *harr, uint ns, time32_t tm)
{
uint i;
- if ( harr[ns-1].sh_time < tm )
+ if (harr[ns-1].sh_time < tm)
return ns;
/* since ns > 1, our split point > 0 */
- for ( i = ns - 1; i > 0; i-- ) {
+ for (i = ns - 1; i > 0; i--) {
/* these are ordered in ascending order */
- if ( harr[i].sh_time > harr[i-1].sh_time )
+ if (harr[i].sh_time > harr[i-1].sh_time)
return i;
}
@@ -143,7 +143,7 @@ stobj_find_splitpoint( int fd, invt_seshdr_t *harr, uint ns, time32_t tm )
really possible, but either way, we split at the last entry.
This will impact the guarantee that invindex tries to give - that
there's always a unique stobj for every session. */
- mlog( MLOG_VERBOSE | MLOG_INV, _(
+ mlog(MLOG_VERBOSE | MLOG_INV, _(
"INV: failed to find a different sh_time to split\n")
);
@@ -162,8 +162,8 @@ stobj_find_splitpoint( int fd, invt_seshdr_t *harr, uint ns, time32_t tm )
/*----------------------------------------------------------------------*/
int
-stobj_split( invt_idxinfo_t *idx, int fd, invt_sescounter_t *sescnt,
- invt_sessinfo_t *newsess )
+stobj_split(invt_idxinfo_t *idx, int fd, invt_sescounter_t *sescnt,
+ invt_sessinfo_t *newsess)
{
invt_seshdr_t *harr = NULL;
uint i, ix, ns = sescnt->ic_curnum;
@@ -172,22 +172,22 @@ stobj_split( invt_idxinfo_t *idx, int fd, invt_sescounter_t *sescnt,
invt_sessinfo_t sesinfo;
invt_entry_t ient;
- if ( GET_SESHEADERS( fd, &harr, ns ) < 0 )
+ if (GET_SESHEADERS(fd, &harr, ns) < 0)
return -1;
- assert( harr != NULL );
+ assert(harr != NULL);
- if ( ( ix = stobj_find_splitpoint( fd, harr, ns,
- newsess->seshdr->sh_time ) ) == 0 )
+ if ((ix = stobj_find_splitpoint(fd, harr, ns,
+ newsess->seshdr->sh_time)) == 0)
return -1;
- if ( ix == ns ) {
+ if (ix == ns) {
ient.ie_timeperiod.tp_start = ient.ie_timeperiod.tp_end =
newsess->seshdr->sh_time;
} else {
ient.ie_timeperiod.tp_start = ient.ie_timeperiod.tp_end =
harr[ix].sh_time;
- if ( harr[ix - 1].sh_time > newsess->seshdr->sh_time )
+ if (harr[ix - 1].sh_time > newsess->seshdr->sh_time)
idx->iarr[idx->index].ie_timeperiod.tp_end
= harr[ix - 1].sh_time;
else
@@ -198,11 +198,11 @@ stobj_split( invt_idxinfo_t *idx, int fd, invt_sescounter_t *sescnt,
/* Get the new stobj to put the 'spilling' sessinfo in. We know the
idx of the current stobj, and by definition, the new stobj
should come right afterwards. */
- newsess->stobjfd = idx_put_newentry( idx, &ient );
- if ( newsess->stobjfd < 0 )
+ newsess->stobjfd = idx_put_newentry(idx, &ient);
+ if (newsess->stobjfd < 0)
return -1;
- if ( ix == ns ) {
+ if (ix == ns) {
invt_sescounter_t *scnt = NULL;
off64_t rval;
@@ -210,55 +210,55 @@ stobj_split( invt_idxinfo_t *idx, int fd, invt_sescounter_t *sescnt,
the new stobj, and rest in peace */
idx->index++;
- if ( GET_SESCOUNTERS( newsess->stobjfd, &scnt ) < 0 )
+ if (GET_SESCOUNTERS(newsess->stobjfd, &scnt) < 0)
return -1;
- rval = stobj_put_session( newsess->stobjfd, scnt,
+ rval = stobj_put_session(newsess->stobjfd, scnt,
newsess->ses,
newsess->seshdr, newsess->strms,
- newsess->mfiles );
- free( scnt );
+ newsess->mfiles);
+ free(scnt);
return (rval < 0)? -1: 1;
}
- for ( i = ix; i < ns; i++ ) {
+ for (i = ix; i < ns; i++) {
invt_session_t session;
bufpp = NULL;
bufszp = 0;
newsess->seshdr->sh_sess_off = harr[i].sh_sess_off;
- if ( GET_REC_NOLOCK( fd, &session, sizeof( invt_session_t ),
- harr[i].sh_sess_off ) < 0 )
+ if (GET_REC_NOLOCK(fd, &session, sizeof(invt_session_t),
+ harr[i].sh_sess_off) < 0)
return -1;
- if (! stobj_pack_sessinfo( fd, &session, &harr[i], &bufpp,
- &bufszp ))
+ if (! stobj_pack_sessinfo(fd, &session, &harr[i], &bufpp,
+ &bufszp))
return -1;
/* Now we need to put this in the new StObj. So, first
unpack it. */
- if (! stobj_unpack_sessinfo( bufpp, bufszp, &sesinfo ) )
+ if (! stobj_unpack_sessinfo(bufpp, bufszp, &sesinfo))
return -1;
/* There is no chance of a recursion here */
- if ( stobj_insert_session( idx, newsess->stobjfd, &sesinfo )
- < 0 )
+ if (stobj_insert_session(idx, newsess->stobjfd, &sesinfo)
+ < 0)
return -1;
/* Now delete that session from this StObj */
- if (! stobj_delete_sessinfo( fd, sescnt, &session,
- &harr[i] ) )
+ if (! stobj_delete_sessinfo(fd, sescnt, &session,
+ &harr[i]))
return -1;
- free( bufpp );
+ free(bufpp);
}
/* Put the new session in the stobj that we just split. Make
sure that we use the updated sescnt and not the stale stuff
from disk. stobj_put_session() writes sescnt and sessinfo to
disk */
- if ( stobj_put_session( fd, sescnt, newsess->ses, newsess->seshdr,
- newsess->strms, newsess->mfiles ) < 0 ) {
- free ( sescnt);
+ if (stobj_put_session(fd, sescnt, newsess->ses, newsess->seshdr,
+ newsess->strms, newsess->mfiles) < 0) {
+ free (sescnt);
return -1;
}
@@ -271,8 +271,8 @@ stobj_split( invt_idxinfo_t *idx, int fd, invt_sescounter_t *sescnt,
/* ARGSUSED */
int
-stobj_delete_mfile( int fd, inv_stream_t *strm, invt_mediafile_t *mf,
- off64_t mfileoff )
+stobj_delete_mfile(int fd, inv_stream_t *strm, invt_mediafile_t *mf,
+ off64_t mfileoff)
{
return 1;
@@ -284,9 +284,9 @@ stobj_delete_mfile( int fd, inv_stream_t *strm, invt_mediafile_t *mf,
/* ARGSUSED */
bool_t
-stobj_delete_sessinfo( int fd, /* kept locked EX by caller */
+stobj_delete_sessinfo(int fd, /* kept locked EX by caller */
invt_sescounter_t *sescnt,
- invt_session_t *ses, invt_seshdr_t *hdr )
+ invt_session_t *ses, invt_seshdr_t *hdr)
{
/* we change the sescnt here, but dont write it back to disk
until later */
@@ -314,65 +314,65 @@ stobj_put_session(
invt_session_t *ses,
invt_seshdr_t *hdr,
invt_stream_t *strms,
- invt_mediafile_t *mfiles )
+ invt_mediafile_t *mfiles)
{
off64_t hoff;
/* figure out the place where the header will go */
- hoff = STOBJ_OFFSET( sescnt->ic_curnum, 0 );
+ hoff = STOBJ_OFFSET(sescnt->ic_curnum, 0);
/* figure out where the session information is going to go. */
- if ( hdr->sh_sess_off < 0 )
- hdr->sh_sess_off = STOBJ_OFFSET( sescnt->ic_maxnum,
- sescnt->ic_curnum );
+ if (hdr->sh_sess_off < 0)
+ hdr->sh_sess_off = STOBJ_OFFSET(sescnt->ic_maxnum,
+ sescnt->ic_curnum);
sescnt->ic_curnum++;
#ifdef INVT_DEBUG
- mlog ( MLOG_VERBOSE,
+ mlog (MLOG_VERBOSE,
"INV: create sess #%d @ offset %d ic_eof = %d\n",
sescnt->ic_curnum, (int) hdr->sh_sess_off,
- (int) sescnt->ic_eof );
+ (int) sescnt->ic_eof);
#endif
/* we need to know where the streams begin, and where the
media files will begin, at the end of the streams */
hdr->sh_streams_off = sescnt->ic_eof;
- if ( strms == NULL ) {
- sescnt->ic_eof += (off64_t)( ses->s_max_nstreams *
- sizeof( invt_stream_t ) );
+ if (strms == NULL) {
+ sescnt->ic_eof += (off64_t)(ses->s_max_nstreams *
+ sizeof(invt_stream_t));
} else {
uint i;
size_t nmf = 0;
- sescnt->ic_eof += (off64_t)( ses->s_cur_nstreams *
- sizeof( invt_stream_t ) );
+ sescnt->ic_eof += (off64_t)(ses->s_cur_nstreams *
+ sizeof(invt_stream_t));
for (i=0; i<ses->s_cur_nstreams; i++)
- nmf += ( size_t ) strms[i].st_nmediafiles;
+ nmf += (size_t) strms[i].st_nmediafiles;
- sescnt->ic_eof += (off64_t)( sizeof( invt_mediafile_t )
- * nmf );
- if ( stobj_put_streams( fd, hdr, ses, strms, mfiles ) < 0 )
+ sescnt->ic_eof += (off64_t)(sizeof(invt_mediafile_t)
+ * nmf);
+ if (stobj_put_streams(fd, hdr, ses, strms, mfiles) < 0)
return -1;
}
/* we write back the counters of this storage object first */
- if ( PUT_SESCOUNTERS( fd, sescnt ) < 0 )
+ if (PUT_SESCOUNTERS(fd, sescnt) < 0)
return -1;
/* write the header next; lseek to the right position */
- if ( PUT_REC_NOLOCK( fd, hdr, sizeof( invt_seshdr_t ), hoff ) < 0 ) {
+ if (PUT_REC_NOLOCK(fd, hdr, sizeof(invt_seshdr_t), hoff) < 0) {
return -1;
}
/* write the header information to the storage object */
- if ( PUT_REC_NOLOCK( fd, ses, sizeof( invt_session_t ),
- hdr->sh_sess_off ) < 0 ) {
+ if (PUT_REC_NOLOCK(fd, ses, sizeof(invt_session_t),
+ hdr->sh_sess_off) < 0) {
return -1;
}
- if ( strms != NULL )
- stobj_sortheaders( fd, sescnt->ic_curnum );
+ if (strms != NULL)
+ stobj_sortheaders(fd, sescnt->ic_curnum);
return hoff;
}
@@ -387,41 +387,41 @@ stobj_put_session(
/*----------------------------------------------------------------------*/
int
-stobj_sortheaders( int fd, uint num )
+stobj_sortheaders(int fd, uint num)
{
- size_t sz = sizeof( invt_seshdr_t ) * num;
+ size_t sz = sizeof(invt_seshdr_t) * num;
invt_seshdr_t *hdrs;
#ifdef INVT_DEBUG
int i;
#endif
- if ( num < 2 ) return 1;
+ if (num < 2) return 1;
- hdrs = malloc( sz );
- assert( hdrs );
+ hdrs = malloc(sz);
+ assert(hdrs);
- if ( GET_REC_NOLOCK( fd, hdrs, sz, STOBJ_OFFSET( 0, 0 ) ) < 0 ) {
- free ( hdrs );
+ if (GET_REC_NOLOCK(fd, hdrs, sz, STOBJ_OFFSET(0, 0)) < 0) {
+ free (hdrs);
return -1;
}
#ifdef INVT_DEBUG
- printf("\nBEF\n" );
+ printf("\nBEF\n");
for (i=0; i<(int)num; i++)
- printf("%ld\n", (long) hdrs[i].sh_time );
+ printf("%ld\n", (long) hdrs[i].sh_time);
#endif
- qsort( (void*) hdrs, (size_t) num,
- sizeof( invt_seshdr_t ), stobj_hdrcmp );
+ qsort((void*) hdrs, (size_t) num,
+ sizeof(invt_seshdr_t), stobj_hdrcmp);
#ifdef INVT_DEBUG
- printf("\n\nAFT\n" );
+ printf("\n\nAFT\n");
for (i=0; i<(int)num; i++)
- printf("%ld\n", (long) hdrs[i].sh_time );
+ printf("%ld\n", (long) hdrs[i].sh_time);
#endif
- if ( PUT_REC_NOLOCK( fd, hdrs, sz, STOBJ_OFFSET( 0, 0 ) ) < 0 ) {
- free ( hdrs );
+ if (PUT_REC_NOLOCK(fd, hdrs, sz, STOBJ_OFFSET(0, 0)) < 0) {
+ free (hdrs);
return -1;
}
- free ( hdrs );
+ free (hdrs);
return 1;
}
@@ -437,51 +437,51 @@ stobj_sortheaders( int fd, uint num )
/*----------------------------------------------------------------------*/
int
-stobj_put_streams( int fd, invt_seshdr_t *hdr, invt_session_t *ses,
+stobj_put_streams(int fd, invt_seshdr_t *hdr, invt_session_t *ses,
invt_stream_t *strms,
- invt_mediafile_t *mfiles )
+ invt_mediafile_t *mfiles)
{
uint nstm = ses->s_cur_nstreams;
off64_t off = hdr->sh_streams_off;
- off64_t mfileoff = off + (off64_t)( nstm * sizeof( invt_stream_t ) );
+ off64_t mfileoff = off + (off64_t)(nstm * sizeof(invt_stream_t));
uint nmfiles = 0;
uint i,j;
/* fix the offsets in streams */
- for ( i = 0; i < nstm; i++ ) {
+ for (i = 0; i < nstm; i++) {
strms[i].st_firstmfile = mfileoff +
- (off64_t) ((size_t) nmfiles * sizeof( invt_mediafile_t ) );
+ (off64_t) ((size_t) nmfiles * sizeof(invt_mediafile_t));
/* now fix the offsets in mediafiles */
- for ( j = 0; j < strms[i].st_nmediafiles; j++ ) {
+ for (j = 0; j < strms[i].st_nmediafiles; j++) {
/* no need to fix the last element's next ptr */
- if ( j < strms[i].st_nmediafiles - 1 )
- mfiles[ nmfiles + j ].mf_nextmf =
+ if (j < strms[i].st_nmediafiles - 1)
+ mfiles[nmfiles + j].mf_nextmf =
strms[i].st_firstmfile +
- (off64_t) ((j+1) * sizeof( invt_mediafile_t ));
+ (off64_t) ((j+1) * sizeof(invt_mediafile_t));
/* no need to fix the first element's prev ptr */
- if ( j )
- mfiles[ nmfiles + j ].mf_prevmf =
+ if (j)
+ mfiles[nmfiles + j].mf_prevmf =
strms[i].st_firstmfile +
- (off64_t) ((j-1) * sizeof( invt_mediafile_t ));
+ (off64_t) ((j-1) * sizeof(invt_mediafile_t));
}
/* adjust the offsets of the first and the last elements
in the mediafile chain */
- mfiles[ nmfiles ].mf_prevmf = 0;
+ mfiles[nmfiles].mf_prevmf = 0;
nmfiles += strms[i].st_nmediafiles;
- mfiles[ nmfiles - 1 ].mf_nextmf = 0;
+ mfiles[nmfiles - 1].mf_nextmf = 0;
}
/* first put the streams. hdr already points at the right place */
- if ( PUT_REC_NOLOCK( fd, strms, nstm * sizeof( invt_stream_t ),
- off ) < 0 )
+ if (PUT_REC_NOLOCK(fd, strms, nstm * sizeof(invt_stream_t),
+ off) < 0)
return -1;
- if ( PUT_REC_NOLOCK( fd, mfiles, nmfiles * sizeof( invt_mediafile_t ),
- mfileoff ) < 0 )
+ if (PUT_REC_NOLOCK(fd, mfiles, nmfiles * sizeof(invt_mediafile_t),
+ mfileoff) < 0)
return -1;
return 1;
@@ -498,21 +498,21 @@ stobj_put_streams( int fd, invt_seshdr_t *hdr, invt_session_t *ses,
/*----------------------------------------------------------------------*/
void
-stobj_makefname( char *fname )
+stobj_makefname(char *fname)
{
/* come up with a new unique name */
uuid_t fn;
char str[UUID_STR_LEN + 1];
- uuid_generate( fn );
- uuid_unparse( fn, str );
+ uuid_generate(fn);
+ uuid_unparse(fn, str);
- strcpy( fname, INV_DIRPATH );
- strcat( fname, "/" );
- strcat( fname, str );
- strcat( fname, INV_STOBJ_PREFIX );
+ strcpy(fname, INV_DIRPATH);
+ strcat(fname, "/");
+ strcat(fname, str);
+ strcat(fname, INV_STOBJ_PREFIX);
- assert( (int) strlen( fname ) < INV_STRLEN );
+ assert((int) strlen(fname) < INV_STRLEN);
}
@@ -523,39 +523,39 @@ stobj_makefname( char *fname )
/* NOTE: this doesnt update counters or headers in the inv_index */
int
-stobj_create( char *fname )
+stobj_create(char *fname)
{
int fd;
invt_sescounter_t sescnt;
inv_oflag_t forwhat = INV_SEARCH_N_MOD;
#ifdef INVT_DEBUG
- mlog( MLOG_VERBOSE | MLOG_INV, "INV: creating storage obj %s\n", fname);
+ mlog(MLOG_VERBOSE | MLOG_INV, "INV: creating storage obj %s\n", fname);
#endif
/* create the new storage object */
- if (( fd = open( fname, INV_OFLAG(forwhat) | O_EXCL | O_CREAT, S_IRUSR|S_IWUSR )) < 0 ) {
- INV_PERROR ( fname );
- memset( fname, 0, INV_STRLEN );
+ if ((fd = open(fname, INV_OFLAG(forwhat) | O_EXCL | O_CREAT, S_IRUSR|S_IWUSR)) < 0) {
+ INV_PERROR (fname);
+ memset(fname, 0, INV_STRLEN);
return -1;
}
- INVLOCK( fd, LOCK_EX );
- fchmod( fd, INV_PERMS );
+ INVLOCK(fd, LOCK_EX);
+ fchmod(fd, INV_PERMS);
sescnt.ic_vernum = INV_VERSION;
sescnt.ic_curnum = 0; /* there are no sessions as yet */
sescnt.ic_maxnum = INVT_STOBJ_MAXSESSIONS;
sescnt.ic_eof = SC_EOF_INITIAL_POS;
- if ( PUT_SESCOUNTERS ( fd, &sescnt ) < 0 ) {
- memset( fname, 0, INV_STRLEN );
- INVLOCK( fd, LOCK_UN );
- close( fd );
+ if (PUT_SESCOUNTERS (fd, &sescnt) < 0) {
+ memset(fname, 0, INV_STRLEN);
+ INVLOCK(fd, LOCK_UN);
+ close(fd);
return -1;
}
- INVLOCK( fd, LOCK_UN );
+ INVLOCK(fd, LOCK_UN);
return fd;
}
@@ -574,16 +574,16 @@ stobj_create_session(
int fd, /* kept locked EX by caller */
invt_sescounter_t *sescnt,
invt_session_t *ses,
- invt_seshdr_t *hdr )
+ invt_seshdr_t *hdr)
{
off64_t hoff;
- assert( tok && sescnt && ses && hdr );
+ assert(tok && sescnt && ses && hdr);
hdr->sh_sess_off = -1;
ses->s_cur_nstreams = 0;
- if ((hoff = stobj_put_session( fd, sescnt, ses, hdr, NULL, NULL ))
+ if ((hoff = stobj_put_session(fd, sescnt, ses, hdr, NULL, NULL))
< 0) {
return -1;
}
@@ -603,7 +603,7 @@ stobj_create_session(
/*----------------------------------------------------------------------*/
int
-stobj_put_mediafile( inv_stmtoken_t tok, invt_mediafile_t *mf )
+stobj_put_mediafile(inv_stmtoken_t tok, invt_mediafile_t *mf)
{
int rval;
invt_sescounter_t *sescnt = NULL;
@@ -615,31 +615,31 @@ stobj_put_mediafile( inv_stmtoken_t tok, invt_mediafile_t *mf )
/* first we need to find out where the current write-position is.
so, we first read the sescounter that is at the top of this
storage object */
- if ( GET_SESCOUNTERS( fd, &sescnt ) < 0 )
+ if (GET_SESCOUNTERS(fd, &sescnt) < 0)
return -1;
pos = sescnt->ic_eof;
/* increment the pointer to give space for this media file */
- sescnt->ic_eof += (off64_t) sizeof( invt_mediafile_t );
+ sescnt->ic_eof += (off64_t) sizeof(invt_mediafile_t);
- if ( PUT_SESCOUNTERS( fd, sescnt ) < 0 )
+ if (PUT_SESCOUNTERS(fd, sescnt) < 0)
return -1;
/* get the stream information, and update number of mediafiles.
we also need to link the new mediafile into the linked-list of
media files of this stream */
- if ( GET_REC_NOLOCK( fd, &stream, sizeof( stream ),
- tok->md_stream_off ) < 0 )
+ if (GET_REC_NOLOCK(fd, &stream, sizeof(stream),
+ tok->md_stream_off) < 0)
return -1;
/* We need to update the last ino of this STREAM, which is now the
last ino of the new mediafile. If this is the first mediafile, we
have to update the startino as well. Note that ino is a <ino,off>
tuple */
- if ( ! ( mf->mf_flag & INVT_MFILE_INVDUMP )) {
- if ( stream.st_nmediafiles == 0 )
+ if (! (mf->mf_flag & INVT_MFILE_INVDUMP)) {
+ if (stream.st_nmediafiles == 0)
stream.st_startino = mf->mf_startino;
stream.st_endino = mf->mf_endino;
}
@@ -655,7 +655,7 @@ stobj_put_mediafile( inv_stmtoken_t tok, invt_mediafile_t *mf )
mf->mf_prevmf = stream.st_lastmfile;
- if ( tok->md_lastmfile )
+ if (tok->md_lastmfile)
tok->md_lastmfile->mf_nextmf = pos;
else {
stream.st_firstmfile = pos;
@@ -665,29 +665,29 @@ stobj_put_mediafile( inv_stmtoken_t tok, invt_mediafile_t *mf )
/* write the stream to disk */
- if ( PUT_REC_NOLOCK( fd, &stream, sizeof( stream ),
- tok->md_stream_off ) < 0 )
+ if (PUT_REC_NOLOCK(fd, &stream, sizeof(stream),
+ tok->md_stream_off) < 0)
return -1;
/* write the prev media file to disk too */
- if ( tok->md_lastmfile ) {
- rval = PUT_REC_NOLOCK( fd, tok->md_lastmfile,
- sizeof( invt_mediafile_t ),
- mf->mf_prevmf );
- free ( tok->md_lastmfile );
- if ( rval < 0 )
+ if (tok->md_lastmfile) {
+ rval = PUT_REC_NOLOCK(fd, tok->md_lastmfile,
+ sizeof(invt_mediafile_t),
+ mf->mf_prevmf);
+ free (tok->md_lastmfile);
+ if (rval < 0)
return -1;
}
- if ( ! ( mf->mf_flag & INVT_MFILE_INVDUMP )) {
+ if (! (mf->mf_flag & INVT_MFILE_INVDUMP)) {
tok->md_lastmfile = mf;
} else {
tok->md_lastmfile = NULL;
}
/* at last, write the new media file to disk */
- rval = PUT_REC_NOLOCK( fd, mf, sizeof( invt_mediafile_t ), pos );
- if ( rval < 0 ) {
+ rval = PUT_REC_NOLOCK(fd, mf, sizeof(invt_mediafile_t), pos);
+ if (rval < 0) {
return -1;
}
@@ -709,17 +709,17 @@ stobj_put_mediafile( inv_stmtoken_t tok, invt_mediafile_t *mf )
/*----------------------------------------------------------------------*/
int
-stobj_get_sessinfo ( inv_sestoken_t tok, invt_seshdr_t *hdr,
- invt_session_t *ses )
+stobj_get_sessinfo (inv_sestoken_t tok, invt_seshdr_t *hdr,
+ invt_session_t *ses)
{
int rval;
int fd = tok->sd_invtok->d_stobj_fd;
/* get the session header first */
- if ( ( rval = GET_REC_NOLOCK( fd, hdr, sizeof( invt_seshdr_t ),
- tok->sd_sesshdr_off ) ) > 0 ) {
- rval = GET_REC_NOLOCK( fd, ses, sizeof( invt_session_t ),
- tok->sd_session_off );
+ if ((rval = GET_REC_NOLOCK(fd, hdr, sizeof(invt_seshdr_t),
+ tok->sd_sesshdr_off)) > 0) {
+ rval = GET_REC_NOLOCK(fd, ses, sizeof(invt_session_t),
+ tok->sd_session_off);
}
return rval;
@@ -734,8 +734,8 @@ stobj_get_sessinfo ( inv_sestoken_t tok, invt_seshdr_t *hdr,
/*----------------------------------------------------------------------*/
bool_t
-stobj_pack_sessinfo( int fd, invt_session_t *ses, invt_seshdr_t *hdr,
- void **bufpp, size_t *bufszp )
+stobj_pack_sessinfo(int fd, invt_session_t *ses, invt_seshdr_t *hdr,
+ void **bufpp, size_t *bufszp)
{
size_t stmsz;
uint i, j;
@@ -745,38 +745,38 @@ stobj_pack_sessinfo( int fd, invt_session_t *ses, invt_seshdr_t *hdr,
off64_t off;
invt_mediafile_t mf;
- stmsz = sizeof( invt_stream_t ) * ses->s_cur_nstreams;
+ stmsz = sizeof(invt_stream_t) * ses->s_cur_nstreams;
/* the initial size without the mediafiles */
- sessz = strlen( INVTSESS_COOKIE ) * sizeof( char ) +
- sizeof( inv_version_t ) +
- sizeof( inv_version_t ) + /* added to fix 64 bit alignment prob */
- sizeof( invt_session_t) + sizeof( invt_seshdr_t ) + stmsz;
+ sessz = strlen(INVTSESS_COOKIE) * sizeof(char) +
+ sizeof(inv_version_t) +
+ sizeof(inv_version_t) + /* added to fix 64 bit alignment prob */
+ sizeof(invt_session_t) + sizeof(invt_seshdr_t) + stmsz;
/* now get all the streams of this session */
- strms = calloc ( ses->s_cur_nstreams, sizeof( invt_stream_t ) );
- if ( GET_REC_NOLOCK( fd, strms, stmsz, hdr->sh_streams_off ) < 0 ) {
- free ( strms );
+ strms = calloc (ses->s_cur_nstreams, sizeof(invt_stream_t));
+ if (GET_REC_NOLOCK(fd, strms, stmsz, hdr->sh_streams_off) < 0) {
+ free (strms);
return BOOL_FALSE;
}
- for ( i = 0; i < ses->s_cur_nstreams; i++ )
- sessz += sizeof( invt_mediafile_t ) *
+ for (i = 0; i < ses->s_cur_nstreams; i++)
+ sessz += sizeof(invt_mediafile_t) *
(size_t) strms[i].st_nmediafiles;
/* Now we know how big this entire thing is going to be */
- sesbufcp = sesbuf = calloc( 1, sessz );
- assert( sesbuf );
+ sesbufcp = sesbuf = calloc(1, sessz);
+ assert(sesbuf);
/* Copy everything. Note that we don't bother to adjust the offsets
either in the seshdr or in the mediafiles, because we don't need
- those in order to restore this session ( since everything's
- contiguous ) */
+ those in order to restore this session (since everything's
+ contiguous) */
/* magic cookie that we put for sanity checking in case of an
earthquake or something :) */
- strcpy( sesbuf, INVTSESS_COOKIE );
- sesbuf += (size_t)( strlen( INVTSESS_COOKIE ) * sizeof( char ) );
+ strcpy(sesbuf, INVTSESS_COOKIE);
+ sesbuf += (size_t)(strlen(INVTSESS_COOKIE) * sizeof(char));
/* This was originally INV_VERSION. Changed it to mean packed inventory
* version number and added another inv_version_t to contain the INV_VERSION.
@@ -785,43 +785,43 @@ stobj_pack_sessinfo( int fd, invt_session_t *ses, invt_seshdr_t *hdr,
* the general inventory version
*/
*(inv_version_t *)sesbuf = INT_GET(PACKED_INV_VERSION, ARCH_CONVERT);
- sesbuf += sizeof( inv_version_t );
+ sesbuf += sizeof(inv_version_t);
/* This has the INV_VERSION */
*(inv_version_t *)sesbuf = INT_GET(INV_VERSION, ARCH_CONVERT);
- sesbuf += sizeof( inv_version_t );
+ sesbuf += sizeof(inv_version_t);
xlate_invt_seshdr(hdr, (invt_seshdr_t *)sesbuf, 1);
- sesbuf += sizeof( invt_seshdr_t );
+ sesbuf += sizeof(invt_seshdr_t);
- xlate_invt_session( ses, (invt_session_t *)sesbuf, 1 );
- sesbuf += sizeof( invt_session_t );
+ xlate_invt_session(ses, (invt_session_t *)sesbuf, 1);
+ sesbuf += sizeof(invt_session_t);
- for ( i = 0; i < ses->s_cur_nstreams; i++ ) {
- xlate_invt_stream( strms, (invt_stream_t *)sesbuf, 1 );
- sesbuf += sizeof( invt_stream_t );
+ for (i = 0; i < ses->s_cur_nstreams; i++) {
+ xlate_invt_stream(strms, (invt_stream_t *)sesbuf, 1);
+ sesbuf += sizeof(invt_stream_t);
}
/* now append all the mediafiles */
- for ( i = 0; i < ses->s_cur_nstreams; i++ ) {
+ for (i = 0; i < ses->s_cur_nstreams; i++) {
off = strms[i].st_firstmfile;
- for ( j = 0; j < strms[i].st_nmediafiles;
+ for (j = 0; j < strms[i].st_nmediafiles;
j++,
- off = mf.mf_nextmf ) {
- assert( off );
- if ( GET_REC_NOLOCK( fd, &mf,
- sizeof( invt_mediafile_t ),
- off ) <= 0 ) {
- free( strms );
- free( sesbuf );
+ off = mf.mf_nextmf) {
+ assert(off);
+ if (GET_REC_NOLOCK(fd, &mf,
+ sizeof(invt_mediafile_t),
+ off) <= 0) {
+ free(strms);
+ free(sesbuf);
return BOOL_FALSE;
}
xlate_invt_mediafile(&mf, (invt_mediafile_t *)sesbuf, 1);
- sesbuf += sizeof( invt_mediafile_t );
+ sesbuf += sizeof(invt_mediafile_t);
}
}
- free( strms );
+ free(strms);
*bufpp = sesbufcp;
*bufszp = sessz;
@@ -840,13 +840,13 @@ stobj_getsession_byuuid(
int fd,
invt_seshdr_t *hdr,
void *sesid,
- void **buf )
+ void **buf)
{
invt_session_t ses;
/* retrieve the session */
- if ( GET_REC_NOLOCK( fd, &ses, sizeof( invt_session_t ),
- hdr->sh_sess_off ) < 0 )
+ if (GET_REC_NOLOCK(fd, &ses, sizeof(invt_session_t),
+ hdr->sh_sess_off) < 0)
return -1;
/* now see if this is the one that caller is askin for */
@@ -876,13 +876,13 @@ stobj_getsession_bylabel(
int fd,
invt_seshdr_t *hdr,
void *seslabel,
- void **buf )
+ void **buf)
{
invt_session_t ses;
/* retrieve the session */
- if ( GET_REC_NOLOCK( fd, &ses, sizeof( invt_session_t ),
- hdr->sh_sess_off ) < 0 )
+ if (GET_REC_NOLOCK(fd, &ses, sizeof(invt_session_t),
+ hdr->sh_sess_off) < 0)
return -1;
/* now see if this is the one that caller is askin for */
@@ -910,7 +910,7 @@ bool_t
stobj_delete_mobj(int fd,
invt_seshdr_t *hdr,
void *arg ,
- void **buf )
+ void **buf)
{
/* XXX fd needs to be locked EX, not SH */
uuid_t *moid = *buf;
@@ -922,38 +922,38 @@ stobj_delete_mobj(int fd,
uint i, j;
bool_t dirty;
- if ( GET_REC_NOLOCK( fd, &ses, sizeof( invt_session_t ),
- hdr->sh_sess_off ) < 0 )
+ if (GET_REC_NOLOCK(fd, &ses, sizeof(invt_session_t),
+ hdr->sh_sess_off) < 0)
return -1;
/* now get all the streams of this session */
- strms = calloc ( ses.s_cur_nstreams, sizeof( invt_stream_t ) );
- if ( GET_REC_NOLOCK( fd, strms,
- sizeof( invt_stream_t ) * ses.s_cur_nstreams,
- hdr->sh_streams_off ) < 0 ) {
- free ( strms );
+ strms = calloc (ses.s_cur_nstreams, sizeof(invt_stream_t));
+ if (GET_REC_NOLOCK(fd, strms,
+ sizeof(invt_stream_t) * ses.s_cur_nstreams,
+ hdr->sh_streams_off) < 0) {
+ free (strms);
return BOOL_FALSE;
}
/* now look at all the mediafiles in all the streams */
- for ( i = 0; i < ses.s_cur_nstreams; i++ ) {
+ for (i = 0; i < ses.s_cur_nstreams; i++) {
off = strms[i].st_firstmfile;
nmfiles = strms[i].st_nmediafiles;
- mfiles = mf = calloc( nmfiles, sizeof( invt_mediafile_t ) );
- for ( j = 0; j < nmfiles;
+ mfiles = mf = calloc(nmfiles, sizeof(invt_mediafile_t));
+ for (j = 0; j < nmfiles;
j++,
off = mf->mf_nextmf,
- mf++ ) {
+ mf++) {
/* The prob is that we need to keep track of where we got these mfiles from
as we get them, or we wont know how to put them back if they are dirty.
*/
- assert( off );
- if ( GET_REC_NOLOCK( fd, mf,
- sizeof( invt_mediafile_t ),
- off ) <= 0 ) {
- free( strms );
- free( mfiles );
+ assert(off);
+ if (GET_REC_NOLOCK(fd, mf,
+ sizeof(invt_mediafile_t),
+ off) <= 0) {
+ free(strms);
+ free(mfiles);
return BOOL_FALSE;
}
}
@@ -962,31 +962,31 @@ stobj_delete_mobj(int fd,
pass, checking to see if we need to remove any mfiles */
dirty = BOOL_FALSE;
- for ( j = 0; j < nmfiles; j++ ) {
+ for (j = 0; j < nmfiles; j++) {
mf = &mfiles[j];
- if ( !uuid_compare( mf->mf_moid, *moid ) ) {
+ if (!uuid_compare(mf->mf_moid, *moid)) {
#ifdef INVT_DEBUG
- printf(" found one\n" );
+ printf(" found one\n");
#endif
/* dirty = BOOL_TRUE;
- if ( j == 0 )
+ if (j == 0)
strms[i].st_firstmfile = mf->mf_nextmf;
else
mfiles[j-1].mf_nextmf = mf->mf_nextmf;
- if ( j == nmfiles - 1 )
+ if (j == nmfiles - 1)
strms[i].st_lastmfile = ;
*/
}
}
- free ( mfiles );
- if ( dirty );
+ free (mfiles);
+ if (dirty);
}
- free ( strms );
+ free (strms);
return BOOL_FALSE; /* ret FALSE, or it'll stop iteration */
}
@@ -1006,36 +1006,36 @@ bool_t
stobj_unpack_sessinfo(
void *bufp,
size_t bufsz,
- invt_sessinfo_t *s )
+ invt_sessinfo_t *s)
{
uint i;
char *tmpbuf;
char *p = (char *)bufp;
- assert ( bufp );
+ assert (bufp);
tmpbuf = (char *)malloc(bufsz);
/* first make sure that the magic cookie at the beginning is right.
this isn't null-terminated */
- if (strncmp( p, INVTSESS_COOKIE, strlen( INVTSESS_COOKIE ) ) != 0) {
- mlog( MLOG_NORMAL | MLOG_INV, _(
- "INV: inv_put_session: unknown cookie\n") );
+ if (strncmp(p, INVTSESS_COOKIE, strlen(INVTSESS_COOKIE)) != 0) {
+ mlog(MLOG_NORMAL | MLOG_INV, _(
+ "INV: inv_put_session: unknown cookie\n"));
return BOOL_FALSE;
}
/* skip the cookie */
- p += strlen( INVTSESS_COOKIE ) * sizeof( char );
+ p += strlen(INVTSESS_COOKIE) * sizeof(char);
/* Check the packing version number. In version 1 , this was the only version number.
* see the comment in stobj_pack_sessinfo().
*/
- if ( INT_GET(*( inv_version_t *) p, ARCH_CONVERT) == PACKED_INV_VERSION_1 ) {
+ if (INT_GET(*(inv_version_t *) p, ARCH_CONVERT) == PACKED_INV_VERSION_1) {
char *temp_p;
size_t tempsz;
- mlog( MLOG_DEBUG | MLOG_INV,"INV: packed inventory version = 1\n" );
+ mlog(MLOG_DEBUG | MLOG_INV,"INV: packed inventory version = 1\n");
- p += sizeof( inv_version_t );
+ p += sizeof(inv_version_t);
/* We hit a 64 bit alignment issue at this point leading to a
* SIGBUS and core dump. The best way to handle it is to
@@ -1047,19 +1047,19 @@ stobj_unpack_sessinfo(
* have the INV_VERSION. This makes everything 64 bit aligned.
*/
- tempsz = bufsz - (strlen( INVTSESS_COOKIE ) * sizeof( char ))
- - sizeof( inv_version_t ) ;
+ tempsz = bufsz - (strlen(INVTSESS_COOKIE) * sizeof(char))
+ - sizeof(inv_version_t) ;
temp_p = calloc(1, tempsz);
bcopy(p, temp_p, tempsz);
p = temp_p;
- } else if ( INT_GET(*( inv_version_t *) p, ARCH_CONVERT) == PACKED_INV_VERSION_2 ) {
- mlog( MLOG_DEBUG | MLOG_INV,"INV: packed inventory version = 2\n" );
+ } else if (INT_GET(*(inv_version_t *) p, ARCH_CONVERT) == PACKED_INV_VERSION_2) {
+ mlog(MLOG_DEBUG | MLOG_INV,"INV: packed inventory version = 2\n");
- p += sizeof( inv_version_t ); /* skip the packed inventory version */
+ p += sizeof(inv_version_t); /* skip the packed inventory version */
/* At this point , don't care about the INV_VERSION. Maybe in future */
- p += sizeof( inv_version_t ); /* skip the inventory version */
+ p += sizeof(inv_version_t); /* skip the inventory version */
} else {
- mlog( MLOG_NORMAL | MLOG_INV, _(
+ mlog(MLOG_NORMAL | MLOG_INV, _(
"INV: inv_put_session: unknown packed inventory version"
" %d\n"), *( inv_version_t *) p);
return BOOL_FALSE;
@@ -1071,52 +1071,52 @@ stobj_unpack_sessinfo(
/* get the seshdr and then, the remainder of the session */
s->seshdr = (invt_seshdr_t *)p;
s->seshdr->sh_sess_off = -1;
- p += sizeof( invt_seshdr_t );
+ p += sizeof(invt_seshdr_t);
xlate_invt_session((invt_session_t *)p, (invt_session_t *)tmpbuf, 1);
bcopy (tmpbuf, p, sizeof(invt_session_t));
s->ses = (invt_session_t *)p;
- p += sizeof( invt_session_t );
+ p += sizeof(invt_session_t);
/* the array of all the streams belonging to this session */
xlate_invt_stream((invt_stream_t *)p, (invt_stream_t *)tmpbuf, 1);
bcopy(tmpbuf, p, sizeof(invt_stream_t));
s->strms = (invt_stream_t *)p;
- p += s->ses->s_cur_nstreams * sizeof( invt_stream_t );
+ p += s->ses->s_cur_nstreams * sizeof(invt_stream_t);
/* all the media files */
s->mfiles = (invt_mediafile_t *)p;
#ifdef INVT_DELETION
{
- int tmpfd = open( "moids", O_RDWR | O_CREAT, S_IRUSR|S_IWUSR );
+ int tmpfd = open("moids", O_RDWR | O_CREAT, S_IRUSR|S_IWUSR);
uint j;
invt_mediafile_t *mmf = s->mfiles;
- for (i=0; i< s->ses->s_cur_nstreams; i++ ) {
- for (j=0; j< s->strms[ i ].st_nmediafiles;
- j++, mmf++ )
+ for (i=0; i< s->ses->s_cur_nstreams; i++) {
+ for (j=0; j< s->strms[i].st_nmediafiles;
+ j++, mmf++)
xlate_invt_mediafile((invt_mediafile_t *)mmf, (invt_mediafile_t *)tmpbuf, 1);
bcopy(tmpbuf, mmf, sizeof(invt_mediafile_t));
- put_invtrecord( tmpfd, &mmf->mf_moid,
- sizeof( uuid_t ), 0, SEEK_END, 0 );
+ put_invtrecord(tmpfd, &mmf->mf_moid,
+ sizeof(uuid_t), 0, SEEK_END, 0);
}
- close( tmpfd );
+ close(tmpfd);
}
#endif
- for ( i = 0; i < s->ses->s_cur_nstreams; i++ ) {
- p += (size_t) ( s->strms[ i ].st_nmediafiles )
- * sizeof( invt_mediafile_t );
+ for (i = 0; i < s->ses->s_cur_nstreams; i++) {
+ p += (size_t) (s->strms[i].st_nmediafiles)
+ * sizeof(invt_mediafile_t);
}
/* sanity check the size of the buffer given to us vs. the size it
should be */
- if ( (size_t) ( p - (char *) bufp ) != bufsz ) {
- mlog( MLOG_DEBUG | MLOG_INV, "p-bufp %d != bufsz %d entsz %d\n",
- (int)( p - (char *) bufp ), (int) bufsz,
- (int) ( sizeof( invt_entry_t ) ) );
+ if ((size_t) (p - (char *) bufp) != bufsz) {
+ mlog(MLOG_DEBUG | MLOG_INV, "p-bufp %d != bufsz %d entsz %d\n",
+ (int)(p - (char *) bufp), (int) bufsz,
+ (int) (sizeof(invt_entry_t)));
}
- assert( (size_t) ( p - (char *) bufp ) == bufsz );
+ assert((size_t) (p - (char *) bufp) == bufsz);
return BOOL_TRUE;
}
@@ -1129,13 +1129,13 @@ stobj_unpack_sessinfo(
/*----------------------------------------------------------------------*/
int
-stobj_make_invsess( int fd, inv_session_t **buf, invt_seshdr_t *hdr )
+stobj_make_invsess(int fd, inv_session_t **buf, invt_seshdr_t *hdr)
{
invt_session_t ses;
/* load in the rest of the session, but not the streams */
- if ( GET_REC_NOLOCK( fd, &ses, sizeof(ses), hdr->sh_sess_off )
- < 0 ) {
+ if (GET_REC_NOLOCK(fd, &ses, sizeof(ses), hdr->sh_sess_off)
+ < 0) {
return -1;
}
@@ -1147,15 +1147,15 @@ void
stobj_convert_mfile(inv_mediafile_t *expmf, invt_mediafile_t *mf)
{
/* copy the mediafile into the exported structure */
- memcpy( &expmf->m_moid, &mf->mf_moid, sizeof( uuid_t ) );
- strcpy( expmf->m_label, mf->mf_label );
+ memcpy(&expmf->m_moid, &mf->mf_moid, sizeof(uuid_t));
+ strcpy(expmf->m_label, mf->mf_label);
expmf->m_mfile_index = mf->mf_mfileidx;
expmf->m_startino = mf->mf_startino.ino;
expmf->m_startino_off = mf->mf_startino.offset;
expmf->m_endino = mf->mf_endino.ino;
expmf->m_endino_off = mf->mf_endino.offset;
expmf->m_size = mf->mf_size;
- expmf->m_isgood = (mf->mf_flag & INVT_MFILE_GOOD ) ?
+ expmf->m_isgood = (mf->mf_flag & INVT_MFILE_GOOD) ?
BOOL_TRUE : BOOL_FALSE;
expmf->m_isinvdump = (mf->mf_flag & INVT_MFILE_INVDUMP)?
BOOL_TRUE : BOOL_FALSE;
@@ -1172,7 +1172,7 @@ stobj_convert_strm(inv_stream_t *expstrm, invt_stream_t *strm)
strm->st_startino.offset;
expstrm->st_endino = strm->st_endino.ino;
expstrm->st_endino_off = strm->st_endino.offset;
- strcpy( expstrm->st_cmdarg, strm->st_cmdarg );
+ strcpy(expstrm->st_cmdarg, strm->st_cmdarg);
expstrm->st_nmediafiles = strm->st_nmediafiles;
@@ -1186,14 +1186,14 @@ stobj_convert_session(inv_session_t *ises, invt_session_t *ses,
{
ises->s_time = hdr->sh_time;
ises->s_level = hdr->sh_level;
- ises->s_ispartial = IS_PARTIAL_SESSION( hdr )? BOOL_TRUE: BOOL_FALSE;
- ises->s_isresumed = IS_RESUMED_SESSION( hdr )? BOOL_TRUE: BOOL_FALSE;
+ ises->s_ispartial = IS_PARTIAL_SESSION(hdr)? BOOL_TRUE: BOOL_FALSE;
+ ises->s_isresumed = IS_RESUMED_SESSION(hdr)? BOOL_TRUE: BOOL_FALSE;
ises->s_nstreams = ses->s_cur_nstreams;
- memcpy( &ises->s_sesid, &ses->s_sesid, sizeof( uuid_t ) );
- memcpy( &ises->s_fsid, &ses->s_fsid, sizeof( uuid_t ) );
- strcpy( ises->s_mountpt, ses->s_mountpt );
- strcpy( ises->s_devpath, ses->s_devpath );
- strcpy( ises->s_label, ses->s_label );
+ memcpy(&ises->s_sesid, &ses->s_sesid, sizeof(uuid_t));
+ memcpy(&ises->s_fsid, &ses->s_fsid, sizeof(uuid_t));
+ strcpy(ises->s_mountpt, ses->s_mountpt);
+ strcpy(ises->s_devpath, ses->s_devpath);
+ strcpy(ises->s_label, ses->s_label);
/* caller is responsible for initializing this */
ises->s_streams = NULL;
@@ -1218,23 +1218,23 @@ stobj_copy_invsess(int fd,
int i;
invt_mediafile_t mf;
- strms = calloc ( ses->s_cur_nstreams, sizeof( invt_stream_t ) );
+ strms = calloc (ses->s_cur_nstreams, sizeof(invt_stream_t));
/* load in all the stream-headers */
- if ( GET_REC_NOLOCK( fd, strms,
- ses->s_cur_nstreams * sizeof( invt_stream_t ),
- hdr->sh_streams_off ) < 0 ) {
+ if (GET_REC_NOLOCK(fd, strms,
+ ses->s_cur_nstreams * sizeof(invt_stream_t),
+ hdr->sh_streams_off) < 0) {
free (strms);
return -1;
}
- ises = calloc( 1, sizeof( inv_session_t ) );
+ ises = calloc(1, sizeof(inv_session_t));
stobj_convert_session(ises, ses, hdr);
- ises->s_streams = calloc(ses->s_cur_nstreams, sizeof( inv_stream_t ));
+ ises->s_streams = calloc(ses->s_cur_nstreams, sizeof(inv_stream_t));
/* fill in the stream structures too */
i = (int) ses->s_cur_nstreams;
- while ( i-- ) {
+ while (i--) {
off64_t off;
uint j, nmf;
@@ -1243,31 +1243,31 @@ stobj_copy_invsess(int fd,
off = strms[i].st_firstmfile;
if (nmf)
- ises->s_streams[i].st_mediafiles = calloc( nmf,
- sizeof( inv_mediafile_t ) );
- assert( !nmf || ises->s_streams[i].st_mediafiles );
+ ises->s_streams[i].st_mediafiles = calloc(nmf,
+ sizeof(inv_mediafile_t));
+ assert(!nmf || ises->s_streams[i].st_mediafiles);
- for ( j = 0; j < nmf;
+ for (j = 0; j < nmf;
j++,
- off = mf.mf_nextmf ) {
- assert( off );
- if ( GET_REC_NOLOCK( fd, &mf,
- sizeof( invt_mediafile_t ),
- off ) <= 0 ) {
- INV_PERROR( "stobj::make_invsess\n" );
- free( strms );
- free( ises );
+ off = mf.mf_nextmf) {
+ assert(off);
+ if (GET_REC_NOLOCK(fd, &mf,
+ sizeof(invt_mediafile_t),
+ off) <= 0) {
+ INV_PERROR("stobj::make_invsess\n");
+ free(strms);
+ free(ises);
return -1;
}
/* copy the mediafile into the exported structure */
if (ises->s_streams[i].st_mediafiles) {
- stobj_convert_mfile( &ises->s_streams[i].st_mediafiles[j],
+ stobj_convert_mfile(&ises->s_streams[i].st_mediafiles[j],
&mf);
} else {
mlog(MLOG_ERROR, _(
"Failed to get data from media file: "
- "possible file corruption\n") );
+ "possible file corruption\n"));
mlog_exit_hint(RV_CORRUPT);
return -1;
}
@@ -1276,7 +1276,7 @@ stobj_copy_invsess(int fd,
}
- free( strms );
+ free(strms);
*buf = ises;
return 1;
@@ -1297,21 +1297,21 @@ stobj_convert_sessinfo(inv_session_t **buf, invt_sessinfo_t *sinfo)
int nstreams;
invt_mediafile_t *mf;
- ises = calloc( 1, sizeof( inv_session_t ) );
+ ises = calloc(1, sizeof(inv_session_t));
stobj_convert_session(ises, sinfo->ses, sinfo->seshdr);
- ises->s_streams = calloc( ises->s_nstreams, sizeof( inv_stream_t ) );
+ ises->s_streams = calloc(ises->s_nstreams, sizeof(inv_stream_t));
mf = sinfo->mfiles;
nstreams = (int) ises->s_nstreams;
- for ( i = 0 ; i < nstreams ; i++ ) {
+ for (i = 0 ; i < nstreams ; i++) {
stobj_convert_strm(&ises->s_streams[i], &sinfo->strms[i]);
nmf = (int) ises->s_streams[i].st_nmediafiles;
- ises->s_streams[i].st_mediafiles = calloc( (uint) nmf,
- sizeof( inv_mediafile_t ) );
+ ises->s_streams[i].st_mediafiles = calloc((uint) nmf,
+ sizeof(inv_mediafile_t));
- for ( j = 0; j < nmf; j++ ) {
- stobj_convert_mfile( &ises->s_streams[i].st_mediafiles[j],
- mf++ );
+ for (j = 0; j < nmf; j++) {
+ stobj_convert_mfile(&ises->s_streams[i].st_mediafiles[j],
+ mf++);
}
}
@@ -1321,10 +1321,10 @@ stobj_convert_sessinfo(inv_session_t **buf, invt_sessinfo_t *sinfo)
int
-stobj_hdrcmp( const void *h1, const void *h2 )
+stobj_hdrcmp(const void *h1, const void *h2)
{
- return (int) ( ((invt_seshdr_t *)h1)->sh_time -
- ((invt_seshdr_t *)h2)->sh_time );
+ return (int) (((invt_seshdr_t *)h1)->sh_time -
+ ((invt_seshdr_t *)h2)->sh_time);
}
@@ -1335,32 +1335,32 @@ stobj_hdrcmp( const void *h1, const void *h2 )
void
-DEBUG_sessprint( invt_session_t *ses )
+DEBUG_sessprint(invt_session_t *ses)
{
char str[UUID_STR_LEN + 1];
- uuid_unparse( ses->s_fsid, str );
+ uuid_unparse(ses->s_fsid, str);
printf("-------- session -------------\n");
printf("label\t%s\n", ses->s_label);
printf("mount\t%s\n", ses->s_mountpt);
printf("devpath\t%s\n", ses->s_devpath);
- printf("strms\t%d\n", ses->s_cur_nstreams );
+ printf("strms\t%d\n", ses->s_cur_nstreams);
printf("fsid\t%s\n", str);
printf("-------- end -------------\n");
}
bool_t
-mobj_eql ( inv_mediafile_t *mfp, invt_mobjinfo_t *mobj )
+mobj_eql (inv_mediafile_t *mfp, invt_mobjinfo_t *mobj)
{
- if ( mobj->type == INVT_MOID ) {
- if ( !uuid_compare( *((uuid_t*) mobj->value),
- mfp->m_moid) ) {
+ if (mobj->type == INVT_MOID) {
+ if (!uuid_compare(*((uuid_t*) mobj->value),
+ mfp->m_moid)) {
return BOOL_TRUE;
}
} else {
- if ( STREQL( (char*) mobj->value,
- mfp->m_label ) ) {
+ if (STREQL((char*) mobj->value,
+ mfp->m_label)) {
return BOOL_TRUE;
}
}
@@ -1370,16 +1370,16 @@ mobj_eql ( inv_mediafile_t *mfp, invt_mobjinfo_t *mobj )
bool_t
-check_for_mobj ( inv_session_t *ses, invt_mobjinfo_t *mobj )
+check_for_mobj (inv_session_t *ses, invt_mobjinfo_t *mobj)
{
int i;
uint j;
inv_mediafile_t *mfp;
- for (i = 0; i < (int) ses->s_nstreams; i++ ) {
- for ( j = 0 ; j < ses->s_streams[i].st_nmediafiles ; j++ ) {
+ for (i = 0; i < (int) ses->s_nstreams; i++) {
+ for (j = 0 ; j < ses->s_streams[i].st_nmediafiles ; j++) {
mfp = &ses->s_streams[i].st_mediafiles[j];
- if (mobj_eql( mfp, mobj ))
+ if (mobj_eql(mfp, mobj))
return BOOL_TRUE;
}
}
@@ -1391,7 +1391,7 @@ check_for_mobj ( inv_session_t *ses, invt_mobjinfo_t *mobj )
void
-DEBUG_sessionprint( inv_session_t *ses, uint ref, invt_pr_ctx_t *prctx)
+DEBUG_sessionprint(inv_session_t *ses, uint ref, invt_pr_ctx_t *prctx)
{
char str[UUID_STR_LEN + 1];
int i;
@@ -1400,17 +1400,17 @@ DEBUG_sessionprint( inv_session_t *ses, uint ref, invt_pr_ctx_t *prctx)
invt_mobjinfo_t *mobj = &prctx->mobj;
- bool_t moidsearch = ( mobj && mobj->type != INVT_NULLTYPE );
- if ( moidsearch ){
+ bool_t moidsearch = (mobj && mobj->type != INVT_NULLTYPE);
+ if (moidsearch){
if (!check_for_mobj (ses, mobj))
return;
}
- if ( ref == 0 || fsidxprinted != (uint) prctx->index ) {
+ if (ref == 0 || fsidxprinted != (uint) prctx->index) {
fsidxprinted = (uint) prctx->index;
printf("file system %d:\n", prctx->index);
- uuid_unparse( ses->s_fsid, str );
+ uuid_unparse(ses->s_fsid, str);
printf("\tfs id:\t\t%s\n", str);
}
@@ -1423,73 +1423,73 @@ DEBUG_sessionprint( inv_session_t *ses, uint ref, invt_pr_ctx_t *prctx)
printf("\tsession %d:\n", ref);
printf("\t\tmount point:\t%s\n", ses->s_mountpt);
printf("\t\tdevice:\t\t%s\n", ses->s_devpath);
- printf("\t\ttime:\t\t%s", ctime32( &ses->s_time ));
+ printf("\t\ttime:\t\t%s", ctime32( &ses->s_time));
printf("\t\tsession label:\t\"%s\"\n", ses->s_label);
- uuid_unparse( ses->s_sesid, str );
+ uuid_unparse(ses->s_sesid, str);
printf("\t\tsession id:\t%s\n", str);
printf("\t\tlevel:\t\t%d\n", ses->s_level);
- printf("\t\tresumed:\t%s\n", ses->s_isresumed ? "YES" : "NO" );
- printf( "\t\tsubtree:\t%s\n", ses->s_ispartial ? "YES" : "NO" );
- printf("\t\tstreams:\t%d\n", ses->s_nstreams );
+ printf("\t\tresumed:\t%s\n", ses->s_isresumed ? "YES" : "NO");
+ printf("\t\tsubtree:\t%s\n", ses->s_ispartial ? "YES" : "NO");
+ printf("\t\tstreams:\t%d\n", ses->s_nstreams);
- if (prctx->depth == PR_SESSONLY )
+ if (prctx->depth == PR_SESSONLY)
return;
- for (i = 0; i < (int) ses->s_nstreams; i++ ) {
+ for (i = 0; i < (int) ses->s_nstreams; i++) {
uint j;
- printf("\t\tstream %d:\n", i );
- printf( "\t\t\tpathname:\t%s\n", ses->s_streams[i].st_cmdarg );
- printf( "\t\t\tstart:\t\tino %llu offset %lld\n",
+ printf("\t\tstream %d:\n", i);
+ printf("\t\t\tpathname:\t%s\n", ses->s_streams[i].st_cmdarg);
+ printf("\t\t\tstart:\t\tino %llu offset %lld\n",
(unsigned long long)ses->s_streams[i].st_startino,
- (long long)ses->s_streams[i].st_startino_off );
- printf( "\t\t\tend:\t\tino %llu offset %lld\n",
+ (long long)ses->s_streams[i].st_startino_off);
+ printf("\t\t\tend:\t\tino %llu offset %lld\n",
(unsigned long long)ses->s_streams[i].st_endino,
- (long long)ses->s_streams[i].st_endino_off );
- printf( "\t\t\tinterrupted:\t%s\n",
- ses->s_streams[i].st_interrupted ? "YES" : "NO" );
- printf( "\t\t\tmedia files:\t%d\n",
+ (long long)ses->s_streams[i].st_endino_off);
+ printf("\t\t\tinterrupted:\t%s\n",
+ ses->s_streams[i].st_interrupted ? "YES" : "NO");
+ printf("\t\t\tmedia files:\t%d\n",
ses->s_streams[i].st_nmediafiles);
- if (prctx->depth == PR_STRMSONLY )
+ if (prctx->depth == PR_STRMSONLY)
continue;
- for ( j = 0 ; j < ses->s_streams[i].st_nmediafiles ; j++ ) {
+ for (j = 0 ; j < ses->s_streams[i].st_nmediafiles ; j++) {
mfp = &ses->s_streams[i].st_mediafiles[j];
- if ( moidsearch ) {
- if (! mobj_eql( mfp, mobj ) )
+ if (moidsearch) {
+ if (! mobj_eql(mfp, mobj))
continue;
}
- printf( "\t\t\tmedia file %d:", j );
+ printf("\t\t\tmedia file %d:", j);
/*
if (mfp->m_isinvdump)
printf(" SESSION INVENTORY");
*/
- printf( "\n");
- printf( "\t\t\t\tmfile index:\t%d\n", mfp->m_mfile_index );
- printf( "\t\t\t\tmfile type:\t" );
+ printf("\n");
+ printf("\t\t\t\tmfile index:\t%d\n", mfp->m_mfile_index);
+ printf("\t\t\t\tmfile type:\t");
if (mfp->m_isinvdump) {
- printf( "inventory\n" );
+ printf("inventory\n");
} else {
- printf( "data\n" );
+ printf("data\n");
}
- printf( "\t\t\t\tmfile size:\t%llu\n",
+ printf("\t\t\t\tmfile size:\t%llu\n",
(unsigned long long)mfp->m_size);
if (! mfp->m_isinvdump) {
- printf( "\t\t\t\tmfile start:"
+ printf("\t\t\t\tmfile start:"
"\tino %llu offset %lld\n",
(unsigned long long)mfp->m_startino,
- (long long)mfp->m_startino_off );
- printf( "\t\t\t\tmfile end:"
+ (long long)mfp->m_startino_off);
+ printf("\t\t\t\tmfile end:"
"\tino %llu offset %lld\n",
(unsigned long long)mfp->m_endino,
- (long long)mfp->m_endino_off );
+ (long long)mfp->m_endino_off);
}
- printf( "\t\t\t\tmedia label:\t\"%s\"\n",
+ printf("\t\t\t\tmedia label:\t\"%s\"\n",
mfp->m_label);
- uuid_unparse( mfp->m_moid, str );
- printf( "\t\t\t\tmedia id:\t%s\n", str );
+ uuid_unparse(mfp->m_moid, str);
+ printf("\t\t\t\tmedia id:\t%s\n", str);
}
}
}
@@ -189,12 +189,12 @@ extern inv_idbtoken_t
inv_open(
inv_predicate_t bywhat, /* BY_UUID, BY_MOUNTPT, BY_DEVPATH */
inv_oflag_t forwhat,/* SEARCH_ONLY, SEARCH_N_MOD */
- void *pred );/* uuid_t *,char * mntpt, or char *dev */
+ void *pred);/* uuid_t *,char * mntpt, or char *dev */
extern bool_t
inv_close(
- inv_idbtoken_t tok );
+ inv_idbtoken_t tok);
extern inv_sestoken_t
@@ -209,21 +209,21 @@ inv_writesession_open(
uint nstreams,
time32_t time,
char *mntpt,
- char *devpath );
+ char *devpath);
extern bool_t
inv_writesession_close(
- inv_sestoken_t tok );
+ inv_sestoken_t tok);
extern inv_stmtoken_t
inv_stream_open(
inv_sestoken_t tok,
- char *cmdarg );
+ char *cmdarg);
extern bool_t
inv_stream_close(
inv_stmtoken_t tok,
- bool_t wasinterrupted );
+ bool_t wasinterrupted);
extern bool_t
inv_put_mediafile(
@@ -291,29 +291,29 @@ extern bool_t
inv_get_sessioninfo(
inv_sestoken_t tok,
void **bufpp, /* out */
- size_t *bufszp ); /* out */
+ size_t *bufszp); /* out */
extern bool_t
-inv_delete_mediaobj( uuid_t *moid );
+inv_delete_mediaobj(uuid_t *moid);
extern bool_t
-inv_DEBUG_print( int argc, char **argv );
+inv_DEBUG_print(int argc, char **argv);
extern int
-inv_setup_base( void );
+inv_setup_base(void);
extern char *
-inv_dirpath( void );
+inv_dirpath(void);
extern char *
-inv_fstab( void );
+inv_fstab(void);
extern char *
-inv_lockfile( void );
+inv_lockfile(void);
extern char *
-inv_basepath( void );
+inv_basepath(void);
#endif /* INVENTORY_H */
@@ -52,28 +52,28 @@ static char *dev_str[] = { "/dev/usr/lib", "/dev/usr", "/dev/u/sw/courses",
typedef enum { BULL = -1, WRI, REC, QUE, DEL, MP, QUE2 } hi;
-void usage( void );
+void usage(void);
char *progname;
char *sesfile;
void
-CREAT_mfiles( inv_stmtoken_t tok, uuid_t *moid, ino_t f, ino_t n )
+CREAT_mfiles(inv_stmtoken_t tok, uuid_t *moid, ino_t f, ino_t n)
{
uuid_t labelid;
char label[128], strbuf[20];
char *str;
unsigned int stat;
- uuid_create( &labelid, &stat );
- uuid_to_string( &labelid, &str, &stat );
- strncpy( strbuf, str, 8 );
+ uuid_create(&labelid, &stat);
+ uuid_to_string(&labelid, &str, &stat);
+ strncpy(strbuf, str, 8);
free (str);
strbuf[8] = '\0';
- sprintf(label,"%s_%s (%d-%d)\0","MEDIA_FILE", strbuf, (int)f, (int)n );
+ sprintf(label,"%s_%s (%d-%d)\0","MEDIA_FILE", strbuf, (int)f, (int)n);
- inv_put_mediafile( tok, moid, label, 12, f, 0, n, 0, 0xffff,
- BOOL_TRUE, BOOL_FALSE );
+ inv_put_mediafile(tok, moid, label, 12, f, 0, n, 0, 0xffff,
+ BOOL_TRUE, BOOL_FALSE);
}
@@ -86,33 +86,33 @@ typedef struct ses{
#define SESLIM 240
int
-recons_test( int howmany )
+recons_test(int howmany)
{
int fd, i, rval = 1;
off64_t off = 0;
- ses sarr[ SESLIM];
+ ses sarr[SESLIM];
- fd = open( sesfile, O_RDONLY );
+ fd = open(sesfile, O_RDONLY);
- for ( i=0; i<howmany && i < SESLIM; i++ ){
- rval = get_invtrecord( fd, &sarr[i],
- sizeof( uuid_t ) + sizeof( size_t ), off,
- BOOL_FALSE );
- assert( rval > 0 );
- assert( sarr[i].sz > 0 );
- sarr[i].buf = calloc( 1, sarr[i].sz );
+ for (i=0; i<howmany && i < SESLIM; i++){
+ rval = get_invtrecord(fd, &sarr[i],
+ sizeof(uuid_t) + sizeof(size_t), off,
+ BOOL_FALSE);
+ assert(rval > 0);
+ assert(sarr[i].sz > 0);
+ sarr[i].buf = calloc(1, sarr[i].sz);
off += (off64_t)(sizeof(uuid_t) + sizeof(size_t));
- rval = get_invtrecord( fd, sarr[i].buf, sarr[i].sz, off,
- BOOL_FALSE );
- assert( rval > 0 );
+ rval = get_invtrecord(fd, sarr[i].buf, sarr[i].sz, off,
+ BOOL_FALSE);
+ assert(rval > 0);
off += sarr[i].sz;
}
- for ( i=0; i<howmany && i < SESLIM; i++ ){
- if ( inv_put_sessioninfo( sarr[i].buf, sarr[i].sz ) < 0)
+ for (i=0; i<howmany && i < SESLIM; i++){
+ if (inv_put_sessioninfo(sarr[i].buf, sarr[i].sz) < 0)
printf("$ insert failed.\n");
}
@@ -125,21 +125,21 @@ recons_test( int howmany )
int
-delete_test( int n )
+delete_test(int n)
{
int fd, i;
uuid_t moid;
char *str = 0;
unsigned int stat;
- fd = open( "moids", O_RDONLY );
- if ( fd < 0 ) return -1;
+ fd = open("moids", O_RDONLY);
+ if (fd < 0) return -1;
- get_invtrecord( fd, &moid, sizeof(uuid_t), (n-1)* sizeof( uuid_t), 0 );
- uuid_to_string( &moid, &str, &stat );
- printf("Searching for Moid = %s\n", str );
- free( str );
- if (! inv_delete_mediaobj( &moid ) ) return -1;
+ get_invtrecord(fd, &moid, sizeof(uuid_t), (n-1)* sizeof(uuid_t), 0);
+ uuid_to_string(&moid, &str, &stat);
+ printf("Searching for Moid = %s\n", str);
+ free(str);
+ if (! inv_delete_mediaobj(&moid)) return -1;
return 1;
@@ -193,7 +193,7 @@ sess_queries_bylabel(char *lab)
int
-query_test( int level )
+query_test(int level)
{
int i;
inv_idbtoken_t tok;
@@ -203,40 +203,40 @@ query_test( int level )
if (level == -2) {
printf("mount pt %s\n",sesfile);
- tok = inv_open( INV_BY_MOUNTPT, INV_SEARCH_ONLY, sesfile );
- if (! tok ) return -1;
+ tok = inv_open(INV_BY_MOUNTPT, INV_SEARCH_ONLY, sesfile);
+ if (! tok) return -1;
idx_DEBUG_print (tok->d_invindex_fd);
return 1;
}
for (i = 7; i<8; i++) {
printf("\n\n\n----------------------------------\n"
- "$ Searching fs %s\n", mnt_str[7-i] );
- tok = inv_open( INV_BY_MOUNTPT, INV_SEARCH_ONLY, mnt_str[7-i] );
- if (! tok ) return -1;
+ "$ Searching fs %s\n", mnt_str[7-i]);
+ tok = inv_open(INV_BY_MOUNTPT, INV_SEARCH_ONLY, mnt_str[7-i]);
+ if (! tok) return -1;
prctx.index = i;
- if (level == -1 )
- invmgr_inv_print( tok->d_invindex_fd, &prctx );
+ if (level == -1)
+ invmgr_inv_print(tok->d_invindex_fd, &prctx);
else {
- if (inv_lasttime_level_lessthan( tok, level, &tm ) && tm) {
- printf("\n\nTIME %s %ld\n", ctime(tm), (long) *tm );
+ if (inv_lasttime_level_lessthan(tok, level, &tm) && tm) {
+ printf("\n\nTIME %s %ld\n", ctime(tm), (long) *tm);
free (tm);
}
- if (inv_lastsession_level_lessthan( tok, level, &ses ) && ses) {
- DEBUG_sessionprint( ses, 99, &prctx);
- free ( ses->s_streams );
- free ( ses );
+ if (inv_lastsession_level_lessthan(tok, level, &ses) && ses) {
+ DEBUG_sessionprint(ses, 99, &prctx);
+ free (ses->s_streams);
+ free (ses);
}
- if (inv_lastsession_level_equalto( tok, level, &ses ) && ses) {
+ if (inv_lastsession_level_equalto(tok, level, &ses) && ses) {
printf("Gotcha\n");
- DEBUG_sessionprint( ses, 99, &prctx );
- free ( ses->s_streams );
- free ( ses );
+ DEBUG_sessionprint(ses, 99, &prctx);
+ free (ses->s_streams);
+ free (ses);
}
}
- inv_close( tok );
+ inv_close(tok);
}
return 1;
}
@@ -249,7 +249,7 @@ query_test( int level )
/*----------------------------------------------------------------------*/
int
-write_test( int nsess, int nstreams, int nmedia, int dumplevel )
+write_test(int nsess, int nstreams, int nmedia, int dumplevel)
{
int i,j,k,m,fd;
unsigned int stat;
@@ -274,23 +274,23 @@ write_test( int nsess, int nstreams, int nmedia, int dumplevel )
#ifdef FIRSTTIME
printf("first time!\n");
for (i=0; i<8; i++) {
- uuid_create( &fsidarr[i], &stat );
- assert ( stat == uuid_s_ok );
- uuid_create( &sesidarr[i], &stat );
- assert ( stat == uuid_s_ok );
+ uuid_create(&fsidarr[i], &stat);
+ assert (stat == uuid_s_ok);
+ uuid_create(&sesidarr[i], &stat);
+ assert (stat == uuid_s_ok);
}
- fd = open( "uuids", O_RDWR | O_CREAT );
- PUT_REC(fd, (void *)fsidarr, sizeof (uuid_t) * 8, 0L );
- PUT_REC(fd, (void *)sesidarr, sizeof (uuid_t) * 8, sizeof (uuid_t) * 8 );
+ fd = open("uuids", O_RDWR | O_CREAT);
+ PUT_REC(fd, (void *)fsidarr, sizeof (uuid_t) * 8, 0L);
+ PUT_REC(fd, (void *)sesidarr, sizeof (uuid_t) * 8, sizeof (uuid_t) * 8);
close(fd);
#endif
- fd = open("uuids", O_RDONLY );
- GET_REC( fd, fsidarr, sizeof (uuid_t) * 8, 0L );
- GET_REC( fd, sesidarr, sizeof (uuid_t) * 8, sizeof (uuid_t) * 8 );
+ fd = open("uuids", O_RDONLY);
+ GET_REC(fd, fsidarr, sizeof (uuid_t) * 8, 0L);
+ GET_REC(fd, sesidarr, sizeof (uuid_t) * 8, sizeof (uuid_t) * 8);
close(fd);
#ifdef RECONS
- rfd = open( sesfile, O_RDWR | O_CREAT );
- fchmod( rfd, INV_PERMS );
+ rfd = open(sesfile, O_RDWR | O_CREAT);
+ fchmod(rfd, INV_PERMS);
if (fstat64(fd, &statbuf) < 0) {
perror("fstat64 session file");
return -1;
@@ -298,22 +298,22 @@ write_test( int nsess, int nstreams, int nmedia, int dumplevel )
off = (off64_t)statbuf.st_size;
#endif
- for ( i = 0; i < nsess; i++ ) {
+ for (i = 0; i < nsess; i++) {
j = i % 8;
/*mnt = mnt_str[j];
dev = dev_str[7-j];*/
mnt = mnt_str[0];
dev = dev_str[7];
fsidp = &fsidarr[0]; /* j */
- tok1 = inv_open( INV_BY_UUID, INV_SEARCH_N_MOD, fsidp );
- assert (tok1 != INV_TOKEN_NULL );
+ tok1 = inv_open(INV_BY_UUID, INV_SEARCH_N_MOD, fsidp);
+ assert (tok1 != INV_TOKEN_NULL);
- uuid_create( &labelid, &stat );
- uuid_to_string( &labelid, &str, &stat );
- strncpy( strbuf, str, 8 );
+ uuid_create(&labelid, &stat);
+ uuid_to_string(&labelid, &str, &stat);
+ strncpy(strbuf, str, 8);
free (str);
strbuf[8] = '\0';
- sprintf(label,"%s_%s (%d)\0","SESSION_LABEL", strbuf, i );
+ sprintf(label,"%s_%s (%d)\0","SESSION_LABEL", strbuf, i);
tok2 = inv_writesession_open(tok1, fsidp,
&labelid,
@@ -322,47 +322,47 @@ write_test( int nsess, int nstreams, int nmedia, int dumplevel )
(bool_t)i%2,
dumplevel, nstreams,
time(NULL),
- mnt, dev );
- assert (tok2 != INV_TOKEN_NULL );
+ mnt, dev);
+ assert (tok2 != INV_TOKEN_NULL);
for (m = 0; m<nstreams; m++) {
- tok3 = inv_stream_open( tok2,"/dev/rmt");
- assert (tok3 != INV_TOKEN_NULL );
+ tok3 = inv_stream_open(tok2,"/dev/rmt");
+ assert (tok3 != INV_TOKEN_NULL);
- for (k = 0; k<nmedia; k++ )
- CREAT_mfiles( tok3, &labelid, k*100,
- k*100 + 99 );
- inv_stream_close( tok3, BOOL_TRUE );
+ for (k = 0; k<nmedia; k++)
+ CREAT_mfiles(tok3, &labelid, k*100,
+ k*100 + 99);
+ inv_stream_close(tok3, BOOL_TRUE);
}
#ifdef RECONS
- if (inv_get_sessioninfo( tok2, &bufp, &sz ) == BOOL_TRUE ) {
- put_invtrecord( rfd, fsidp, sizeof( uuid_t ), off,
- BOOL_FALSE );
+ if (inv_get_sessioninfo(tok2, &bufp, &sz) == BOOL_TRUE) {
+ put_invtrecord(rfd, fsidp, sizeof(uuid_t), off,
+ BOOL_FALSE);
off += (off64_t)sizeof(uuid_t);
- put_invtrecord( rfd, &sz, sizeof( size_t ), off,
+ put_invtrecord(rfd, &sz, sizeof(size_t), off,
BOOL_FALSE);
off += (off64_t)sizeof(size_t);
- put_invtrecord( rfd, bufp, sz, off, BOOL_FALSE );
+ put_invtrecord(rfd, bufp, sz, off, BOOL_FALSE);
}
#endif
#ifdef NOTDEF
- if (inv_get_sessioninfo( tok2, &bufp, &sz ) == BOOL_TRUE )
- inv_put_sessioninfo( fsidp, bufp, sz );
+ if (inv_get_sessioninfo(tok2, &bufp, &sz) == BOOL_TRUE)
+ inv_put_sessioninfo(fsidp, bufp, sz);
#endif
- inv_writesession_close( tok2 );
- inv_close( tok1 );
+ inv_writesession_close(tok2);
+ inv_close(tok1);
}
#ifdef RECONS
- close( rfd );
+ close(rfd);
#endif
return 1;
}
-void usage( void )
+void usage(void)
{
printf("( %s ./inv w|r|q -v <verbosity> -s <nsess>"
- "-t <strms> -m <nmediafiles> \n", optarg );
+ "-t <strms> -m <nmediafiles> \n", optarg);
}
@@ -370,8 +370,8 @@ int
mp_test(int nstreams)
{
#if 0
- tok1 = inv_open( INV_BY_UUID, fsidp );
- assert (tok1 != INV_TOKEN_NULL );
+ tok1 = inv_open(INV_BY_UUID, fsidp);
+ assert (tok1 != INV_TOKEN_NULL);
tok2 = inv_writesession_open(tok1, fsidp,
&labelid,
@@ -380,17 +380,17 @@ mp_test(int nstreams)
(bool_t)i%2,
dumplevel, nstreams,
time(NULL),
- mnt, dev );
- assert (tok2 != INV_TOKEN_NULL );
+ mnt, dev);
+ assert (tok2 != INV_TOKEN_NULL);
for (m = 0; m<nstreams; m++) {
- tok3 = inv_stream_open( tok2,"/dev/rmt");
- assert (tok3 != INV_TOKEN_NULL );
+ tok3 = inv_stream_open(tok2,"/dev/rmt");
+ assert (tok3 != INV_TOKEN_NULL);
- for (k = 0; k<nmedia; k++ )
- CREAT_mfiles( tok3, &labelid, k*100,
- k*100 + 99 );
- inv_stream_close( tok3, BOOL_TRUE );
+ for (k = 0; k<nmedia; k++)
+ CREAT_mfiles(tok3, &labelid, k*100,
+ k*100 + 99);
+ inv_stream_close(tok3, BOOL_TRUE);
}
#endif
}
@@ -417,9 +417,9 @@ main(int argc, char *argv[])
progname = argv[0];
sesfile = "sessions";
- assert( argc > 1 );
+ assert(argc > 1);
- mlog_init( argc, argv );
+ mlog_init(argc, argv);
if (! inv_DEBUG_print(argc, argv))
return 0;
@@ -427,8 +427,8 @@ main(int argc, char *argv[])
optind = 1;
optarg = 0;
- while( ( cc = getopt( argc, argv, GETOPT_CMDSTRING)) != EOF ) {
- switch ( cc ) {
+ while((cc = getopt(argc, argv, GETOPT_CMDSTRING)) != EOF) {
+ switch (cc) {
case 'w':
op = WRI;
break;
@@ -473,7 +473,7 @@ main(int argc, char *argv[])
break;
case 'm':
- nmedia = atoi( optarg );
+ nmedia = atoi(optarg);
break;
case 'v':
break;
@@ -489,17 +489,17 @@ main(int argc, char *argv[])
}
- if ( op == WRI )
- rval = write_test( nsess, nstreams, nmedia, level );
- else if ( op == QUE )
- rval = query_test( level );
- else if ( op == REC )
- rval = recons_test( nsess );
- else if ( op == DEL )
- rval = delete_test( nsess );
- else if ( op == MP )
+ if (op == WRI)
+ rval = write_test(nsess, nstreams, nmedia, level);
+ else if (op == QUE)
+ rval = query_test(level);
+ else if (op == REC)
+ rval = recons_test(nsess);
+ else if (op == DEL)
+ rval = delete_test(nsess);
+ else if (op == MP)
rval = mp_test (nstreams);
- else if ( op == QUE2 ) {
+ else if (op == QUE2) {
if (uuid)
rval = sess_queries_byuuid(uuid);
else if (label)
@@ -508,10 +508,10 @@ main(int argc, char *argv[])
else
usage();
- if (rval < 0 )
- printf( "aborted\n");
+ if (rval < 0)
+ printf("aborted\n");
else
- printf( "done\n" );
+ printf("done\n");
}
@@ -44,18 +44,18 @@ typedef enum {
} alignment_t;
typedef struct menu_ops_s {
- int (* op_delete ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_undelete ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_saveexit ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_select ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_collapse ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_expand ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_collapseall ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_expandall ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_highlight ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_unhighlight ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_commit ) (WINDOW *win, node_t *current, node_t *list);
- int (* op_prune ) (char *mountpt, uuid_t *uuidp, time32_t prunetime, node_t *node, node_t *list);
+ int (* op_delete) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_undelete) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_saveexit) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_select) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_collapse) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_expand) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_collapseall) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_expandall) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_highlight) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_unhighlight) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_commit) (WINDOW *win, node_t *current, node_t *list);
+ int (* op_prune) (char *mountpt, uuid_t *uuidp, time32_t prunetime, node_t *node, node_t *list);
} menu_ops_t;
typedef struct {
@@ -83,7 +83,7 @@ fstab_commit(WINDOW *win, node_t *current, node_t *list)
fstabentry_idx = (int)(((long)fstabentry - (long)fstab_file[fidx].mapaddr - sizeof(invt_counter_t)) / sizeof(invt_fstab_t));
- if ( fstab_file[fidx].counter->ic_curnum > 1 ) {
+ if (fstab_file[fidx].counter->ic_curnum > 1) {
memmove(fstabentry,
fstabentry + 1,
(sizeof(invt_fstab_t) * (fstab_file[fidx].counter->ic_curnum - fstabentry_idx - 1)));
@@ -355,7 +355,7 @@ remmap_fstab(int fidx, int num)
nEntries = fstab_file[fidx].counter->ic_curnum;
- munmap( fstab_file[fidx].mapaddr,
+ munmap(fstab_file[fidx].mapaddr,
(nEntries * sizeof(invt_fstab_t)) + sizeof(invt_counter_t));
/* need to lseek on the file to grow it to the right size - no autogrow on linux */
@@ -395,9 +395,9 @@ open_fstab(char *fstabname)
char *name;
invt_counter_t cnt;
- fd = open_and_lock( fstabname, FILE_WRITE, wait_for_locks );
+ fd = open_and_lock(fstabname, FILE_WRITE, wait_for_locks);
if (fd < 0) {
- fprintf( stderr, "%s: abnormal termination\n", g_programName );
+ fprintf(stderr, "%s: abnormal termination\n", g_programName);
exit(1);
}
@@ -426,7 +426,7 @@ close_fstab(int fidx)
fstabentries = fstab_file[fidx].counter->ic_curnum;
- munmap( fstab_file[fidx].mapaddr,
+ munmap(fstab_file[fidx].mapaddr,
(fstab_file[fidx].counter->ic_curnum * sizeof(invt_fstab_t)) + sizeof(invt_counter_t));
if ((fstabentries != 0) && (fstabentries < fstab_file[fidx].nEntries)) {
@@ -437,7 +437,7 @@ close_fstab(int fidx)
close(fstab_file[fidx].fd);
if (fstabentries == 0) {
- unlink( fstab_file[fidx].name );
+ unlink(fstab_file[fidx].name);
}
free(fstab_file[fidx].name);
@@ -47,7 +47,7 @@ int invidx_numfiles;
extern stobj_fileinfo_t *stobj_file;
extern int stobj_numfiles;
-static void stobj_makefname_len( char *fname, int fname_len );
+static void stobj_makefname_len(char *fname, int fname_len);
menu_ops_t invidx_ops = {
NULL,
@@ -94,7 +94,7 @@ invidx_commit(WINDOW *win, node_t *current, node_t *list)
}
mark_all_children_commited(current);
- if ( invidx_file[fidx].counter->ic_curnum > 1 ) {
+ if (invidx_file[fidx].counter->ic_curnum > 1) {
memmove(&inv_entry[idx],
&inv_entry[idx + 1],
(sizeof(invt_entry_t) * (invidx_file[fidx].counter->ic_curnum - idx - 1)));
@@ -547,7 +547,7 @@ insert_stobj_into_stobjfile(int invidx_fileidx, char *filename, int fd,
}
/* stobj file not full, just insert the entry */
- hdr->sh_sess_off = STOBJ_OFFSET( sescnt.ic_maxnum, pos);
+ hdr->sh_sess_off = STOBJ_OFFSET(sescnt.ic_maxnum, pos);
hdr->sh_streams_off = sescnt.ic_eof;
/* for seshdr: malloc buffer, copy new entry into buffer, read file entries into buffer, write the lot out */
@@ -584,31 +584,31 @@ insert_stobj_into_stobjfile(int invidx_fileidx, char *filename, int fd,
}
static void
-stobj_makefname_len( char *fname, int fname_len )
+stobj_makefname_len(char *fname, int fname_len)
{
/* come up with a new unique name */
uuid_t fn;
char str[UUID_STR_LEN + 1];
- uuid_generate( fn );
- uuid_unparse( fn, str );
+ uuid_generate(fn);
+ uuid_unparse(fn, str);
snprintf(fname, fname_len, "%s/%s.StObj", inventory_path, str);
}
int
-stobj_create( char *fname )
+stobj_create(char *fname)
{
int fd;
invt_sescounter_t sescnt;
/* create the new storage object */
- if (( fd = open( fname, O_RDWR | O_EXCL | O_CREAT, S_IRUSR|S_IWUSR )) < 0 ) {
+ if ((fd = open(fname, O_RDWR | O_EXCL | O_CREAT, S_IRUSR|S_IWUSR)) < 0) {
return -1;
}
- INVLOCK( fd, LOCK_EX );
- fchmod( fd, INV_PERMS );
+ INVLOCK(fd, LOCK_EX);
+ fchmod(fd, INV_PERMS);
memset(&sescnt, 0, sizeof(sescnt));
sescnt.ic_vernum = INV_VERSION;
@@ -617,51 +617,51 @@ stobj_create( char *fname )
sescnt.ic_eof = SC_EOF_INITIAL_POS;
lseek(fd, 0, SEEK_SET);
- write_n_bytes ( fd, (char *)&sescnt, sizeof(sescnt), "new stobj file" );
+ write_n_bytes (fd, (char *)&sescnt, sizeof(sescnt), "new stobj file");
- INVLOCK( fd, LOCK_UN );
+ INVLOCK(fd, LOCK_UN);
return fd;
}
int
-stobj_put_streams( int fd, invt_seshdr_t *hdr, invt_session_t *ses,
+stobj_put_streams(int fd, invt_seshdr_t *hdr, invt_session_t *ses,
invt_stream_t *strms,
- invt_mediafile_t *mfiles )
+ invt_mediafile_t *mfiles)
{
uint nstm = ses->s_cur_nstreams;
off64_t off = hdr->sh_streams_off;
- off64_t mfileoff= off + (off64_t)( nstm * sizeof( invt_stream_t ) );
+ off64_t mfileoff= off + (off64_t)(nstm * sizeof(invt_stream_t));
uint nmfiles = 0;
uint i,j;
/* fix the offsets in streams */
- for ( i = 0; i < nstm; i++ ) {
- strms[i].st_firstmfile = mfileoff + (off64_t) ((size_t) nmfiles * sizeof( invt_mediafile_t ) );
+ for (i = 0; i < nstm; i++) {
+ strms[i].st_firstmfile = mfileoff + (off64_t) ((size_t) nmfiles * sizeof(invt_mediafile_t));
/* now fix the offsets in mediafiles */
- for ( j = 0; j < strms[i].st_nmediafiles; j++ ) {
+ for (j = 0; j < strms[i].st_nmediafiles; j++) {
/* no need to fix the last element's next ptr */
- if ( j < strms[i].st_nmediafiles - 1 )
- mfiles[ nmfiles + j ].mf_nextmf = strms[i].st_firstmfile + (off64_t) ((j+1) * sizeof( invt_mediafile_t ));
+ if (j < strms[i].st_nmediafiles - 1)
+ mfiles[nmfiles + j].mf_nextmf = strms[i].st_firstmfile + (off64_t) ((j+1) * sizeof(invt_mediafile_t));
/* no need to fix the first element's prev ptr */
- if ( j )
- mfiles[ nmfiles + j ].mf_prevmf = strms[i].st_firstmfile + (off64_t) ((j-1) * sizeof( invt_mediafile_t ));
+ if (j)
+ mfiles[nmfiles + j].mf_prevmf = strms[i].st_firstmfile + (off64_t) ((j-1) * sizeof(invt_mediafile_t));
}
/* adjust the offsets of the first and the last elements
in the mediafile chain */
- mfiles[ nmfiles ].mf_prevmf = 0;
+ mfiles[nmfiles].mf_prevmf = 0;
nmfiles += strms[i].st_nmediafiles;
- mfiles[ nmfiles - 1 ].mf_nextmf = 0;
+ mfiles[nmfiles - 1].mf_nextmf = 0;
}
/* first put the streams. hdr already points at the right place */
lseek(fd, off, SEEK_SET);
- write_n_bytes( fd, strms, nstm * sizeof( invt_stream_t ), "stobj file" );
+ write_n_bytes(fd, strms, nstm * sizeof(invt_stream_t ), "stobj file");
lseek(fd, mfileoff, SEEK_SET);
- write_n_bytes( fd, mfiles, nmfiles * sizeof( invt_mediafile_t ), "stobj file" );
+ write_n_bytes(fd, mfiles, nmfiles * sizeof(invt_mediafile_t ), "stobj file");
return 1;
}
@@ -834,7 +834,7 @@ find_invidx_insert_pos(int fidx, invt_entry_t *inv_entry)
next_entry = invidx_file[fidx].data[i+1];
if(inv_entry->ie_timeperiod.tp_start > entry->ie_timeperiod.tp_end
- && inv_entry->ie_timeperiod.tp_end < next_entry->ie_timeperiod.tp_start ) {
+ && inv_entry->ie_timeperiod.tp_end < next_entry->ie_timeperiod.tp_start) {
return i;
}
}
@@ -916,7 +916,7 @@ generate_invidx_menu(char * inv_path, node_t *startnode, int level, char *idxFil
return startnode;
}
- invidx_entry = (invt_entry_t *)( invidx_file[idx].mapaddr + sizeof(invt_counter_t));
+ invidx_entry = (invt_entry_t *)(invidx_file[idx].mapaddr + sizeof(invt_counter_t));
n = startnode;
for (i=0; i < invidx_file[idx].counter->ic_curnum; i++) {
@@ -947,7 +947,7 @@ generate_invidx_menu(char * inv_path, node_t *startnode, int level, char *idxFil
add_invidx_data(idx, &(invidx_entry[i]));
stobjname = GetNameOfStobj(inv_path, invidx_entry[i].ie_filename);
- n = generate_stobj_menu( n, level + 1, stobjname );
+ n = generate_stobj_menu(n, level + 1, stobjname);
free(stobjname);
}
@@ -1001,7 +1001,7 @@ remmap_invidx(int fidx, int num)
nEntries = invidx_file[fidx].counter->ic_curnum;
- munmap( invidx_file[fidx].mapaddr,
+ munmap(invidx_file[fidx].mapaddr,
(nEntries * sizeof(invt_entry_t)) + sizeof(invt_counter_t));
/* need to lseek on the file to grow it to the right size - no autogrow on linux */
@@ -1042,7 +1042,7 @@ open_invidx(char *idxFileName)
invt_counter_t header;
errno=0;
- fd = open_and_lock( idxFileName, FILE_WRITE, wait_for_locks );
+ fd = open_and_lock(idxFileName, FILE_WRITE, wait_for_locks);
if (fd < 0) {
return fd;
}
@@ -1053,7 +1053,7 @@ open_invidx(char *idxFileName)
exit(1);
}
- read_n_bytes( fd, &header, sizeof(invt_counter_t), idxFileName);
+ read_n_bytes(fd, &header, sizeof(invt_counter_t), idxFileName);
nEntries = header.ic_curnum;
@@ -1075,21 +1075,21 @@ close_invidx(int idx)
return 0;
nEntries = invidx_file[idx].counter->ic_curnum;
- munmap( invidx_file[idx].mapaddr,
- (invidx_file[idx].nEntries*sizeof(invt_entry_t)) + sizeof(invt_counter_t) );
+ munmap(invidx_file[idx].mapaddr,
+ (invidx_file[idx].nEntries*sizeof(invt_entry_t)) + sizeof(invt_counter_t));
if(nEntries != 0 && nEntries != invidx_file[idx].nEntries) {
ftruncate(invidx_file[idx].fd,
- sizeof(invt_counter_t) + (nEntries * sizeof(invt_entry_t)) );
+ sizeof(invt_counter_t) + (nEntries * sizeof(invt_entry_t)));
}
- close( invidx_file[idx].fd );
+ close(invidx_file[idx].fd);
if(nEntries == 0) {
unlink(invidx_file[idx].name);
}
- free( invidx_file[idx].name );
- free( invidx_file[idx].data );
+ free(invidx_file[idx].name);
+ free(invidx_file[idx].data);
invidx_file[idx].fd = -1;
invidx_file[idx].name = NULL;
@@ -78,51 +78,51 @@ main(int argc, char *argv[])
uuid_clear(uuid);
uuid_clear(session);
- while((c = getopt( argc, argv, GETOPT_CMDSTRING)) != EOF) {
+ while((c = getopt(argc, argv, GETOPT_CMDSTRING)) != EOF) {
switch(c) {
case GETOPT_DEBUG:
debug = BOOL_TRUE;
break;
case GETOPT_INTERACTIVE:
if (force) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_FORCE,
- c );
+ c);
usage();
}
if (session_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_PRUNESESSION,
- c );
+ c);
usage();
}
interactive_option = BOOL_TRUE;
break;
case GETOPT_NONINTERACTIVE: /* obsoleted by -F */
if (interactive_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_INTERACTIVE,
- c );
+ c);
usage();
}
force = BOOL_TRUE;
break;
case GETOPT_UUID:
if (check_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_CHECKPRUNEFSTAB,
- c );
+ c);
usage();
}
if (mntpnt_option || session_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
mntpnt_option ? GETOPT_PRUNEMNT : GETOPT_PRUNESESSION,
- c );
+ c);
usage();
}
uuid_option = BOOL_TRUE;
@@ -133,51 +133,51 @@ main(int argc, char *argv[])
break;
case GETOPT_CHECKPRUNEFSTAB:
if (mntpnt_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_PRUNEMNT,
- c );
+ c);
usage();
}
if (uuid_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_UUID,
- c );
+ c);
usage();
}
if (session_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_PRUNESESSION,
- c );
+ c);
usage();
}
check_option = BOOL_TRUE;
break;
case GETOPT_FORCE:
if (interactive_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_INTERACTIVE,
- c );
+ c);
usage();
}
force = BOOL_TRUE;
break;
case GETOPT_PRUNEMNT:
if (check_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_CHECKPRUNEFSTAB,
- c );
+ c);
usage();
}
if (uuid_option || session_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
uuid_option ? GETOPT_UUID : GETOPT_PRUNESESSION,
- c );
+ c);
usage();
}
mntpnt_option = BOOL_TRUE;
@@ -188,24 +188,24 @@ main(int argc, char *argv[])
break;
case GETOPT_PRUNESESSION:
if (check_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_CHECKPRUNEFSTAB,
- c );
+ c);
usage();
}
if (interactive_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
GETOPT_INTERACTIVE,
- c );
+ c);
usage();
}
if (mntpnt_option || uuid_option) {
- fprintf( stderr, "%s: may not specify both -%c and -%c\n",
+ fprintf(stderr, "%s: may not specify both -%c and -%c\n",
g_programName,
mntpnt_option ? GETOPT_PRUNEMNT : GETOPT_UUID,
- c );
+ c);
usage();
}
session_option = BOOL_TRUE;
@@ -218,11 +218,11 @@ main(int argc, char *argv[])
}
if (r_mf_label != NULL && !(mntpnt_option || uuid_option)) {
- fprintf( stderr, "%s: -%c requires either -%c or -%c\n",
+ fprintf(stderr, "%s: -%c requires either -%c or -%c\n",
g_programName,
GETOPT_PRUNEMEDIALABEL,
GETOPT_PRUNEMNT,
- GETOPT_UUID );
+ GETOPT_UUID);
usage();
}
@@ -245,9 +245,9 @@ main(int argc, char *argv[])
/* sanity check the inventory database directory, setup global paths
*/
if (!inv_setup_base()) {
- fprintf( stderr,
+ fprintf(stderr,
"%s: both /var/lib/xfsdump and /var/xfsdump exist - fatal\n",
- g_programName );
+ g_programName);
exit(1);
}
inventory_path = INV_DIRPATH;
@@ -276,7 +276,7 @@ main(int argc, char *argv[])
&session, timeSecs, r_mf_label);
}
}
- else if ( interactive_option ) {
+ else if (interactive_option) {
invutil_interactive(inventory_path, mntPoint, &uuid, 0);
printf("\n");
}
@@ -370,7 +370,7 @@ ParseDate(char *strDate)
#endif
if (*fmt == NULL || (date = mktime(&tm)) < 0) {
- fprintf(stderr, "%s: bad date, \"%s\"\n", g_programName, strDate );
+ fprintf(stderr, "%s: bad date, \"%s\"\n", g_programName, strDate);
usage();
}
@@ -408,10 +408,10 @@ GetNameOfStobj (char *inv_path, char *filename)
char *name;
str = basename(filename);
- name = (char *) malloc( strlen( inv_path ) + 1 + strlen( str ) + 1);
- strcpy( name, inv_path );
- strcat( name, "/" );
- strcat( name, str );
+ name = (char *) malloc(strlen(inv_path) + 1 + strlen(str) + 1);
+ strcpy(name, inv_path);
+ strcat(name, "/");
+ strcat(name, str);
return(name);
}
@@ -422,13 +422,13 @@ GetNameOfInvIndex (char *inv_path, uuid_t uuid)
char str[UUID_STR_LEN + 1];
char *name;
- uuid_unparse( uuid, str );
- name = (char *) malloc( strlen( inv_path ) + 1 + strlen( str )
- + strlen( INV_INVINDEX_PREFIX ) + 1);
- strcpy( name, inv_path );
- strcat( name, "/" );
- strcat( name, str );
- strcat( name, INV_INVINDEX_PREFIX );
+ uuid_unparse(uuid, str);
+ name = (char *) malloc(strlen(inv_path) + 1 + strlen(str)
+ + strlen(INV_INVINDEX_PREFIX) + 1);
+ strcpy(name, inv_path);
+ strcat(name, "/");
+ strcat(name, str);
+ strcat(name, INV_INVINDEX_PREFIX);
return(name);
}
@@ -438,11 +438,11 @@ GetFstabFullPath(char *inv_path)
{
char *fstabname;
- fstabname = (char *) malloc( strlen(inv_path) + 1 /* one for the "/" */
- + strlen("fstab") + 1 );
- strcpy( fstabname, inv_path );
- strcat( fstabname, "/" );
- strcat( fstabname, "fstab" );
+ fstabname = (char *) malloc(strlen(inv_path) + 1 /* one for the "/" */
+ + strlen("fstab") + 1);
+ strcpy(fstabname, inv_path);
+ strcat(fstabname, "/");
+ strcat(fstabname, "fstab");
return(fstabname);
}
@@ -463,18 +463,18 @@ CheckAndPruneFstab(char *inv_path, bool_t checkonly, char *mountPt,
invt_counter_t *counter,cnt;
if (mountPt == NULL && uuid_is_null(*uuidp) && uuid_is_null(*sessionp)) {
- fprintf( stderr, "%s: mountpoint, uuid or session "
- "must be specified\n", g_programName );
- fprintf( stderr, "%s: abnormal termination\n", g_programName );
+ fprintf(stderr, "%s: mountpoint, uuid or session "
+ "must be specified\n", g_programName);
+ fprintf(stderr, "%s: abnormal termination\n", g_programName);
exit(1);
}
fstabname = GetFstabFullPath(inv_path);
- fd = open_and_lock( fstabname,
+ fd = open_and_lock(fstabname,
FILE_WRITE,
- wait_for_locks );
+ wait_for_locks);
if (fd < 0) {
- fprintf( stderr, "%s: abnormal termination\n", g_programName );
+ fprintf(stderr, "%s: abnormal termination\n", g_programName);
exit(1);
}
@@ -492,13 +492,13 @@ CheckAndPruneFstab(char *inv_path, bool_t checkonly, char *mountPt,
printf("Processing file %s\n", fstabname);
/* check each entry in fstab for mount pt or uuid match */
- for (i = 0; i < counter->ic_curnum; )
+ for (i = 0; i < counter->ic_curnum;)
{
removeflag = BOOL_FALSE;
printf(" Found entry for %s\n" , fstabentry[i].ft_mountpt);
- for (j = i +1 ; j < counter->ic_curnum ; j++ ) {
+ for (j = i +1 ; j < counter->ic_curnum ; j++) {
if (uuid_compare(fstabentry[i].ft_uuid, fstabentry[j].ft_uuid) == 0)
{
printf(" duplicate fstab entry\n");
@@ -519,7 +519,7 @@ CheckAndPruneFstab(char *inv_path, bool_t checkonly, char *mountPt,
(r_mf_label ? r_mf_label : "(NULL)"));
#endif
- if ( checkonly == BOOL_FALSE ) {
+ if (checkonly == BOOL_FALSE) {
if(mountPt != NULL && strcmp(mountPt, fstabentry[i].ft_mountpt) == 0) {
printf(" Match on hostname and path\n");
IdxCheckOnly = BOOL_FALSE;
@@ -542,18 +542,18 @@ CheckAndPruneFstab(char *inv_path, bool_t checkonly, char *mountPt,
if (CheckAndPruneInvIndexFile(
IdxCheckOnly, invname, sessionp,
- prunetime, r_mf_label) == -1 ) {
+ prunetime, r_mf_label) == -1) {
removeflag = BOOL_TRUE;
}
- free( invname );
+ free(invname);
}
if (removeflag == BOOL_TRUE)
{
printf(" removing fstab entry %s\n", fstabentry[i].ft_mountpt);
- if ( counter->ic_curnum > 1 ) {
+ if (counter->ic_curnum > 1) {
bcopy((void *)&fstabentry[i + 1],
(void *)&fstabentry[i],
(sizeof(invt_fstab_t) * (counter->ic_curnum - i - 1)));
@@ -566,7 +566,7 @@ CheckAndPruneFstab(char *inv_path, bool_t checkonly, char *mountPt,
fstabEntries = counter->ic_curnum;
- munmap( mapaddr,
+ munmap(mapaddr,
(nEntries*sizeof(invt_fstab_t)) + sizeof(invt_counter_t));
if ((fstabEntries != 0) && (fstabEntries != nEntries)) {
@@ -588,14 +588,14 @@ CheckAndPruneFstab(char *inv_path, bool_t checkonly, char *mountPt,
if(debug) {
printf("unlink fstab file %s\n", fstabname);
}
- unlink( fstabname );
+ unlink(fstabname);
}
- free( fstabname );
+ free(fstabname);
}
int
-CheckAndPruneInvIndexFile( bool_t checkonly,
+CheckAndPruneInvIndexFile(bool_t checkonly,
char *idxFileName,
uuid_t *sessionp,
time32_t prunetime,
@@ -615,14 +615,14 @@ CheckAndPruneInvIndexFile( bool_t checkonly,
printf(" processing index file \n"
" %s\n",idxFileName);
- fd = open_and_lock( idxFileName,
+ fd = open_and_lock(idxFileName,
FILE_WRITE,
- wait_for_locks );
+ wait_for_locks);
if (fd < 0) {
return -1;
}
- read_n_bytes( fd, &header, sizeof(invt_counter_t), idxFileName);
+ read_n_bytes(fd, &header, sizeof(invt_counter_t), idxFileName);
nEntries = header.ic_curnum;
temp = mmap_n_bytes(fd,
@@ -630,9 +630,9 @@ CheckAndPruneInvIndexFile( bool_t checkonly,
BOOL_FALSE, idxFileName);
counter = (invt_counter_t *)temp;
- invIndexEntry = (invt_entry_t *)( temp + sizeof(invt_counter_t));
+ invIndexEntry = (invt_entry_t *)(temp + sizeof(invt_counter_t));
- for (i=0; i < counter->ic_curnum; )
+ for (i=0; i < counter->ic_curnum;)
{
removeflag = BOOL_FALSE;
printf(" Checking access for\n"
@@ -644,7 +644,7 @@ CheckAndPruneInvIndexFile( bool_t checkonly,
ctime32(&(invIndexEntry[i].ie_timeperiod.tp_end)));
}
- if (( access( invIndexEntry[i].ie_filename, R_OK | W_OK ) == -1) &&
+ if ((access(invIndexEntry[i].ie_filename, R_OK | W_OK) == -1) &&
(errno == ENOENT))
{
printf(" Unable to access %s referred in %s\n",
@@ -660,7 +660,7 @@ CheckAndPruneInvIndexFile( bool_t checkonly,
if (removeflag == BOOL_TRUE)
{
- if ( counter->ic_curnum > 1 ) {
+ if (counter->ic_curnum > 1) {
bcopy((void *)&invIndexEntry[i + 1],
(void *)&invIndexEntry[i],
(sizeof(invt_entry_t) * (counter->ic_curnum - i - 1)));
@@ -673,18 +673,18 @@ CheckAndPruneInvIndexFile( bool_t checkonly,
validEntries = counter->ic_curnum;
- munmap( temp, (nEntries*sizeof(invt_entry_t)) + sizeof(invt_counter_t) );
+ munmap(temp, (nEntries*sizeof(invt_entry_t)) + sizeof(invt_counter_t));
if ((validEntries != 0) && (validEntries != nEntries)) {
if(debug) {
printf("ftruncate idx from %d to %d (%ld bytes)\n",
nEntries,
validEntries,
- (long) sizeof(invt_counter_t) + (validEntries * sizeof(invt_entry_t)) );
+ (long) sizeof(invt_counter_t) + (validEntries * sizeof(invt_entry_t)));
printf("- truncate %s\n", idxFileName);
}
- ftruncate( fd,
- sizeof(invt_counter_t) + (validEntries * sizeof(invt_entry_t)) );
+ ftruncate(fd,
+ sizeof(invt_counter_t) + (validEntries * sizeof(invt_entry_t)));
}
if (debug) {
@@ -693,14 +693,14 @@ CheckAndPruneInvIndexFile( bool_t checkonly,
validEntries);
}
- close( fd );
+ close(fd);
if (validEntries == 0)
{
if(debug) {
printf("unlink idx file %s\n", idxFileName);
}
- unlink( idxFileName );
+ unlink(idxFileName);
return(-1);
}
@@ -708,7 +708,7 @@ CheckAndPruneInvIndexFile( bool_t checkonly,
}
int
-CheckAndPruneStObjFile( bool_t checkonly,
+CheckAndPruneStObjFile(bool_t checkonly,
char *StObjFileName,
uuid_t *sessionp,
time32_t prunetime,
@@ -734,9 +734,9 @@ CheckAndPruneStObjFile( bool_t checkonly,
invt_sescounter_t *counter;
invt_sescounter_t header;
- fd = open_and_lock( StObjFileName,
+ fd = open_and_lock(StObjFileName,
FILE_WRITE,
- wait_for_locks );
+ wait_for_locks);
if (fd < 0) {
return -1;
}
@@ -751,11 +751,11 @@ CheckAndPruneStObjFile( bool_t checkonly,
temp = mmap_n_bytes(fd, sb.st_size, BOOL_FALSE, StObjFileName);
counter = (invt_sescounter_t *)temp;
- StObjhdr = (invt_seshdr_t *)( temp + sizeof(invt_sescounter_t));
+ StObjhdr = (invt_seshdr_t *)(temp + sizeof(invt_sescounter_t));
StObjses = (invt_session_t *)(temp + StObjhdr->sh_sess_off);
sescount = 0;
- for (i=0; i < counter->ic_curnum; ) {
+ for (i=0; i < counter->ic_curnum;) {
removeflag = BOOL_FALSE;
if (StObjhdr->sh_pruned)
prunedcount++;
@@ -788,37 +788,37 @@ CheckAndPruneStObjFile( bool_t checkonly,
ctime32(&StObjhdr->sh_time));
printf("\t\tdevice:\t\t%s\n", StObjses->s_devpath);
printf("\t\tsession label:\t\"%s\"\n", StObjses->s_label);
- uuid_unparse( StObjses->s_sesid, str );
+ uuid_unparse(StObjses->s_sesid, str);
printf("\t\tsession id:\t%s\n", str);
printf("\t\tlevel:\t\t%d\n", StObjhdr->sh_level);
- printf("\t\tstreams:\t%d\n", StObjses->s_cur_nstreams );
- for ( i = 0; i < (int) StObjses->s_cur_nstreams; i++ ) {
- printf( "\t\tstream %d:\n", i);
+ printf("\t\tstreams:\t%d\n", StObjses->s_cur_nstreams);
+ for (i = 0; i < (int) StObjses->s_cur_nstreams; i++) {
+ printf("\t\tstream %d:\n", i);
StObjstrm = (invt_stream_t *)(temp +
StObjhdr->sh_streams_off +
(i * sizeof(invt_stream_t)));
- printf( "\t\t\tpathname:\t%s\n",
+ printf("\t\t\tpathname:\t%s\n",
StObjstrm->st_cmdarg);
- printf( "\t\t\tinode start:\t%llu\n",
+ printf("\t\t\tinode start:\t%llu\n",
(unsigned long long) StObjstrm->st_startino.ino);
- printf( "\t\t\tinode end:\t%llu\n",
+ printf("\t\t\tinode end:\t%llu\n",
(unsigned long long) StObjstrm->st_endino.ino);
- printf( "\t\t\tinterrupted:\t%s\n",
- StObjstrm->st_interrupted ? "YES" : "NO" );
- printf( "\t\t\tmedia files:\t%d\n",
+ printf("\t\t\tinterrupted:\t%s\n",
+ StObjstrm->st_interrupted ? "YES" : "NO");
+ printf("\t\t\tmedia files:\t%d\n",
StObjstrm->st_nmediafiles);
- for ( j = 0; j < StObjstrm->st_nmediafiles; j++) {
+ for (j = 0; j < StObjstrm->st_nmediafiles; j++) {
StObjmed = (invt_mediafile_t *)(temp +
StObjstrm->st_firstmfile +
(j * sizeof(invt_mediafile_t)));
- printf( "\t\t\tmfile file %d:\n", j);
- printf( "\t\t\t\tmfile size:\t%lld\n",
+ printf("\t\t\tmfile file %d:\n", j);
+ printf("\t\t\t\tmfile size:\t%lld\n",
(long long) StObjmed->mf_size);
- printf( "\t\t\t\tmfile start:\t%llu\n",
+ printf("\t\t\t\tmfile start:\t%llu\n",
(unsigned long long) StObjmed->mf_startino.ino);
- printf( "\t\t\t\tmfile end:\t%llu\n",
+ printf("\t\t\t\tmfile end:\t%llu\n",
(unsigned long long) StObjmed->mf_endino.ino);
- printf( "\t\t\t\tmedia label:\t\"%s\"\n",
+ printf("\t\t\t\tmedia label:\t\"%s\"\n",
StObjmed->mf_label);
}
}
@@ -842,12 +842,12 @@ CheckAndPruneStObjFile( bool_t checkonly,
&& (uses_specified_mf_label(StObjhdr, StObjses, temp, r_mf_label))){
bool_t GotResponse = BOOL_FALSE;
- uuid_unparse( StObjses->s_sesid, str );
+ uuid_unparse(StObjses->s_sesid, str);
if(force) {
printf("-------------------------------------------------\n");
printf("Pruning this matching entry:\n");
- printf( "UUID\t\t:\t%s\nMOUNT POINT\t:\t%s\n"
+ printf("UUID\t\t:\t%s\nMOUNT POINT\t:\t%s\n"
"DEV PATH\t:\t%s\n"
"LABEL\t\t:\t%s\n"
"TIME OF DUMP\t:\t%s",
@@ -862,20 +862,20 @@ CheckAndPruneStObjFile( bool_t checkonly,
"DEV PATH\t:\t%s\nTIME OF DUMP\t:\t%s",
str, StObjses->s_mountpt, StObjses->s_devpath,
ctime32(&StObjhdr->sh_time));
- while ( GotResponse == BOOL_FALSE )
+ while (GotResponse == BOOL_FALSE)
{
char *chp;
printf("\nDo you want to prune this entry: [y/n] ");
- fgets( response, GEN_STRLEN, stdin );
- chp = strchr( response, '\n');
+ fgets(response, GEN_STRLEN, stdin);
+ chp = strchr(response, '\n');
if (chp)
*chp = '\0';
- if (strcasecmp( response, "Y" ) == 0) {
+ if (strcasecmp(response, "Y") == 0) {
removeflag = BOOL_TRUE;
GotResponse = BOOL_TRUE;
}
- else if (strcasecmp( response, "N" ) == 0) {
+ else if (strcasecmp(response, "N") == 0) {
GotResponse = BOOL_TRUE;
}
}
@@ -891,26 +891,26 @@ CheckAndPruneStObjFile( bool_t checkonly,
i++;
- StObjhdr = (invt_seshdr_t *)( temp + sizeof(invt_sescounter_t) +
- (i * sizeof(invt_seshdr_t)) );
+ StObjhdr = (invt_seshdr_t *)(temp + sizeof(invt_sescounter_t) +
+ (i * sizeof(invt_seshdr_t)));
StObjses = (invt_session_t *)(temp + StObjhdr->sh_sess_off);
}
validEntries = counter->ic_curnum - prunedcount - removedcount;
- munmap( temp, sb.st_size);
+ munmap(temp, sb.st_size);
if (debug && removedcount)
printf(" pruned %d entries from this StObj file,"
" %d remaining\n", removedcount, validEntries);
- close( fd );
+ close(fd);
if (validEntries == 0)
{
if (debug)
printf("Removing: %s\n", StObjFileName);
- unlink( StObjFileName );
+ unlink(StObjFileName);
return(-1);
}
@@ -938,10 +938,10 @@ uses_specified_mf_label(
if (!r_mf_label) {
return 1; /* prune */
}
- for ( s = 0; s < (int) StObjses->s_cur_nstreams; s++ ) {
+ for (s = 0; s < (int) StObjses->s_cur_nstreams; s++) {
StObjstrm = (invt_stream_t *)
(temp + StObjhdr->sh_streams_off + (s * sizeof(invt_stream_t)));
- for ( m = 0; m < StObjstrm->st_nmediafiles; m++, num_media_objects++) {
+ for (m = 0; m < StObjstrm->st_nmediafiles; m++, num_media_objects++) {
StObjmed = (invt_mediafile_t *)
(temp + StObjstrm->st_firstmfile + (m * sizeof(invt_mediafile_t)));
if (!strncmp(StObjmed->mf_label, r_mf_label,
@@ -963,7 +963,7 @@ uses_specified_mf_label(
/* copied from inv_api.c */
char *
-inv_DEBUG_lock_str( int c )
+inv_DEBUG_lock_str(int c)
{
#ifdef USE_LOCKF
static char *lockstr[] = {
@@ -1050,9 +1050,9 @@ open_and_lock(char * path, Open_t open_type, uint lock_wait_flag)
fd = open(path, open_mode);
if (fd < 0) {
- fprintf( stderr, "%s: open of %s failed.\n",
+ fprintf(stderr, "%s: open of %s failed.\n",
g_programName, path);
- perror( "open" );
+ perror("open");
return SYSCALL_FAILED;
}
@@ -1146,16 +1146,16 @@ mmap_n_bytes(int fd, size_t count, bool_t checkonly, char *path)
{
void * temp;
- lseek( fd, 0, SEEK_SET );
- temp = mmap( NULL, count,
+ lseek(fd, 0, SEEK_SET);
+ temp = mmap(NULL, count,
(checkonly == BOOL_TRUE) ? PROT_READ : PROT_READ|PROT_WRITE,
- MAP_SHARED, fd, 0 );
+ MAP_SHARED, fd, 0);
if (temp == (void *)-1) {
- fprintf( stderr, "%s: error in mmap of %ld bytes for file %s\n",
+ fprintf(stderr, "%s: error in mmap of %ld bytes for file %s\n",
g_programName, (long) count, path);
perror("mmap");
- fprintf( stderr, "%s: abnormal termination\n", g_programName );
+ fprintf(stderr, "%s: abnormal termination\n", g_programName);
exit(1);
}
return temp;
@@ -46,8 +46,8 @@ char * GetNameOfInvIndex (char *, uuid_t);
char * GetNameOfStobj (char *inv_path, char *filename);
void CheckAndPruneFstab(
char *, bool_t, char *, uuid_t *, uuid_t *, time32_t, char *);
-int CheckAndPruneInvIndexFile( bool_t, char *, uuid_t *, time32_t, char *);
-int CheckAndPruneStObjFile( bool_t, char *, uuid_t *, time32_t, char *);
+int CheckAndPruneInvIndexFile(bool_t, char *, uuid_t *, time32_t, char *);
+int CheckAndPruneStObjFile(bool_t, char *, uuid_t *, time32_t, char *);
int uses_specified_mf_label(
invt_seshdr_t *, invt_session_t *, char *, char *);
time32_t ParseDate(char *);
@@ -57,7 +57,7 @@ void read_n_bytes(int, void *, size_t, char *);
void write_n_bytes(int, void *, size_t, char *);
void * mmap_n_bytes(int, size_t, bool_t, char *);
void ListFstab(void);
-int ListInvIndexFile( char *);
+int ListInvIndexFile(char *);
int ListStObjFile(char *);
int invutil_interactive(char *, char *, uuid_t *, time32_t timeSecs);
int mntpnt_equal(char *s1, char *s2);
@@ -409,12 +409,12 @@ generate_stobj_menu(node_t *startnode, int level, char *StObjFileName)
return startnode;
}
- StObjhdr = (invt_seshdr_t *)( stobj_file[idx].mapaddr + sizeof(invt_sescounter_t));
+ StObjhdr = (invt_seshdr_t *)(stobj_file[idx].mapaddr + sizeof(invt_sescounter_t));
StObjses = (invt_session_t *)(stobj_file[idx].mapaddr + StObjhdr->sh_sess_off);
data_idx = 0;
n = startnode;
- for (i=0; i < stobj_file[idx].counter->ic_curnum; ) {
+ for (i=0; i < stobj_file[idx].counter->ic_curnum;) {
session = malloc(sizeof(*session));
if(session == NULL) {
fprintf(stderr, "%s: internal memory error: session malloc\n", g_programName);
@@ -453,7 +453,7 @@ generate_stobj_menu(node_t *startnode, int level, char *StObjFileName)
add_stobj_data(idx, session);
parent_session = n;
- for ( j = 0; j < (int) StObjses->s_cur_nstreams; j++ ) {
+ for (j = 0; j < (int) StObjses->s_cur_nstreams; j++) {
StObjstrm = (invt_stream_t *)(stobj_file[idx].mapaddr +
StObjhdr->sh_streams_off +
(j * sizeof(invt_stream_t)));
@@ -486,7 +486,7 @@ generate_stobj_menu(node_t *startnode, int level, char *StObjFileName)
add_stobj_data(idx, StObjstrm);
parent_stream = n;
- for ( k = 0; k < StObjstrm->st_nmediafiles; k++) {
+ for (k = 0; k < StObjstrm->st_nmediafiles; k++) {
StObjmed = (invt_mediafile_t *)(stobj_file[idx].mapaddr +
StObjstrm->st_firstmfile +
(k * sizeof(invt_mediafile_t)));
@@ -522,8 +522,8 @@ generate_stobj_menu(node_t *startnode, int level, char *StObjFileName)
i++;
- StObjhdr = (invt_seshdr_t *)( stobj_file[idx].mapaddr + sizeof(invt_sescounter_t) +
- (i * sizeof(invt_seshdr_t)) );
+ StObjhdr = (invt_seshdr_t *)(stobj_file[idx].mapaddr + sizeof(invt_sescounter_t) +
+ (i * sizeof(invt_seshdr_t)));
StObjses = (invt_session_t *)(stobj_file[idx].mapaddr + StObjhdr->sh_sess_off);
}
@@ -578,13 +578,13 @@ open_stobj(char *StObjFileName)
char *name;
errno=0;
- fd = open_and_lock( StObjFileName, FILE_WRITE, wait_for_locks );
+ fd = open_and_lock(StObjFileName, FILE_WRITE, wait_for_locks);
if (fd < 0) {
return fd;
}
read_n_bytes(fd, &cnt, sizeof(invt_sescounter_t), StObjFileName);
- lseek( fd, 0, SEEK_SET );
+ lseek(fd, 0, SEEK_SET);
errno = 0;
if (fstat(fd, &sb) < 0) {
fprintf(stderr, "Could not get stat info on %s\n", StObjFileName);
@@ -610,16 +610,16 @@ close_stobj_file(int fidx, int unlink_ok)
if(fidx >= stobj_numfiles || stobj_file[fidx].fd < 0)
return 0;
- munmap( stobj_file[fidx].mapaddr, stobj_file[fidx].size);
- close( stobj_file[fidx].fd );
+ munmap(stobj_file[fidx].mapaddr, stobj_file[fidx].size);
+ close(stobj_file[fidx].fd);
stobj_file[fidx].fd = -1;
if(unlink_ok == BOOL_TRUE) {
unlink(stobj_file[fidx].name);
}
- free( stobj_file[fidx].name );
- free( stobj_file[fidx].data );
+ free(stobj_file[fidx].name);
+ free(stobj_file[fidx].data);
stobj_file[fidx].name = NULL;
stobj_file[fidx].data = NULL;
@@ -641,15 +641,15 @@ close_all_stobj()
continue;
unlink_ok = BOOL_TRUE;
- StObjhdr = (invt_seshdr_t *)( stobj_file[i].mapaddr + sizeof(invt_sescounter_t));
- for(j = 0; j < stobj_file[i].counter->ic_curnum; ) {
+ StObjhdr = (invt_seshdr_t *)(stobj_file[i].mapaddr + sizeof(invt_sescounter_t));
+ for(j = 0; j < stobj_file[i].counter->ic_curnum;) {
if(StObjhdr->sh_pruned != 1) {
unlink_ok = BOOL_FALSE;
break;
}
j++;
- StObjhdr = (invt_seshdr_t *)( stobj_file[i].mapaddr + sizeof(invt_sescounter_t) +
- (j * sizeof(invt_seshdr_t)) );
+ StObjhdr = (invt_seshdr_t *)(stobj_file[i].mapaddr + sizeof(invt_sescounter_t) +
+ (j * sizeof(invt_seshdr_t)));
}
close_stobj_file(i, unlink_ok);
@@ -56,7 +56,7 @@ char *buf;
_rmt_abort(fildes);
- setoserror( EIO );
+ setoserror(EIO);
return(-1);
}
@@ -54,10 +54,10 @@ struct stat *buf;
static int
_rmt_fstat(int fildes, char *arg)
{
- char buffer[ BUFMAGIC ];
+ char buffer[BUFMAGIC];
int rc, cnt, adj_rc;
- sprintf( buffer, "Z%d\n", fildes );
+ sprintf(buffer, "Z%d\n", fildes);
/*
* grab the status and read it directly into the structure
@@ -83,7 +83,7 @@ _rmt_fstat(int fildes, char *arg)
{
abortit:
_rmt_abort(fildes);
- setoserror( EIO );
+ setoserror(EIO);
return(-1);
}
}
@@ -193,7 +193,7 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
if (RMTHOST(fildes) == UNAME_UNDEFINED) {
_rmt_msg(RMTWARN,
_("rmtioctl: remote host type not supported for MTIOCTOP\n"));
- setoserror( EPROTONOSUPPORT );
+ setoserror(EPROTONOSUPPORT);
return(-1);
}
@@ -201,7 +201,7 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
if (RMTHOST(fildes) == UNAME_IRIX) {
mt_op = mtop_irixmap[mt_op];
if (mt_op == -1) {
- setoserror( EINVAL );
+ setoserror(EINVAL);
return(-1);
}
}
@@ -209,7 +209,7 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
/* map the linux op code to the standard/fallback op code */
mt_op = mtop_stdmap[mt_op];
if (mt_op == -1) {
- setoserror( EINVAL );
+ setoserror(EINVAL);
return(-1);
}
}
@@ -248,7 +248,7 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
case UNAME_UNDEFINED:
_rmt_msg(RMTWARN,
_("rmtioctl: remote host type not supported for MTIOCGET\n"));
- setoserror( EPROTONOSUPPORT );
+ setoserror(EPROTONOSUPPORT);
return(-1);
case UNAME_IRIX:
if (sizeof(struct irix_mtget) != rc) {
@@ -256,7 +256,7 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
_("rmtioctl: IRIX mtget structure of wrong size"
" - got %d, wanted %d\n"),
rc, sizeof(struct irix_mtget));
- setoserror( EPROTONOSUPPORT );
+ setoserror(EPROTONOSUPPORT);
return(-1);
}
break;
@@ -273,12 +273,12 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
"- got %d, wanted %d or %d\n"),
rc, sizeof(struct linux32_mtget),
sizeof(struct linux64_mtget));
- setoserror( EPROTONOSUPPORT );
+ setoserror(EPROTONOSUPPORT);
return(-1);
}
break;
default:
- setoserror( EPROTONOSUPPORT );
+ setoserror(EPROTONOSUPPORT);
return(-1);
}
@@ -303,7 +303,7 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
cnt = read(READ(fildes), p, ssize);
if (cnt <= 0) {
_rmt_abort(fildes);
- setoserror( EIO );
+ setoserror(EIO);
return(-1);
}
}
@@ -421,7 +421,7 @@ _rmt_ioctl(int fildes, unsigned int op, void *arg)
}
else {
- setoserror( EINVAL );
+ setoserror(EINVAL);
return(-1);
}
}
@@ -120,7 +120,7 @@ static int _rmt_open (char *path, int oflag, int mode)
if (i == MAXUNIT)
{
- setoserror( EMFILE );
+ setoserror(EMFILE);
return(-1);
}
@@ -144,7 +144,7 @@ static int _rmt_open (char *path, int oflag, int mode)
}
else
{
- for ( user = login; (*sys = *user); user++, sys++ )
+ for (user = login; (*sys = *user); user++, sys++)
;
user = login;
}
@@ -47,7 +47,7 @@ int fildes;
if (read(READ(fildes), cp, 1) != 1)
{
_rmt_abort(fildes);
- setoserror( EIO );
+ setoserror(EIO);
return(-1);
}
if (*cp == '\n')
@@ -60,7 +60,7 @@ int fildes;
if (i == BUFMAGIC)
{
_rmt_abort(fildes);
- setoserror( EIO );
+ setoserror(EIO);
return(-1);
}
@@ -74,7 +74,7 @@ int fildes;
if (*cp == 'E' || *cp == 'F')
{
- setoserror( atoi(cp + 1) );
+ setoserror(atoi(cp + 1));
while (read(READ(fildes), &c, 1) == 1)
if (c == '\n')
break;
@@ -92,7 +92,7 @@ int fildes;
if (*cp != 'A')
{
_rmt_abort(fildes);
- setoserror( EIO );
+ setoserror(EIO);
return(-1);
}
@@ -67,6 +67,6 @@ static int _rmt_write(int fildes, char *buf, unsigned int nbyte)
}
_rmt_abort(fildes);
- setoserror( EIO );
+ setoserror(EIO);
return(-1);
}
@@ -28,33 +28,33 @@
#include "bag.h"
bag_t *
-bag_alloc( void )
+bag_alloc(void)
{
bag_t *bagp;
- bagp = ( bag_t * )calloc( 1, sizeof( bag_t ));
- assert( bagp );
+ bagp = (bag_t *)calloc(1, sizeof(bag_t));
+ assert(bagp);
return bagp;
}
void
-bag_insert( bag_t *bagp,
+bag_insert(bag_t *bagp,
bagelem_t *newp,
size64_t key,
- void *payloadp )
+ void *payloadp)
{
register bagelem_t *nextp;
register bagelem_t *prevp;
- assert( ! newp->be_loaded );
+ assert(! newp->be_loaded);
newp->be_loaded = BOOL_TRUE;
- assert( ! newp->be_bagp );
+ assert(! newp->be_bagp);
newp->be_bagp = bagp;
newp->be_key = key;
newp->be_payloadp = payloadp;
- if ( bagp->b_headp ) {
+ if (bagp->b_headp) {
nextp = bagp->b_headp;
prevp = bagp->b_headp->be_prevp;
} else {
@@ -71,16 +71,16 @@ bag_insert( bag_t *bagp,
}
void
-bag_remove( bag_t *bagp,
+bag_remove(bag_t *bagp,
bagelem_t *oldp,
size64_t *keyp,
- void **payloadpp )
+ void **payloadpp)
{
register bagelem_t *nextp;
register bagelem_t *prevp;
- assert( oldp->be_loaded );
- assert( oldp->be_bagp == bagp );
+ assert(oldp->be_loaded);
+ assert(oldp->be_bagp == bagp);
nextp = oldp->be_nextp;
prevp = oldp->be_prevp;
@@ -88,9 +88,9 @@ bag_remove( bag_t *bagp,
nextp->be_prevp = prevp;
prevp->be_nextp = nextp;
- if ( bagp->b_headp == oldp ) {
- if ( nextp == oldp ) {
- assert( prevp == oldp );
+ if (bagp->b_headp == oldp) {
+ if (nextp == oldp) {
+ assert(prevp == oldp);
bagp->b_headp = 0;
} else {
bagp->b_headp = nextp;
@@ -100,29 +100,29 @@ bag_remove( bag_t *bagp,
*keyp = oldp->be_key;
*payloadpp = oldp->be_payloadp;
- memset( ( void * )oldp, 0, sizeof( bagelem_t ));
+ memset((void *)oldp, 0, sizeof(bagelem_t));
}
bagelem_t *
-bag_find( bag_t *bagp,
+bag_find(bag_t *bagp,
size64_t key,
- void **payloadpp )
+ void **payloadpp)
{
register bagelem_t *p;
- for ( p = bagp->b_headp
+ for (p = bagp->b_headp
;
p && p->be_nextp != bagp->b_headp && p->be_key != key
;
- p = p->be_nextp )
+ p = p->be_nextp)
;
- if ( ! p || p->be_key != key ) {
+ if (! p || p->be_key != key) {
*payloadpp = 0;
return 0;
} else {
- assert( p->be_loaded );
- assert( p->be_bagp == bagp );
+ assert(p->be_loaded);
+ assert(p->be_bagp == bagp);
*payloadpp = p->be_payloadp;
return p;
}
@@ -130,10 +130,10 @@ bag_find( bag_t *bagp,
void
-bagiter_init( bag_t *bagp, bagiter_t *iterp )
+bagiter_init(bag_t *bagp, bagiter_t *iterp)
{
iterp->bi_bagp = bagp;
- if ( ! bagp->b_headp ) {
+ if (! bagp->b_headp) {
iterp->bi_nextp = 0;
return;
}
@@ -142,13 +142,13 @@ bagiter_init( bag_t *bagp, bagiter_t *iterp )
}
bagelem_t *
-bagiter_next( bagiter_t *iterp, void **payloadpp )
+bagiter_next(bagiter_t *iterp, void **payloadpp)
{
bagelem_t *returnp;
/* termination condition
*/
- if ( ! iterp->bi_nextp ) {
+ if (! iterp->bi_nextp) {
*payloadpp = 0;
return 0;
}
@@ -159,7 +159,7 @@ bagiter_next( bagiter_t *iterp, void **payloadpp )
/* calculate next. if returning last, set next to NULL
*/
- if ( iterp->bi_nextp == iterp->bi_lastp ) {
+ if (iterp->bi_nextp == iterp->bi_lastp) {
iterp->bi_nextp = 0;
} else {
iterp->bi_nextp = iterp->bi_nextp->be_nextp;
@@ -170,21 +170,21 @@ bagiter_next( bagiter_t *iterp, void **payloadpp )
}
void
-bag_free( bag_t *bagp )
+bag_free(bag_t *bagp)
{
register bagelem_t *p;
p = bagp->b_headp;
- while ( p ) {
+ while (p) {
register bagelem_t *nextp = p->be_nextp;
- memset( ( void * )p, 0, sizeof( bagelem_t ));
+ memset((void *)p, 0, sizeof(bagelem_t));
p = nextp;
- if ( p == bagp->b_headp ) {
+ if (p == bagp->b_headp) {
break;
}
- assert( p );
+ assert(p);
}
- memset( ( void * )bagp, 0, sizeof( bag_t ));
- free( ( void * )bagp );
+ memset((void *)bagp, 0, sizeof(bag_t));
+ free((void *)bagp);
}
@@ -45,32 +45,32 @@ typedef struct bag bag_t;
/* creates a new bag
*/
-extern bag_t *bag_alloc( void );
+extern bag_t *bag_alloc(void);
/* insert the item into the bag. the caller supplies a search key
* and arbitrary payload.
*/
-extern void bag_insert( bag_t *bagp,
+extern void bag_insert(bag_t *bagp,
bagelem_t *bagelemp,
size64_t key,
- void *payloadp );
+ void *payloadp);
/* remove the item from the bag. the key and payload originally supplied
* to the insert operator are returned by reference.
*/
-extern void bag_remove( bag_t *bagp,
+extern void bag_remove(bag_t *bagp,
bagelem_t *bagelemp,
size64_t *keyp,
- void **payloadpp );
+ void **payloadpp);
/* search by key for an element in the bag.
* returns the element pointer if a matching item is found, as well as
* the payload (by reference). if the item is not in the bag, returns
* a null pointer and (by reference) payload.
*/
-extern bagelem_t *bag_find( bag_t *bagp,
+extern bagelem_t *bag_find(bag_t *bagp,
size64_t key,
- void **payloadpp );
+ void **payloadpp);
/* private bag iterator
*/
@@ -84,15 +84,15 @@ typedef struct bagiter bagiter_t;
/* initializes a bag iterator
*/
-extern void bagiter_init( bag_t *bagp, bagiter_t *iterp );
+extern void bagiter_init(bag_t *bagp, bagiter_t *iterp);
/* returns the next element in the bag. caller may remove the element
* prior to the next call.
*/
-extern bagelem_t * bagiter_next( bagiter_t *iterp, void **payloadpp );
+extern bagelem_t * bagiter_next(bagiter_t *iterp, void **payloadpp);
/* destroys the bag.
*/
-extern void bag_free( bag_t *bagp );
+extern void bag_free(bag_t *bagp);
#endif /* BAG_H */
Transform "( x, y )" to "(x, y)", and the same for []. Created by this script: ***** #!/usr/bin/env bash # transform 'foo( x, y )' -> 'foo(x, y)' set -euo pipefail # regexps in order: # - remove spaces after opening parentheses ( # - remove spaces after opening brackets [ # - remove spaces before closing parentheses ) # - remove spaces before closing brackets ] # # Run multiple iterations to get all overlapping matches. for i in {1..8}; do echo "iteration $i" find . -name '*.[ch]' ! -type d -exec gawk -i inplace '{ $0 = gensub(/^([^"]*)\(\s+/, "\\1(", "g") $0 = gensub(/^([^"]*)\[\s+/, "\\1[", "g") $0 = gensub(/(\S)\s+\)([^"]*)$/, "\\1)\\2", "g") $0 = gensub(/(\S)\s+\]([^"]*)$/, "\\1]\\2", "g") }; {print }' {} \; done # Revert changes in defines that would cause redefinition error sed -i \ -e 's/^#define sizeofmember.*$/#define sizeofmember( t, m )\tsizeof( ( ( t * )0 )->m )/' \ -e 's/^#define offsetofmember.*$/#define offsetofmember( t, m )\t( ( size_t )( char * )\&( ( ( t * )0 )->m ) )/' \ common/types.h ***** Signed-off-by: Jan Tulak <jtulak@redhat.com> --- inventory/inv_stobj.c | 746 +++++++++++++++++++++--------------------- inventory/inventory.h | 28 +- inventory/testmain.c | 236 ++++++------- invutil/cmenu.h | 24 +- invutil/fstab.c | 12 +- invutil/invidx.c | 76 ++--- invutil/invutil.c | 246 +++++++------- invutil/invutil.h | 6 +- invutil/stobj.c | 32 +- librmt/rmtcommand.c | 2 +- librmt/rmtfstat.c | 6 +- librmt/rmtioctl.c | 18 +- librmt/rmtopen.c | 4 +- librmt/rmtstatus.c | 8 +- librmt/rmtwrite.c | 2 +- restore/bag.c | 70 ++-- restore/bag.h | 20 +- 17 files changed, 768 insertions(+), 768 deletions(-)