#include <string.h>#include <sys/types.h>#include <sys/socket.h>#include <netinet/in.h>#include <arpa/inet.h>#include <unistd.h>#include <netdb.h>#include <mxml.h>#include "include/libmc.h"#include "include/agent.h"#include "include/mc_platform.h"#include "include/message.h"#include "include/mtp_http.h"#include "include/xml_compose.h"#include "include/xml_helper.h"#include "include/xml_parser.h"#include "security/asm_node.h"Go to the source code of this file.
Defines | |
| #define | SOCKET_INPUT_SIZE 4096 |
Functions | |
| message_p | message_New (void) |
| message_p | message_Copy (message_p src) |
| int | message_InitializeFromAgent (mc_platform_p mc_platform, message_p message, agent_p agent) |
| int | message_InitializeFromConnection (mc_platform_p mc_platform, message_p message, connection_p connection) |
| int | http_to_hostport (const char *http_str, char **host, int *port, char **target) |
| int | message_InitializeFromString (mc_platform_p mc_platform, message_p message, const char *string, const char *destination_host, int destination_port, const char *target) |
| int | message_Destroy (message_p message) |
| int | message_Send (message_p message) |
Definition at line 605 of file message.c.
References message_s::addr, message_s::agent_xml_flag, message_s::from_address, MC_SUCCESS, message_s::message_body, mxmlDelete(), message_s::target, message_s::to_address, message_s::update_name, and message_s::xml_root.
Referenced by acc_MessageHandlerThread(), acc_Thread(), ams_ManageAgentList(), MC_AclSend(), MC_LoadAgentFromFile(), MC_SendAgentMigrationMessage(), MC_SendAgentMigrationMessageFile(), message_InitializeFromConnection(), and message_queue_SendOutgoing().
| int message_InitializeFromAgent | ( | mc_platform_p | mc_platform, | |
| message_p | message, | |||
| agent_p | agent | |||
| ) |
Definition at line 318 of file message.c.
References message_s::addr, agent_xml_compose(), message_s::agent_xml_flag, CHECK_NULL, agent_s::datastate, mc_platform_s::err, message_s::from_address, agent_s::home, mc_platform_s::hostname, MC_ERR_MEMORY, MC_SUCCESS, message_s::message_body, message_s::message_id, message_s::message_type, MOBILE_AGENT, MXML_NO_CALLBACK, mxmlSaveAllocString(), agent_datastate_s::number_of_tasks, mc_platform_s::port, agent_task_s::server_name, strtok_r, message_s::target, agent_datastate_s::task_progress, agent_datastate_s::tasks, message_s::to_address, message_s::update_name, WARN, and message_s::xml_root.
| int message_InitializeFromConnection | ( | mc_platform_p | mc_platform, | |
| message_p | message, | |||
| connection_p | connection | |||
| ) |
Definition at line 417 of file message.c.
References connection_s::addr, message_s::addr, CHECK_NULL, connection_s::clientfd, connection_s::connect_id, message_s::connect_id, message_s::from_address, MC_ERR_CONNECT, MC_ERR_PARSE, MC_SUCCESS, message_s::message_body, message_Destroy(), message_s::message_id, message_xml_parse(), MXML_NO_CALLBACK, mxmlLoadString(), SOCKET_INPUT_SIZE, message_s::target, message_s::to_address, and message_s::xml_root.
| int message_InitializeFromString | ( | mc_platform_p | mc_platform, | |
| message_p | message, | |||
| const char * | string, | |||
| const char * | destination_host, | |||
| int | destination_port, | |||
| const char * | target | |||
| ) |
Definition at line 541 of file message.c.
References message_s::addr, CHECK_NULL, message_s::connect_id, mc_platform_s::err, message_s::from_address, mc_platform_s::hostname, MC_ERR_MEMORY, MC_SUCCESS, message_s::message_body, message_s::message_id, message_s::message_type, MOBILE_AGENT, mc_platform_s::port, message_s::target, message_s::to_address, message_s::update_name, and message_s::xml_root.
| message_p message_New | ( | void | ) |
Definition at line 286 of file message.c.
References message_s::addr, message_s::agent_xml_flag, CHECK_NULL, message_s::connect_id, message_s::from_address, message_s::http_type, message_s::isHTTP, message_s::message_body, message_s::message_id, message_s::message_type, message_s::target, message_s::to_address, message_s::update_name, message_s::update_num, message_s::xml_payload, and message_s::xml_root.
Referenced by acc_Thread(), ams_ManageAgentList(), MC_LoadAgentFromFile(), MC_SendAgentMigrationMessage(), MC_SendAgentMigrationMessageFile(), and mtp_http_CreateMessage().
Definition at line 643 of file message.c.
References CHECK_NULL, MC_ERR, MC_ERR_CONNECT, MC_ERR_SEND, message_s::message_body, mtp_http_ComposeMessage(), mtp_http_New(), mtp_http_Parse(), port, send, SOCKET_INPUT_SIZE, strtok_r, and message_s::to_address.
Referenced by acc_MessageHandlerThread(), MC_AclSend(), and message_queue_SendOutgoing().
1.5.5