Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 3 additions & 5 deletions core/sip/tcp_trsp.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -238,18 +238,16 @@ int tcp_trsp_socket::check_connection()
create_events();

if(ret < 0) {
add_write_event_ul(server_sock->get_connect_timeout());
add_write_event(server_sock->get_connect_timeout());
DBG("connect event added...");

// because of unlock in ad_write_event_ul,
// on_connect() might already have been scheduled
if(closed)
return -1;
}
else {
// connect succeeded immediatly
connected = true;
add_read_event_ul();
add_read_event();
}
}

Expand All @@ -267,7 +265,7 @@ int tcp_trsp_socket::send(const sockaddr_storage* sa, const char* msg,
send_q.push_back(new msg_buf(sa,msg,msg_len));

if(connected) {
add_write_event_ul();
add_write_event();
DBG("write event added...");
}

Expand Down
Loading