serval-dna.h File Reference

re-implementation of the serval-dna daemon as a commotiond plugin More...

Go to the source code of this file.

Macros
#define	DEFAULT_SID   "0000000000000000000000000000000000000000000000000000000000000000"
#define	DEFAULT_MDP_PATH   "/etc/commotion/keys.d/mdp.keyring/serval.keyring"
#define	DEFAULT_SERVAL_PATH   "/var/serval-node"
#define	PATH_MAX   4096
#define	CHECK_ERR(A, M,...)
#define	CHECK_ERR(A, M,...)
#define	CLEAR_ERR()   err_msg = NULL;
#define	INS_ERROR()   if (err_msg) { CMD_OUTPUT("errors",err_msg); }

Functions
int	co_plugin_register (co_obj_t *self, co_obj_t **output, co_obj_t *params)
int	co_plugin_init (co_obj_t *self, co_obj_t **output, co_obj_t *params)
int	co_plugin_name (co_obj_t *self, co_obj_t **output, co_obj_t *params)
int	co_plugin_shutdown (co_obj_t *self, co_obj_t **output, co_obj_t *params)
int	serval_socket_cb (co_obj_t *self, co_obj_t *context)
int	serval_timer_cb (co_obj_t *self, co_obj_t **output, co_obj_t *context)
int	serval_schema (co_obj_t *self, co_obj_t **output, co_obj_t *params)
int	serval_daemon_handler (co_obj_t *self, co_obj_t **output, co_obj_t *params)

Detailed Description

re-implementation of the serval-dna daemon as a commotiond plugin

Author

Dan Staples (dismantl), danst.nosp@m.aple.nosp@m.s@ope.nosp@m.ntec.nosp@m.hinst.nosp@m.itut.nosp@m.e.org

Macro Definition Documentation

#define CHECK_ERR	(		A,
			M,
			...
	)

Value:

if(!(A)) { \
    ERROR(M, ##__VA_ARGS__); \
    if (err_msg == NULL) \
      err_msg = co_list16_create(); \
    char *msg = NULL; \
    int len = snprintf(NULL, 0, M, ##__VA_ARGS__); \
    msg = calloc(len + 1,sizeof(char)); \
    sprintf(msg, M, ##__VA_ARGS__); \
    if (len < UINT8_MAX) { \
      co_list_append(err_msg, co_str8_create(msg,len+1,0)); \
    } else if (len < UINT16_MAX) { \
      co_list_append(err_msg, co_str16_create(msg,len+1,0)); \
    } else if (len < UINT32_MAX) { \
      co_list_append(err_msg, co_str32_create(msg,len+1,0)); \
    } \
    free(msg); \
    goto error; \
  }

until we have nested tree support

#define CHECK_ERR	(		A,
			M,
			...
	)

Value:

if(!(A)) { \
    ERROR(M, ##__VA_ARGS__); \
    if (err_msg) \
      co_obj_free(err_msg); \
    char *msg = NULL; \
    int len = snprintf(NULL, 0, M, ##__VA_ARGS__); \
    msg = calloc(len + 1,sizeof(char)); \
    sprintf(msg, M, ##__VA_ARGS__); \
    if (len < UINT8_MAX) { \
      err_msg = co_str8_create(msg,len+1,0); \
    } else if (len < UINT16_MAX) { \
      err_msg = co_str16_create(msg,len+1,0); \
    } else if (len < UINT32_MAX) { \
      err_msg = co_str32_create(msg,len+1,0); \
    } \
    free(msg); \
    goto error; \
  }

until we have nested tree support

Function Documentation

int serval_socket_cb	(	co_obj_t *	self,
		co_obj_t *	context
	)

Callback function for when Serval socket has data to read

References co_list_parse().

Referenced by _watch().

                                                        {
//   DEBUG("SERVAL_SOCKET_CB");
  co_socket_t *sock = (co_socket_t*)self;
  co_obj_t *node = NULL;
  struct sched_ent *alarm = NULL;
  
  // find alarm associated w/ sock, call alarm->function(alarm)
  if ((node = co_list_parse(sock_alarms, _alarm_fd_match_i, &sock->fd->fd))) {
    alarm = ((co_alarm_t*)node)->alarm;
    alarm->poll.revents = sock->events;
    
    alarm->function(alarm); // Serval callback function associated with alarm/socket
    alarm->poll.revents = 0;
    
    return 1;
  }
  
  return 0;
}