Fix memory leaks in core shutdown path (#13027)

* Fix NetAccept leak in stop_accept() — delete objects after
  stopping and clear naVec.

* Fix acceptor objects leak — delete SSLNextProtocolAccept,
  ProtocolProbeSessionAccept, and plugin accepts in
  stop_HttpProxyServer().

* Fix AIOCallback leak for API-originated AIO ops — add
  from_api flag, delete callback in io_complete and on
  error path.

Author: bryancall

include/iocore/aio/AIO.h

@@ -83,6 +83,7 @@ struct AIOCallback : public Continuation {
   int64_t    aio_result = 0;
   AIO_Reqs  *aio_req    = nullptr;
   ink_hrtime sleep_time = 0;
+  bool       from_api   = false;
   SLINK(AIOCallback, alink); /* for AIO_Reqs::aio_temp_list */
 #if TS_USE_LINUX_IO_URING
   iovec        iov     = {}; // this is to support older kernels that only support readv/writev

src/api/InkAPI.cc

@@ -7067,11 +7067,13 @@ TSAIORead(int fd, off_t offset, char *buf, size_t buffSize, TSCont contp)
   pAIO->aiocb.aio_buf = buf;
   pAIO->action        = pCont;
   pAIO->thread        = pCont->mutex->thread_holding;
+  pAIO->from_api      = true;
 
   if (ink_aio_read(pAIO, 1) == 1) {
     return TS_SUCCESS;
   }
 
+  delete pAIO;
   return TS_ERROR;
 }
 
@@ -7106,11 +7108,13 @@ TSAIOWrite(int fd, off_t offset, char *buf, const size_t bufSize, TSCont contp)
   pAIO->aiocb.aio_nbytes = bufSize;
   pAIO->action           = pCont;
   pAIO->thread           = pCont->mutex->thread_holding;
+  pAIO->from_api         = true;
 
   if (ink_aio_write(pAIO, 1) == 1) {
     return TS_SUCCESS;
   }
 
+  delete pAIO;
   return TS_ERROR;
 }
 

src/iocore/aio/AIO.cc

@@ -99,6 +99,9 @@ AIOCallback::io_complete(int event, void *data)
   if (!action.cancelled && action.continuation) {
     action.continuation->handleEvent(AIO_EVENT_DONE, this);
   }
+  if (from_api) {
+    delete this;
+  }
   return EVENT_DONE;
 }
 

src/iocore/net/UnixNetProcessor.cc

@@ -167,9 +167,11 @@ void
 UnixNetProcessor::stop_accept()
 {
   SCOPED_MUTEX_LOCK(lock, naVecMutex, this_ethread());
-  for (auto &na : naVec) {
+  for (auto *na : naVec) {
     na->stop_accept();
+    delete na;
   }
+  naVec.clear();
 }
 
 Action *

src/proxy/http/HttpProxyServerMain.cc

@@ -376,4 +376,16 @@ stop_HttpProxyServer()
 {
   sslNetProcessor.stop_accept();
   netProcessor.stop_accept();
+
+  for (auto &acceptor : HttpProxyAcceptors) {
+    delete acceptor._accept;
+    acceptor._accept = nullptr;
+  }
+  HttpProxyAcceptors.clear();
+
+  delete plugin_http_accept;
+  plugin_http_accept = nullptr;
+
+  delete plugin_http_transparent_accept;
+  plugin_http_transparent_accept = nullptr;
 }