Lines Matching refs:msg_len
81 int msg_len = 0; in delay_send() local
87 msg_len = snprintf(msg_pub, sizeof(msg_pub), UAGENT_INFO_STR, uganet_send_id++, in delay_send()
90 msg_len = snprintf(msg_pub, sizeof(msg_pub), UAGENT_INFO_STR, uganet_send_id++, in delay_send()
94 msg_len = snprintf(msg_pub, sizeof(msg_pub), UAGENT_INFO_STR, uganet_send_id++, in delay_send()
98 if (msg_len > 0 && msg_len < UAGENT_INFO_PAYLOAD_SIZE) { in delay_send()
100 rc = pub_info(msg_len, msg_pub, (policy&send_policy_trans_guarantee) ? 1 : 0); in delay_send()
102 UAGENT_ERR("[uA]miss pub as payload over flow %d\n", msg_len); in delay_send()
143 … short msg_len = snprintf(msg_pub, sizeof(msg_pub), UAGENT_FORMAT_PRE, uganet_send_id++, in uagent_send() local
146 if(msg_len>0){ in uagent_send()
149 … empty_room_for_data = UAGENT_INFO_PAYLOAD_SIZE-msg_len-strlen(UAGENT_FORMAT_OBJ_SUFFIX)-1; in uagent_send()
150 … strncpy(&msg_pub[msg_len], data, len<empty_room_for_data?len:empty_room_for_data); in uagent_send()
151 msg_len += (len<empty_room_for_data?len:empty_room_for_data); in uagent_send()
152 … strncpy(&msg_pub[msg_len], UAGENT_FORMAT_OBJ_SUFFIX, UAGENT_INFO_PAYLOAD_SIZE-msg_len-1); in uagent_send()
153 msg_len += strlen(UAGENT_FORMAT_OBJ_SUFFIX); in uagent_send()
154 if (msg_len < UAGENT_INFO_PAYLOAD_SIZE) { in uagent_send()
155 … rc = pub_info(msg_len, msg_pub, POLICY_SET(policy,send_policy_trans_guarantee)); in uagent_send()
157 UAGENT_ERR("[uA]miss pub as payload over flow %d\n", msg_len); in uagent_send()
160 msg_pub[msg_len++] = '"'; in uagent_send()
161 … empty_room_for_data = UAGENT_INFO_PAYLOAD_SIZE-msg_len-strlen(UAGENT_FORMAT_STR_SUFFIX)-1; in uagent_send()
167 … strncpy(&msg_pub[msg_len], (char *)msg_pub_base64, empty_room_for_data); in uagent_send()
170 strncpy(&msg_pub[msg_len], data, empty_room_for_data); in uagent_send()
174 strncpy(&msg_pub[msg_len], data, empty_room_for_data); in uagent_send()
176 … msg_len += (actual_len<empty_room_for_data?actual_len:empty_room_for_data); in uagent_send()
177 … strncpy(&msg_pub[msg_len], UAGENT_FORMAT_STR_SUFFIX, UAGENT_INFO_PAYLOAD_SIZE-msg_len-1); in uagent_send()
178 msg_len += strlen(UAGENT_FORMAT_STR_SUFFIX); in uagent_send()
180 if (msg_len < UAGENT_INFO_PAYLOAD_SIZE) { in uagent_send()
181 … rc = pub_info(msg_len, msg_pub, POLICY_SET(policy,send_policy_trans_guarantee)); in uagent_send()
183 UAGENT_ERR("[uA]miss pub as payload over flow %d\n", msg_len); in uagent_send()
206 int msg_len = 0; in uagent_ack() local
209 msg_len = snprintf(msg_pub_ack, sizeof(msg_pub_ack), UAGENT_INFO_ACK_OK, in uagent_ack()
213 … msg_len = snprintf(msg_pub_ack, sizeof(msg_pub_ack), UAGENT_INFO_ACK_FAIL, uganet_send_id++, in uagent_ack()
219 if (msg_len > 0 && msg_len < UAGENT_INFO_PAYLOAD_SIZE) { in uagent_ack()
220 rc = pub_info(msg_len, msg_pub_ack, 0); in uagent_ack()
222 UAGENT_ERR("[uA]miss pub as payload over flow %d\n", msg_len); in uagent_ack()