Function xmlrpc_sendmsg

modules/event_xmlrpc/xmlrpc_send.c:166–224

sends the buffer */

/* sends the buffer */
static int xmlrpc_sendmsg(xmlrpc_send_t *sock)
{
	unsigned long i;
	int len = 0;
	int fd, ret = -1;
	int aux;

	xmlrpc_iov[xmlrpc_first_line_index].iov_base = sock->first_line.s;
	xmlrpc_iov[xmlrpc_first_line_index].iov_len = sock->first_line.len;

	xmlrpc_iov[xmlrpc_host_index].iov_base = sock->host.s;
	xmlrpc_iov[xmlrpc_host_index].iov_len = sock->host.len;

	/* event name */
	xmlrpc_iov[xmlrpc_ev_name_index].iov_base = sock->event.s;
	xmlrpc_iov[xmlrpc_ev_name_index].iov_len = sock->event.len;

	/* method name */
	xmlrpc_iov[xmlrpc_met_name_index].iov_base = sock->method.s;
	xmlrpc_iov[xmlrpc_met_name_index].iov_len = sock->method.len;

	/* msg body */
	xmlrpc_iov[xmlrpc_params_index].iov_base = sock->body.s;
	xmlrpc_iov[xmlrpc_params_index].iov_len = sock->body.len;

	/* now compute content length */
	for (i = xmlrpc_xmlbody_index; i < xmlrpc_iov_len; i++)
		len += xmlrpc_iov[i].iov_len;

	xmlrpc_iov[xmlrpc_ct_len_index].iov_base = int2str(len, &aux);
	xmlrpc_iov[xmlrpc_ct_len_index].iov_len = aux;

	/* writing the iov on the network */
	if ((fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
		LM_ERR("cannot create socket\n");
		return -1;
	}

	if (connect(fd, &sock->addr.s, sizeof(struct sockaddr_in)) < 0) {
		LM_ERR("cannot connect to %s[%d:%s]\n",
				inet_ntoa(sock->addr.sin.sin_addr),
				errno, strerror(errno));
		goto close;
	}

	do {
		len = writev(fd, xmlrpc_iov, xmlrpc_iov_len);
	} while ((len < 0 && (IS_ERR(EINTR)||IS_ERR(EAGAIN)||IS_ERR(EWOULDBLOCK))));
	if (len <= 0) {
		LM_ERR("cannot send xmlrpc command %s[%d]\n", strerror(errno), errno);
		goto close;
	}

	ret = 0;
close:
	shutdown(fd, SHUT_RDWR);
	close(fd);
	return ret;