size_t filename_len;
ssize_t wr;
size_t total_write;
- if ((adc->do_stop || should_stop (adc)) && reason != GNUNET_DIR_SCANNER_ASKED_TO_STOP
- && reason != GNUNET_DIR_SCANNER_FINISHED)
+ if ((adc->do_stop || should_stop (adc)) && reason != GNUNET_FS_DIRSCANNER_ASKED_TO_STOP
+ && reason != GNUNET_FS_DIRSCANNER_FINISHED)
return 1;
total_write = 0;
wr = 1;
if (0 != STAT (filename, &sbuf))
{
(void) write_progress (adc, filename, S_ISDIR (sbuf.st_mode),
- GNUNET_DIR_SCANNER_DOES_NOT_EXIST);
+ GNUNET_FS_DIRSCANNER_DOES_NOT_EXIST);
return GNUNET_OK;
}
/* Report the progress */
do_stop = write_progress (adc, filename, S_ISDIR (sbuf.st_mode),
- GNUNET_DIR_SCANNER_NEW_FILE);
+ GNUNET_FS_DIRSCANNER_NEW_FILE);
if (do_stop)
{
/* We were asked to stop, acknowledge that and return */
(void) write_progress (adc, filename, S_ISDIR (sbuf.st_mode),
- GNUNET_DIR_SCANNER_ASKED_TO_STOP);
+ GNUNET_FS_DIRSCANNER_ASKED_TO_STOP);
return GNUNET_SYSERR;
}
if (adc->plugins != NULL)
EXTRACTOR_plugin_remove_all (adc->plugins);
/* Tell the initiator that we're finished, it can now join the thread */
- write_progress (adc, NULL, 0, GNUNET_DIR_SCANNER_FINISHED);
+ write_progress (adc, NULL, 0, GNUNET_FS_DIRSCANNER_FINISHED);
return 0;
}
if (!(tc->reason & GNUNET_SCHEDULER_REASON_READ_READY))
{
- ds->progress_callback (ds->cls, ds, NULL, 0, GNUNET_DIR_SCANNER_SHUTDOWN);
+ ds->progress_callback (ds->cls, ds, NULL, 0, GNUNET_FS_DIRSCANNER_SHUTDOWN);
return;
}
total_read += rd;
}
if (total_read != sizeof (reason)
- || reason <= GNUNET_DIR_SCANNER_FIRST
- || reason >= GNUNET_DIR_SCANNER_LAST)
+ || reason <= GNUNET_FS_DIRSCANNER_FIRST
+ || reason >= GNUNET_FS_DIRSCANNER_LAST)
{
end_it = 1;
- reason = GNUNET_DIR_SCANNER_PROTOCOL_ERROR;
+ reason = GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR;
}
if (!end_it)
if (rd != sizeof (size_t))
{
end_it = 1;
- reason = GNUNET_DIR_SCANNER_PROTOCOL_ERROR;
+ reason = GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR;
}
}
if (!end_it)
else if (filename_len > PATH_MAX)
{
end_it = 1;
- reason = GNUNET_DIR_SCANNER_PROTOCOL_ERROR;
+ reason = GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR;
}
}
if (!end_it)
if (rd != filename_len)
{
GNUNET_free (filename);
- reason = GNUNET_DIR_SCANNER_PROTOCOL_ERROR;
+ reason = GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR;
end_it = 1;
}
}
if (rd != sizeof (char))
{
GNUNET_free (filename);
- reason = GNUNET_DIR_SCANNER_PROTOCOL_ERROR;
+ reason = GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR;
end_it = 1;
}
}
struct GNUNET_DISK_PipeHandle *progress_pipe;
int ok;
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Starting to scan directory `%s'\n",
+ filename);
if (0 != STAT (filename, &sbuf))
return NULL;
ds->progress_read = GNUNET_DISK_pipe_handle (progress_pipe,
GNUNET_DISK_PIPE_END_READ);
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Creating thread to scan directory `%s'\n",
+ filename);
+
#if WINDOWS
ds->thread = CreateThread (NULL, 0,
(LPTHREAD_START_ROUTINE) &run_directory_scan_thread, (LPVOID) adc,
{
switch (reason)
{
- case GNUNET_DIR_SCANNER_NEW_FILE:
+ case GNUNET_FS_DIRSCANNER_NEW_FILE:
if (filename != NULL)
{
if (is_directory)
FPRINTF (stdout, _("Scanning file `%s'.\n"), filename);
}
break;
- case GNUNET_DIR_SCANNER_DOES_NOT_EXIST:
+ case GNUNET_FS_DIRSCANNER_DOES_NOT_EXIST:
if (filename != NULL)
{
FPRINTF (stdout,
filename);
}
break;
- case GNUNET_DIR_SCANNER_ASKED_TO_STOP:
+ case GNUNET_FS_DIRSCANNER_ASKED_TO_STOP:
if (filename != NULL)
{
FPRINTF (stdout,
else
FPRINTF (stdout, "%s", _("Scanner is stopping.\n"));
break;
- case GNUNET_DIR_SCANNER_SHUTDOWN:
+ case GNUNET_FS_DIRSCANNER_SHUTDOWN:
FPRINTF (stdout, "%s", _("Client is shutting down.\n"));
break;
- case GNUNET_DIR_SCANNER_FINISHED:
+ case GNUNET_FS_DIRSCANNER_FINISHED:
FPRINTF (stdout, "%s", _("Scanner has finished.\n"));
break;
- case GNUNET_DIR_SCANNER_PROTOCOL_ERROR:
+ case GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR:
FPRINTF (stdout, "%s",
_("There was a failure communicating with the scanner.\n"));
break;
filename);
break;
}
- if ((filename == NULL && GNUNET_DIR_SCANNER_FINISHED)
- || reason == GNUNET_DIR_SCANNER_PROTOCOL_ERROR
- || reason == GNUNET_DIR_SCANNER_SHUTDOWN)
+ if ((filename == NULL && GNUNET_FS_DIRSCANNER_FINISHED)
+ || reason == GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR
+ || reason == GNUNET_FS_DIRSCANNER_SHUTDOWN)
{
/* Any of this causes us to try to clean up the scanner */
directory_scan_intermediary_result = GNUNET_FS_directory_scan_cleanup (ds);
enum GNUNET_FS_DirScannerProgressUpdateReason
{
- GNUNET_DIR_SCANNER_FIRST = 0,
- GNUNET_DIR_SCANNER_NEW_FILE = 1,
- GNUNET_DIR_SCANNER_DOES_NOT_EXIST = 2,
- GNUNET_DIR_SCANNER_ASKED_TO_STOP = 3,
- GNUNET_DIR_SCANNER_FINISHED = 4,
- GNUNET_DIR_SCANNER_PROTOCOL_ERROR = 5,
- GNUNET_DIR_SCANNER_SHUTDOWN = 6,
- GNUNET_DIR_SCANNER_LAST = 7
+ GNUNET_FS_DIRSCANNER_FIRST = 0,
+ GNUNET_FS_DIRSCANNER_NEW_FILE = 1,
+ GNUNET_FS_DIRSCANNER_DOES_NOT_EXIST = 2,
+ GNUNET_FS_DIRSCANNER_ASKED_TO_STOP = 3,
+ GNUNET_FS_DIRSCANNER_FINISHED = 4,
+ GNUNET_FS_DIRSCANNER_PROTOCOL_ERROR = 5,
+ GNUNET_FS_DIRSCANNER_SHUTDOWN = 6,
+ GNUNET_FS_DIRSCANNER_LAST = 7
};