You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafficserver.apache.org by ma...@apache.org on 2022/08/02 22:37:15 UTC
[trafficserver] branch master updated: Add RangeTransform::m_write_vio state checks (#8980)
This is an automated email from the ASF dual-hosted git repository.
masaori pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/trafficserver.git
The following commit(s) were added to refs/heads/master by this push:
new e912ecef7 Add RangeTransform::m_write_vio state checks (#8980)
e912ecef7 is described below
commit e912ecef7065b6c04183e10e29b15f1056a7f281
Author: Masaori Koshiba <ma...@apache.org>
AuthorDate: Wed Aug 3 07:37:09 2022 +0900
Add RangeTransform::m_write_vio state checks (#8980)
---
proxy/Transform.cc | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/proxy/Transform.cc b/proxy/Transform.cc
index 664e310df..5013d3192 100644
--- a/proxy/Transform.cc
+++ b/proxy/Transform.cc
@@ -791,7 +791,9 @@ RangeTransform::handle_event(int event, void *edata)
} else {
switch (event) {
case VC_EVENT_ERROR:
- m_write_vio.cont->handleEvent(VC_EVENT_ERROR, &m_write_vio);
+ if (m_write_vio.cont) {
+ m_write_vio.cont->handleEvent(VC_EVENT_ERROR, &m_write_vio);
+ }
break;
case VC_EVENT_WRITE_COMPLETE:
ink_assert(m_output_vio == (VIO *)edata);
@@ -814,6 +816,10 @@ RangeTransform::handle_event(int event, void *edata)
}
}
+ if (!m_write_vio.mutex) {
+ return 0;
+ }
+
MUTEX_TRY_LOCK(trylock, m_write_vio.mutex, this_ethread());
if (!trylock.is_locked()) {
retry(10);