fd.c File Reference

#include <stdio.h>
#include <fcntl.h>
#include <unistd.h>
#include <pthread.h>
#include "internal.h"
#include <spawn.h>

Include dependency graph for fd.c:

Go to the source code of this file.

Macros
#define	NCPOLLEVENTS   (POLLIN)

Functions
ncfdplane *	ncfdplane_create (ncplane *n, const ncfdplane_options *opts, int fd, ncfdplane_callback cbfxn, ncfdplane_done_cb donecbfxn)
ncplane *	ncfdplane_plane (ncfdplane *n)
int	ncfdplane_destroy (ncfdplane *n)
ncsubproc *	ncsubproc_createv (ncplane *n, const ncsubproc_options *opts, const char *bin, const char *const arg[], ncfdplane_callback cbfxn, ncfdplane_done_cb donecbfxn)
ncsubproc *	ncsubproc_createvp (ncplane *n, const ncsubproc_options *opts, const char *bin, const char *const arg[], ncfdplane_callback cbfxn, ncfdplane_done_cb donecbfxn)
ncsubproc *	ncsubproc_createvpe (ncplane *n, const ncsubproc_options *opts, const char *bin, const char *const arg[], const char *const env[], ncfdplane_callback cbfxn, ncfdplane_done_cb donecbfxn)
int	ncsubproc_destroy (ncsubproc *n)
ncplane *	ncsubproc_plane (ncsubproc *n)
int	get_tty_fd (FILE *ttyfp)

Macro Definition Documentation

NCPOLLEVENTS

#define NCPOLLEVENTS   (POLLIN)

Definition at line 23 of file fd.c.

Function Documentation

get_tty_fd()

int get_tty_fd

(

FILE *

ttyfp

)

Definition at line 455 of file fd.c.

                           {
  int fd = -1;
  if(ttyfp){
    if((fd = fileno(ttyfp)) < 0){
      logwarn("no file descriptor was available in outfp %p", ttyfp);
    }else{
      if(tty_check(fd)){
        fd = dup(fd);
      }else{
        loginfo("fd %d is not a TTY", fd);
        fd = -1;
      }
    }
  }
  if(fd < 0){
    fd = open("/dev/tty", O_RDWR | O_CLOEXEC | O_NOCTTY);
    if(fd < 0){
      loginfo("couldn't open /dev/tty (%s)", strerror(errno));
    }else{
      if(!tty_check(fd)){
        loginfo("file descriptor for /dev/tty (%d) is not actually a TTY", fd);
        close(fd);
        fd = -1;
      }
    }
  }
  if(fd >= 0){
    loginfo("returning TTY fd %d", fd);
  }
  return fd;
}

Here is the caller graph for this function:

ncfdplane_create()

ncfdplane * ncfdplane_create	(	ncplane *	n,
		const ncfdplane_options *	opts,
		int	fd,
		ncfdplane_callback	cbfxn,
		ncfdplane_done_cb	donecbfxn
	)

Definition at line 120 of file fd.c.

                                                                                  {
  ncfdplane_options zeroed = {0};
  if(!opts){
    opts = &zeroed;
  }
  if(fd < 0 || !cbfxn || !donecbfxn){
    return NULL;
  }
  return ncfdplane_create_internal(n, opts, fd, cbfxn, donecbfxn, true);
}

ncfdplane_destroy()

int ncfdplane_destroy

(

ncfdplane *

n

)

Definition at line 136 of file fd.c.

                                   {
  int ret = 0;
  if(n){
    if(pthread_equal(pthread_self(), n->tid)){
      n->destroyed = true; // ncfdplane_destroy_inner() is called on thread exit
    }else{
      void* vret = NULL;
      ret |= cancel_and_join("fdplane", n->tid, &vret);
      ret |= ncfdplane_destroy_inner(n);
    }
  }
  return ret;
}

Here is the caller graph for this function:

ncfdplane_plane()

ncplane * ncfdplane_plane

(

ncfdplane *

n

)

Definition at line 132 of file fd.c.

                                      {
  return n->ncp;
}

Here is the caller graph for this function:

ncsubproc_createv()

ncsubproc * ncsubproc_createv	(	ncplane *	n,
		const ncsubproc_options *	opts,
		const char *	bin,
		const char *const	arg[],
		ncfdplane_callback	cbfxn,
		ncfdplane_done_cb	donecbfxn
	)

Definition at line 383 of file fd.c.

                                                                                   {
  return ncexecvpe(n, opts, 0, bin, (char* const *)arg, NULL, cbfxn, donecbfxn);
}

ncsubproc_createvp()

ncsubproc * ncsubproc_createvp	(	ncplane *	n,
		const ncsubproc_options *	opts,
		const char *	bin,
		const char *const	arg[],
		ncfdplane_callback	cbfxn,
		ncfdplane_done_cb	donecbfxn
	)

Definition at line 389 of file fd.c.

                                                                                    {
  return ncexecvpe(n, opts, 1, bin, (char* const *)arg, NULL, cbfxn, donecbfxn);
}

ncsubproc_createvpe()

ncsubproc * ncsubproc_createvpe	(	ncplane *	n,
		const ncsubproc_options *	opts,
		const char *	bin,
		const char *const	arg[],
		const char *const	env[],
		ncfdplane_callback	cbfxn,
		ncfdplane_done_cb	donecbfxn
	)

Definition at line 395 of file fd.c.

                                                                             {
  return ncexecvpe(n, opts, 1, bin, (char* const *)arg, (char* const*)env, cbfxn, donecbfxn);
}

ncsubproc_destroy()

int ncsubproc_destroy

(

ncsubproc *

n

)

Definition at line 402 of file fd.c.

                                   {
  int ret = 0;
  if(n){
    void* vret = NULL;
//fprintf(stderr, "pid: %u pidfd: %d waittid: %u\n", n->pid, n->pidfd, n->waittid);
#ifndef __MINGW32__
#ifdef USING_PIDFD
    if(n->pidfd >= 0){
      loginfo("sending SIGKILL to pidfd %d", n->pidfd);
      if(syscall(__NR_pidfd_send_signal, n->pidfd, SIGKILL, NULL, 0)){
        kill(n->pid, SIGKILL);
      }
    }
#else
    pthread_mutex_lock(&n->lock);
    if(!n->waited){
      loginfo("sending SIGKILL to PID %d", n->pid);
      kill(n->pid, SIGKILL);
    }
    pthread_mutex_unlock(&n->lock);
#endif
#endif
    // the thread waits on the subprocess via pidfd (iff pidfd >= 0), and
    // then exits. don't try to cancel the thread in that case; rely instead on
    // killing the subprocess.
    if(n->pidfd < 0){
      pthread_cancel(n->nfp->tid);
      // shouldn't need a cancellation of waittid thanks to SIGKILL
      pthread_join(n->waittid, &vret);
    }
    if(vret == NULL){
      pthread_join(n->nfp->tid, &vret);
    }else{
      pthread_join(n->nfp->tid, NULL);
    }
    pthread_mutex_destroy(&n->lock);
    free(n);
    if(vret == NULL){
      ret = -1;
    }else if(vret != PTHREAD_CANCELED){
      ret = *(int*)vret;
      free(vret);
    }
  }
  return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

ncsubproc_plane()

ncplane * ncsubproc_plane

(

ncsubproc *

n

)

Definition at line 449 of file fd.c.

                                      {
  return n->nfp->ncp;
}

Here is the caller graph for this function: