corosync  2.4.6
Data Structures | Macros | Functions | Variables
main.c File Reference
#include <config.h>
#include <pthread.h>
#include <assert.h>
#include <sys/types.h>
#include <sys/file.h>
#include <sys/poll.h>
#include <sys/uio.h>
#include <sys/mman.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <sys/time.h>
#include <sys/resource.h>
#include <sys/stat.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <signal.h>
#include <sched.h>
#include <time.h>
#include <semaphore.h>
#include <string.h>
#include <qb/qbdefs.h>
#include <qb/qblog.h>
#include <qb/qbloop.h>
#include <qb/qbutil.h>
#include <qb/qbipcs.h>
#include <corosync/swab.h>
#include <corosync/corotypes.h>
#include <corosync/corodefs.h>
#include <corosync/list.h>
#include <corosync/totem/totempg.h>
#include <corosync/logsys.h>
#include <corosync/icmap.h>
#include "quorum.h"
#include "totemsrp.h"
#include "logconfig.h"
#include "totemconfig.h"
#include "main.h"
#include "sync.h"
#include "timer.h"
#include "util.h"
#include "apidef.h"
#include "service.h"
#include "schedwrk.h"
Include dependency graph for main.c:

Go to the source code of this file.

Data Structures

struct  sending_allowed_private_data_struct
 
struct  scheduler_pause_timeout_data
 

Macros

#define IPC_LOGSYS_SIZE   8192*128
 
#define SERVER_BACKLOG   5
 
#define LOCALHOST_IP   inet_addr("127.0.0.1")
 
#define RLIMIT_MEMLOCK   RLIMIT_VMEM
 

Functions

 LOGSYS_DECLARE_SYSTEM ("corosync", LOGSYS_MODE_OUTPUT_STDERR|LOGSYS_MODE_OUTPUT_SYSLOG, LOG_DAEMON, LOG_EMERG)
 
 LOGSYS_DECLARE_SUBSYS ("MAIN")
 
qb_loop_t * cs_poll_handle_get (void)
 
int cs_poll_dispatch_add (qb_loop_t *handle, int fd, int events, void *data, int(*dispatch_fn)(int fd, int revents, void *data))
 
int cs_poll_dispatch_delete (qb_loop_t *handle, int fd)
 
void corosync_state_dump (void)
 
void corosync_shutdown_request (void)
 
int main_mcast (const struct iovec *iovec, unsigned int iov_len, unsigned int guarantee)
 
void corosync_recheck_the_q_level (void *data)
 
int corosync_sending_allowed (unsigned int service, unsigned int id, const void *msg, void *sending_allowed_private_data)
 
void corosync_sending_allowed_release (void *sending_allowed_private_data)
 
int message_source_is_local (const mar_message_source_t *source)
 
void message_source_set (mar_message_source_t *source, void *conn)
 
int main (int argc, char **argv, char **envp)
 

Variables

struct sched_param global_sched_param
 

Macro Definition Documentation

#define IPC_LOGSYS_SIZE   8192*128

Definition at line 132 of file main.c.

#define LOCALHOST_IP   inet_addr("127.0.0.1")

Definition at line 266 of file main.c.

#define RLIMIT_MEMLOCK   RLIMIT_VMEM
#define SERVER_BACKLOG   5

Definition at line 147 of file main.c.

Function Documentation

void corosync_recheck_the_q_level ( void *  data)
int corosync_sending_allowed ( unsigned int  service,
unsigned int  id,
const void *  msg,
void *  sending_allowed_private_data 
)
void corosync_sending_allowed_release ( void *  sending_allowed_private_data)
void corosync_shutdown_request ( void  )

Definition at line 240 of file main.c.

References corosync_service_unlink_all().

void corosync_state_dump ( void  )
int cs_poll_dispatch_add ( qb_loop_t *  handle,
int  fd,
int  events,
void *  data,
int(*)(int fd, int revents, void *data)  dispatch_fn 
)

Definition at line 174 of file main.c.

int cs_poll_dispatch_delete ( qb_loop_t *  handle,
int  fd 
)

Definition at line 187 of file main.c.

qb_loop_t* cs_poll_handle_get ( void  )
LOGSYS_DECLARE_SUBSYS ( "MAIN"  )
LOGSYS_DECLARE_SYSTEM ( "corosync"  ,
LOGSYS_MODE_OUTPUT_STDERR LOGSYS_MODE_OUTPUT_SYSLOG,
LOG_DAEMON  ,
LOG_EMERG   
)
int main ( int  argc,
char **  argv,
char **  envp 
)

Definition at line 1232 of file main.c.

References _logsys_subsys_create(), apidef_get(), coroparse_configparse(), COROSYNC_DONE_DIR_NOT_PRESENT, COROSYNC_DONE_EXIT, COROSYNC_DONE_FATAL_ERR, COROSYNC_DONE_ICMAP, COROSYNC_DONE_LOGCONFIGREAD, COROSYNC_DONE_MAINCONFIGREAD, corosync_exit_error, corosync_log_config_read(), CS_OK, get_run_dir(), icmap_get_global_map(), icmap_init(), totem_config::ip_version, totem_logging_configuration::log_level_debug, totem_logging_configuration::log_level_error, totem_logging_configuration::log_level_notice, totem_logging_configuration::log_level_security, totem_logging_configuration::log_level_trace, totem_logging_configuration::log_level_warning, totem_logging_configuration::log_printf, log_printf, totem_logging_configuration::log_subsys_id, logsys_blackbox_postfork(), logsys_blackbox_prefork(), logsys_config_apply(), LOGSYS_LEVEL_DEBUG, LOGSYS_LEVEL_ERROR, LOGSYS_LEVEL_INFO, LOGSYS_LEVEL_NOTICE, LOGSYS_LEVEL_TRACE, LOGSYS_LEVEL_WARNING, LOGSYS_PERROR, logsys_system_fini(), logsys_thread_start(), PACKAGE_FEATURES, schedwrk_init(), scheduler_pause_timeout_data::totem_config, TOTEM_CONFIG_BINDNETADDR_NODELIST_SET, totem_config_keyread(), totem_config_read(), totem_config_validate(), TOTEM_CONFIG_WARNING_MEMBERS_DEPRECATED, TOTEM_CONFIG_WARNING_MEMBERS_IGNORED, TOTEM_CONFIG_WARNING_TOTEM_NODEID_IGNORED, totem_config::totem_logging_configuration, totem_config::totem_memb_ring_id_create_or_load, totem_config::totem_memb_ring_id_store, totempg_finalize(), totempg_groups_initialize(), totempg_groups_join(), totempg_initialize(), totempg_service_ready_register(), and VERSION.

int main_mcast ( const struct iovec *  iovec,
unsigned int  iov_len,
unsigned int  guarantee 
)
int message_source_is_local ( const mar_message_source_t source)

Definition at line 804 of file main.c.

References totempg_my_nodeid_get().

void message_source_set ( mar_message_source_t source,
void *  conn 
)

Definition at line 815 of file main.c.

References totempg_my_nodeid_get().

Variable Documentation

struct sched_param global_sched_param

Definition at line 161 of file main.c.