Asterisk: manager.h File Reference

01222 { 01223 struct ast_config *cfg; 01224 char *val; 01225 int oldportno = portno; 01226 static struct sockaddr_in ba; 01227 int x = 1; 01228 if (!registered) { 01229 /* Register default actions */ 01230 ast_manager_register2("Ping", 0, action_ping, "Ping", mandescr_ping); 01231 ast_manager_register( "Events", 0, action_events, "Contol Event Flow" ); 01232 ast_manager_register( "Logoff", 0, action_logoff, "Logoff Manager" ); 01233 ast_manager_register( "Hangup", EVENT_FLAG_CALL, action_hangup, "Hangup Channel" ); 01234 ast_manager_register( "Status", EVENT_FLAG_CALL, action_status, "Status" ); 01235 ast_manager_register( "Setvar", EVENT_FLAG_CALL, action_setvar, "Set Channel Variable" ); 01236 ast_manager_register( "Getvar", EVENT_FLAG_CALL, action_getvar, "Gets a Channel Variable" ); 01237 ast_manager_register( "Redirect", EVENT_FLAG_CALL, action_redirect, "Redirect" ); 01238 ast_manager_register2("Originate", EVENT_FLAG_CALL, action_originate, "Originate Call", mandescr_originate); 01239 ast_manager_register( "MailboxStatus", EVENT_FLAG_CALL, action_mailboxstatus, "Check Mailbox" ); 01240 ast_manager_register( "Command", EVENT_FLAG_COMMAND, action_command, "Execute Command" ); 01241 ast_manager_register( "ExtensionState", EVENT_FLAG_CALL, action_extensionstate, "Check Extension Status" ); 01242 ast_manager_register( "AbsoluteTimeout", EVENT_FLAG_CALL, action_timeout, "Set Absolute Timeout" ); 01243 ast_manager_register( "MailboxCount", EVENT_FLAG_CALL, action_mailboxcount, "Check Mailbox Message Count" ); 01244 ast_manager_register2("ListCommands", 0, action_listcommands, "List available manager commands", mandescr_listcommands); 01245 01246 ast_cli_register(&show_mancmd_cli); 01247 ast_cli_register(&show_mancmds_cli); 01248 ast_cli_register(&show_manconn_cli); 01249 ast_extension_state_add(NULL, NULL, manager_state_cb, NULL); 01250 registered = 1; 01251 } 01252 portno = DEFAULT_MANAGER_PORT; 01253 cfg = ast_load("manager.conf"); 01254 if (!cfg) { 01255 ast_log(LOG_NOTICE, "Unable to open management configuration manager.conf. Call management disabled.\n"); 01256 return 0; 01257 } 01258 memset(&ba, 0, sizeof(ba)); 01259 val = ast_variable_retrieve(cfg, "general", "enabled"); 01260 if (val) 01261 enabled = ast_true(val); 01262 01263 val = ast_variable_retrieve(cfg, "general", "block-sockets"); 01264 if(val) 01265 block_sockets = ast_true(val); 01266 01267 if ((val = ast_variable_retrieve(cfg, "general", "port"))) { 01268 if (sscanf(val, "%d", &portno) != 1) { 01269 ast_log(LOG_WARNING, "Invalid port number '%s'\n", val); 01270 portno = DEFAULT_MANAGER_PORT; 01271 } 01272 } else if ((val = ast_variable_retrieve(cfg, "general", "portno"))) { 01273 if (sscanf(val, "%d", &portno) != 1) { 01274 ast_log(LOG_WARNING, "Invalid port number '%s'\n", val); 01275 portno = DEFAULT_MANAGER_PORT; 01276 } 01277 ast_log(LOG_NOTICE, "Use of portno in manager.conf deprecated. Please use 'port=%s' instead.\n", val); 01278 } 01279 01280 ba.sin_family = AF_INET; 01281 ba.sin_port = htons(portno); 01282 memset(&ba.sin_addr, 0, sizeof(ba.sin_addr)); 01283 01284 if ((val = ast_variable_retrieve(cfg, "general", "bindaddr"))) { 01285 if (!inet_aton(val, &ba.sin_addr)) { 01286 ast_log(LOG_WARNING, "Invalid address '%s' specified, using 0.0.0.0\n", val); 01287 memset(&ba.sin_addr, 0, sizeof(ba.sin_addr)); 01288 } 01289 } 01290 01291 if ((asock > -1) && ((portno != oldportno) || !enabled)) { 01292 #if 0 01293 /* Can't be done yet */ 01294 close(asock); 01295 asock = -1; 01296 #else 01297 ast_log(LOG_WARNING, "Unable to change management port / enabled\n"); 01298 #endif 01299 } 01300 ast_destroy(cfg); 01301 01302 /* If not enabled, do nothing */ 01303 if (!enabled) { 01304 return 0; 01305 } 01306 if (asock < 0) { 01307 asock = socket(AF_INET, SOCK_STREAM, 0); 01308 if (asock < 0) { 01309 ast_log(LOG_WARNING, "Unable to create socket: %s\n", strerror(errno)); 01310 return -1; 01311 } 01312 setsockopt(asock, SOL_SOCKET, SO_REUSEADDR, &x, sizeof(x)); 01313 if (bind(asock, (struct sockaddr *)&ba, sizeof(ba))) { 01314 ast_log(LOG_WARNING, "Unable to bind socket: %s\n", strerror(errno)); 01315 close(asock); 01316 asock = -1; 01317 return -1; 01318 } 01319 if (listen(asock, 2)) { 01320 ast_log(LOG_WARNING, "Unable to listen on socket: %s\n", strerror(errno)); 01321 close(asock); 01322 asock = -1; 01323 return -1; 01324 } 01325 if (option_verbose) 01326 ast_verbose("Asterisk Management interface listening on port %d\n", portno); 01327 pthread_create(&t, NULL, accept_thread, NULL); 01328 } 01329 return 0; 01330 }


Data Structures
struct	mansession
struct	message
struct	manager_action
Defines
#define	DEFAULT_MANAGER_PORT 5038 /* Default port for Asterisk management via TCP */
#define	EVENT_FLAG_SYSTEM (1 << 0) /* System events such as module load/unload */
#define	EVENT_FLAG_CALL (1 << 1) /* Call event, such as state change, etc */
#define	EVENT_FLAG_LOG (1 << 2) /* Log events */
#define	EVENT_FLAG_VERBOSE (1 << 3) /* Verbose messages */
#define	EVENT_FLAG_COMMAND (1 << 4) /* Ability to read/set commands */
#define	EVENT_FLAG_AGENT (1 << 5) /* Ability to read/set agent info */
#define	EVENT_FLAG_USER (1 << 6) /* Ability to read/set user info */
#define	MAX_HEADERS 80
#define	MAX_LEN 256
#define	ast_manager_register(a, b, c, d) ast_manager_register2(a, b, c, d, NULL)
Functions
int	ast_carefulwrite (int fd, char *s, int len, int timeoutms)
int	ast_manager_register2 (char action, int authority, int(func)(struct mansession s, struct message m), char synopsis, char description)
int	ast_manager_unregister (char *action)
int	manager_event (int category, char event, char contents,...) __attribute__((format(printf
char *	astman_get_header (struct message m, char var)
void	astman_send_error (struct mansession s, struct message m, char *error)
void	astman_send_response (struct mansession s, struct message m, char resp, char msg)
void	astman_send_ack (struct mansession s, struct message m, char *msg)
int	init_manager (void)
int	reload_manager (void)

manager.h File Reference

Data Structures

Defines

Functions

Define Documentation

Function Documentation