| 144 | ////////////////////////////////////////////////////////////////////////// |
| 145 | |
| 146 | void master_proc::service_main(void* ctx, ACL_VSTREAM *stream) |
| 147 | { |
| 148 | master_proc* mp = (master_proc *) ctx; |
| 149 | acl_assert(mp != NULL); |
| 150 | |
| 151 | socket_stream* client = NEW socket_stream(); |
| 152 | if (!client->open(stream)) { |
| 153 | logger_fatal("open stream error!"); |
| 154 | } |
| 155 | |
| 156 | #ifndef ACL_WINDOWS |
| 157 | if (mp->daemon_mode_) { |
| 158 | acl_watchdog_pat(); // ����֪ͨ acl_master ���һ�� |
| 159 | } |
| 160 | #endif |
| 161 | mp->on_accept(client); |
| 162 | client->unbind(); |
| 163 | delete client; |
| 164 | } |
| 165 | |
| 166 | void master_proc::service_pre_jail(void* ctx) |
| 167 | { |
nothing calls this directly
no test coverage detected