| 216 | } |
| 217 | |
| 218 | RemoveResult |
| 219 | ThreadPerConnectionSendTask::remove_sample(const DataSampleElement* element) |
| 220 | { |
| 221 | DBG_ENTRY("ThreadPerConnectionSendTask", "remove_sample"); |
| 222 | |
| 223 | ACE_Message_Block* payload = element->get_sample()->cont(); |
| 224 | ThreadPerConRemoveVisitor visitor(payload); |
| 225 | |
| 226 | GuardType guard(lock_); |
| 227 | |
| 228 | queue_.accept_visitor(visitor); |
| 229 | |
| 230 | return visitor.status(); |
| 231 | } |
| 232 | |
| 233 | void ThreadPerConnectionSendTask::execute(SendRequest& req) |
| 234 | { |
nothing calls this directly
no test coverage detected