common/src/tx_queue_delete.c (threadx)

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

/**************************************************************************/ /* */ /* Copyright (c) Microsoft Corporation. All rights reserved. */ /* */ /* This software is licensed under the Microsoft Software License */ /* Terms for Microsoft Azure RTOS. Full text of the license can be */ /* found in the LICENSE file at https://aka.ms/AzureRTOS_EULA */ /* and in the root directory of this software. */ /* */ /**************************************************************************/ /**************************************************************************/ /**************************************************************************/ /** */ /** ThreadX Component */ /** */ /** Queue */ /** */ /**************************************************************************/ /**************************************************************************/ #define TX_SOURCE_CODE /* Include necessary system files. */ #include "tx_api.h" #include "tx_trace.h" #include "tx_thread.h" #include "tx_queue.h" /**************************************************************************/ /* */ /* FUNCTION RELEASE */ /* */ /* _tx_queue_delete PORTABLE C */ /* 6.1 */ /* AUTHOR */ /* */ /* William E. Lamie, Microsoft Corporation */ /* */ /* DESCRIPTION */ /* */ /* This function deletes the specified queue. All threads suspended */ /* on the queue are resumed with the TX_DELETED status code. */ /* */ /* INPUT */ /* */ /* queue_ptr Pointer to queue control block */ /* */ /* OUTPUT */ /* */ /* TX_SUCCESS Successful completion status */ /* */ /* CALLS */ /* */ /* _tx_thread_system_preempt_check Check for preemption */ /* _tx_thread_system_resume Resume thread service */ /* _tx_thread_system_ni_resume Non-interruptable resume thread */ /* */ /* CALLED BY */ /* */ /* Application Code */ /* */ /* RELEASE HISTORY */ /* */ /* DATE NAME DESCRIPTION */ /* */ /* 05-19-2020 William E. Lamie Initial Version 6.0 */ /* 09-30-2020 Yuxin Zhou Modified comment(s), */ /* resulting in version 6.1 */ /* */ /**************************************************************************/ UINT _tx_queue_delete(TX_QUEUE *queue_ptr) { TX_INTERRUPT_SAVE_AREA TX_THREAD *thread_ptr; TX_THREAD *next_thread; UINT suspended_count; TX_QUEUE *next_queue; TX_QUEUE *previous_queue; /* Disable interrupts to remove the queue from the created list. */ TX_DISABLE /* If trace is enabled, insert this event into the trace buffer. */ TX_TRACE_IN_LINE_INSERT(TX_TRACE_QUEUE_DELETE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(&thread_ptr), 0, 0, TX_TRACE_QUEUE_EVENTS) /* Optional queue delete extended processing. */ TX_QUEUE_DELETE_EXTENSION(queue_ptr) /* If trace is enabled, unregister this object. */ TX_TRACE_OBJECT_UNREGISTER(queue_ptr) /* Log this kernel call. */ TX_EL_QUEUE_DELETE_INSERT /* Clear the queue ID to make it invalid. */ queue_ptr -> tx_queue_id = TX_CLEAR_ID; /* Decrement the number of created queues. */ _tx_queue_created_count--; /* See if the queue is the only one on the list. */ if (_tx_queue_created_count == TX_EMPTY) { /* Only created queue, just set the created list to NULL. */ _tx_queue_created_ptr = TX_NULL; } else { /* Link-up the neighbors. */ next_queue = queue_ptr -> tx_queue_created_next; previous_queue = queue_ptr -> tx_queue_created_previous; next_queue -> tx_queue_created_previous = previous_queue; previous_queue -> tx_queue_created_next = next_queue; /* See if we have to update the created list head pointer. */ if (_tx_queue_created_ptr == queue_ptr) { /* Yes, move the head pointer to the next link. */ _tx_queue_created_ptr = next_queue; } } /* Temporarily disable preemption. */ _tx_thread_preempt_disable++; /* Pickup the suspension information. */ thread_ptr = queue_ptr -> tx_queue_suspension_list; queue_ptr -> tx_queue_suspension_list = TX_NULL; suspended_count = queue_ptr -> tx_queue_suspended_count; queue_ptr -> tx_queue_suspended_count = TX_NO_SUSPENSIONS; /* Restore interrupts. */ TX_RESTORE /* Walk through the queue list to resume any and all threads suspended on this queue. */ while (suspended_count != TX_NO_SUSPENSIONS) { /* Decrement the suspension count. */ suspended_count--; /* Lockout interrupts. */ TX_DISABLE /* Clear the cleanup pointer, this prevents the timeout from doing anything. */ thread_ptr -> tx_thread_suspend_cleanup = TX_NULL; /* Set the return status in the thread to TX_DELETED. */ thread_ptr -> tx_thread_suspend_status = TX_DELETED; /* Move the thread pointer ahead. */ next_thread = thread_ptr -> tx_thread_suspended_next; #ifdef TX_NOT_INTERRUPTABLE /* Resume the thread! */ _tx_thread_system_ni_resume(thread_ptr); /* Restore interrupts. */ TX_RESTORE #else /* Temporarily disable preemption again. */ _tx_thread_preempt_disable++; /* Restore interrupts. */ TX_RESTORE /* Resume the thread. */ _tx_thread_system_resume(thread_ptr); #endif /* Move to next thread. */ thread_ptr = next_thread; } /* Execute Port-Specific completion processing. If needed, it is typically defined in tx_port.h. */ TX_QUEUE_DELETE_PORT_COMPLETION(queue_ptr) /* Disable interrupts. */ TX_DISABLE /* Release previous preempt disable. */ _tx_thread_preempt_disable--; /* Restore interrupts. */ TX_RESTORE /* Check for preemption. */ _tx_thread_system_preempt_check(); /* Return TX_SUCCESS. */ return(TX_SUCCESS); }