in.c File Reference

#include <stdio.h>
#include <fcntl.h>
#include <unistd.h>
#include "automaton.h"
#include "internal.h"
#include "unixsig.h"
#include "render.h"
#include "in.h"

Include dependency graph for in.c:

Go to the source code of this file.

Data Structures
struct	cursorloc
struct	inputctx

Typedefs
typedef struct cursorloc	cursorloc
typedef int	ipipe
typedef struct inputctx	inputctx

Functions
void	sigwinch_handler (int signo)
int	ncinput_shovel (inputctx *ictx, const void *buf, int len)
int	init_inputlayer (tinfo *ti, FILE *infp, int lmargin, int tmargin, int rmargin, int bmargin, ncsharedstats *stats, unsigned drain, int linesigs_enabled)
int	stop_inputlayer (tinfo *ti)
int	inputready_fd (const inputctx *ictx)
uint32_t	notcurses_get (notcurses *nc, const struct timespec *absdl, ncinput *ni)
int	notcurses_getvec (notcurses *n, const struct timespec *absdl, ncinput *ni, int vcount)
uint32_t	ncdirect_get (ncdirect *n, const struct timespec *absdl, ncinput *ni)
int	get_cursor_location (inputctx *ictx, const char *u7, unsigned *y, unsigned *x)
int	notcurses_linesigs_disable (notcurses *nc)
int	notcurses_linesigs_enable (notcurses *n)
struct initial_responses *	inputlayer_get_responses (inputctx *ictx)

Typedef Documentation

cursorloc

typedef struct cursorloc cursorloc

inputctx

typedef struct inputctx inputctx

ipipe

typedef int ipipe

Definition at line 46 of file in.c.

Function Documentation

get_cursor_location()

int get_cursor_location	(	inputctx *	ictx,
		const char *	u7,
		unsigned *	y,
		unsigned *	x
	)

Definition at line 2810 of file in.c.

                                                                                 {
  pthread_mutex_lock(&ictx->clock);
  while(ictx->cvalid == 0){
    if(ictx->coutstanding == 0){
      if(tty_emit(u7, ictx->ti->ttyfd)){
        pthread_mutex_unlock(&ictx->clock);
        return -1;
      }
      ++ictx->coutstanding;
    }
    pthread_cond_wait(&ictx->ccond, &ictx->clock);
  }
  const cursorloc* cloc = &ictx->csrs[ictx->cread];
  if(++ictx->cread == ictx->csize){
    ictx->cread = 0;
  }
  --ictx->cvalid;
  if(y){
    *y = cloc->y;
  }
  if(x){
    *x = cloc->x;
  }
  pthread_mutex_unlock(&ictx->clock);
  return 0;
}

Here is the caller graph for this function:

init_inputlayer()

int init_inputlayer	(	tinfo *	ti,
		FILE *	infp,
		int	lmargin,
		int	tmargin,
		int	rmargin,
		int	bmargin,
		ncsharedstats *	stats,
		unsigned	drain,
		int	linesigs_enabled
	)

Definition at line 2638 of file in.c.

                                                         {
  inputctx* ictx = create_inputctx(ti, infp, lmargin, tmargin, rmargin,
                                   bmargin, stats, drain, linesigs_enabled);
  if(ictx == NULL){
    return -1;
  }
  if(pthread_create(&ictx->tid, NULL, input_thread, ictx)){
    free_inputctx(ictx);
    return -1;
  }
  ti->ictx = ictx;
  loginfo("spun up input thread");
  return 0;
}

Here is the caller graph for this function:

inputlayer_get_responses()

struct initial_responses * inputlayer_get_responses

(

inputctx *

ictx

)

Definition at line 2921 of file in.c.

                                                                  {
  struct initial_responses* iresp;
  pthread_mutex_lock(&ictx->ilock);
  while(ictx->initdata || !ictx->initdata_complete){
    pthread_cond_wait(&ictx->icond, &ictx->ilock);
  }
  iresp = ictx->initdata_complete;
  ictx->initdata_complete = NULL;
  pthread_mutex_unlock(&ictx->ilock);
  if(ictx->failed){
    logpanic("aborting after automaton construction failure");
    free(iresp);
    return NULL;
  }
  return iresp;
}

inputready_fd()

int inputready_fd

(

const inputctx *

ictx

)

Definition at line 2672 of file in.c.

                                       {
#ifndef __MINGW32__
  return ictx->readypipes[0];
#else
  (void)ictx;
  logerror("readiness descriptor unavailable on windows");
  return -1;
#endif
}

Here is the caller graph for this function:

ncdirect_get()

uint32_t ncdirect_get	(	ncdirect *	n,
		const struct timespec *	absdl,
		ncinput *	ni
	)

Definition at line 2798 of file in.c.

                                                                             {
  if(n->eof){
    logerror("already got EOF");
    return -1;
  }
  uint32_t r = internal_get(n->tcache.ictx, absdl, ni);
  if(r == NCKEY_EOF){
    n->eof = 1;
  }
  return r;
}

Here is the caller graph for this function:

ncinput_shovel()

int ncinput_shovel	(	inputctx *	ictx,
		const void *	buf,
		int	len
	)

Definition at line 2476 of file in.c.

                                                            {
  process_melange(ictx, buf, &len);
  if(len){
    logwarn("dropping %d byte%s", len, len == 1 ? "" : "s");
    inc_input_errors(ictx);
  }
  return 0;
}

notcurses_get()

uint32_t notcurses_get	(	notcurses *	nc,
		const struct timespec *	absdl,
		ncinput *	ni
	)

Definition at line 2776 of file in.c.

                                                                                {
  uint32_t ret = internal_get(nc->tcache.ictx, absdl, ni);
  return ret;
}

Here is the caller graph for this function:

notcurses_getvec()

int notcurses_getvec	(	notcurses *	n,
		const struct timespec *	absdl,
		ncinput *	ni,
		int	vcount
	)

Definition at line 2782 of file in.c.

                                             {
  for(int v = 0 ; v < vcount ; ++v){
    uint32_t u = notcurses_get(n, absdl, &ni[v]);
    if(u == (uint32_t)-1){
      if(v == 0){
        return -1;
      }
      return v;
    }else if(u == 0){
      return v;
    }
  }
  return vcount;
}

Here is the call graph for this function:

notcurses_linesigs_disable()

int notcurses_linesigs_disable

(

notcurses *

nc

)

Definition at line 2875 of file in.c.

                                             {
  return linesigs_disable(&nc->tcache);
}

Here is the caller graph for this function:

notcurses_linesigs_enable()

int notcurses_linesigs_enable

(

notcurses *

n

)

Definition at line 2917 of file in.c.

                                           {
  return linesigs_enable(&n->tcache);
}

Here is the caller graph for this function:

sigwinch_handler()

void sigwinch_handler

(

int

signo

)

Definition at line 31 of file in.c.

                                {
  if(signo == SIGWINCH){
    resize_seen = signo;
    sigcont_seen_for_render = 1;
  }else if(signo == SIGCONT){
    cont_seen = signo;
    sigcont_seen_for_render = 1;
  }
}

Here is the caller graph for this function:

stop_inputlayer()

int stop_inputlayer

(

tinfo *

ti

)

Definition at line 2655 of file in.c.

                              {
  int ret = 0;
  if(ti){
    // FIXME cancellation on shutdown does not yet work on windows #2192
#ifndef __MINGW32__
    if(ti->ictx){
      loginfo("tearing down input thread");
      ret |= cancel_and_join("input", ti->ictx->tid, NULL);
      ret |= set_fd_nonblocking(ti->ictx->stdinfd, ti->stdio_blocking_save, NULL);
      free_inputctx(ti->ictx);
      ti->ictx = NULL;
    }
#endif
  }
  return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function: