drivers/tty/tty_buffer.c

   1 /*
   2  * Tty buffer allocation management
   3  */
   4
   5 #include <linux/types.h>
   6 #include <linux/errno.h>
   7 #include <linux/tty.h>
   8 #include <linux/tty_driver.h>
   9 #include <linux/tty_flip.h>
  10 #include <linux/timer.h>
  11 #include <linux/string.h>
  12 #include <linux/slab.h>
  13 #include <linux/sched.h>
  14 #include <linux/wait.h>
  15 #include <linux/bitops.h>
  16 #include <linux/delay.h>
  17 #include <linux/module.h>
  18 #include <linux/ratelimit.h>
  19
  20
  21 #define MIN_TTYB_SIZE   256
  22 #define TTYB_ALIGN_MASK 255
  23
  24 /*
  25  * Byte threshold to limit memory consumption for flip buffers.
  26  * The actual memory limit is > 2x this amount.
  27  */
  28 #define TTYB_DEFAULT_MEM_LIMIT  65536
  29
  30 /*
  31  * We default to dicing tty buffer allocations to this many characters
  32  * in order to avoid multiple page allocations. We know the size of
  33  * tty_buffer itself but it must also be taken into account that the
  34  * the buffer is 256 byte aligned. See tty_buffer_find for the allocation
  35  * logic this must match
  36  */
  37
  38 #define TTY_BUFFER_PAGE (((PAGE_SIZE - sizeof(struct tty_buffer)) / 2) & ~0xFF)
  39
  40 /*
  41  * If all tty flip buffers have been processed by flush_to_ldisc() or
  42  * dropped by tty_buffer_flush(), check if the linked pty has been closed.
  43  * If so, wake the reader/poll to process
  44  */
  45 static inline void check_other_closed(struct tty_struct *tty)
  46 {
  47         unsigned long flags, old;
  48
  49         /* transition from TTY_OTHER_CLOSED => TTY_OTHER_DONE must be atomic */
  50         for (flags = ACCESS_ONCE(tty->flags);
  51              test_bit(TTY_OTHER_CLOSED, &flags);
  52              ) {
  53                 old = flags;
  54                 __set_bit(TTY_OTHER_DONE, &flags);
  55                 flags = cmpxchg(&tty->flags, old, flags);
  56                 if (old == flags) {
  57                         wake_up_interruptible(&tty->read_wait);
  58                         break;
  59                 }
  60         }
  61 }
  62
  63 /**
  64  *      tty_buffer_lock_exclusive       -       gain exclusive access to buffer
  65  *      tty_buffer_unlock_exclusive     -       release exclusive access
  66  *
  67  *      @port - tty_port owning the flip buffer
  68  *
  69  *      Guarantees safe use of the line discipline's receive_buf() method by
  70  *      excluding the buffer work and any pending flush from using the flip
  71  *      buffer. Data can continue to be added concurrently to the flip buffer
  72  *      from the driver side.
  73  *
  74  *      On release, the buffer work is restarted if there is data in the
  75  *      flip buffer
  76  */
  77
  78 void tty_buffer_lock_exclusive(struct tty_port *port)
  79 {
  80         struct tty_bufhead *buf = &port->buf;
  81
  82         atomic_inc(&buf->priority);
  83         mutex_lock(&buf->lock);
  84 }
  85 EXPORT_SYMBOL_GPL(tty_buffer_lock_exclusive);
  86
  87 void tty_buffer_unlock_exclusive(struct tty_port *port)
  88 {
  89         struct tty_bufhead *buf = &port->buf;
  90         int restart;
  91
  92         restart = buf->head->commit != buf->head->read;
  93
  94         atomic_dec(&buf->priority);
  95         mutex_unlock(&buf->lock);
  96         if (restart)
  97                 queue_work(system_unbound_wq, &buf->work);
  98 }
  99 EXPORT_SYMBOL_GPL(tty_buffer_unlock_exclusive);
 100
 101 /**
 102  *      tty_buffer_space_avail  -       return unused buffer space
 103  *      @port - tty_port owning the flip buffer
 104  *
 105  *      Returns the # of bytes which can be written by the driver without
 106  *      reaching the buffer limit.
 107  *
 108  *      Note: this does not guarantee that memory is available to write
 109  *      the returned # of bytes (use tty_prepare_flip_string_xxx() to
 110  *      pre-allocate if memory guarantee is required).
 111  */
 112
 113 int tty_buffer_space_avail(struct tty_port *port)
 114 {
 115         int space = port->buf.mem_limit - atomic_read(&port->buf.mem_used);
 116         return max(space, 0);
 117 }
 118 EXPORT_SYMBOL_GPL(tty_buffer_space_avail);
 119
 120 static void tty_buffer_reset(struct tty_buffer *p, size_t size)
 121 {
 122         p->used = 0;
 123         p->size = size;
 124         p->next = NULL;
 125         p->commit = 0;
 126         p->read = 0;
 127         p->flags = 0;
 128 }
 129
 130 /**
 131  *      tty_buffer_free_all             -       free buffers used by a tty
 132  *      @tty: tty to free from
 133  *
 134  *      Remove all the buffers pending on a tty whether queued with data
 135  *      or in the free ring. Must be called when the tty is no longer in use
 136  */
 137
 138 void tty_buffer_free_all(struct tty_port *port)
 139 {
 140         struct tty_bufhead *buf = &port->buf;
 141         struct tty_buffer *p, *next;
 142         struct llist_node *llist;
 143
 144         while ((p = buf->head) != NULL) {
 145                 buf->head = p->next;
 146                 if (p->size > 0)
 147                         kfree(p);
 148         }
 149         llist = llist_del_all(&buf->free);
 150         llist_for_each_entry_safe(p, next, llist, free)
 151                 kfree(p);
 152
 153         tty_buffer_reset(&buf->sentinel, 0);
 154         buf->head = &buf->sentinel;
 155         buf->tail = &buf->sentinel;
 156
 157         atomic_set(&buf->mem_used, 0);
 158 }
 159
 160 /**
 161  *      tty_buffer_alloc        -       allocate a tty buffer
 162  *      @tty: tty device
 163  *      @size: desired size (characters)
 164  *
 165  *      Allocate a new tty buffer to hold the desired number of characters.
 166  *      We round our buffers off in 256 character chunks to get better
 167  *      allocation behaviour.
 168  *      Return NULL if out of memory or the allocation would exceed the
 169  *      per device queue
 170  */
 171
 172 static struct tty_buffer *tty_buffer_alloc(struct tty_port *port, size_t size)
 173 {
 174         struct llist_node *free;
 175         struct tty_buffer *p;
 176
 177         /* Round the buffer size out */
 178         size = __ALIGN_MASK(size, TTYB_ALIGN_MASK);
 179
 180         if (size <= MIN_TTYB_SIZE) {
 181                 free = llist_del_first(&port->buf.free);
 182                 if (free) {
 183                         p = llist_entry(free, struct tty_buffer, free);
 184                         goto found;
 185                 }
 186         }
 187
 188         /* Should possibly check if this fails for the largest buffer we
 189            have queued and recycle that ? */
 190         if (atomic_read(&port->buf.mem_used) > port->buf.mem_limit)
 191                 return NULL;
 192         p = kmalloc(sizeof(struct tty_buffer) + 2 * size, GFP_ATOMIC);
 193         if (p == NULL)
 194                 return NULL;
 195
 196 found:
 197         tty_buffer_reset(p, size);
 198         atomic_add(size, &port->buf.mem_used);
 199         return p;
 200 }
 201
 202 /**
 203  *      tty_buffer_free         -       free a tty buffer
 204  *      @tty: tty owning the buffer
 205  *      @b: the buffer to free
 206  *
 207  *      Free a tty buffer, or add it to the free list according to our
 208  *      internal strategy
 209  */
 210
 211 static void tty_buffer_free(struct tty_port *port, struct tty_buffer *b)
 212 {
 213         struct tty_bufhead *buf = &port->buf;
 214
 215         /* Dumb strategy for now - should keep some stats */
 216         WARN_ON(atomic_sub_return(b->size, &buf->mem_used) < 0);
 217
 218         if (b->size > MIN_TTYB_SIZE)
 219                 kfree(b);
 220         else if (b->size > 0)
 221                 llist_add(&b->free, &buf->free);
 222 }
 223
 224 /**
 225  *      tty_buffer_flush                -       flush full tty buffers
 226  *      @tty: tty to flush
 227  *      @ld:  optional ldisc ptr (must be referenced)
 228  *
 229  *      flush all the buffers containing receive data. If ld != NULL,
 230  *      flush the ldisc input buffer.
 231  *
 232  *      Locking: takes buffer lock to ensure single-threaded flip buffer
 233  *               'consumer'
 234  */
 235
 236 void tty_buffer_flush(struct tty_struct *tty, struct tty_ldisc *ld)
 237 {
 238         struct tty_port *port = tty->port;
 239         struct tty_bufhead *buf = &port->buf;
 240         struct tty_buffer *next;
 241
 242         atomic_inc(&buf->priority);
 243
 244         mutex_lock(&buf->lock);
 245         while ((next = buf->head->next) != NULL) {
 246                 tty_buffer_free(port, buf->head);
 247                 buf->head = next;
 248         }
 249         buf->head->read = buf->head->commit;
 250
 251         if (ld && ld->ops->flush_buffer)
 252                 ld->ops->flush_buffer(tty);
 253
 254         check_other_closed(tty);
 255
 256         atomic_dec(&buf->priority);
 257         mutex_unlock(&buf->lock);
 258 }
 259
 260 /**
 261  *      tty_buffer_request_room         -       grow tty buffer if needed
 262  *      @tty: tty structure
 263  *      @size: size desired
 264  *      @flags: buffer flags if new buffer allocated (default = 0)
 265  *
 266  *      Make at least size bytes of linear space available for the tty
 267  *      buffer. If we fail return the size we managed to find.
 268  *
 269  *      Will change over to a new buffer if the current buffer is encoded as
 270  *      TTY_NORMAL (so has no flags buffer) and the new buffer requires
 271  *      a flags buffer.
 272  */
 273 static int __tty_buffer_request_room(struct tty_port *port, size_t size,
 274                                      int flags)
 275 {
 276         struct tty_bufhead *buf = &port->buf;
 277         struct tty_buffer *b, *n;
 278         int left, change;
 279
 280         b = buf->tail;
 281         if (b->flags & TTYB_NORMAL)
 282                 left = 2 * b->size - b->used;
 283         else
 284                 left = b->size - b->used;
 285
 286         change = (b->flags & TTYB_NORMAL) && (~flags & TTYB_NORMAL);
 287         if (change || left < size) {
 288                 /* This is the slow path - looking for new buffers to use */
 289                 n = tty_buffer_alloc(port, size);
 290                 if (n != NULL) {
 291                         n->flags = flags;
 292                         buf->tail = n;
 293                         b->commit = b->used;
 294                         /* paired w/ acquire in flush_to_ldisc(); ensures the
 295                          * latest commit value can be read before the head is
 296                          * advanced to the next buffer
 297                          */
 298                         smp_store_release(&b->next, n);
 299                 } else if (change)
 300                         size = 0;
 301                 else
 302                         size = left;
 303         }
 304         return size;
 305 }
 306
 307 int tty_buffer_request_room(struct tty_port *port, size_t size)
 308 {
 309         return __tty_buffer_request_room(port, size, 0);
 310 }
 311 EXPORT_SYMBOL_GPL(tty_buffer_request_room);
 312
 313 /**
 314  *      tty_insert_flip_string_fixed_flag - Add characters to the tty buffer
 315  *      @port: tty port
 316  *      @chars: characters
 317  *      @flag: flag value for each character
 318  *      @size: size
 319  *
 320  *      Queue a series of bytes to the tty buffering. All the characters
 321  *      passed are marked with the supplied flag. Returns the number added.
 322  */
 323
 324 int tty_insert_flip_string_fixed_flag(struct tty_port *port,
 325                 const unsigned char *chars, char flag, size_t size)
 326 {
 327         int copied = 0;
 328         do {
 329                 int goal = min_t(size_t, size - copied, TTY_BUFFER_PAGE);
 330                 int flags = (flag == TTY_NORMAL) ? TTYB_NORMAL : 0;
 331                 int space = __tty_buffer_request_room(port, goal, flags);
 332                 struct tty_buffer *tb = port->buf.tail;
 333                 if (unlikely(space == 0))
 334                         break;
 335                 memcpy(char_buf_ptr(tb, tb->used), chars, space);
 336                 if (~tb->flags & TTYB_NORMAL)
 337                         memset(flag_buf_ptr(tb, tb->used), flag, space);
 338                 tb->used += space;
 339                 copied += space;
 340                 chars += space;
 341                 /* There is a small chance that we need to split the data over
 342                    several buffers. If this is the case we must loop */
 343         } while (unlikely(size > copied));
 344         return copied;
 345 }
 346 EXPORT_SYMBOL(tty_insert_flip_string_fixed_flag);
 347
 348 /**
 349  *      tty_insert_flip_string_flags    -       Add characters to the tty buffer
 350  *      @port: tty port
 351  *      @chars: characters
 352  *      @flags: flag bytes
 353  *      @size: size
 354  *
 355  *      Queue a series of bytes to the tty buffering. For each character
 356  *      the flags array indicates the status of the character. Returns the
 357  *      number added.
 358  */
 359
 360 int tty_insert_flip_string_flags(struct tty_port *port,
 361                 const unsigned char *chars, const char *flags, size_t size)
 362 {
 363         int copied = 0;
 364         do {
 365                 int goal = min_t(size_t, size - copied, TTY_BUFFER_PAGE);
 366                 int space = tty_buffer_request_room(port, goal);
 367                 struct tty_buffer *tb = port->buf.tail;
 368                 if (unlikely(space == 0))
 369                         break;
 370                 memcpy(char_buf_ptr(tb, tb->used), chars, space);
 371                 memcpy(flag_buf_ptr(tb, tb->used), flags, space);
 372                 tb->used += space;
 373                 copied += space;
 374                 chars += space;
 375                 flags += space;
 376                 /* There is a small chance that we need to split the data over
 377                    several buffers. If this is the case we must loop */
 378         } while (unlikely(size > copied));
 379         return copied;
 380 }
 381 EXPORT_SYMBOL(tty_insert_flip_string_flags);
 382
 383 /**
 384  *      tty_schedule_flip       -       push characters to ldisc
 385  *      @port: tty port to push from
 386  *
 387  *      Takes any pending buffers and transfers their ownership to the
 388  *      ldisc side of the queue. It then schedules those characters for
 389  *      processing by the line discipline.
 390  */
 391
 392 void tty_schedule_flip(struct tty_port *port)
 393 {
 394         struct tty_bufhead *buf = &port->buf;
 395
 396         buf->tail->commit = buf->tail->used;
 397         schedule_work(&buf->work);
 398 }
 399 EXPORT_SYMBOL(tty_schedule_flip);
 400
 401 /**
 402  *      tty_prepare_flip_string         -       make room for characters
 403  *      @port: tty port
 404  *      @chars: return pointer for character write area
 405  *      @size: desired size
 406  *
 407  *      Prepare a block of space in the buffer for data. Returns the length
 408  *      available and buffer pointer to the space which is now allocated and
 409  *      accounted for as ready for normal characters. This is used for drivers
 410  *      that need their own block copy routines into the buffer. There is no
 411  *      guarantee the buffer is a DMA target!
 412  */
 413
 414 int tty_prepare_flip_string(struct tty_port *port, unsigned char **chars,
 415                 size_t size)
 416 {
 417         int space = __tty_buffer_request_room(port, size, TTYB_NORMAL);
 418         if (likely(space)) {
 419                 struct tty_buffer *tb = port->buf.tail;
 420                 *chars = char_buf_ptr(tb, tb->used);
 421                 if (~tb->flags & TTYB_NORMAL)
 422                         memset(flag_buf_ptr(tb, tb->used), TTY_NORMAL, space);
 423                 tb->used += space;
 424         }
 425         return space;
 426 }
 427 EXPORT_SYMBOL_GPL(tty_prepare_flip_string);
 428
 429
 430 static int
 431 receive_buf(struct tty_struct *tty, struct tty_buffer *head, int count)
 432 {
 433         struct tty_ldisc *disc = tty->ldisc;
 434         unsigned char *p = char_buf_ptr(head, head->read);
 435         char          *f = NULL;
 436
 437         if (~head->flags & TTYB_NORMAL)
 438                 f = flag_buf_ptr(head, head->read);
 439
 440         if (disc->ops->receive_buf2)
 441                 count = disc->ops->receive_buf2(tty, p, f, count);
 442         else {
 443                 count = min_t(int, count, tty->receive_room);
 444                 if (count)
 445                         disc->ops->receive_buf(tty, p, f, count);
 446         }
 447         return count;
 448 }
 449
 450 /**
 451  *      flush_to_ldisc
 452  *      @work: tty structure passed from work queue.
 453  *
 454  *      This routine is called out of the software interrupt to flush data
 455  *      from the buffer chain to the line discipline.
 456  *
 457  *      The receive_buf method is single threaded for each tty instance.
 458  *
 459  *      Locking: takes buffer lock to ensure single-threaded flip buffer
 460  *               'consumer'
 461  */
 462
 463 static void flush_to_ldisc(struct work_struct *work)
 464 {
 465         struct tty_port *port = container_of(work, struct tty_port, buf.work);
 466         struct tty_bufhead *buf = &port->buf;
 467         struct tty_struct *tty;
 468         struct tty_ldisc *disc;
 469
 470         tty = port->itty;
 471         if (tty == NULL)
 472                 return;
 473
 474         disc = tty_ldisc_ref(tty);
 475         if (disc == NULL)
 476                 return;
 477
 478         mutex_lock(&buf->lock);
 479
 480         while (1) {
 481                 struct tty_buffer *head = buf->head;
 482                 struct tty_buffer *next;
 483                 int count;
 484
 485                 /* Ldisc or user is trying to gain exclusive access */
 486                 if (atomic_read(&buf->priority))
 487                         break;
 488
 489                 /* paired w/ release in __tty_buffer_request_room();
 490                  * ensures commit value read is not stale if the head
 491                  * is advancing to the next buffer
 492                  */
 493                 next = smp_load_acquire(&head->next);
 494                 count = head->commit - head->read;
 495                 if (!count) {
 496                         if (next == NULL) {
 497                                 check_other_closed(tty);
 498                                 break;
 499                         }
 500                         buf->head = next;
 501                         tty_buffer_free(port, head);
 502                         continue;
 503                 }
 504
 505                 count = receive_buf(tty, head, count);
 506                 if (!count)
 507                         break;
 508                 head->read += count;
 509         }
 510
 511         mutex_unlock(&buf->lock);
 512
 513         tty_ldisc_deref(disc);
 514 }
 515
 516 /**
 517  *      tty_flip_buffer_push    -       terminal
 518  *      @port: tty port to push
 519  *
 520  *      Queue a push of the terminal flip buffers to the line discipline.
 521  *      Can be called from IRQ/atomic context.
 522  *
 523  *      In the event of the queue being busy for flipping the work will be
 524  *      held off and retried later.
 525  */
 526
 527 void tty_flip_buffer_push(struct tty_port *port)
 528 {
 529         tty_schedule_flip(port);
 530 }
 531 EXPORT_SYMBOL(tty_flip_buffer_push);
 532
 533 /**
 534  *      tty_buffer_init         -       prepare a tty buffer structure
 535  *      @tty: tty to initialise
 536  *
 537  *      Set up the initial state of the buffer management for a tty device.
 538  *      Must be called before the other tty buffer functions are used.
 539  */
 540
 541 void tty_buffer_init(struct tty_port *port)
 542 {
 543         struct tty_bufhead *buf = &port->buf;
 544
 545         mutex_init(&buf->lock);
 546         tty_buffer_reset(&buf->sentinel, 0);
 547         buf->head = &buf->sentinel;
 548         buf->tail = &buf->sentinel;
 549         init_llist_head(&buf->free);
 550         atomic_set(&buf->mem_used, 0);
 551         atomic_set(&buf->priority, 0);
 552         INIT_WORK(&buf->work, flush_to_ldisc);
 553         buf->mem_limit = TTYB_DEFAULT_MEM_LIMIT;
 554 }
 555
 556 /**
 557  *      tty_buffer_set_limit    -       change the tty buffer memory limit
 558  *      @port: tty port to change
 559  *
 560  *      Change the tty buffer memory limit.
 561  *      Must be called before the other tty buffer functions are used.
 562  */
 563
 564 int tty_buffer_set_limit(struct tty_port *port, int limit)
 565 {
 566         if (limit < MIN_TTYB_SIZE)
 567                 return -EINVAL;
 568         port->buf.mem_limit = limit;
 569         return 0;
 570 }
 571 EXPORT_SYMBOL_GPL(tty_buffer_set_limit);
 572
 573 /* slave ptys can claim nested buffer lock when handling BRK and INTR */
 574 void tty_buffer_set_lock_subclass(struct tty_port *port)
 575 {
 576         lockdep_set_subclass(&port->buf.lock, TTY_LOCK_SLAVE);
 577 }