|
@@ -384,6 +384,10 @@ void TcpTransport::triggerBufferedAmount(size_t amount) {
|
|
}
|
|
}
|
|
|
|
|
|
void TcpTransport::process(PollService::Event event) {
|
|
void TcpTransport::process(PollService::Event event) {
|
|
|
|
+ auto self = weak_from_this().lock();
|
|
|
|
+ if (!self)
|
|
|
|
+ return;
|
|
|
|
+
|
|
try {
|
|
try {
|
|
switch (event) {
|
|
switch (event) {
|
|
case PollService::Event::Error: {
|
|
case PollService::Event::Error: {
|