| 10 | { |
| 11 | |
| 12 | event_mutex::event_mutex(bool recursive /* = true */) |
| 13 | : recursive_(recursive) |
| 14 | , nested_(0) |
| 15 | , count_(0) |
| 16 | , tid_(0) |
| 17 | { |
| 18 | ACL_SOCKET fds[2]; |
| 19 | |
| 20 | if (acl_sane_socketpair(AF_UNIX, SOCK_STREAM, 0, fds) < 0) { |
| 21 | logger_fatal("socketpair error=%s", last_serror()); |
| 22 | } |
| 23 | |
| 24 | in_ = fds[0]; |
| 25 | out_ = fds[1]; |
| 26 | // acl_tcp_nodelay(in_, 1); |
| 27 | // acl_tcp_nodelay(out_, 1); |
| 28 | } |
| 29 | |
| 30 | event_mutex::~event_mutex(void) |
| 31 | { |
nothing calls this directly
no test coverage detected