Add missing log.c. Enable syslog wrapping
Signed-off-by: Lon Hohberger <lhh@redhat.com>
This commit is contained in:
Lon Hohberger
parent
d72d4a754f
commit
481905d8bf
191
common/log.c
Normal file
191
common/log.c
Normal file
@ -0,0 +1,191 @@
|
||||
/**
|
||||
* Syslog wrapper that does not block
|
||||
*
|
||||
* Lon Hohberger, 2009
|
||||
*/
|
||||
#include <pthread.h>
|
||||
#include <unistd.h>
|
||||
#include <sys/syslog.h>
|
||||
#include <signal.h>
|
||||
#include <string.h>
|
||||
#include <stdlib.h>
|
||||
#include <unistd.h>
|
||||
#include <stdarg.h>
|
||||
#include <stdio.h>
|
||||
#include <sys/types.h>
|
||||
#include <sys/time.h>
|
||||
#include <errno.h>
|
||||
#include "list.h"
|
||||
|
||||
struct log_entry {
|
||||
list_head();
|
||||
char *message;
|
||||
int sev;
|
||||
int bufsz;
|
||||
};
|
||||
|
||||
#define MAX_QUEUE_LENGTH 10
|
||||
#define LOGLEN 256
|
||||
|
||||
static struct log_entry *_log_entries = NULL;
|
||||
static pthread_mutex_t log_mutex = PTHREAD_MUTEX_INITIALIZER;
|
||||
static pthread_cond_t log_cond = PTHREAD_COND_INITIALIZER;
|
||||
static int log_size = 0;
|
||||
static int dropped = 0;
|
||||
static pthread_t thread_id = 0;
|
||||
|
||||
void __real_syslog(int severity, const char *fmt, ...);
|
||||
|
||||
static void *
|
||||
_log_thread(void *arg)
|
||||
{
|
||||
struct timeval tv;
|
||||
struct timespec ts;
|
||||
struct log_entry *entry;
|
||||
|
||||
pthread_mutex_lock(&log_mutex);
|
||||
|
||||
do {
|
||||
gettimeofday(&tv, NULL);
|
||||
ts.tv_sec = tv.tv_sec + 10;
|
||||
ts.tv_nsec = tv.tv_usec;
|
||||
|
||||
while (!(entry = _log_entries)) {
|
||||
if (pthread_cond_timedwait(&log_cond,
|
||||
&log_mutex,
|
||||
&ts) == ETIMEDOUT)
|
||||
goto out;
|
||||
}
|
||||
|
||||
list_remove(&_log_entries, entry);
|
||||
--log_size;
|
||||
if (log_size < 0)
|
||||
raise(SIGSEGV);
|
||||
pthread_mutex_unlock(&log_mutex);
|
||||
|
||||
__real_syslog(entry->sev, entry->message);
|
||||
free(entry->message);
|
||||
free(entry);
|
||||
} while (1);
|
||||
|
||||
out:
|
||||
thread_id = (pthread_t)0;
|
||||
pthread_mutex_unlock(&log_mutex);
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
static int
|
||||
insert_entry(int sev, char *buf, int bufsz)
|
||||
{
|
||||
struct log_entry *lent;
|
||||
pthread_attr_t attrs;
|
||||
|
||||
lent = malloc(sizeof(*lent));
|
||||
if (!lent)
|
||||
return -1;
|
||||
lent->sev = sev;
|
||||
lent->message = buf;
|
||||
lent->bufsz = bufsz;
|
||||
|
||||
pthread_mutex_lock(&log_mutex);
|
||||
if (log_size >= MAX_QUEUE_LENGTH) {
|
||||
free(lent->message);
|
||||
free(lent);
|
||||
|
||||
++dropped;
|
||||
lent = (struct log_entry *)(le(_log_entries)->le_prev);
|
||||
|
||||
lent->sev = LOG_WARNING;
|
||||
snprintf(lent->message, lent->bufsz,
|
||||
"%d message(s) lost due to syslog load\n",
|
||||
dropped + 1);
|
||||
/* Dropped +1 because we overwrote a message to
|
||||
* give the 'dropped' message */
|
||||
} else {
|
||||
++log_size;
|
||||
dropped = 0;
|
||||
list_insert(&_log_entries, lent);
|
||||
}
|
||||
|
||||
if (!thread_id) {
|
||||
pthread_attr_init(&attrs);
|
||||
pthread_attr_setinheritsched(&attrs, PTHREAD_INHERIT_SCHED);
|
||||
|
||||
if (pthread_create(&thread_id, &attrs, _log_thread, NULL) < 0)
|
||||
thread_id = 0;
|
||||
pthread_mutex_unlock(&log_mutex);
|
||||
} else {
|
||||
pthread_mutex_unlock(&log_mutex);
|
||||
pthread_cond_signal(&log_cond);
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
__wrap_syslog(int severity, const char *fmt, ...)
|
||||
{
|
||||
va_list args;
|
||||
char *logmsg;
|
||||
|
||||
logmsg = malloc(LOGLEN);
|
||||
if (!logmsg)
|
||||
return;
|
||||
memset(logmsg, 0, LOGLEN);
|
||||
|
||||
va_start(args, fmt);
|
||||
vsnprintf(logmsg + strlen(logmsg), LOGLEN - strlen(logmsg),
|
||||
fmt, args);
|
||||
va_end(args);
|
||||
|
||||
insert_entry(severity, logmsg, LOGLEN);
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
void __real_closelog(void);
|
||||
|
||||
void
|
||||
__wrap_closelog(void)
|
||||
{
|
||||
struct log_entry *lent;
|
||||
int lost = 0;
|
||||
|
||||
pthread_cancel(thread_id);
|
||||
pthread_join(thread_id, NULL);
|
||||
thread_id = 0;
|
||||
__real_closelog();
|
||||
while (_log_entries) {
|
||||
++lost;
|
||||
lent = _log_entries;
|
||||
list_remove(&_log_entries, lent);
|
||||
free(lent->message);
|
||||
free(lent);
|
||||
}
|
||||
|
||||
#ifdef DEBUG
|
||||
printf("%d lost\n", lost);
|
||||
#endif
|
||||
}
|
||||
|
||||
|
||||
#ifdef STANDALONE
|
||||
int
|
||||
main(int argc, char**argv)
|
||||
{
|
||||
int x;
|
||||
|
||||
for (x = 0; x < 100; x++) {
|
||||
syslog(1, "Yo %d\n", x);
|
||||
}
|
||||
sleep(1);
|
||||
|
||||
closelog();
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
#endif
|
||||
707
common/options.c
707
common/options.c
@ -1,707 +0,0 @@
|
||||
/*
|
||||
Copyright Red Hat, Inc. 2006
|
||||
|
||||
This program is free software; you can redistribute it and/or modify it
|
||||
under the terms of the GNU General Public License as published by the
|
||||
Free Software Foundation; either version 2, or (at your option) any
|
||||
later version.
|
||||
|
||||
This program is distributed in the hope that it will be useful, but
|
||||
WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program; see the file COPYING. If not, write to the
|
||||
Free Software Foundation, Inc., 675 Mass Ave, Cambridge,
|
||||
MA 02139, USA.
|
||||
*/
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <string.h>
|
||||
#include <unistd.h>
|
||||
#include <signal.h>
|
||||
#include <sys/types.h>
|
||||
#include <sys/stat.h>
|
||||
#include <sys/wait.h>
|
||||
#include <sys/un.h>
|
||||
#include <sys/socket.h>
|
||||
#include <sys/select.h>
|
||||
#include <sys/ioctl.h>
|
||||
#include <arpa/inet.h>
|
||||
#include <net/if.h>
|
||||
#include <netinet/in.h>
|
||||
#include <netdb.h>
|
||||
#include <sys/time.h>
|
||||
#include <fcntl.h>
|
||||
#include <errno.h>
|
||||
|
||||
/* Local includes */
|
||||
#include "xvm.h"
|
||||
#include "simple_auth.h"
|
||||
#include "mcast.h"
|
||||
#include "options.h"
|
||||
|
||||
|
||||
|
||||
/* Assignment functions */
|
||||
|
||||
static inline void
|
||||
assign_debug(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
if (!value) {
|
||||
/* GNU getopt sets optarg to NULL for options w/o a param
|
||||
We rely on this here... */
|
||||
args->debug++;
|
||||
return;
|
||||
}
|
||||
|
||||
args->debug = atoi(value);
|
||||
if (args->debug < 0) {
|
||||
args->debug = 1;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_foreground(fence_virt_args_t *args, struct arg_info *arg,
|
||||
char *value)
|
||||
{
|
||||
args->flags |= F_FOREGROUND;
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_family(fence_virt_args_t *args, struct arg_info *arg,
|
||||
char *value)
|
||||
{
|
||||
if (!strcasecmp(value, "ipv4")) {
|
||||
args->net.family = PF_INET;
|
||||
} else if (!strcasecmp(value, "ipv6")) {
|
||||
args->net.family = PF_INET6;
|
||||
} else if (!strcasecmp(value, "auto")) {
|
||||
args->net.family = 0;
|
||||
} else {
|
||||
printf("Unsupported family: '%s'\n", value);
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_address(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
if (args->net.addr)
|
||||
free(args->net.addr);
|
||||
args->net.addr = strdup(value);
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_port(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->net.port = atoi(value);
|
||||
if (args->net.port <= 0 || args->net.port >= 65500) {
|
||||
printf("Invalid port: '%s'\n", value);
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_interface(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->net.ifindex = if_nametoindex(value);
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_retrans(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->retr_time = atoi(value);
|
||||
if (args->retr_time <= 0) {
|
||||
printf("Invalid retransmit time: '%s'\n", value);
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
static inline void
|
||||
assign_hash(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
if (!strcasecmp(value, "none")) {
|
||||
args->net.hash = HASH_NONE;
|
||||
} else if (!strcasecmp(value, "sha1")) {
|
||||
args->net.hash = HASH_SHA1;
|
||||
} else if (!strcasecmp(value, "sha256")) {
|
||||
args->net.hash = HASH_SHA256;
|
||||
} else if (!strcasecmp(value, "sha512")) {
|
||||
args->net.hash = HASH_SHA512;
|
||||
} else {
|
||||
printf("Unsupported hash: %s\n", value);
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_auth(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
if (!strcasecmp(value, "none")) {
|
||||
args->net.auth = AUTH_NONE;
|
||||
} else if (!strcasecmp(value, "sha1")) {
|
||||
args->net.auth = AUTH_SHA1;
|
||||
} else if (!strcasecmp(value, "sha256")) {
|
||||
args->net.auth = AUTH_SHA256;
|
||||
} else if (!strcasecmp(value, "sha512")) {
|
||||
args->net.auth = AUTH_SHA512;
|
||||
} else {
|
||||
printf("Unsupported auth type: %s\n", value);
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
static inline void
|
||||
assign_key(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
struct stat st;
|
||||
|
||||
if (args->net.key_file)
|
||||
free(args->net.key_file);
|
||||
args->net.key_file = strdup(value);
|
||||
|
||||
if (stat(value, &st) == -1) {
|
||||
printf("Invalid key file: '%s' (%s)\n", value,
|
||||
strerror(errno));
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_op(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
if (!strcasecmp(value, "null")) {
|
||||
args->op = FENCE_NULL;
|
||||
} else if (!strcasecmp(value, "off")) {
|
||||
args->op = FENCE_OFF;
|
||||
} else if (!strcasecmp(value, "reboot")) {
|
||||
args->op = FENCE_REBOOT;
|
||||
} else if (!strcasecmp(value, "status")) {
|
||||
args->op = FENCE_STATUS;
|
||||
} else if (!strcasecmp(value, "devstatus")) {
|
||||
args->op = FENCE_DEVSTATUS;
|
||||
} else {
|
||||
printf("Unsupported operation: %s\n", value);
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_device(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->serial.device = strdup(value);
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_params(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->serial.speed = strdup(value);
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_domain(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
if (args->domain) {
|
||||
printf("Domain/UUID may not be specified more than once\n");
|
||||
args->flags |= F_ERR;
|
||||
return;
|
||||
}
|
||||
|
||||
args->domain = strdup(value);
|
||||
|
||||
if (strlen(value) <= 0) {
|
||||
printf("Invalid domain name\n");
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
|
||||
if (strlen(value) >= MAX_DOMAINNAME_LENGTH) {
|
||||
errno = ENAMETOOLONG;
|
||||
printf("Invalid domain name: '%s' (%s)\n",
|
||||
value, strerror(errno));
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_uuid_lookup(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
if (!value) {
|
||||
/* GNU getopt sets optarg to NULL for options w/o a param
|
||||
We rely on this here... */
|
||||
args->flags |= F_USE_UUID;
|
||||
return;
|
||||
}
|
||||
|
||||
args->flags |= ( !!atoi(value) ? F_USE_UUID : 0);
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_timeout(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->timeout = atoi(value);
|
||||
if (args->timeout <= 0) {
|
||||
printf("Invalid timeout: '%s'\n", value);
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_help(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->flags |= F_HELP;
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_version(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->flags |= F_VERSION;
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_noccs(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->flags |= F_NOCCS;
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_nocluster(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
args->flags |= F_NOCCS;
|
||||
args->flags |= F_NOCLUSTER;
|
||||
}
|
||||
|
||||
|
||||
static inline void
|
||||
assign_uri(fence_virt_args_t *args, struct arg_info *arg, char *value)
|
||||
{
|
||||
#if 0
|
||||
if (args->uri)
|
||||
free(args->uri);
|
||||
|
||||
/* XXX NO validation yet */
|
||||
args->uri = strdup(value);
|
||||
#endif
|
||||
}
|
||||
|
||||
|
||||
|
||||
/** ALL valid command line and stdin arguments for this fencing agent */
|
||||
static struct arg_info _arg_info[] = {
|
||||
{ '\xff', NULL, "agent",
|
||||
"Not user serviceable",
|
||||
NULL },
|
||||
|
||||
{ '\xff', NULL, "self",
|
||||
"Not user serviceable",
|
||||
NULL },
|
||||
|
||||
{ 'd', "-d", "debug",
|
||||
"Specify (CCS) / increment (command line) debug level",
|
||||
assign_debug },
|
||||
|
||||
{ 'f', "-f", NULL,
|
||||
"Foreground mode (do not fork)",
|
||||
assign_foreground },
|
||||
|
||||
{ 'i', "-i <family>", "ip_family",
|
||||
"IP Family ([auto], ipv4, ipv6)",
|
||||
assign_family },
|
||||
|
||||
{ 'a', "-a <address>", "multicast_address",
|
||||
"Multicast address (default=225.0.0.12 / ff02::3:1)",
|
||||
assign_address },
|
||||
|
||||
{ 'p', "-p <port>", "port",
|
||||
"IP port (default=1229)",
|
||||
assign_port },
|
||||
|
||||
{ 'I', "-I <interface>", "interface",
|
||||
"Network interface name to listen on",
|
||||
assign_interface },
|
||||
|
||||
{ 'r', "-r <retrans>", "retrans",
|
||||
"Multicast retransmit time (in 1/10sec; default=20)",
|
||||
assign_retrans },
|
||||
|
||||
{ 'c', "-c <hash>", "hash",
|
||||
"Packet hash strength (none, sha1, [sha256], sha512)",
|
||||
assign_hash },
|
||||
|
||||
{ 'C', "-C <auth>", "auth",
|
||||
"Authentication (none, sha1, [sha256], sha512)",
|
||||
assign_auth },
|
||||
|
||||
{ 'k', "-k <file>", "key_file",
|
||||
"Shared key file (default=/etc/cluster/fence_virt.key)",
|
||||
assign_key },
|
||||
|
||||
{ 'D', "-D <device>", "serial_device",
|
||||
"Shared key file (default=" DEFAULT_SERIAL_DEVICE ")",
|
||||
assign_device },
|
||||
|
||||
{ 'P', "-P <param>", "serial_params",
|
||||
"Serial Parameters (default=" DEFAULT_SERIAL_SPEED ")",
|
||||
assign_params },
|
||||
|
||||
{ 'o', "-o <operation>", "option",
|
||||
"Fencing operation (null, off, [reboot], status, devstatus)",
|
||||
assign_op },
|
||||
|
||||
{ 'H', "-H <domain>", "domain",
|
||||
"Xen host (domain name) to fence",
|
||||
assign_domain },
|
||||
|
||||
{ 'u', "-u", "use_uuid",
|
||||
"Treat <domain> as UUID instead of domain name",
|
||||
assign_uuid_lookup },
|
||||
|
||||
{ 't', "-t <timeout>", "timeout",
|
||||
"Fencing timeout (in seconds; default=30)",
|
||||
assign_timeout },
|
||||
|
||||
{ 'h', "-h", NULL,
|
||||
"Help",
|
||||
assign_help },
|
||||
|
||||
{ '?', "-?", NULL,
|
||||
"Help (alternate)",
|
||||
assign_help },
|
||||
|
||||
{ 'X', "-X", NULL,
|
||||
"Do not connect to CCS for configuration",
|
||||
assign_noccs },
|
||||
|
||||
{ 'L', "-L", NULL,
|
||||
"Local mode only (no cluster; implies -X)",
|
||||
assign_nocluster },
|
||||
|
||||
{ 'U', "-U", "uri",
|
||||
"URI for Hypervisor (default: auto detect)",
|
||||
assign_uri },
|
||||
|
||||
{ 'V', "-V", NULL,
|
||||
"Display version and exit",
|
||||
assign_version },
|
||||
|
||||
/* Terminator */
|
||||
{ 0, NULL, NULL, NULL, NULL }
|
||||
};
|
||||
|
||||
|
||||
struct arg_info *
|
||||
find_arg_by_char(char arg)
|
||||
{
|
||||
int x = 0;
|
||||
|
||||
for (x = 0; _arg_info[x].opt != 0; x++) {
|
||||
if (_arg_info[x].opt == arg)
|
||||
return &_arg_info[x];
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
struct arg_info *
|
||||
find_arg_by_string(char *arg)
|
||||
{
|
||||
int x = 0;
|
||||
|
||||
for (x = 0; _arg_info[x].opt != 0; x++) {
|
||||
if (!_arg_info[x].stdin_opt)
|
||||
continue;
|
||||
if (!strcasecmp(_arg_info[x].stdin_opt, arg))
|
||||
return &_arg_info[x];
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
/* ============================================================= */
|
||||
|
||||
/**
|
||||
Initialize an args structure.
|
||||
|
||||
@param args Pointer to args structure to initialize.
|
||||
*/
|
||||
void
|
||||
args_init(fence_virt_args_t *args)
|
||||
{
|
||||
args->domain = NULL;
|
||||
//args->uri = NULL;
|
||||
args->op = FENCE_REBOOT;
|
||||
args->net.key_file = strdup(DEFAULT_KEY_FILE);
|
||||
args->net.hash = DEFAULT_HASH;
|
||||
args->net.auth = DEFAULT_AUTH;
|
||||
args->net.addr = NULL;
|
||||
args->net.port = DEFAULT_MCAST_PORT;
|
||||
args->net.ifindex = 0;
|
||||
args->net.family = PF_INET;
|
||||
args->serial.device = strdup(DEFAULT_SERIAL_DEVICE);
|
||||
args->serial.speed = strdup(DEFAULT_SERIAL_SPEED);
|
||||
args->timeout = 30;
|
||||
args->retr_time = 20;
|
||||
args->flags = 0;
|
||||
args->debug = 0;
|
||||
}
|
||||
|
||||
|
||||
#define _pr_int(piece) printf(" %s = %d\n", #piece, piece)
|
||||
#define _pr_str(piece) printf(" %s = %s\n", #piece, piece)
|
||||
|
||||
|
||||
/**
|
||||
Prints out the contents of an args structure for debugging.
|
||||
|
||||
@param args Pointer to args structure to print out.
|
||||
*/
|
||||
void
|
||||
args_print(fence_virt_args_t *args)
|
||||
{
|
||||
printf("-- args @ %p --\n", args);
|
||||
_pr_str(args->domain);
|
||||
_pr_int(args->op);
|
||||
|
||||
_pr_str(args->net.key_file);
|
||||
_pr_int(args->net.hash);
|
||||
_pr_str(args->net.addr);
|
||||
_pr_int(args->net.auth);
|
||||
_pr_int(args->net.port);
|
||||
_pr_int(args->net.ifindex);
|
||||
_pr_int(args->net.family);
|
||||
_pr_int(args->timeout);
|
||||
_pr_int(args->retr_time);
|
||||
_pr_int(args->flags);
|
||||
_pr_int(args->debug);
|
||||
printf("-- end args --\n");
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
Print out arguments and help information based on what is allowed in
|
||||
the getopt string optstr.
|
||||
|
||||
@param progname Program name.
|
||||
@param optstr Getopt(3) style options string
|
||||
@param print_stdin 0 = print command line options + description,
|
||||
1 = print fence-style stdin args + description
|
||||
*/
|
||||
void
|
||||
args_usage(char *progname, char *optstr, int print_stdin)
|
||||
{
|
||||
int x;
|
||||
struct arg_info *arg;
|
||||
|
||||
if (!print_stdin) {
|
||||
if (progname) {
|
||||
printf("usage: %s [args]\n", progname);
|
||||
} else {
|
||||
printf("usage: fence_virt [args]\n");
|
||||
}
|
||||
}
|
||||
|
||||
for (x = 0; x < strlen(optstr); x++) {
|
||||
arg = find_arg_by_char(optstr[x]);
|
||||
if (!arg)
|
||||
continue;
|
||||
|
||||
if (print_stdin) {
|
||||
if (arg && arg->stdin_opt)
|
||||
printf(" %-20.20s %-55.55s\n",
|
||||
arg->stdin_opt, arg->desc);
|
||||
} else {
|
||||
printf(" %-20.20s %-55.55s\n", arg->opt_desc,
|
||||
arg->desc);
|
||||
}
|
||||
}
|
||||
|
||||
printf("\n");
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
Remove leading and trailing whitespace from a line of text.
|
||||
|
||||
@param line Line to clean up
|
||||
@param linelen Max size of line
|
||||
@return 0 on success, -1 on failure
|
||||
*/
|
||||
int
|
||||
cleanup(char *line, size_t linelen)
|
||||
{
|
||||
char *p;
|
||||
int x;
|
||||
|
||||
/* Remove leading whitespace. */
|
||||
p = line;
|
||||
for (x = 0; x <= linelen; x++) {
|
||||
switch (line[x]) {
|
||||
case '\t':
|
||||
case ' ':
|
||||
break;
|
||||
case '\n':
|
||||
case '\r':
|
||||
return -1;
|
||||
default:
|
||||
goto eol;
|
||||
}
|
||||
}
|
||||
eol:
|
||||
/* Move the remainder down by as many whitespace chars as we
|
||||
chewed up */
|
||||
if (x)
|
||||
memmove(p, &line[x], linelen-x);
|
||||
|
||||
/* Remove trailing whitespace. */
|
||||
for (x=0; x <= linelen; x++) {
|
||||
switch(line[x]) {
|
||||
case '\t':
|
||||
case ' ':
|
||||
case '\r':
|
||||
case '\n':
|
||||
line[x] = 0;
|
||||
case 0:
|
||||
/* End of line */
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
return -1;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
Parse args from stdin and assign to the specified args structure.
|
||||
|
||||
@param optstr Command line option string in getopt(3) format
|
||||
@param args Args structure to fill in.
|
||||
*/
|
||||
void
|
||||
args_get_stdin(char *optstr, fence_virt_args_t *args)
|
||||
{
|
||||
char in[256];
|
||||
int line = 0;
|
||||
char *name, *val;
|
||||
struct arg_info *arg;
|
||||
|
||||
while (fgets(in, sizeof(in), stdin)) {
|
||||
++line;
|
||||
|
||||
if (in[0] == '#')
|
||||
continue;
|
||||
|
||||
if (cleanup(in, sizeof(in)) == -1)
|
||||
continue;
|
||||
|
||||
name = in;
|
||||
if ((val = strchr(in, '='))) {
|
||||
*val = 0;
|
||||
++val;
|
||||
}
|
||||
|
||||
arg = find_arg_by_string(name);
|
||||
if (!arg || (arg->opt != '\xff' &&
|
||||
!strchr(optstr, arg->opt))) {
|
||||
fprintf(stderr,
|
||||
"parse warning: "
|
||||
"illegal variable '%s' on line %d\n", name,
|
||||
line);
|
||||
continue;
|
||||
}
|
||||
|
||||
if (arg->assign)
|
||||
arg->assign(args, arg, val);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
Parse args from stdin and assign to the specified args structure.
|
||||
|
||||
@param optstr Command line option string in getopt(3) format
|
||||
@param args Args structure to fill in.
|
||||
*/
|
||||
void
|
||||
args_get_getopt(int argc, char **argv, char *optstr, fence_virt_args_t *args)
|
||||
{
|
||||
int opt;
|
||||
struct arg_info *arg;
|
||||
|
||||
while ((opt = getopt(argc, argv, optstr)) != EOF) {
|
||||
|
||||
arg = find_arg_by_char(opt);
|
||||
|
||||
if (!arg) {
|
||||
args->flags |= F_ERR;
|
||||
continue;
|
||||
}
|
||||
|
||||
if (arg->assign)
|
||||
arg->assign(args, arg, optarg);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void
|
||||
args_finalize(fence_virt_args_t *args)
|
||||
{
|
||||
char *addr = NULL;
|
||||
|
||||
if (!args->net.addr) {
|
||||
switch(args->net.family) {
|
||||
case 0:
|
||||
case PF_INET:
|
||||
addr = IPV4_MCAST_DEFAULT;
|
||||
break;
|
||||
case PF_INET6:
|
||||
addr = IPV6_MCAST_DEFAULT;
|
||||
break;
|
||||
default:
|
||||
args->flags |= F_ERR;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (!args->net.addr)
|
||||
args->net.addr = addr;
|
||||
|
||||
if (!args->net.addr) {
|
||||
printf("No multicast address available\n");
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
|
||||
if (!args->net.addr)
|
||||
return;
|
||||
if (args->net.family)
|
||||
return;
|
||||
|
||||
/* Set family */
|
||||
if (strchr(args->net.addr, ':'))
|
||||
args->net.family = PF_INET6;
|
||||
if (strchr(args->net.addr, '.'))
|
||||
args->net.family = PF_INET;
|
||||
if (!args->net.family) {
|
||||
printf("Could not determine address family\n");
|
||||
args->flags |= F_ERR;
|
||||
}
|
||||
}
|
||||
@ -32,7 +32,7 @@ INCLUDES=-I../include\
|
||||
CFLAGS+=-DFENCE_RELEASE_NAME=\"devel\" -D_MODULE
|
||||
|
||||
LIBS+=-L/usr/lib64/openais -lnss3 -lxml2 -lSaCkpt -lccs -lvirt -lcman \
|
||||
-L../common -lfence_virt
|
||||
-L../common -lfence_virt -Wl,-wrap,syslog,-wrap,-closelog -lpthread
|
||||
|
||||
MAIN_LIBS=-L../config -lsimpleconfig
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user