port_user.c 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218
  1. /*
  2. * Copyright (C) 2001 Jeff Dike (jdike@karaya.com)
  3. * Licensed under the GPL
  4. */
  5. #include <stdio.h>
  6. #include <stddef.h>
  7. #include <stdlib.h>
  8. #include <string.h>
  9. #include <errno.h>
  10. #include <unistd.h>
  11. #include <termios.h>
  12. #include <sys/socket.h>
  13. #include <sys/un.h>
  14. #include <netinet/in.h>
  15. #include "user_util.h"
  16. #include "kern_util.h"
  17. #include "user.h"
  18. #include "chan_user.h"
  19. #include "port.h"
  20. #include "os.h"
  21. #include "um_malloc.h"
  22. struct port_chan {
  23. int raw;
  24. struct termios tt;
  25. void *kernel_data;
  26. char dev[sizeof("32768\0")];
  27. };
  28. static void *port_init(char *str, int device, const struct chan_opts *opts)
  29. {
  30. struct port_chan *data;
  31. void *kern_data;
  32. char *end;
  33. int port;
  34. if(*str != ':'){
  35. printk("port_init : channel type 'port' must specify a "
  36. "port number\n");
  37. return(NULL);
  38. }
  39. str++;
  40. port = strtoul(str, &end, 0);
  41. if((*end != '\0') || (end == str)){
  42. printk("port_init : couldn't parse port '%s'\n", str);
  43. return(NULL);
  44. }
  45. kern_data = port_data(port);
  46. if(kern_data == NULL)
  47. return(NULL);
  48. data = um_kmalloc(sizeof(*data));
  49. if(data == NULL)
  50. goto err;
  51. *data = ((struct port_chan) { .raw = opts->raw,
  52. .kernel_data = kern_data });
  53. sprintf(data->dev, "%d", port);
  54. return(data);
  55. err:
  56. port_kern_free(kern_data);
  57. return(NULL);
  58. }
  59. static void port_free(void *d)
  60. {
  61. struct port_chan *data = d;
  62. port_kern_free(data->kernel_data);
  63. kfree(data);
  64. }
  65. static int port_open(int input, int output, int primary, void *d,
  66. char **dev_out)
  67. {
  68. struct port_chan *data = d;
  69. int fd, err;
  70. fd = port_wait(data->kernel_data);
  71. if((fd >= 0) && data->raw){
  72. CATCH_EINTR(err = tcgetattr(fd, &data->tt));
  73. if(err)
  74. return(err);
  75. err = raw(fd);
  76. if(err)
  77. return(err);
  78. }
  79. *dev_out = data->dev;
  80. return(fd);
  81. }
  82. static void port_close(int fd, void *d)
  83. {
  84. struct port_chan *data = d;
  85. port_remove_dev(data->kernel_data);
  86. os_close_file(fd);
  87. }
  88. const struct chan_ops port_ops = {
  89. .type = "port",
  90. .init = port_init,
  91. .open = port_open,
  92. .close = port_close,
  93. .read = generic_read,
  94. .write = generic_write,
  95. .console_write = generic_console_write,
  96. .window_size = generic_window_size,
  97. .free = port_free,
  98. .winch = 1,
  99. };
  100. int port_listen_fd(int port)
  101. {
  102. struct sockaddr_in addr;
  103. int fd, err, arg;
  104. fd = socket(PF_INET, SOCK_STREAM, 0);
  105. if(fd == -1)
  106. return(-errno);
  107. arg = 1;
  108. if(setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &arg, sizeof(arg)) < 0){
  109. err = -errno;
  110. goto out;
  111. }
  112. addr.sin_family = AF_INET;
  113. addr.sin_port = htons(port);
  114. addr.sin_addr.s_addr = htonl(INADDR_ANY);
  115. if(bind(fd, (struct sockaddr *) &addr, sizeof(addr)) < 0){
  116. err = -errno;
  117. goto out;
  118. }
  119. if(listen(fd, 1) < 0){
  120. err = -errno;
  121. goto out;
  122. }
  123. err = os_set_fd_block(fd, 0);
  124. if(err < 0)
  125. goto out;
  126. return(fd);
  127. out:
  128. os_close_file(fd);
  129. return(err);
  130. }
  131. struct port_pre_exec_data {
  132. int sock_fd;
  133. int pipe_fd;
  134. };
  135. void port_pre_exec(void *arg)
  136. {
  137. struct port_pre_exec_data *data = arg;
  138. dup2(data->sock_fd, 0);
  139. dup2(data->sock_fd, 1);
  140. dup2(data->sock_fd, 2);
  141. os_close_file(data->sock_fd);
  142. dup2(data->pipe_fd, 3);
  143. os_shutdown_socket(3, 1, 0);
  144. os_close_file(data->pipe_fd);
  145. }
  146. int port_connection(int fd, int *socket, int *pid_out)
  147. {
  148. int new, err;
  149. char *argv[] = { "/usr/sbin/in.telnetd", "-L",
  150. "/usr/lib/uml/port-helper", NULL };
  151. struct port_pre_exec_data data;
  152. new = os_accept_connection(fd);
  153. if(new < 0)
  154. return(new);
  155. err = os_pipe(socket, 0, 0);
  156. if(err < 0)
  157. goto out_close;
  158. data = ((struct port_pre_exec_data)
  159. { .sock_fd = new,
  160. .pipe_fd = socket[1] });
  161. err = run_helper(port_pre_exec, &data, argv, NULL);
  162. if(err < 0)
  163. goto out_shutdown;
  164. *pid_out = err;
  165. return(new);
  166. out_shutdown:
  167. os_shutdown_socket(socket[0], 1, 1);
  168. os_close_file(socket[0]);
  169. os_shutdown_socket(socket[1], 1, 1);
  170. os_close_file(socket[1]);
  171. out_close:
  172. os_close_file(new);
  173. return(err);
  174. }
  175. /*
  176. * Overrides for Emacs so that we follow Linus's tabbing style.
  177. * Emacs will notice this stuff at the end of the file and automatically
  178. * adjust the settings for this buffer only. This must remain at the end
  179. * of the file.
  180. * ---------------------------------------------------------------------------
  181. * Local variables:
  182. * c-file-style: "linux"
  183. * End:
  184. */