| 213 | } |
| 214 | |
| 215 | void master_udp::service_on_unbind(void* ctx, ACL_VSTREAM* stream) |
| 216 | { |
| 217 | master_udp* mu = (master_udp *) ctx; |
| 218 | acl_assert(mu); |
| 219 | |
| 220 | socket_stream* ss = (socket_stream *) stream->context; |
| 221 | if (ss == NULL) { |
| 222 | logger_error("stream->context null, stream=%p", stream); |
| 223 | return; |
| 224 | } else if (ss->get_vstream() != stream) { |
| 225 | logger_error("invalid stream=%p, ss->get_vstream()=%p", |
| 226 | stream, ss->get_vstream()); |
| 227 | return; |
| 228 | } |
| 229 | |
| 230 | mu->proc_on_unbind(*ss); |
| 231 | mu->remove(ss); |
| 232 | ss->unbind(); |
| 233 | delete ss; |
| 234 | } |
| 235 | |
| 236 | int master_udp::service_on_sighup(void* ctx, ACL_VSTRING* buf) |
| 237 | { |
nothing calls this directly
no test coverage detected