| 1062 | } |
| 1063 | |
| 1064 | Action * |
| 1065 | PluginVCCore::connect_re(Continuation *c) |
| 1066 | { |
| 1067 | ink_release_assert(connect_to != nullptr); |
| 1068 | |
| 1069 | EThread *my_thread = this_ethread(); |
| 1070 | MUTEX_TAKE_LOCK(this->mutex, my_thread); |
| 1071 | |
| 1072 | connected = true; |
| 1073 | state_send_accept(EVENT_IMMEDIATE, nullptr); |
| 1074 | |
| 1075 | // We have to take out our mutex because rest of the |
| 1076 | // system expects the VC mutex to held when calling back. |
| 1077 | // We can use take lock here instead of try lock because the |
| 1078 | // lock should never already be held. |
| 1079 | |
| 1080 | c->handleEvent(NET_EVENT_OPEN, &active_vc); |
| 1081 | MUTEX_UNTAKE_LOCK(this->mutex, my_thread); |
| 1082 | |
| 1083 | return ACTION_RESULT_DONE; |
| 1084 | } |
| 1085 | |
| 1086 | int |
| 1087 | PluginVCCore::state_send_accept_failed(int /* event ATS_UNUSED */, void * /* data ATS_UNUSED */) |
no test coverage detected