mq_msgfree.c 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117
  1. /****************************************************************************
  2. * sched/mqueue/mq_msgfree.c
  3. *
  4. * Copyright (C) 2007, 2013, 2016 Gregory Nutt. All rights reserved.
  5. * Author: Gregory Nutt <gnutt@nuttx.org>
  6. *
  7. * Redistribution and use in source and binary forms, with or without
  8. * modification, are permitted provided that the following conditions
  9. * are met:
  10. *
  11. * 1. Redistributions of source code must retain the above copyright
  12. * notice, this list of conditions and the following disclaimer.
  13. * 2. Redistributions in binary form must reproduce the above copyright
  14. * notice, this list of conditions and the following disclaimer in
  15. * the documentation and/or other materials provided with the
  16. * distribution.
  17. * 3. Neither the name NuttX nor the names of its contributors may be
  18. * used to endorse or promote products derived from this software
  19. * without specific prior written permission.
  20. *
  21. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  22. * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  23. * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
  24. * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
  25. * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
  26. * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
  27. * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
  28. * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
  29. * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30. * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
  31. * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  32. * POSSIBILITY OF SUCH DAMAGE.
  33. *
  34. ****************************************************************************/
  35. /****************************************************************************
  36. * Included Files
  37. ****************************************************************************/
  38. #include <nuttx/config.h>
  39. #include <queue.h>
  40. #include <nuttx/irq.h>
  41. #include <nuttx/arch.h>
  42. #include <nuttx/kmalloc.h>
  43. #include "mqueue/mqueue.h"
  44. /****************************************************************************
  45. * Public Functions
  46. ****************************************************************************/
  47. /****************************************************************************
  48. * Name: nxmq_free_msg
  49. *
  50. * Description:
  51. * The nxmq_free_msg function will return a message to the free pool of
  52. * messages if it was a pre-allocated message. If the message was
  53. * allocated dynamically it will be deallocated.
  54. *
  55. * Input Parameters:
  56. * mqmsg - message to free
  57. *
  58. * Returned Value:
  59. * None
  60. *
  61. ****************************************************************************/
  62. void nxmq_free_msg(FAR struct mqueue_msg_s *mqmsg)
  63. {
  64. irqstate_t flags;
  65. /* If this is a generally available pre-allocated message,
  66. * then just put it back in the free list.
  67. */
  68. if (mqmsg->type == MQ_ALLOC_FIXED)
  69. {
  70. /* Make sure we avoid concurrent access to the free
  71. * list from interrupt handlers.
  72. */
  73. flags = enter_critical_section();
  74. sq_addlast((FAR sq_entry_t *)mqmsg, &g_msgfree);
  75. leave_critical_section(flags);
  76. }
  77. /* If this is a message pre-allocated for interrupts,
  78. * then put it back in the correct free list.
  79. */
  80. else if (mqmsg->type == MQ_ALLOC_IRQ)
  81. {
  82. /* Make sure we avoid concurrent access to the free
  83. * list from interrupt handlers.
  84. */
  85. flags = enter_critical_section();
  86. sq_addlast((FAR sq_entry_t *)mqmsg, &g_msgfreeirq);
  87. leave_critical_section(flags);
  88. }
  89. /* Otherwise, deallocate it. Note: interrupt handlers
  90. * will never deallocate messages because they will not
  91. * received them.
  92. */
  93. else if (mqmsg->type == MQ_ALLOC_DYN)
  94. {
  95. sched_kfree(mqmsg);
  96. }
  97. else
  98. {
  99. DEBUGPANIC();
  100. }
  101. }