/*
|
* Create a squashfs filesystem. This is a highly compressed read only
|
* filesystem.
|
*
|
* Copyright (c) 2013, 2014
|
* Phillip Lougher <phillip@squashfs.org.uk>
|
*
|
* This program is free software; you can redistribute it and/or
|
* modify it under the terms of the GNU General Public License
|
* as published by the Free Software Foundation; either version 2,
|
* or (at your option) any later version.
|
*
|
* This program is distributed in the hope that it will be useful,
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
* GNU General Public License for more details.
|
*
|
* You should have received a copy of the GNU General Public License
|
* along with this program; if not, write to the Free Software
|
* Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
|
*
|
* info.c
|
*/
|
|
#include <pthread.h>
|
#include <sys/ioctl.h>
|
#include <unistd.h>
|
#include <signal.h>
|
#include <sys/time.h>
|
#include <stdio.h>
|
#include <math.h>
|
#include <stdarg.h>
|
#include <errno.h>
|
#include <stdlib.h>
|
#include <dirent.h>
|
#include <sys/types.h>
|
#include <sys/stat.h>
|
#include <string.h>
|
|
#include "squashfs_fs.h"
|
#include "mksquashfs.h"
|
#include "error.h"
|
#include "progressbar.h"
|
#include "caches-queues-lists.h"
|
|
static int silent = 0;
|
static struct dir_ent *ent = NULL;
|
|
pthread_t info_thread;
|
|
|
void disable_info()
|
{
|
ent = NULL;
|
}
|
|
|
void update_info(struct dir_ent *dir_ent)
|
{
|
ent = dir_ent;
|
}
|
|
|
void print_filename()
|
{
|
struct dir_ent *dir_ent = ent;
|
|
if(dir_ent == NULL)
|
return;
|
|
if(dir_ent->our_dir->subpath[0] != '\0')
|
INFO("%s/%s\n", dir_ent->our_dir->subpath, dir_ent->name);
|
else
|
INFO("/%s\n", dir_ent->name);
|
}
|
|
|
void dump_state()
|
{
|
disable_progress_bar();
|
|
printf("Queue and Cache status dump\n");
|
printf("===========================\n");
|
|
printf("file buffer queue (reader thread -> deflate thread(s))\n");
|
dump_queue(to_deflate);
|
|
printf("uncompressed fragment queue (reader thread -> fragment"
|
" thread(s))\n");
|
dump_queue(to_process_frag);
|
|
printf("processed fragment queue (fragment thread(s) -> main"
|
" thread)\n");
|
dump_seq_queue(to_main, 1);
|
|
printf("compressed block queue (deflate thread(s) -> main thread)\n");
|
dump_seq_queue(to_main, 0);
|
|
printf("uncompressed packed fragment queue (main thread -> fragment"
|
" deflate thread(s))\n");
|
dump_queue(to_frag);
|
|
|
printf("locked frag queue (compressed frags waiting while multi-block"
|
" file is written)\n");
|
dump_queue(locked_fragment);
|
|
printf("compressed block queue (main & fragment deflate threads(s) ->"
|
" writer thread)\n");
|
dump_queue(to_writer);
|
|
printf("read cache (uncompressed blocks read by reader thread)\n");
|
dump_cache(reader_buffer);
|
|
printf("block write cache (compressed blocks waiting for the writer"
|
" thread)\n");
|
dump_cache(bwriter_buffer);
|
printf("fragment write cache (compressed fragments waiting for the"
|
" writer thread)\n");
|
dump_cache(fwriter_buffer);
|
|
printf("fragment cache (frags waiting to be compressed by fragment"
|
" deflate thread(s))\n");
|
dump_cache(fragment_buffer);
|
|
printf("fragment reserve cache (avoids pipeline stall if frag cache"
|
" full in dup check)\n");
|
dump_cache(reserve_cache);
|
|
enable_progress_bar();
|
}
|
|
|
void *info_thrd(void *arg)
|
{
|
sigset_t sigmask;
|
int sig, err, waiting = 0;
|
|
sigemptyset(&sigmask);
|
sigaddset(&sigmask, SIGQUIT);
|
sigaddset(&sigmask, SIGHUP);
|
sigaddset(&sigmask, SIGALRM);
|
|
while(1) {
|
err = sigwait(&sigmask, &sig);
|
|
if(err == -1) {
|
switch(errno) {
|
case EINTR:
|
continue;
|
default:
|
BAD_ERROR("sigwait failed "
|
"because %s\n", strerror(errno));
|
}
|
}
|
|
if(sig == SIGQUIT && !waiting) {
|
print_filename();
|
|
/* set one second interval period, if ^\ received
|
within then, dump queue and cache status */
|
waiting = 1;
|
alarm(1);
|
} else if (sig == SIGQUIT) {
|
dump_state();
|
} else if (sig == SIGALRM) {
|
waiting = 0;
|
}
|
}
|
}
|
|
|
void init_info()
|
{
|
pthread_create(&info_thread, NULL, info_thrd, NULL);
|
}
|
