From patchwork Mon Aug 7 08:53:13 2017 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Bhupinder Thakur X-Patchwork-Id: 109534 Delivered-To: patch@linaro.org Received: by 10.182.109.195 with SMTP id hu3csp2482068obb; Mon, 7 Aug 2017 01:55:59 -0700 (PDT) X-Received: by 10.36.122.70 with SMTP id a67mr142730itc.147.1502096159232; Mon, 07 Aug 2017 01:55:59 -0700 (PDT) ARC-Seal: i=1; a=rsa-sha256; t=1502096159; cv=none; d=google.com; s=arc-20160816; b=RfRBw12MOYnI6Pem3GaM/Nejdjfu4Vv6e4hkMcqGAY5X0J4DQHDhs+cDl5NcghlzZ5 NnMaqi5+E5os8ZTLG5375O1NqN4BefW50N6Gr6QEToSC+xBPHvQUNTUBn+wVi0R6ohRg o5W2usSnQwwCqD7CIyjkzYdVClqlEaWADtKrD/mXyGYnRBIg4ZIFn0EtBPm/9paVeSLc RQHCIIUEcf7o3ObXKQIf5FKIMyYVqC/Qw37GVFLWuc8P3NlyWfkmjYuMQLBfiQREFvJW 6BmyBqVSB0U8fiXOCdt7evWtVl5uABhmlYsaiv3S/kz3w6YsXrXqoO1v2nZY1ut1uJ8B utYA== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=sender:errors-to:content-transfer-encoding:mime-version :list-subscribe:list-help:list-post:list-unsubscribe:list-id :precedence:subject:cc:references:in-reply-to:message-id:date:to :from:dkim-signature:arc-authentication-results; bh=oandYAEYp7SK8JP4njapFL8pi5te2QJ5hv730ed/TMg=; b=vZzIOHu6ya+TF7LWCIjq/E7O3MdKYAmgB71q9fBA0L+hD9ic4FcuRIu4ooRbP6Z7ir Uk8eifZAL9iBwvAFsbprFjHqm/iFxYYjf6PbC1EK5ZO705shw/4fSICw+RY0wn91/Jqd 18+qlXdrhEbgEVdf8QYSRpPltjN9Ux/yGGlgGl/L7Gkl+Pkdgz+OVV13eGrThPn8Hw0c Vg385aLcd91pHvwylkhUt7Xg0Njw9nQtcGtcitzTG8txjjxrym4i16uBZAm6FS4dDVtR I6CYwdtWtvOzbs9w+CQMlSLPp7qeT0v0GfRMx/Aara8Rh4KLwqGOB9ZfkpY5RomNskaT hl5g== ARC-Authentication-Results: i=1; mx.google.com; dkim=neutral (body hash did not verify) header.i=@linaro.org header.b=YAVTKJoG; spf=neutral (google.com: 192.237.175.120 is neither permitted nor denied by best guess record for domain of xen-devel-bounces@lists.xen.org) smtp.mailfrom=xen-devel-bounces@lists.xen.org; dmarc=fail (p=NONE sp=NONE dis=NONE) header.from=linaro.org Return-Path: Received: from lists.xenproject.org (lists.xenproject.org. [192.237.175.120]) by mx.google.com with ESMTPS id f78si7977531iof.88.2017.08.07.01.55.59 (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Mon, 07 Aug 2017 01:55:59 -0700 (PDT) Received-SPF: neutral (google.com: 192.237.175.120 is neither permitted nor denied by best guess record for domain of xen-devel-bounces@lists.xen.org) client-ip=192.237.175.120; Authentication-Results: mx.google.com; dkim=neutral (body hash did not verify) header.i=@linaro.org header.b=YAVTKJoG; spf=neutral (google.com: 192.237.175.120 is neither permitted nor denied by best guess record for domain of xen-devel-bounces@lists.xen.org) smtp.mailfrom=xen-devel-bounces@lists.xen.org; dmarc=fail (p=NONE sp=NONE dis=NONE) header.from=linaro.org Received: from localhost ([127.0.0.1] helo=lists.xenproject.org) by lists.xenproject.org with esmtp (Exim 4.84_2) (envelope-from ) id 1dedo3-0005Hm-G7; Mon, 07 Aug 2017 08:54:35 +0000 Received: from mail6.bemta6.messagelabs.com ([193.109.254.103]) by lists.xenproject.org with esmtp (Exim 4.84_2) (envelope-from ) id 1dedo2-0005FN-2E for xen-devel@lists.xenproject.org; Mon, 07 Aug 2017 08:54:34 +0000 Received: from [85.158.143.35] by server-6.bemta-6.messagelabs.com id BC/BF-03937-9CA28895; Mon, 07 Aug 2017 08:54:33 +0000 X-Brightmail-Tracker: H4sIAAAAAAAAA+NgFlrNIsWRWlGSWpSXmKPExsVyMfTAJt0TWh2 RBl+vKVt83zKZyYHR4/CHKywBjFGsmXlJ+RUJrBmXfq9mL5jmXrFkHnsD4z2rLkYuDiGBmYwS /f2HGEEcFoF5zBJ9y9awgjgSAv2sElOXXGHrYuQEctIkps7dywxhV0nMefCcEcQWEtCSOHpqN ivEqDYmiVP71wMlODjYBEwkZnVIgNSICChJ3Fs1mQmkhllgPqNE06ResKHCAlESl5f8ZQKxWQ RUJZ58fsEKYvMK+EhMXPIOarGcxM1znWCLOYHi5y+9YYFY7C1x+1gf4wRGgQWMDKsY1YtTi8p Si3Qt9JKKMtMzSnITM3N0DQ3M9HJTi4sT01NzEpOK9ZLzczcxAgOLAQh2MM6+7H+IUZKDSUmU N35FW6QQX1J+SmVGYnFGfFFpTmrxIUYZDg4lCd5HGh2RQoJFqempFWmZOcAQh0lLcPAoifC+U AdK8xYXJOYWZ6ZDpE4xWnJcubLuCxPHlAPbgeSrCf+/MQmx5OXnpUqJ874BmScA0pBRmgc3Dh aHlxhlpYR5GYEOFOIpSC3KzSxBlX/FKM7BqCTMG6YJNIUnM68EbusroIOYgA56k9gKclBJIkJ KqoFR6P7p/XaH/avTamIuOl/ld4870Slts+DL4bhPIb8W/gk3fOwvdzqiOHe2ftVy17hzQfoG J17x8PRd4DO4xyF4WF91+yah9xNNPmZ97GsL+l7Wt3lR/Wv2WU9vmOk5m9heXfrO/eDh2iTxs AM8tsqcDawPkpV8ln3zO+Rwcmnk6TPJH3fpCjorsRRnJBpqMRcVJwIAcVnHx74CAAA= X-Env-Sender: bhupinder.thakur@linaro.org X-Msg-Ref: server-6.tower-21.messagelabs.com!1502096071!53698472!1 X-Originating-IP: [209.85.192.178] X-SpamReason: No, hits=0.0 required=7.0 tests= X-StarScan-Received: X-StarScan-Version: 9.4.45; banners=-,-,- X-VirusChecked: Checked Received: (qmail 42497 invoked from network); 7 Aug 2017 08:54:32 -0000 Received: from mail-pf0-f178.google.com (HELO mail-pf0-f178.google.com) (209.85.192.178) by server-6.tower-21.messagelabs.com with AES128-GCM-SHA256 encrypted SMTP; 7 Aug 2017 08:54:32 -0000 Received: by mail-pf0-f178.google.com with SMTP id h68so17548959pfk.0 for ; Mon, 07 Aug 2017 01:54:32 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=linaro.org; s=google; h=from:to:cc:subject:date:message-id:in-reply-to:references; bh=d43ELejxQWSRtSCIZ+3JiGeDUd/hSVHCbb3tNhT51wE=; b=YAVTKJoGrHtynUNrO+L+oCpgedwTn7rJPYkw8itJMA74mJXCH1bas0XcT00iYfxg18 619iIqLWeCjSlEC7o93rQo2mCDJYSXQ8P6AUgRCFj/6a8ss340egvtpCEw7p8BkpD+Lh JzQyQT9bt3ZyKWGEbB719YvYx0Dq9T47ovY5I= X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references; bh=d43ELejxQWSRtSCIZ+3JiGeDUd/hSVHCbb3tNhT51wE=; b=sj2ORxAwkYOHkBLdepnTo1S+p9yb730eTslPGmDEPldzR7Ffywh61za6c1AsFEudAK Vkztxn5miwAqaqQr0r4p7I1e7NbJ6ZhQUvV6/wHfIyk3rIN9rrse0amCiXIhi1rwnNwO fesaSLZVFGfsREPrLeN/loTcoIb+KCSgKWuDPpQSXWmMvw0FfNNZMtpqZ9fdJUSu2Swq FboCpWJZqNWgKE216ffOJEHIu5YzwPqabQL4T3Ud8lh+SwAupZSfesKZM006ZLbZ24Tr FhospQAfYW0gK+19d8G7kawremblFtOf18JFrwGxIaEYLqhj02XX8oHPNDtrK63mfBxn FgmA== X-Gm-Message-State: AIVw112bihVEouZNr65zWRkmN1tbUqUZVIkmLfi0Io1q28EP6I9l/TTv pYcY9KvydDXISXgfN8f7/g== X-Received: by 10.84.216.93 with SMTP id f29mr12924982plj.447.1502096070665; Mon, 07 Aug 2017 01:54:30 -0700 (PDT) Received: from blr-ubuntu-linaro.wlan.qualcomm.com ([103.5.19.18]) by smtp.gmail.com with ESMTPSA id p77sm12604047pfi.153.2017.08.07.01.54.27 (version=TLS1_2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Mon, 07 Aug 2017 01:54:30 -0700 (PDT) From: Bhupinder Thakur To: xen-devel@lists.xenproject.org Date: Mon, 7 Aug 2017 14:23:13 +0530 Message-Id: <1502095997-31219-22-git-send-email-bhupinder.thakur@linaro.org> X-Mailer: git-send-email 2.7.4 In-Reply-To: <1502095997-31219-1-git-send-email-bhupinder.thakur@linaro.org> References: <1502095997-31219-1-git-send-email-bhupinder.thakur@linaro.org> Cc: Wei Liu , Julien Grall , Stefano Stabellini , Ian Jackson Subject: [Xen-devel] [PATCH 21/25 v7] xen/arm: vpl011: Add support for multiple consoles in xenconsole X-BeenThere: xen-devel@lists.xen.org X-Mailman-Version: 2.1.18 Precedence: list List-Id: Xen developer discussion List-Unsubscribe: , List-Post: List-Help: List-Subscribe: , MIME-Version: 1.0 Errors-To: xen-devel-bounces@lists.xen.org Sender: "Xen-devel" This patch adds the support for multiple consoles and introduces the iterator functions to operate on multiple consoles. This patch is in preparation to support a new vuart console. Signed-off-by: Bhupinder Thakur --- CC: Ian Jackson CC: Wei Liu CC: Stefano Stabellini CC: Julien Grall Changes since v5: - Split this patch in multiple smaller patches. Changes since v4: - Changes to make event channel handling per console rather than per domain. Changes since v3: - The changes in xenconsole have been split into four patches. This is the third patch. tools/console/daemon/io.c | 156 ++++++++++++++++++++++++++++++++++++---------- 1 file changed, 122 insertions(+), 34 deletions(-) diff --git a/tools/console/daemon/io.c b/tools/console/daemon/io.c index 71465a0..f60312d 100644 --- a/tools/console/daemon/io.c +++ b/tools/console/daemon/io.c @@ -90,12 +90,14 @@ struct buffer { }; struct console { + char *ttyname; int master_fd; int master_pollfd_idx; int slave_fd; int log_fd; struct buffer buffer; char *xspath; + char *log_suffix; int ring_ref; xenevtchn_handle *xce_handle; int xce_pollfd_idx; @@ -107,21 +109,107 @@ struct console { struct domain *d; }; +struct console_data { + char *xsname; + char *ttyname; + char *log_suffix; +}; + +static struct console_data console_data[] = { + { + .xsname = "/console", + .ttyname = "tty", + .log_suffix = "", + }, +}; + +#define MAX_CONSOLE (sizeof(console_data)/sizeof(struct console_data)) + struct domain { int domid; bool is_dead; unsigned last_seen; struct domain *next; - struct console console; + struct console console[MAX_CONSOLE]; }; static struct domain *dom_head; +typedef void (*VOID_ITER_FUNC_ARG1)(struct console *); +typedef bool (*BOOL_ITER_FUNC_ARG1)(struct console *); +typedef int (*INT_ITER_FUNC_ARG1)(struct console *); +typedef void (*VOID_ITER_FUNC_ARG2)(struct console *, void *); +typedef int (*INT_ITER_FUNC_ARG3)(struct console *, + struct domain *dom, void **); + static inline bool console_enabled(struct console *con) { return con->local_port != -1; } +static inline void console_iter_void_arg1(struct domain *d, + VOID_ITER_FUNC_ARG1 iter_func) +{ + int i = 0; + struct console *con = &d->console[0]; + + for (i = 0; i < MAX_CONSOLE; i++, con++) { + iter_func(con); + } +} + +static inline void console_iter_void_arg2(struct domain *d, + VOID_ITER_FUNC_ARG2 iter_func, + void *iter_data) +{ + int i = 0; + struct console *con = &d->console[0]; + + for (i = 0; i < MAX_CONSOLE; i++, con++) { + iter_func(con, iter_data); + } +} + +static inline bool console_iter_bool_arg1(struct domain *d, + BOOL_ITER_FUNC_ARG1 iter_func) +{ + int i = 0; + struct console *con = &d->console[0]; + + for (i = 0; i < MAX_CONSOLE; i++, con++) { + if (iter_func(con)) + return true; + } + return false; +} + +static inline int console_iter_int_arg1(struct domain *d, + INT_ITER_FUNC_ARG1 iter_func) +{ + int i = 0; + struct console *con = &d->console[0]; + + for (i = 0; i < MAX_CONSOLE; i++, con++) { + if (iter_func(con)) + return 1; + } + return 0; +} + +static inline int console_iter_int_arg3(struct domain *d, + INT_ITER_FUNC_ARG3 iter_func, + void **iter_data) +{ + int i = 0; + struct console *con = &d->console[0]; + + for (i = 0; i < MAX_CONSOLE; i++, con++) { + if (iter_func(con, d, iter_data)) + return 1; + } + return 0; +} + static int write_all(int fd, const char* buf, size_t len) { while (len) { @@ -336,7 +424,7 @@ static int create_console_log(struct console *con) return -1; } - snprintf(logfile, PATH_MAX-1, "%s/guest-%s.log", log_dir, data); + snprintf(logfile, PATH_MAX-1, "%s/guest-%s%s.log", log_dir, data, con->log_suffix); free(data); logfile[PATH_MAX-1] = '\0'; @@ -488,7 +576,7 @@ static int console_create_tty(struct console *con) } free(path); - success = (asprintf(&path, "%s/tty", con->xspath) != -1); + success = (asprintf(&path, "%s/%s", con->xspath, con->ttyname) != -1); if (!success) goto out; success = xs_write(xs, XBT_NULL, path, slave, strlen(slave)); @@ -654,13 +742,13 @@ static bool watch_domain(struct domain *dom, bool watch) { char domid_str[3 + MAX_STRLEN(dom->domid)]; bool success; - struct console *con = &dom->console; + struct console *con = &dom->console[0]; snprintf(domid_str, sizeof(domid_str), "dom%u", dom->domid); if (watch) { success = xs_watch(xs, con->xspath, domid_str); if (success) - console_create_ring(con); + console_iter_int_arg1(dom, console_create_ring); else xs_unwatch(xs, con->xspath, domid_str); } else { @@ -670,11 +758,13 @@ static bool watch_domain(struct domain *dom, bool watch) return success; } -static int console_init(struct console *con, struct domain *dom) +static int console_init(struct console *con, struct domain *dom, void **data) { char *s; int err = -1; struct timespec ts; + struct console_data **con_data = (struct console_data **)data; + char *xsname, *xspath; if (clock_gettime(CLOCK_MONOTONIC, &ts) < 0) { dolog(LOG_ERR, "Cannot get time of day %s:%s:L%d", @@ -692,15 +782,21 @@ static int console_init(struct console *con, struct domain *dom) con->xce_pollfd_idx = -1; con->next_period = ((long long)ts.tv_sec * 1000) + (ts.tv_nsec / 1000000) + RATE_LIMIT_PERIOD; con->d = dom; - con->xspath = xs_get_domain_path(xs, dom->domid); - s = realloc(con->xspath, strlen(con->xspath) + - strlen("/console") + 1); + con->ttyname = (*con_data)->ttyname; + con->log_suffix = (*con_data)->log_suffix; + xsname = (char *)(*con_data)->xsname; + xspath = xs_get_domain_path(xs, dom->domid); + s = realloc(xspath, strlen(xspath) + + strlen(xsname) + 1); if (s) { - con->xspath = s; - strcat(con->xspath, "/console"); + xspath = s; + strcat(xspath, xsname); + con->xspath = xspath; err = 0; } + (*con_data)++; + return err; } @@ -713,7 +809,7 @@ static void console_free(struct console *con) static struct domain *create_domain(int domid) { struct domain *dom; - struct console *con; + struct console_data *con_data = &console_data[0]; dom = calloc(1, sizeof *dom); if (dom == NULL) { @@ -723,9 +819,8 @@ static struct domain *create_domain(int domid) } dom->domid = domid; - con = &dom->console; - if (console_init(con, dom)) + if (console_iter_int_arg3(dom, console_init, (void **)&con_data)) goto out; if (!watch_domain(dom, true)) @@ -738,7 +833,7 @@ static struct domain *create_domain(int domid) return dom; out: - console_free(con); + console_iter_void_arg1(dom, console_free); free(dom); return NULL; } @@ -784,11 +879,9 @@ static void console_cleanup(struct console *con) static void cleanup_domain(struct domain *d) { - struct console *con = &d->console; + console_iter_void_arg1(d, console_close_tty); - console_close_tty(con); - - console_cleanup(con); + console_iter_void_arg1(d, console_cleanup); remove_domain(d); } @@ -803,12 +896,10 @@ static void console_close_evtchn(struct console *con) static void shutdown_domain(struct domain *d) { - struct console *con = &d->console; - d->is_dead = true; watch_domain(d, false); - console_unmap_interface(con); - console_close_evtchn(con); + console_iter_void_arg1(d, console_unmap_interface); + console_iter_void_arg1(d, console_close_evtchn); } static unsigned enum_pass = 0; @@ -1003,7 +1094,7 @@ static void handle_xs(void) /* We may get watches firing for domains that have recently been removed, so dom may be NULL here. */ if (dom && dom->is_dead == false) - console_create_ring(&dom->console); + console_iter_int_arg1(dom, console_create_ring); } free(vec); @@ -1058,9 +1149,7 @@ static void handle_log_reload(void) if (log_guest) { struct domain *d; for (d = dom_head; d; d = d->next) { - struct console *con = &d->console; - - console_open_log(con); + console_iter_void_arg1(d, console_open_log); } } @@ -1223,13 +1312,13 @@ void handle_io(void) /* Re-calculate any event counter allowances & unblock domains with new allowance */ for (d = dom_head; d; d = d->next) { - struct console *con = &d->console; - console_evtchn_unmask(con, (void *)now); + console_iter_void_arg2(d, console_evtchn_unmask, (void *)now); - maybe_add_console_evtchn_fd(con, (void *)&next_timeout); + console_iter_void_arg2(d, maybe_add_console_evtchn_fd, + (void *)&next_timeout); - maybe_add_console_tty_fd(con); + console_iter_void_arg1(d, maybe_add_console_tty_fd); } /* If any domain has been rate limited, we need to work @@ -1290,13 +1379,12 @@ void handle_io(void) } for (d = dom_head; d; d = n) { - struct console *con = &d->console; n = d->next; - handle_console_ring(con); + console_iter_void_arg1(d, handle_console_ring); - handle_console_tty(con); + console_iter_void_arg1(d, handle_console_tty); if (d->last_seen != enum_pass) shutdown_domain(d);