[xen master] xen/arm: vpl011: Add support for multiple consoles in xenconsole

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[xen master] xen/arm: vpl011: Add support for multiple consoles in xenconsole

patchbot
commit 2a9e1692c94cab81f0e122e02ab19ee4a0485ef8
Author:     Bhupinder Thakur <[hidden email]>
AuthorDate: Wed Sep 27 11:43:30 2017 +0530
Commit:     Stefano Stabellini <[hidden email]>
CommitDate: Tue Oct 3 15:23:37 2017 -0700

    xen/arm: vpl011: Add support for multiple consoles in xenconsole
   
    This patch adds the support for multiple consoles and introduces the
    iterator functions to operate on multiple consoles.
   
    The functions called by the iterators check that they are operating
    on valid I/O parameters. This ensures that if a particular console is
    not initialized then the functions will not do anything for that
    console type.
   
    This patch is in preparation to support a new vuart console.
   
    Signed-off-by: Bhupinder Thakur <[hidden email]>
    Acked-by: Wei Liu <[hidden email]>
---
 tools/console/daemon/io.c | 160 ++++++++++++++++++++++++++++++++++++----------
 1 file changed, 126 insertions(+), 34 deletions(-)

diff --git a/tools/console/daemon/io.c b/tools/console/daemon/io.c
index 71465a0..a198dbb 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,109 @@ struct console {
  struct domain *d;
 };
 
+struct console_type {
+ char *xsname;
+ char *ttyname;
+ char *log_suffix;
+};
+
+static struct console_type console_type[] = {
+ {
+ .xsname = "/console",
+ .ttyname = "tty",
+ .log_suffix = "",
+ },
+};
+
+#define NUM_CONSOLE_TYPE (sizeof(console_type)/sizeof(struct console_type))
+
 struct domain {
  int domid;
  bool is_dead;
  unsigned last_seen;
  struct domain *next;
- struct console console;
+ struct console console[NUM_CONSOLE_TYPE];
 };
 
 static struct domain *dom_head;
 
+typedef void (*VOID_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)
+{
+ unsigned int i;
+ struct console *con = &d->console[0];
+
+ for (i = 0; i < NUM_CONSOLE_TYPE; i++, con++) {
+ iter_func(con);
+ }
+}
+
+static inline void console_iter_void_arg2(struct domain *d,
+  VOID_ITER_FUNC_ARG2 iter_func,
+  void *iter_data)
+{
+ unsigned int i;
+ struct console *con = &d->console[0];
+
+ for (i = 0; i < NUM_CONSOLE_TYPE; i++, con++) {
+ iter_func(con, iter_data);
+ }
+}
+
+static inline int console_iter_int_arg1(struct domain *d,
+ INT_ITER_FUNC_ARG1 iter_func)
+{
+ unsigned int i;
+ int ret;
+ struct console *con = &d->console[0];
+
+ for (i = 0; i < NUM_CONSOLE_TYPE; i++, con++) {
+ /*
+ * Zero return values means success.
+ *
+ * Non-zero return value indicates an error in which
+ * case terminate the loop.
+ */
+ ret = iter_func(con);
+ if (ret)
+ break;
+ }
+ return ret;
+}
+
+static inline int console_iter_int_arg3(struct domain *d,
+ INT_ITER_FUNC_ARG3 iter_func,
+ void **iter_data)
+{
+ unsigned int i;
+ int ret;
+ struct console *con = &d->console[0];
+
+ for (i = 0; i < NUM_CONSOLE_TYPE; i++, con++) {
+ /*
+ * Zero return values means success.
+ *
+ * Non-zero return value indicates an error in which
+ * case terminate the loop.
+ */
+ ret = iter_func(con, d, iter_data);
+ if (ret)
+ break;
+ }
+ return ret;
+}
+
 static int write_all(int fd, const char* buf, size_t len)
 {
  while (len) {
@@ -336,7 +426,9 @@ 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 +580,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 +746,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 +762,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_type **con_type = (struct console_type **)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 +786,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_type)->ttyname;
+ con->log_suffix = (*con_type)->log_suffix;
+ xsname = (char *)(*con_type)->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_type)++;
+
  return err;
 }
 
@@ -713,7 +813,7 @@ static void console_free(struct console *con)
 static struct domain *create_domain(int domid)
 {
  struct domain *dom;
- struct console *con;
+ struct console_type *con_type = &console_type[0];
 
  dom = calloc(1, sizeof *dom);
  if (dom == NULL) {
@@ -723,9 +823,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_type))
  goto out;
 
  if (!watch_domain(dom, true))
@@ -738,7 +837,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 +883,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 +900,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 +1098,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 +1153,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 +1316,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 +1383,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);
--
generated by git-patchbot for /home/xen/git/xen.git#master

_______________________________________________
Xen-changelog mailing list
[hidden email]
https://lists.xenproject.org/xen-changelog