Function data_event_handle

dpdk/app/graph/conn.c:22–76

#define MSG_CMD_TOO_LONG "Command too long."

static int
data_event_handle(struct conn *conn, int fd_client)
{
	ssize_t len, i, rc = 0;

	/* Read input message */
	len = read(fd_client, conn->buf, conn->buf_size);
	if (len == -1) {
		if ((errno == EAGAIN) || (errno == EWOULDBLOCK))
			return 0;

		return -1;
	}

	if (len == 0)
		return rc;

	/* Handle input messages */
	for (i = 0; i < len; i++) {
		if (conn->buf[i] == '\n') {
			size_t n;

			conn->msg_in[conn->msg_in_len] = 0;
			conn->msg_out[0] = 0;

			conn->msg_handle(conn->msg_in, conn->msg_out, conn->msg_out_len_max,
					 conn->msg_handle_arg);

			n = strlen(conn->msg_out);
			if (n) {
				rc = write(fd_client, conn->msg_out, n);
				if (rc == -1)
					goto exit;
			}

			conn->msg_in_len = 0;
		} else if (conn->msg_in_len < conn->msg_in_len_max) {
			conn->msg_in[conn->msg_in_len] = conn->buf[i];
			conn->msg_in_len++;
		} else {
			rc = write(fd_client, MSG_CMD_TOO_LONG, strlen(MSG_CMD_TOO_LONG));
			if (rc == -1)
				goto exit;

			conn->msg_in_len = 0;
		}
	}

	/* Write prompt */
	rc = write(fd_client, conn->prompt, strlen(conn->prompt));
	rc = (rc == -1) ? -1 : 0;

exit:
	return rc;
}

static int
control_event_handle(struct conn *conn, int fd_client)