Function DoInteractive

tools/ngctl/main.c:331–391

* Here we start a thread, that will monitor the netgraph * sockets and catch any unexpected messages or data on them, * that can arrive while user edits his/her commands. * * Whenever we expect data on netgraph sockets, we send signal * to monitoring thread. The signal forces it to exit select() * system call and sleep on condvar until we wake it. While * monitoring thread sleeps, we can do

 * sockets.
 */
static int
DoInteractive(void)
{
#ifndef FSTACK
	pthread_t monitor;
#endif
	EditLine *el;
	History *hist;
	HistEvent hev = { 0, "" };

	(*help_cmd.func)(0, NULL);
#ifndef FSTACK
	pthread_create(&monitor, NULL, Monitor, NULL);
#endif
	el = el_init(getprogname(), stdin, stdout, stderr);
	if (el == NULL)
		return (CMDRTN_ERROR);
	el_set(el, EL_PROMPT, Prompt);
	el_set(el, EL_SIGNAL, 1);
	el_set(el, EL_EDITOR, "emacs");
	hist = history_init();
	if (hist == NULL)
		return (CMDRTN_ERROR);
	history(hist, &hev, H_SETSIZE, 100);
	history(hist, &hev, H_SETUNIQUE, 1);
	el_set(el, EL_HIST, history, (const char *)hist);
	el_source(el, NULL);

	for (;;) {
		const char *buf;
		int count;

		if ((buf = el_gets(el, &count)) == NULL) {
			printf("\n");
			break;
		}
		history(hist, &hev, H_ENTER, buf);
#ifndef FSTACK
		pthread_kill(monitor, SIGUSR1);
		pthread_mutex_lock(&mutex);
#endif
		if (DoParseCommand(buf) == CMDRTN_QUIT) {
#ifndef FSTACK
			pthread_mutex_unlock(&mutex);
#endif
			break;
		}
#ifndef FSTACK
		pthread_cond_signal(&cond);
		pthread_mutex_unlock(&mutex);
#endif
	}

	history_end(hist);
	el_end(el);
#ifndef FSTACK
	pthread_cancel(monitor);
#endif