diff --git a/configure.ac b/configure.ac index 57c5cdafc6f..bff6f54c30e 100644 --- a/configure.ac +++ b/configure.ac @@ -2993,6 +2993,7 @@ AC_CONFIG_FILES([ src/adaptation/icap/Makefile src/adaptation/ecap/Makefile src/anyp/Makefile + src/async/Makefile src/auth/Makefile src/auth/basic/Makefile src/auth/basic/DB/Makefile diff --git a/src/AsyncEngine.cc b/src/AsyncEngine.cc index 2b934472e35..d7776022855 100644 --- a/src/AsyncEngine.cc +++ b/src/AsyncEngine.cc @@ -8,4 +8,3 @@ #include "squid.h" #include "AsyncEngine.h" - diff --git a/src/BodyPipe.cc b/src/BodyPipe.cc index dfdf53ae1c9..47c19fc8c79 100644 --- a/src/BodyPipe.cc +++ b/src/BodyPipe.cc @@ -7,7 +7,7 @@ */ #include "squid.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "base/TextException.h" #include "BodyPipe.h" diff --git a/src/BodyPipe.h b/src/BodyPipe.h index 5427d1d918b..66a95b12ca9 100644 --- a/src/BodyPipe.h +++ b/src/BodyPipe.h @@ -9,7 +9,7 @@ #ifndef SQUID_BODY_PIPE_H #define SQUID_BODY_PIPE_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/CbcPointer.h" #include "MemBuf.h" diff --git a/src/CollapsedForwarding.cc b/src/CollapsedForwarding.cc index 62d8a993cfa..0845129bbf2 100644 --- a/src/CollapsedForwarding.cc +++ b/src/CollapsedForwarding.cc @@ -9,7 +9,7 @@ /* DEBUG: section 17 Request Forwarding */ #include "squid.h" -#include "base/AsyncFunCalls.h" +#include "async/AsyncFunCalls.h" #include "CollapsedForwarding.h" #include "globals.h" #include "ipc/mem/Segment.h" diff --git a/src/CommCalls.h b/src/CommCalls.h index a5c422c19fb..7b7a2138d1d 100644 --- a/src/CommCalls.h +++ b/src/CommCalls.h @@ -9,8 +9,8 @@ #ifndef SQUID_COMMCALLS_H #define SQUID_COMMCALLS_H -#include "base/AsyncCall.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncCall.h" +#include "async/AsyncJobCalls.h" #include "comm/Flag.h" #include "comm/forward.h" #include "MasterXaction.h" diff --git a/src/CompositePoolNode.h b/src/CompositePoolNode.h index 173b55b9786..bcf144367c4 100644 --- a/src/CompositePoolNode.h +++ b/src/CompositePoolNode.h @@ -12,8 +12,8 @@ #define COMPOSITEPOOLNODE_H #if USE_DELAY_POOLS +#include "async/DelayedAsyncCalls.h" #include "auth/UserRequest.h" -#include "base/DelayedAsyncCalls.h" #include "DelayIdComposite.h" #include "DelayPools.h" #include "ip/Address.h" diff --git a/src/DelayId.cc b/src/DelayId.cc index 6143ff806f2..b89775cd4a4 100644 --- a/src/DelayId.cc +++ b/src/DelayId.cc @@ -15,7 +15,7 @@ */ #if USE_DELAY_POOLS #include "acl/FilledChecklist.h" -#include "base/DelayedAsyncCalls.h" +#include "async/DelayedAsyncCalls.h" #include "client_side_request.h" #include "DelayId.h" #include "DelayPool.h" diff --git a/src/DelayIdComposite.h b/src/DelayIdComposite.h index c5426a7f525..7413c23e75f 100644 --- a/src/DelayIdComposite.h +++ b/src/DelayIdComposite.h @@ -12,7 +12,7 @@ #define DELAYIDCOMPOSITE_H #if USE_DELAY_POOLS -#include "base/forward.h" +#include "async/forward.h" #include "base/RefCount.h" #include "fatal.h" diff --git a/src/DelayVector.cc b/src/DelayVector.cc index d6681951e69..1ca39b4a054 100644 --- a/src/DelayVector.cc +++ b/src/DelayVector.cc @@ -11,8 +11,8 @@ #include "squid.h" #if USE_DELAY_POOLS -#include "base/AsyncCall.h" -#include "base/DelayedAsyncCalls.h" +#include "async/AsyncCall.h" +#include "async/DelayedAsyncCalls.h" #include "comm/Connection.h" #include "DelayVector.h" diff --git a/src/DiskIO/IpcIo/IpcIoFile.cc b/src/DiskIO/IpcIo/IpcIoFile.cc index 449a6c97b09..12f3f47ce42 100644 --- a/src/DiskIO/IpcIo/IpcIoFile.cc +++ b/src/DiskIO/IpcIo/IpcIoFile.cc @@ -9,7 +9,7 @@ /* DEBUG: section 47 Store Directory Routines */ #include "squid.h" -#include "base/AsyncFunCalls.h" +#include "async/AsyncFunCalls.h" #include "base/CodeContext.h" #include "base/RunnersRegistry.h" #include "base/TextException.h" diff --git a/src/DiskIO/IpcIo/IpcIoFile.h b/src/DiskIO/IpcIo/IpcIoFile.h index b01b8ba5ddd..f9246cb7cee 100644 --- a/src/DiskIO/IpcIo/IpcIoFile.h +++ b/src/DiskIO/IpcIo/IpcIoFile.h @@ -9,7 +9,7 @@ #ifndef SQUID_IPC_IOFILE_H #define SQUID_IPC_IOFILE_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "cbdata.h" #include "DiskIO/DiskFile.h" #include "DiskIO/IORequestor.h" diff --git a/src/Downloader.h b/src/Downloader.h index 1698ba24744..652dabd5771 100644 --- a/src/Downloader.h +++ b/src/Downloader.h @@ -9,8 +9,8 @@ #ifndef SQUID_DOWNLOADER_H #define SQUID_DOWNLOADER_H -#include "base/AsyncCallbacks.h" -#include "base/AsyncJob.h" +#include "async/AsyncCallbacks.h" +#include "async/AsyncJob.h" #include "defines.h" #include "http/forward.h" #include "http/StatusCode.h" diff --git a/src/EventLoop.cc b/src/EventLoop.cc index 00920c732dd..052254c6f10 100644 --- a/src/EventLoop.cc +++ b/src/EventLoop.cc @@ -9,8 +9,8 @@ /* DEBUG: section 01 Main Loop */ #include "squid.h" +#include "async/AsyncCallQueue.h" #include "AsyncEngine.h" -#include "base/AsyncCallQueue.h" #include "debug/Stream.h" #include "EventLoop.h" #include "fatal.h" diff --git a/src/FwdState.cc b/src/FwdState.cc index 509127fc525..a3179c46e3b 100644 --- a/src/FwdState.cc +++ b/src/FwdState.cc @@ -14,8 +14,9 @@ #include "acl/FilledChecklist.h" #include "acl/Gadgets.h" #include "anyp/PortCfg.h" -#include "base/AsyncCallbacks.h" -#include "base/AsyncCbdataCalls.h" +#include "async/AsyncCallbacks.h" +#include "async/AsyncCbdataCalls.h" +#include "async/Event.h" #include "CacheManager.h" #include "CachePeer.h" #include "client_side.h" @@ -27,7 +28,6 @@ #include "comm/Loops.h" #include "CommCalls.h" #include "errorpage.h" -#include "event.h" #include "fd.h" #include "fde.h" #include "FwdState.h" diff --git a/src/FwdState.h b/src/FwdState.h index bd99f786c9b..216624e462d 100644 --- a/src/FwdState.h +++ b/src/FwdState.h @@ -9,8 +9,8 @@ #ifndef SQUID_FORWARD_H #define SQUID_FORWARD_H +#include "async/JobWait.h" #include "base/forward.h" -#include "base/JobWait.h" #include "base/RefCount.h" #include "clients/forward.h" #include "comm.h" diff --git a/src/HappyConnOpener.cc b/src/HappyConnOpener.cc index 981216030c7..b76b868ae2b 100644 --- a/src/HappyConnOpener.cc +++ b/src/HappyConnOpener.cc @@ -8,7 +8,7 @@ #include "squid.h" #include "AccessLogEntry.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "base/CodeContext.h" #include "CachePeer.h" #include "errorpage.h" diff --git a/src/HappyConnOpener.h b/src/HappyConnOpener.h index 9e569c71db9..3e912982e85 100644 --- a/src/HappyConnOpener.h +++ b/src/HappyConnOpener.h @@ -8,8 +8,8 @@ #ifndef SQUID_HAPPYCONNOPENER_H #define SQUID_HAPPYCONNOPENER_H -#include "base/AsyncCallbacks.h" -#include "base/JobWait.h" +#include "async/AsyncCallbacks.h" +#include "async/JobWait.h" #include "base/RefCount.h" #include "comm.h" #include "comm/Connection.h" diff --git a/src/HttpControlMsg.h b/src/HttpControlMsg.h index 08b4ebe20ad..750a1f0d357 100644 --- a/src/HttpControlMsg.h +++ b/src/HttpControlMsg.h @@ -9,7 +9,7 @@ #ifndef SQUID_HTTP_CONTROL_MSG_H #define SQUID_HTTP_CONTROL_MSG_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "HttpReply.h" class CommIoCbParams; diff --git a/src/Makefile.am b/src/Makefile.am index 8921c4f1430..c1dc26553dc 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -16,7 +16,7 @@ LOADABLE_MODULES_SOURCES = \ LoadableModules.cc \ LoadableModules.h -SUBDIRS = mem time debug base anyp helper dns html ftp parser comm error eui acl format clients sbuf servers fs repl store DiskIO proxyp +SUBDIRS = async mem time debug base anyp helper dns html ftp parser comm error eui acl format clients sbuf servers fs repl store DiskIO proxyp if ENABLE_AUTH SUBDIRS += auth @@ -24,7 +24,7 @@ AUTH_LIBS= auth/libauth.la AUTH_ACL_LIBS= auth/libacls.la endif -SUBDIRS += http ip icmp ident log ipc mgr +SUBDIRS += http ip icmp ident log ipc mgr SSL_LIBS= if ENABLE_SSL @@ -354,8 +354,6 @@ squid_SOURCES = \ enums.h \ errorpage.cc \ errorpage.h \ - event.cc \ - event.h \ external_acl.cc \ fatal.cc \ fatal.h \ @@ -490,6 +488,7 @@ squid_LDADD = \ helper/libhelper.la \ http/libhttp.la \ dns/libdns.la \ + async/libasync.la \ base/libbase.la \ libsquid.la \ ip/libip.la \ @@ -1072,7 +1071,6 @@ tests_testRock_SOURCES = \ tests/stub_client_side_request.cc \ tests/stub_debug.cc \ tests/stub_errorpage.cc \ - event.cc \ fatal.cc \ fatal.h \ fd.cc \ @@ -1143,6 +1141,7 @@ tests_testRock_LDADD = \ eui/libeui.la \ $(SSL_LIBS) \ ipc/libipc.la \ + async/libasync.la \ base/libbase.la \ mem/libmem.la \ store/libstore.la \ @@ -1240,7 +1239,6 @@ tests_testUfs_SOURCES = \ tests/stub_client_side_request.cc \ tests/stub_debug.cc \ tests/stub_errorpage.cc \ - event.cc \ tests/stub_fatal.cc \ fatal.h \ fd.cc \ @@ -1319,6 +1317,7 @@ tests_testUfs_LDADD = \ ipc/libipc.la \ comm/libcomm.la \ dns/libdns.la \ + async/libasync.la \ base/libbase.la \ mem/libmem.la \ store/libstore.la \ @@ -1414,7 +1413,6 @@ tests_testStore_SOURCES = \ tests/stub_comm.cc \ tests/stub_debug.cc \ tests/stub_errorpage.cc \ - event.cc \ tests/stub_fatal.cc \ fatal.h \ tests/stub_fd.cc \ @@ -1477,6 +1475,7 @@ tests_testStore_LDADD= \ acl/libstate.la \ acl/libapi.la \ dns/libdns.la \ + async/libasync.la \ base/libbase.la \ ip/libip.la \ fs/libfs.la \ @@ -1577,7 +1576,6 @@ tests_testDiskIO_SOURCES = \ client_side_request.h \ tests/stub_debug.cc \ tests/stub_errorpage.cc \ - event.cc \ tests/stub_fatal.cc \ fatal.h \ fd.cc \ @@ -1660,6 +1658,7 @@ tests_testDiskIO_LDADD = \ $(SSL_LIBS) \ ipc/libipc.la \ dns/libdns.la \ + async/libasync.la \ base/libbase.la \ mem/libmem.la \ sbuf/libsbuf.la \ @@ -1715,6 +1714,7 @@ tests_testACLMaxUserIP_LDADD = \ ip/libip.la \ parser/libparser.la \ sbuf/libsbuf.la \ + async/libasync.la \ base/libbase.la \ $(SSLLIB) \ $(LIBCPPUNIT_LIBS) \ @@ -1847,7 +1847,6 @@ tests_test_http_range_SOURCES = \ dlink.cc \ dlink.h \ errorpage.cc \ - event.cc \ tests/stub_external_acl.cc \ tests/stub_fatal.cc \ fatal.h \ @@ -1959,6 +1958,7 @@ tests_test_http_range_LDADD = \ $(SSL_LIBS) \ ipc/libipc.la \ dns/libdns.la \ + async/libasync.la \ base/libbase.la \ mgr/libmgr.la \ html/libhtml.la \ @@ -2016,6 +2016,7 @@ tests_testHttp1Parser_LDADD= \ parser/libparser.la \ anyp/libanyp.la \ SquidConfig.o \ + async/libasync.la \ base/libbase.la \ ip/libip.la \ sbuf/libsbuf.la \ @@ -2116,6 +2117,7 @@ tests_testHttpReply_LDADD=\ acl/libstate.la \ anyp/libanyp.la \ ip/libip.la \ + async/libasync.la \ base/libbase.la \ ipc/libipc.la \ sbuf/libsbuf.la \ @@ -2230,7 +2232,6 @@ tests_testHttpRequest_SOURCES = \ dlink.cc \ dlink.h \ errorpage.cc \ - event.cc \ external_acl.cc \ tests/stub_fatal.cc \ fatal.h \ @@ -2334,6 +2335,7 @@ tests_testHttpRequest_LDADD = \ proxyp/libproxyp.la \ parser/libparser.la \ dns/libdns.la \ + async/libasync.la \ base/libbase.la \ mgr/libmgr.la \ html/libhtml.la \ @@ -2525,7 +2527,6 @@ tests_testCacheManager_SOURCES = \ dlink.cc \ dlink.h \ errorpage.cc \ - event.cc \ external_acl.cc \ tests/stub_fatal.cc \ fatal.h \ @@ -2623,6 +2624,7 @@ tests_testCacheManager_LDADD = \ acl/libstate.la \ acl/libapi.la \ dns/libdns.la \ + async/libasync.la \ base/libbase.la \ ip/libip.la \ fs/libfs.la \ @@ -2731,11 +2733,11 @@ nodist_tests_testEvent_SOURCES = \ tests/stub_cache_manager.cc \ tests/stub_cbdata.cc \ tests/stub_debug.cc \ - event.cc \ tests/stub_libmem.cc \ tests/stub_libtime.cc \ tests/stub_tools.cc tests_testEvent_LDADD = \ + async/libasync.la \ base/libbase.la \ $(LIBCPPUNIT_LIBS) \ $(COMPAT_LIB) \ @@ -2752,6 +2754,7 @@ nodist_tests_testEventLoop_SOURCES = \ tests/stub_fatal.cc \ tests/stub_libtime.cc tests_testEventLoop_LDADD = \ + async/libasync.la \ base/libbase.la \ $(LIBCPPUNIT_LIBS) \ $(COMPAT_LIB) \ diff --git a/src/MemObject.h b/src/MemObject.h index 5e90a4734a7..70d951a81d8 100644 --- a/src/MemObject.h +++ b/src/MemObject.h @@ -9,7 +9,7 @@ #ifndef SQUID_MEMOBJECT_H #define SQUID_MEMOBJECT_H -#include "base/DelayedAsyncCalls.h" +#include "async/DelayedAsyncCalls.h" #include "dlink.h" #include "http/RequestMethod.h" #include "HttpReply.h" diff --git a/src/MessageDelayPools.cc b/src/MessageDelayPools.cc index 95f5768183b..c17b263ee4b 100644 --- a/src/MessageDelayPools.cc +++ b/src/MessageDelayPools.cc @@ -10,10 +10,10 @@ #if USE_DELAY_POOLS #include "acl/Gadgets.h" +#include "async/Event.h" #include "cache_cf.h" #include "ConfigParser.h" #include "DelaySpec.h" -#include "event.h" #include "MessageBucket.h" #include "MessageDelayPools.h" #include "Parsing.h" diff --git a/src/PeerPoolMgr.cc b/src/PeerPoolMgr.cc index 6b6b440b6b3..7c76eb8d12c 100644 --- a/src/PeerPoolMgr.cc +++ b/src/PeerPoolMgr.cc @@ -8,7 +8,7 @@ #include "squid.h" #include "AccessLogEntry.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "base/RunnersRegistry.h" #include "CachePeer.h" #include "CachePeers.h" diff --git a/src/PeerPoolMgr.h b/src/PeerPoolMgr.h index 6f487f54a53..76dd9b0e720 100644 --- a/src/PeerPoolMgr.h +++ b/src/PeerPoolMgr.h @@ -9,8 +9,8 @@ #ifndef SQUID_PEERPOOLMGR_H #define SQUID_PEERPOOLMGR_H -#include "base/AsyncJob.h" -#include "base/JobWait.h" +#include "async/AsyncJob.h" +#include "async/JobWait.h" #include "comm/forward.h" #include "security/forward.h" diff --git a/src/Store.h b/src/Store.h index 3b74f07a6ef..296bd09a597 100644 --- a/src/Store.h +++ b/src/Store.h @@ -9,7 +9,7 @@ #ifndef SQUID_STORE_H #define SQUID_STORE_H -#include "base/DelayedAsyncCalls.h" +#include "async/DelayedAsyncCalls.h" #include "base/Packable.h" #include "base/Range.h" #include "base/RefCount.h" diff --git a/src/StoreClient.h b/src/StoreClient.h index 4bd6965b0e9..a1503b08004 100644 --- a/src/StoreClient.h +++ b/src/StoreClient.h @@ -10,7 +10,7 @@ #define SQUID_STORECLIENT_H #include "acl/ChecklistFiller.h" -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "base/forward.h" #include "dlink.h" #include "store/ParsingBuffer.h" diff --git a/src/adaptation/AccessCheck.cc b/src/adaptation/AccessCheck.cc index 279bdc34bd9..192b20c265a 100644 --- a/src/adaptation/AccessCheck.cc +++ b/src/adaptation/AccessCheck.cc @@ -15,7 +15,7 @@ #include "adaptation/Initiator.h" #include "adaptation/Service.h" #include "adaptation/ServiceGroups.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "base/TextException.h" #include "ConfigParser.h" #include "globals.h" diff --git a/src/adaptation/AccessCheck.h b/src/adaptation/AccessCheck.h index fc2459a5f95..9373cf6cbdd 100644 --- a/src/adaptation/AccessCheck.h +++ b/src/adaptation/AccessCheck.h @@ -14,7 +14,7 @@ #include "adaptation/forward.h" #include "adaptation/Initiator.h" #include "adaptation/ServiceFilter.h" -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "log/forward.h" class HttpRequest; diff --git a/src/adaptation/Answer.cc b/src/adaptation/Answer.cc index 8ca8c9d14a1..4e4babc4251 100644 --- a/src/adaptation/Answer.cc +++ b/src/adaptation/Answer.cc @@ -10,7 +10,7 @@ #include "squid.h" #include "adaptation/Answer.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "http/Message.h" Adaptation::Answer diff --git a/src/adaptation/Config.h b/src/adaptation/Config.h index 279cee7d4a8..e0214c7745f 100644 --- a/src/adaptation/Config.h +++ b/src/adaptation/Config.h @@ -12,8 +12,8 @@ #include "acl/forward.h" #include "adaptation/Elements.h" #include "adaptation/forward.h" -#include "base/AsyncCall.h" -#include "event.h" +#include "async/AsyncCall.h" +#include "async/Event.h" #include "Notes.h" #include "SquidString.h" diff --git a/src/adaptation/Initiate.cc b/src/adaptation/Initiate.cc index c2d114331b6..d46d7e55113 100644 --- a/src/adaptation/Initiate.cc +++ b/src/adaptation/Initiate.cc @@ -12,7 +12,7 @@ #include "adaptation/Answer.h" #include "adaptation/Initiate.h" #include "adaptation/Initiator.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "http/Message.h" namespace Adaptation diff --git a/src/adaptation/Initiate.h b/src/adaptation/Initiate.h index 3529f654232..910b384b463 100644 --- a/src/adaptation/Initiate.h +++ b/src/adaptation/Initiate.h @@ -10,7 +10,7 @@ #define SQUID_ADAPTATION__INITIATE_H #include "adaptation/forward.h" -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/CbcPointer.h" namespace Adaptation diff --git a/src/adaptation/Initiator.cc b/src/adaptation/Initiator.cc index e9cc7f0d6a7..bd8ccc30b8f 100644 --- a/src/adaptation/Initiator.cc +++ b/src/adaptation/Initiator.cc @@ -11,7 +11,7 @@ #include "squid.h" #include "adaptation/Initiate.h" #include "adaptation/Initiator.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" void Adaptation::Initiator::noteAdaptationAclCheckDone(Adaptation::ServiceGroupPointer) diff --git a/src/adaptation/Initiator.h b/src/adaptation/Initiator.h index 46d8c6a2489..6c9656167ea 100644 --- a/src/adaptation/Initiator.h +++ b/src/adaptation/Initiator.h @@ -10,7 +10,7 @@ #define SQUID_ADAPTATION__INITIATOR_H #include "adaptation/forward.h" -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/CbcPointer.h" /* diff --git a/src/adaptation/ecap/XactionRep.cc b/src/adaptation/ecap/XactionRep.cc index 264faac87b7..e44f943d6ec 100644 --- a/src/adaptation/ecap/XactionRep.cc +++ b/src/adaptation/ecap/XactionRep.cc @@ -18,7 +18,7 @@ #include "adaptation/ecap/Config.h" #include "adaptation/ecap/XactionRep.h" #include "adaptation/Initiator.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "base/TextException.h" #include "format/Format.h" #include "HttpReply.h" diff --git a/src/adaptation/icap/Config.h b/src/adaptation/icap/Config.h index ccf1ec56063..7bd9799db68 100644 --- a/src/adaptation/icap/Config.h +++ b/src/adaptation/icap/Config.h @@ -12,8 +12,8 @@ #include "acl/forward.h" #include "adaptation/Config.h" #include "adaptation/icap/ServiceRep.h" -#include "base/AsyncCall.h" -#include "event.h" +#include "async/AsyncCall.h" +#include "async/Event.h" namespace Adaptation { diff --git a/src/adaptation/icap/ServiceRep.h b/src/adaptation/icap/ServiceRep.h index 01077009dd3..1bcf08671dc 100644 --- a/src/adaptation/icap/ServiceRep.h +++ b/src/adaptation/icap/ServiceRep.h @@ -13,7 +13,7 @@ #include "adaptation/icap/Elements.h" #include "adaptation/Initiator.h" #include "adaptation/Service.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "cbdata.h" #include "comm.h" #include "FadingCounter.h" diff --git a/src/adaptation/icap/Xaction.cc b/src/adaptation/icap/Xaction.cc index c25d36c2a2e..8657f30fd3e 100644 --- a/src/adaptation/icap/Xaction.cc +++ b/src/adaptation/icap/Xaction.cc @@ -13,9 +13,9 @@ #include "adaptation/icap/Config.h" #include "adaptation/icap/Launcher.h" #include "adaptation/icap/Xaction.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" +#include "async/JobWait.h" #include "base/IoManip.h" -#include "base/JobWait.h" #include "base/TextException.h" #include "comm.h" #include "comm/Connection.h" diff --git a/src/adaptation/icap/Xaction.h b/src/adaptation/icap/Xaction.h index 73bc2dd8ad5..123c7001075 100644 --- a/src/adaptation/icap/Xaction.h +++ b/src/adaptation/icap/Xaction.h @@ -12,7 +12,7 @@ #include "AccessLogEntry.h" #include "adaptation/icap/ServiceRep.h" #include "adaptation/Initiate.h" -#include "base/JobWait.h" +#include "async/JobWait.h" #include "comm/ConnOpener.h" #include "error/forward.h" #include "HttpReply.h" diff --git a/src/base/AsyncCall.cc b/src/async/AsyncCall.cc similarity index 97% rename from src/base/AsyncCall.cc rename to src/async/AsyncCall.cc index 8ef8d5e256f..6403526aa90 100644 --- a/src/base/AsyncCall.cc +++ b/src/async/AsyncCall.cc @@ -7,8 +7,8 @@ */ #include "squid.h" -#include "base/AsyncCall.h" -#include "base/AsyncCallQueue.h" +#include "async/AsyncCall.h" +#include "async/AsyncCallQueue.h" #include "base/CodeContext.h" #include "cbdata.h" #include "debug/Stream.h" diff --git a/src/base/AsyncCall.h b/src/async/AsyncCall.h similarity index 98% rename from src/base/AsyncCall.h rename to src/async/AsyncCall.h index 7e1afb1ff2a..dd2564636e0 100644 --- a/src/base/AsyncCall.h +++ b/src/async/AsyncCall.h @@ -9,11 +9,11 @@ #ifndef SQUID_ASYNCCALL_H #define SQUID_ASYNCCALL_H +#include "async/Event.h" +#include "async/forward.h" #include "base/CodeContext.h" -#include "base/forward.h" #include "base/InstanceId.h" -#include "event.h" -#include "RefCount.h" +#include "base/RefCount.h" /** \defgroup AsynCallsAPI Async-Calls API diff --git a/src/base/AsyncCallList.cc b/src/async/AsyncCallList.cc similarity index 94% rename from src/base/AsyncCallList.cc rename to src/async/AsyncCallList.cc index 5710fc2928c..2645b941ed4 100644 --- a/src/base/AsyncCallList.cc +++ b/src/async/AsyncCallList.cc @@ -7,9 +7,9 @@ */ #include "squid.h" +#include "async/AsyncCall.h" +#include "async/AsyncCallList.h" #include "base/Assure.h" -#include "base/AsyncCall.h" -#include "base/AsyncCallList.h" void AsyncCallList::add(const AsyncCall::Pointer &call) diff --git a/src/base/AsyncCallList.h b/src/async/AsyncCallList.h similarity index 97% rename from src/base/AsyncCallList.h rename to src/async/AsyncCallList.h index 36dda7b4641..34f222d507b 100644 --- a/src/base/AsyncCallList.h +++ b/src/async/AsyncCallList.h @@ -9,7 +9,7 @@ #ifndef SQUID_BASE_ASYNCCALLLIST_H #define SQUID_BASE_ASYNCCALLLIST_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "base/RefCount.h" /// An efficient (but intrusive) AsyncCall storage preserving FIFO order. diff --git a/src/base/AsyncCallQueue.cc b/src/async/AsyncCallQueue.cc similarity index 94% rename from src/base/AsyncCallQueue.cc rename to src/async/AsyncCallQueue.cc index bfa64967e2c..90afa01a538 100644 --- a/src/base/AsyncCallQueue.cc +++ b/src/async/AsyncCallQueue.cc @@ -9,8 +9,8 @@ /* DEBUG: section 41 Event Processing */ #include "squid.h" -#include "base/AsyncCall.h" -#include "base/AsyncCallQueue.h" +#include "async/AsyncCall.h" +#include "async/AsyncCallQueue.h" #include "debug/Stream.h" AsyncCallQueue *AsyncCallQueue::TheInstance = nullptr; diff --git a/src/base/AsyncCallQueue.h b/src/async/AsyncCallQueue.h similarity index 96% rename from src/base/AsyncCallQueue.h rename to src/async/AsyncCallQueue.h index fd844d75b52..ac309beff88 100644 --- a/src/base/AsyncCallQueue.h +++ b/src/async/AsyncCallQueue.h @@ -9,7 +9,7 @@ #ifndef SQUID_ASYNCCALLQUEUE_H #define SQUID_ASYNCCALLQUEUE_H -#include "base/AsyncCallList.h" +#include "async/AsyncCallList.h" #include "base/forward.h" // The queue of asynchronous calls. All calls are fired during a single main diff --git a/src/base/AsyncCallbacks.h b/src/async/AsyncCallbacks.h similarity index 99% rename from src/base/AsyncCallbacks.h rename to src/async/AsyncCallbacks.h index 33173854469..f3ca2301249 100644 --- a/src/base/AsyncCallbacks.h +++ b/src/async/AsyncCallbacks.h @@ -9,8 +9,8 @@ #ifndef SQUID_SRC_BASE_ASYNCCALLBACKS_H #define SQUID_SRC_BASE_ASYNCCALLBACKS_H -#include "base/AsyncCall.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncCall.h" +#include "async/AsyncJobCalls.h" #include "base/TypeTraits.h" /// access to a callback result carried by an asynchronous CallDialer diff --git a/src/base/AsyncCalls.dox b/src/async/AsyncCalls.dox similarity index 100% rename from src/base/AsyncCalls.dox rename to src/async/AsyncCalls.dox diff --git a/src/base/AsyncCbdataCalls.h b/src/async/AsyncCbdataCalls.h similarity index 97% rename from src/base/AsyncCbdataCalls.h rename to src/async/AsyncCbdataCalls.h index fd761e35666..2a64a58f7ae 100644 --- a/src/base/AsyncCbdataCalls.h +++ b/src/async/AsyncCbdataCalls.h @@ -9,7 +9,7 @@ #ifndef SQUID_BASE_ASYNCCBDATACALLS_H #define SQUID_BASE_ASYNCCBDATACALLS_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "base/CbcPointer.h" // dialer to run cbdata callback functions as Async Calls diff --git a/src/base/AsyncFunCalls.h b/src/async/AsyncFunCalls.h similarity index 98% rename from src/base/AsyncFunCalls.h rename to src/async/AsyncFunCalls.h index 5c076856f73..2675811bd56 100644 --- a/src/base/AsyncFunCalls.h +++ b/src/async/AsyncFunCalls.h @@ -9,7 +9,7 @@ #ifndef SQUID_BASE_ASYNCFUNCALLS_H #define SQUID_BASE_ASYNCFUNCALLS_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include diff --git a/src/base/AsyncJob.cc b/src/async/AsyncJob.cc similarity index 98% rename from src/base/AsyncJob.cc rename to src/async/AsyncJob.cc index 5c63bc6b26c..faf4ccda671 100644 --- a/src/base/AsyncJob.cc +++ b/src/async/AsyncJob.cc @@ -9,9 +9,9 @@ /* DEBUG: section 93 ICAP (RFC 3507) Client */ #include "squid.h" -#include "base/AsyncCall.h" -#include "base/AsyncJob.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncCall.h" +#include "async/AsyncJob.h" +#include "async/AsyncJobCalls.h" #include "base/PackableStream.h" #include "base/TextException.h" #include "cbdata.h" diff --git a/src/base/AsyncJob.h b/src/async/AsyncJob.h similarity index 99% rename from src/base/AsyncJob.h rename to src/async/AsyncJob.h index 93faee98841..a1ffa5048f3 100644 --- a/src/base/AsyncJob.h +++ b/src/async/AsyncJob.h @@ -9,7 +9,7 @@ #ifndef SQUID_ASYNC_JOB_H #define SQUID_ASYNC_JOB_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "base/InstanceId.h" #include "cbdata.h" diff --git a/src/base/AsyncJobCalls.h b/src/async/AsyncJobCalls.h similarity index 99% rename from src/base/AsyncJobCalls.h rename to src/async/AsyncJobCalls.h index faa3e49bd39..774b3c8028e 100644 --- a/src/base/AsyncJobCalls.h +++ b/src/async/AsyncJobCalls.h @@ -9,7 +9,7 @@ #ifndef SQUID_ASYNCJOBCALLS_H #define SQUID_ASYNCJOBCALLS_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/CbcPointer.h" #include "debug/Stream.h" diff --git a/src/base/AsyncJobs.dox b/src/async/AsyncJobs.dox similarity index 100% rename from src/base/AsyncJobs.dox rename to src/async/AsyncJobs.dox diff --git a/src/base/DelayedAsyncCalls.cc b/src/async/DelayedAsyncCalls.cc similarity index 90% rename from src/base/DelayedAsyncCalls.cc rename to src/async/DelayedAsyncCalls.cc index 7e848e5c63a..7218c27c40b 100644 --- a/src/base/DelayedAsyncCalls.cc +++ b/src/async/DelayedAsyncCalls.cc @@ -7,8 +7,8 @@ */ #include "squid.h" -#include "base/AsyncCall.h" -#include "base/DelayedAsyncCalls.h" +#include "async/AsyncCall.h" +#include "async/DelayedAsyncCalls.h" #include "debug/Stream.h" void diff --git a/src/base/DelayedAsyncCalls.h b/src/async/DelayedAsyncCalls.h similarity index 96% rename from src/base/DelayedAsyncCalls.h rename to src/async/DelayedAsyncCalls.h index 23f0b28227b..8d41c27fbc1 100644 --- a/src/base/DelayedAsyncCalls.h +++ b/src/async/DelayedAsyncCalls.h @@ -9,7 +9,7 @@ #ifndef SQUID_BASE_DELAYEDASYNCCALLS_H #define SQUID_BASE_DELAYEDASYNCCALLS_H -#include "base/AsyncCallList.h" +#include "async/AsyncCallList.h" /// a FIFO list of async calls, all to be scheduled in FIFO order (on demand via /// the schedule() method or automatically at object destruction time) diff --git a/src/event.cc b/src/async/Event.cc similarity index 99% rename from src/event.cc rename to src/async/Event.cc index 59033388eea..fc63b4a92b7 100644 --- a/src/event.cc +++ b/src/async/Event.cc @@ -9,8 +9,8 @@ /* DEBUG: section 41 Event Processing */ #include "squid.h" +#include "async/Event.h" #include "base/Random.h" -#include "event.h" #include "mgr/Registration.h" #include "Store.h" #include "tools.h" diff --git a/src/event.h b/src/async/Event.h similarity index 100% rename from src/event.h rename to src/async/Event.h diff --git a/src/base/JobWait.cc b/src/async/JobWait.cc similarity index 97% rename from src/base/JobWait.cc rename to src/async/JobWait.cc index e25e791c9bd..94e6dc7e4e8 100644 --- a/src/base/JobWait.cc +++ b/src/async/JobWait.cc @@ -7,8 +7,8 @@ */ #include "squid.h" -#include "base/AsyncJobCalls.h" -#include "base/JobWait.h" +#include "async/AsyncJobCalls.h" +#include "async/JobWait.h" #include #include diff --git a/src/base/JobWait.h b/src/async/JobWait.h similarity index 98% rename from src/base/JobWait.h rename to src/async/JobWait.h index 918f118f27b..f95a1d248b8 100644 --- a/src/base/JobWait.h +++ b/src/async/JobWait.h @@ -9,7 +9,7 @@ #ifndef SQUID_BASE_JOBWAIT_H #define SQUID_BASE_JOBWAIT_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/CbcPointer.h" #include diff --git a/src/async/Makefile.am b/src/async/Makefile.am new file mode 100644 index 00000000000..2df79fd5b26 --- /dev/null +++ b/src/async/Makefile.am @@ -0,0 +1,32 @@ +## Copyright (C) 1996-2023 The Squid Software Foundation and contributors +## +## Squid software is distributed under GPLv2+ license and includes +## contributions from numerous individuals and organizations. +## Please see the COPYING and CONTRIBUTORS files for details. +## + +include $(top_srcdir)/src/Common.am + +noinst_LTLIBRARIES = libasync.la + +libasync_la_SOURCES = \ + AsyncCall.cc \ + AsyncCall.h \ + AsyncCallList.cc \ + AsyncCallList.h \ + AsyncCallQueue.cc \ + AsyncCallQueue.h \ + AsyncCallbacks.h \ + AsyncCbdataCalls.h \ + AsyncFunCalls.h \ + AsyncJob.cc \ + AsyncJob.h \ + AsyncJobCalls.h \ + DelayedAsyncCalls.cc \ + DelayedAsyncCalls.h \ + Event.cc \ + Event.h \ + JobWait.cc \ + JobWait.h \ + Subscription.h \ + forward.h diff --git a/src/base/Subscription.h b/src/async/Subscription.h similarity index 98% rename from src/base/Subscription.h rename to src/async/Subscription.h index dbaf4619a24..7984fee89ec 100644 --- a/src/base/Subscription.h +++ b/src/async/Subscription.h @@ -9,7 +9,7 @@ #ifndef _SQUID_BASE_SUBSCRIPTION_H #define _SQUID_BASE_SUBSCRIPTION_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" /** API for creating a series of AsyncCalls. * This is necessary because the same AsyncCall callback must not be diff --git a/src/async/forward.h b/src/async/forward.h new file mode 100644 index 00000000000..b4596c64c3c --- /dev/null +++ b/src/async/forward.h @@ -0,0 +1,27 @@ +/* + * Copyright (C) 1996-2023 The Squid Software Foundation and contributors + * + * Squid software is distributed under GPLv2+ license and includes + * contributions from numerous individuals and organizations. + * Please see the COPYING and CONTRIBUTORS files for details. + */ + +#ifndef SQUID_SRC_ASYNC_FORWARD_H +#define SQUID_SRC_ASYNC_FORWARD_H + +#include "base/forward.h" + +class AsyncCall; +class AsyncCallQueue; +class AsyncJob; +class CallDialer; +class DelayedAsyncCalls; + +template class AsyncCallback; +using AsyncCallPointer = RefCount; +template class JobWait; + +template class CbcPointer; +typedef CbcPointer AsyncJobPointer; + +#endif /* SQUID_SRC_ASYNC_FORWARD_H */ diff --git a/src/auth/CredentialsCache.cc b/src/auth/CredentialsCache.cc index 318e3092bfd..5e16edb39f8 100644 --- a/src/auth/CredentialsCache.cc +++ b/src/auth/CredentialsCache.cc @@ -10,11 +10,11 @@ #include "squid.h" #include "acl/Gadgets.h" +#include "async/Event.h" #include "auth/Config.h" #include "auth/CredentialsCache.h" #include "base/RunnersRegistry.h" #include "debug/Stream.h" -#include "event.h" namespace Auth { diff --git a/src/auth/User.cc b/src/auth/User.cc index ccbb6acaaeb..6d5893d0975 100644 --- a/src/auth/User.cc +++ b/src/auth/User.cc @@ -11,12 +11,12 @@ #include "squid.h" #include "acl/Acl.h" #include "acl/Gadgets.h" +#include "async/Event.h" #include "auth/Config.h" #include "auth/CredentialsCache.h" #include "auth/Gadgets.h" #include "auth/User.h" #include "auth/UserRequest.h" -#include "event.h" #include "globals.h" #include "Store.h" diff --git a/src/auth/digest/Config.cc b/src/auth/digest/Config.cc index a3c9e938828..c1cdbf22e0e 100644 --- a/src/auth/digest/Config.cc +++ b/src/auth/digest/Config.cc @@ -13,6 +13,7 @@ * See acl.c for access control and client_side.c for auditing */ #include "squid.h" +#include "async/Event.h" #include "auth/CredentialsCache.h" #include "auth/digest/Config.h" #include "auth/digest/Scheme.h" @@ -24,7 +25,6 @@ #include "base/LookupTable.h" #include "base/Random.h" #include "cache_cf.h" -#include "event.h" #include "helper.h" #include "HttpHeaderTools.h" #include "HttpReply.h" diff --git a/src/base/Makefile.am b/src/base/Makefile.am index ba18de1f8cc..e10d4b9bb7a 100644 --- a/src/base/Makefile.am +++ b/src/base/Makefile.am @@ -12,18 +12,6 @@ noinst_LTLIBRARIES = libbase.la libbase_la_SOURCES = \ Assure.cc \ Assure.h \ - AsyncCall.cc \ - AsyncCall.h \ - AsyncCallList.cc \ - AsyncCallList.h \ - AsyncCallQueue.cc \ - AsyncCallQueue.h \ - AsyncCallbacks.h \ - AsyncCbdataCalls.h \ - AsyncFunCalls.h \ - AsyncJob.cc \ - AsyncJob.h \ - AsyncJobCalls.h \ ByteCounter.h \ CbDataList.h \ CbcPointer.h \ @@ -32,8 +20,6 @@ libbase_la_SOURCES = \ ClpMap.h \ CodeContext.cc \ CodeContext.h \ - DelayedAsyncCalls.cc \ - DelayedAsyncCalls.h \ EnumIterator.h \ File.cc \ File.h \ @@ -44,8 +30,6 @@ libbase_la_SOURCES = \ InstanceId.h \ IoManip.cc \ IoManip.h \ - JobWait.cc \ - JobWait.h \ Lock.h \ LookupTable.h \ Packable.h \ @@ -64,7 +48,6 @@ libbase_la_SOURCES = \ RunnersRegistry.h \ Stopwatch.cc \ Stopwatch.h \ - Subscription.h \ SupportOrVeto.h \ TextException.cc \ TextException.h \ diff --git a/src/base/forward.h b/src/base/forward.h index 4a5025974bf..08658b95767 100644 --- a/src/base/forward.h +++ b/src/base/forward.h @@ -9,25 +9,14 @@ #ifndef SQUID_SRC_BASE_FORWARD_H #define SQUID_SRC_BASE_FORWARD_H -class AsyncCall; -class AsyncCallQueue; -class AsyncJob; -class CallDialer; class CodeContext; -class DelayedAsyncCalls; class Raw; class RegexPattern; class ScopedId; class Stopwatch; -template class CbcPointer; template class RefCount; -template class JobWait; -template class AsyncCallback; - -typedef CbcPointer AsyncJobPointer; typedef RefCount CodeContextPointer; -using AsyncCallPointer = RefCount; #endif /* SQUID_SRC_BASE_FORWARD_H */ diff --git a/src/client_db.cc b/src/client_db.cc index ac70562cf24..74b21b5fb74 100644 --- a/src/client_db.cc +++ b/src/client_db.cc @@ -9,10 +9,10 @@ /* DEBUG: section 00 Client Database */ #include "squid.h" +#include "async/Event.h" #include "base/RunnersRegistry.h" #include "client_db.h" #include "ClientInfo.h" -#include "event.h" #include "format/Token.h" #include "fqdncache.h" #include "ip/Address.h" diff --git a/src/client_side.cc b/src/client_side.cc index c9a3a510a6e..d6765297dd5 100644 --- a/src/client_side.cc +++ b/src/client_side.cc @@ -60,8 +60,8 @@ #include "squid.h" #include "acl/FilledChecklist.h" #include "anyp/PortCfg.h" -#include "base/AsyncCallbacks.h" -#include "base/Subscription.h" +#include "async/AsyncCallbacks.h" +#include "async/Subscription.h" #include "base/TextException.h" #include "CachePeer.h" #include "client_db.h" diff --git a/src/client_side_request.cc b/src/client_side_request.cc index 7f802d4219e..256e2bbacce 100644 --- a/src/client_side_request.cc +++ b/src/client_side_request.cc @@ -20,7 +20,7 @@ #include "acl/FilledChecklist.h" #include "acl/Gadgets.h" #include "anyp/PortCfg.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "client_side.h" #include "client_side_reply.h" #include "client_side_request.h" diff --git a/src/clients/Client.cc b/src/clients/Client.cc index 60ab7d08781..832435cc28f 100644 --- a/src/clients/Client.cc +++ b/src/clients/Client.cc @@ -29,7 +29,7 @@ #include "adaptation/AccessCheck.h" #include "adaptation/Answer.h" #include "adaptation/Iterator.h" -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #endif // implemented in client_side_reply.cc until sides have a common parent diff --git a/src/clients/Client.h b/src/clients/Client.h index f60d8cee18e..b1b70e0ef33 100644 --- a/src/clients/Client.h +++ b/src/clients/Client.h @@ -9,7 +9,7 @@ #ifndef SQUID_SRC_CLIENTS_CLIENT_H #define SQUID_SRC_CLIENTS_CLIENT_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "BodyPipe.h" #include "CommCalls.h" #include "FwdState.h" diff --git a/src/clients/FtpClient.cc b/src/clients/FtpClient.cc index fe737832469..0ce1b9e1b2e 100644 --- a/src/clients/FtpClient.cc +++ b/src/clients/FtpClient.cc @@ -10,7 +10,7 @@ #include "squid.h" #include "acl/FilledChecklist.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "base/Range.h" #include "client_side.h" #include "clients/FtpClient.h" diff --git a/src/clients/FtpRelay.cc b/src/clients/FtpRelay.cc index 8720102e6c7..73c8cfd2263 100644 --- a/src/clients/FtpRelay.cc +++ b/src/clients/FtpRelay.cc @@ -10,7 +10,7 @@ #include "squid.h" #include "anyp/PortCfg.h" -#include "base/AsyncCbdataCalls.h" +#include "async/AsyncCbdataCalls.h" #include "client_side.h" #include "clients/forward.h" #include "clients/FtpClient.h" diff --git a/src/clients/HttpTunneler.h b/src/clients/HttpTunneler.h index f31311243ae..4b0e02ed1ac 100644 --- a/src/clients/HttpTunneler.h +++ b/src/clients/HttpTunneler.h @@ -9,8 +9,8 @@ #ifndef SQUID_SRC_CLIENTS_HTTP_TUNNELER_H #define SQUID_SRC_CLIENTS_HTTP_TUNNELER_H -#include "base/AsyncCallbacks.h" -#include "base/AsyncJob.h" +#include "async/AsyncCallbacks.h" +#include "async/AsyncJob.h" #include "clients/forward.h" #include "clients/HttpTunnelerAnswer.h" #include "CommCalls.h" diff --git a/src/comm.cc b/src/comm.cc index af51538a81a..45841d47258 100644 --- a/src/comm.cc +++ b/src/comm.cc @@ -9,7 +9,8 @@ /* DEBUG: section 05 Socket Functions */ #include "squid.h" -#include "base/AsyncFunCalls.h" +#include "async/AsyncFunCalls.h" +#include "async/Event.h" #include "ClientInfo.h" #include "comm/AcceptLimiter.h" #include "comm/comm_internal.h" @@ -21,7 +22,6 @@ #include "comm/Write.h" #include "compat/cmsg.h" #include "DescriptorSet.h" -#include "event.h" #include "fd.h" #include "fde.h" #include "globals.h" diff --git a/src/comm/ConnOpener.h b/src/comm/ConnOpener.h index e4c498bb9e8..baa920cb8b0 100644 --- a/src/comm/ConnOpener.h +++ b/src/comm/ConnOpener.h @@ -9,8 +9,8 @@ #ifndef _SQUID_SRC_COMM_OPENERSTATEDATA_H #define _SQUID_SRC_COMM_OPENERSTATEDATA_H -#include "base/AsyncCall.h" -#include "base/AsyncJob.h" +#include "async/AsyncCall.h" +#include "async/AsyncJob.h" #include "cbdata.h" #include "comm/Flag.h" #include "comm/forward.h" diff --git a/src/comm/Connection.cc b/src/comm/Connection.cc index 47fa98a17b7..c4d4f88ce8d 100644 --- a/src/comm/Connection.cc +++ b/src/comm/Connection.cc @@ -7,7 +7,7 @@ */ #include "squid.h" -#include "base/JobWait.h" +#include "async/JobWait.h" #include "CachePeer.h" #include "cbdata.h" #include "comm.h" diff --git a/src/comm/IoCallback.h b/src/comm/IoCallback.h index 33681e83f4b..fc7177af9f3 100644 --- a/src/comm/IoCallback.h +++ b/src/comm/IoCallback.h @@ -9,7 +9,7 @@ #ifndef _SQUID_COMM_IOCALLBACK_H #define _SQUID_COMM_IOCALLBACK_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "comm/Flag.h" #include "comm/forward.h" #include "mem/forward.h" diff --git a/src/comm/Read.h b/src/comm/Read.h index cfbdf565647..44441e8349e 100644 --- a/src/comm/Read.h +++ b/src/comm/Read.h @@ -9,7 +9,7 @@ #ifndef _SQUID_COMM_READ_H #define _SQUID_COMM_READ_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "comm/forward.h" #include "CommCalls.h" #include "sbuf/forward.h" diff --git a/src/comm/TcpAcceptor.h b/src/comm/TcpAcceptor.h index b14cac34d55..3f0a7d7916c 100644 --- a/src/comm/TcpAcceptor.h +++ b/src/comm/TcpAcceptor.h @@ -10,9 +10,9 @@ #define SQUID_COMM_TCPACCEPTOR_H #include "anyp/forward.h" -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" +#include "async/Subscription.h" #include "base/CbcPointer.h" -#include "base/Subscription.h" #include "comm/Flag.h" #include "comm/forward.h" diff --git a/src/comm/Write.h b/src/comm/Write.h index 2f3625c9d45..82dd9b1803e 100644 --- a/src/comm/Write.h +++ b/src/comm/Write.h @@ -9,7 +9,7 @@ #ifndef _SQUID_COMM_IOWRITE_H #define _SQUID_COMM_IOWRITE_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "comm/forward.h" #include "mem/forward.h" diff --git a/src/delay_pools.cc b/src/delay_pools.cc index 677097206cb..d3a16115a28 100644 --- a/src/delay_pools.cc +++ b/src/delay_pools.cc @@ -16,6 +16,7 @@ #include "squid.h" #if USE_DELAY_POOLS +#include "async/Event.h" #include "client_side_request.h" #include "comm/Connection.h" #include "CommonPool.h" @@ -29,7 +30,6 @@ #include "DelayTagged.h" #include "DelayUser.h" #include "DelayVector.h" -#include "event.h" #include "http/Stream.h" #include "ip/Address.h" #include "MemObject.h" diff --git a/src/dns_internal.cc b/src/dns_internal.cc index fb09f8cc277..c3640cb3ef6 100644 --- a/src/dns_internal.cc +++ b/src/dns_internal.cc @@ -9,6 +9,7 @@ /* DEBUG: section 78 DNS lookups; interacts with dns/rfc1035.cc */ #include "squid.h" +#include "async/Event.h" #include "base/CodeContext.h" #include "base/InstanceId.h" #include "base/IoManip.h" @@ -24,7 +25,6 @@ #include "dlink.h" #include "dns/forward.h" #include "dns/rfc3596.h" -#include "event.h" #include "fd.h" #include "fde.h" #include "ip/tools.h" diff --git a/src/fqdncache.cc b/src/fqdncache.cc index 78670fb2352..f73074c6fb4 100644 --- a/src/fqdncache.cc +++ b/src/fqdncache.cc @@ -9,11 +9,11 @@ /* DEBUG: section 35 FQDN Cache */ #include "squid.h" +#include "async/Event.h" #include "cbdata.h" #include "dns/forward.h" #include "dns/LookupDetails.h" #include "dns/rfc1035.h" -#include "event.h" #include "fqdncache.h" #include "helper.h" #include "mgr/Registration.h" diff --git a/src/fs/rock/RockHeaderUpdater.cc b/src/fs/rock/RockHeaderUpdater.cc index b659f13f56b..50fbd81adc3 100644 --- a/src/fs/rock/RockHeaderUpdater.cc +++ b/src/fs/rock/RockHeaderUpdater.cc @@ -7,7 +7,7 @@ */ #include "squid.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "debug/Stream.h" #include "fs/rock/RockHeaderUpdater.h" #include "fs/rock/RockIoState.h" diff --git a/src/fs/rock/RockHeaderUpdater.h b/src/fs/rock/RockHeaderUpdater.h index 44de05ff87f..be31cf1e8ed 100644 --- a/src/fs/rock/RockHeaderUpdater.h +++ b/src/fs/rock/RockHeaderUpdater.h @@ -9,7 +9,7 @@ #ifndef SQUID_FS_ROCK_HEADER_UPDATER_H #define SQUID_FS_ROCK_HEADER_UPDATER_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "cbdata.h" #include "fs/rock/forward.h" #include "fs/rock/RockSwapDir.h" diff --git a/src/fs/rock/RockRebuild.cc b/src/fs/rock/RockRebuild.cc index b594e9a0fe1..9616579865c 100644 --- a/src/fs/rock/RockRebuild.cc +++ b/src/fs/rock/RockRebuild.cc @@ -9,7 +9,7 @@ /* DEBUG: section 79 Disk IO Routines */ #include "squid.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "debug/Messages.h" #include "fs/rock/RockDbCell.h" #include "fs/rock/RockRebuild.h" diff --git a/src/fs/rock/RockRebuild.h b/src/fs/rock/RockRebuild.h index 62ed4d2fc0e..8ce72385102 100644 --- a/src/fs/rock/RockRebuild.h +++ b/src/fs/rock/RockRebuild.h @@ -9,7 +9,7 @@ #ifndef SQUID_FS_ROCK_REBUILD_H #define SQUID_FS_ROCK_REBUILD_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/RunnersRegistry.h" #include "cbdata.h" #include "fs/rock/forward.h" diff --git a/src/helper.cc b/src/helper.cc index 197cd8f16a2..63273198f5e 100644 --- a/src/helper.cc +++ b/src/helper.cc @@ -9,7 +9,7 @@ /* DEBUG: section 84 Helper process maintenance */ #include "squid.h" -#include "base/AsyncCbdataCalls.h" +#include "async/AsyncCbdataCalls.h" #include "base/Packable.h" #include "base/Raw.h" #include "comm.h" diff --git a/src/helper.h b/src/helper.h index c74e36185b8..5c59a051425 100644 --- a/src/helper.h +++ b/src/helper.h @@ -11,7 +11,7 @@ #ifndef SQUID_HELPER_H #define SQUID_HELPER_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" #include "base/InstanceId.h" #include "base/RefCount.h" #include "cbdata.h" diff --git a/src/htcp.cc b/src/htcp.cc index 21cdf43c6f3..fd0c4a73091 100644 --- a/src/htcp.cc +++ b/src/htcp.cc @@ -12,7 +12,7 @@ #include "AccessLogEntry.h" #include "acl/Acl.h" #include "acl/FilledChecklist.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "CachePeer.h" #include "CachePeers.h" #include "comm.h" diff --git a/src/http.cc b/src/http.cc index 56223e30665..3a1e5439431 100644 --- a/src/http.cc +++ b/src/http.cc @@ -15,8 +15,8 @@ #include "squid.h" #include "acl/FilledChecklist.h" -#include "base/AsyncJobCalls.h" -#include "base/DelayedAsyncCalls.h" +#include "async/AsyncJobCalls.h" +#include "async/DelayedAsyncCalls.h" #include "base/Raw.h" #include "base/TextException.h" #include "base64.h" diff --git a/src/icmp/net_db.cc b/src/icmp/net_db.cc index 095843ae6b7..43c51149433 100644 --- a/src/icmp/net_db.cc +++ b/src/icmp/net_db.cc @@ -17,10 +17,10 @@ */ #include "squid.h" +#include "async/Event.h" #include "CachePeer.h" #include "CachePeers.h" #include "cbdata.h" -#include "event.h" #include "fde.h" #include "fs_io.h" #include "FwdState.h" diff --git a/src/icp_v2.cc b/src/icp_v2.cc index 7c0f571aea7..47e27072a9d 100644 --- a/src/icp_v2.cc +++ b/src/icp_v2.cc @@ -17,7 +17,7 @@ #include "AccessLogEntry.h" #include "acl/Acl.h" #include "acl/FilledChecklist.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "client_db.h" #include "comm.h" #include "comm/Connection.h" diff --git a/src/ident/Ident.cc b/src/ident/Ident.cc index 2f4bd328c05..c56c7ee15c4 100644 --- a/src/ident/Ident.cc +++ b/src/ident/Ident.cc @@ -11,7 +11,7 @@ #include "squid.h" #if USE_IDENT -#include "base/JobWait.h" +#include "async/JobWait.h" #include "comm.h" #include "comm/Connection.h" #include "comm/ConnOpener.h" diff --git a/src/ipc/Coordinator.cc b/src/ipc/Coordinator.cc index 69a4cfd0536..d54c775b9dc 100644 --- a/src/ipc/Coordinator.cc +++ b/src/ipc/Coordinator.cc @@ -9,7 +9,7 @@ /* DEBUG: section 54 Interprocess Communication */ #include "squid.h" -#include "base/Subscription.h" +#include "async/Subscription.h" #include "base/TextException.h" #include "CacheManager.h" #include "comm.h" diff --git a/src/ipc/Forwarder.cc b/src/ipc/Forwarder.cc index f2afcdca1dc..e056dd3c421 100644 --- a/src/ipc/Forwarder.cc +++ b/src/ipc/Forwarder.cc @@ -9,7 +9,7 @@ /* DEBUG: section 54 Interprocess Communication */ #include "squid.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "base/TextException.h" #include "errorpage.h" #include "HttpReply.h" diff --git a/src/ipc/Forwarder.h b/src/ipc/Forwarder.h index d12c59126a3..b8a8564ba1b 100644 --- a/src/ipc/Forwarder.h +++ b/src/ipc/Forwarder.h @@ -11,7 +11,7 @@ #ifndef SQUID_IPC_FORWARDER_H #define SQUID_IPC_FORWARDER_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/forward.h" #include "cbdata.h" #include "ipc/Request.h" diff --git a/src/ipc/Inquirer.h b/src/ipc/Inquirer.h index 56ef3c8c5c1..2dc567d678c 100644 --- a/src/ipc/Inquirer.h +++ b/src/ipc/Inquirer.h @@ -11,8 +11,8 @@ #ifndef SQUID_IPC_INQUIRER_H #define SQUID_IPC_INQUIRER_H -#include "base/AsyncJob.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJob.h" +#include "async/AsyncJobCalls.h" #include "base/forward.h" #include "ipc/forward.h" #include "ipc/Request.h" diff --git a/src/ipc/SharedListen.cc b/src/ipc/SharedListen.cc index c1fbafa7f98..ffe4a372957 100644 --- a/src/ipc/SharedListen.cc +++ b/src/ipc/SharedListen.cc @@ -9,7 +9,7 @@ /* DEBUG: section 54 Interprocess Communication */ #include "squid.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "base/TextException.h" #include "comm.h" #include "comm/Connection.h" diff --git a/src/ipc/SharedListen.h b/src/ipc/SharedListen.h index 7a5d9127992..5a6cc78dff0 100644 --- a/src/ipc/SharedListen.h +++ b/src/ipc/SharedListen.h @@ -11,8 +11,8 @@ #ifndef SQUID_IPC_SHARED_LISTEN_H #define SQUID_IPC_SHARED_LISTEN_H -#include "base/AsyncCall.h" -#include "base/Subscription.h" +#include "async/AsyncCall.h" +#include "async/Subscription.h" #include "ip/Address.h" #include "ipc/QuestionerId.h" #include "ipc/RequestId.h" diff --git a/src/ipc/StartListening.cc b/src/ipc/StartListening.cc index 8a7196524d3..3e9789c0d04 100644 --- a/src/ipc/StartListening.cc +++ b/src/ipc/StartListening.cc @@ -9,7 +9,7 @@ /* DEBUG: section 54 Interprocess Communication */ #include "squid.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "base/TextException.h" #include "comm.h" #include "comm/Connection.h" diff --git a/src/ipc/StartListening.h b/src/ipc/StartListening.h index e4d5df7edb4..701d83653b4 100644 --- a/src/ipc/StartListening.h +++ b/src/ipc/StartListening.h @@ -11,9 +11,9 @@ #ifndef SQUID_IPC_START_LISTENING_H #define SQUID_IPC_START_LISTENING_H -#include "base/AsyncCall.h" +#include "async/AsyncCall.h" +#include "async/Subscription.h" #include "base/forward.h" -#include "base/Subscription.h" #include "comm/forward.h" #include "ip/forward.h" #include "ipc/FdNotes.h" diff --git a/src/ipc/Strand.cc b/src/ipc/Strand.cc index f70869506f0..48fcfe9705e 100644 --- a/src/ipc/Strand.cc +++ b/src/ipc/Strand.cc @@ -9,7 +9,7 @@ /* DEBUG: section 54 Interprocess Communication */ #include "squid.h" -#include "base/Subscription.h" +#include "async/Subscription.h" #include "base/TextException.h" #include "CacheManager.h" #include "CollapsedForwarding.h" diff --git a/src/ipc/UdsOp.h b/src/ipc/UdsOp.h index d594b64c91f..ad60a1b7c67 100644 --- a/src/ipc/UdsOp.h +++ b/src/ipc/UdsOp.h @@ -11,7 +11,7 @@ #ifndef SQUID_IPC_ASYNCUDSOP_H #define SQUID_IPC_ASYNCUDSOP_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/forward.h" #include "cbdata.h" #include "comm/forward.h" diff --git a/src/ipcache.cc b/src/ipcache.cc index 41290fdaee5..75e532f0dc2 100644 --- a/src/ipcache.cc +++ b/src/ipcache.cc @@ -9,6 +9,7 @@ /* DEBUG: section 14 IP Cache */ #include "squid.h" +#include "async/Event.h" #include "base/IoManip.h" #include "CacheManager.h" #include "cbdata.h" @@ -16,7 +17,6 @@ #include "dlink.h" #include "dns/LookupDetails.h" #include "dns/rfc3596.h" -#include "event.h" #include "ip/Address.h" #include "ip/tools.h" #include "ipcache.h" diff --git a/src/log/TcpLogger.h b/src/log/TcpLogger.h index 0347a6fc39c..0bc0ff293ef 100644 --- a/src/log/TcpLogger.h +++ b/src/log/TcpLogger.h @@ -9,8 +9,8 @@ #ifndef _SQUID_SRC_LOG_TCPLOGGER_H #define _SQUID_SRC_LOG_TCPLOGGER_H -#include "base/AsyncJob.h" -#include "base/JobWait.h" +#include "async/AsyncJob.h" +#include "async/JobWait.h" #include "comm/forward.h" #include "ip/Address.h" #include "log/forward.h" diff --git a/src/main.cc b/src/main.cc index ca1877707ff..7f0932d2719 100644 --- a/src/main.cc +++ b/src/main.cc @@ -14,11 +14,12 @@ #include "acl/Asn.h" #include "acl/forward.h" #include "anyp/UriScheme.h" +#include "async/Event.h" +#include "async/Subscription.h" #include "auth/Config.h" #include "auth/Gadgets.h" #include "AuthReg.h" #include "base/RunnersRegistry.h" -#include "base/Subscription.h" #include "base/TextException.h" #include "cache_cf.h" #include "CachePeer.h" @@ -33,7 +34,6 @@ #include "DiskIO/DiskIOModule.h" #include "dns/forward.h" #include "errorpage.h" -#include "event.h" #include "EventLoop.h" #include "ExternalACL.h" #include "fd.h" diff --git a/src/mem/old_api.cc b/src/mem/old_api.cc index 461be27d02d..67fe137712a 100644 --- a/src/mem/old_api.cc +++ b/src/mem/old_api.cc @@ -9,10 +9,10 @@ /* DEBUG: section 13 High Level Memory Pool Management */ #include "squid.h" +#include "async/Event.h" #include "base/PackableStream.h" #include "ClientInfo.h" #include "dlink.h" -#include "event.h" #include "fs_io.h" #include "icmp/net_db.h" #include "md5.h" diff --git a/src/mgr/Forwarder.cc b/src/mgr/Forwarder.cc index 6ebd12ac4a6..8e6f484491e 100644 --- a/src/mgr/Forwarder.cc +++ b/src/mgr/Forwarder.cc @@ -10,7 +10,7 @@ #include "squid.h" #include "AccessLogEntry.h" -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "base/TextException.h" #include "comm.h" #include "comm/Connection.h" diff --git a/src/mgr/StoreToCommWriter.cc b/src/mgr/StoreToCommWriter.cc index 38c979a1506..f1ec76a345e 100644 --- a/src/mgr/StoreToCommWriter.cc +++ b/src/mgr/StoreToCommWriter.cc @@ -9,7 +9,7 @@ /* DEBUG: section 16 Cache Manager API */ #include "squid.h" -#include "base/AsyncCbdataCalls.h" +#include "async/AsyncCbdataCalls.h" #include "base/TextException.h" #include "comm.h" #include "comm/Connection.h" diff --git a/src/mgr/StoreToCommWriter.h b/src/mgr/StoreToCommWriter.h index d3d584d2173..f12110f938e 100644 --- a/src/mgr/StoreToCommWriter.h +++ b/src/mgr/StoreToCommWriter.h @@ -11,7 +11,7 @@ #ifndef SQUID_MGR_STORE_TO_COMM_WRITER_H #define SQUID_MGR_STORE_TO_COMM_WRITER_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "comm/forward.h" #include "http/forward.h" #include "mgr/Action.h" diff --git a/src/neighbors.cc b/src/neighbors.cc index a2719f628f8..928e6065566 100644 --- a/src/neighbors.cc +++ b/src/neighbors.cc @@ -11,6 +11,7 @@ #include "squid.h" #include "acl/FilledChecklist.h" #include "anyp/PortCfg.h" +#include "async/Event.h" #include "base/EnumIterator.h" #include "base/IoManip.h" #include "base/PackableStream.h" @@ -20,7 +21,6 @@ #include "comm/Connection.h" #include "comm/ConnOpener.h" #include "debug/Messages.h" -#include "event.h" #include "FwdState.h" #include "globals.h" #include "htcp.h" diff --git a/src/peer_digest.cc b/src/peer_digest.cc index 7d290cc9013..e4f31c30ed0 100644 --- a/src/peer_digest.cc +++ b/src/peer_digest.cc @@ -10,10 +10,10 @@ #include "squid.h" #if USE_CACHE_DIGESTS +#include "async/Event.h" #include "base/IoManip.h" #include "CacheDigest.h" #include "CachePeer.h" -#include "event.h" #include "FwdState.h" #include "globals.h" #include "HttpReply.h" diff --git a/src/peer_select.cc b/src/peer_select.cc index c1e0d89612c..2ad00e3649f 100644 --- a/src/peer_select.cc +++ b/src/peer_select.cc @@ -10,7 +10,8 @@ #include "squid.h" #include "acl/FilledChecklist.h" -#include "base/AsyncCbdataCalls.h" +#include "async/AsyncCbdataCalls.h" +#include "async/Event.h" #include "base/InstanceId.h" #include "base/TypeTraits.h" #include "CachePeer.h" @@ -19,7 +20,6 @@ #include "client_side.h" #include "dns/LookupDetails.h" #include "errorpage.h" -#include "event.h" #include "FwdState.h" #include "globals.h" #include "hier_code.h" diff --git a/src/security/PeerConnector.cc b/src/security/PeerConnector.cc index f12229403e7..9220508917c 100644 --- a/src/security/PeerConnector.cc +++ b/src/security/PeerConnector.cc @@ -10,7 +10,7 @@ #include "squid.h" #include "acl/FilledChecklist.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "base/IoManip.h" #include "CachePeer.h" #include "comm/Loops.h" diff --git a/src/security/PeerConnector.h b/src/security/PeerConnector.h index 3c7c01b8dcb..60240fa3a37 100644 --- a/src/security/PeerConnector.h +++ b/src/security/PeerConnector.h @@ -11,9 +11,9 @@ #include "acl/Acl.h" #include "acl/ChecklistFiller.h" -#include "base/AsyncCallbacks.h" -#include "base/AsyncJob.h" -#include "base/JobWait.h" +#include "async/AsyncCallbacks.h" +#include "async/AsyncJob.h" +#include "async/JobWait.h" #include "CommCalls.h" #include "http/forward.h" #include "security/EncryptorAnswer.h" diff --git a/src/servers/FtpServer.cc b/src/servers/FtpServer.cc index 976fe4e1f16..6be6cdcb7f5 100644 --- a/src/servers/FtpServer.cc +++ b/src/servers/FtpServer.cc @@ -10,10 +10,10 @@ #include "squid.h" #include "acl/FilledChecklist.h" +#include "async/Subscription.h" #include "base/CharacterSet.h" #include "base/Raw.h" #include "base/RefCount.h" -#include "base/Subscription.h" #include "client_side_reply.h" #include "client_side_request.h" #include "clientStream.h" diff --git a/src/servers/FtpServer.h b/src/servers/FtpServer.h index 4f6ab9264b9..8a33a5dbb44 100644 --- a/src/servers/FtpServer.h +++ b/src/servers/FtpServer.h @@ -11,7 +11,7 @@ #ifndef SQUID_SERVERS_FTP_SERVER_H #define SQUID_SERVERS_FTP_SERVER_H -#include "base/JobWait.h" +#include "async/JobWait.h" #include "base/Lock.h" #include "client_side.h" #include "comm/forward.h" diff --git a/src/servers/Server.h b/src/servers/Server.h index 01cfae1eff6..e9cb7de3560 100644 --- a/src/servers/Server.h +++ b/src/servers/Server.h @@ -13,7 +13,7 @@ #include "anyp/forward.h" #include "anyp/ProtocolVersion.h" -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "BodyPipe.h" #include "comm/Write.h" #include "CommCalls.h" diff --git a/src/snmp_core.cc b/src/snmp_core.cc index 2c13bdb6c39..fb460bd46ed 100644 --- a/src/snmp_core.cc +++ b/src/snmp_core.cc @@ -10,7 +10,7 @@ #include "squid.h" #include "acl/FilledChecklist.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "base/CbcPointer.h" #include "CachePeer.h" #include "CachePeers.h" diff --git a/src/ssl/ServerBump.h b/src/ssl/ServerBump.h index c8af4d0208e..cd1ab36417e 100644 --- a/src/ssl/ServerBump.h +++ b/src/ssl/ServerBump.h @@ -9,7 +9,7 @@ #ifndef _SQUID_SSL_PEEKER_H #define _SQUID_SSL_PEEKER_H -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #include "base/CbcPointer.h" #include "comm/forward.h" #include "HttpRequest.h" diff --git a/src/ssl/helper.cc b/src/ssl/helper.cc index 42b4594b2e2..006eda9d81e 100644 --- a/src/ssl/helper.cc +++ b/src/ssl/helper.cc @@ -9,7 +9,7 @@ #include "squid.h" #include "../helper.h" #include "anyp/PortCfg.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" #include "cache_cf.h" #include "fs_io.h" #include "helper/Reply.h" diff --git a/src/ssl/helper.h b/src/ssl/helper.h index 0810049e134..6b570fe4482 100644 --- a/src/ssl/helper.h +++ b/src/ssl/helper.h @@ -11,7 +11,7 @@ #if USE_OPENSSL -#include "base/AsyncJobCalls.h" +#include "async/AsyncJobCalls.h" #include "base/ClpMap.h" #include "helper/forward.h" #include "security/forward.h" diff --git a/src/stat.cc b/src/stat.cc index e26360930db..b8187899c85 100644 --- a/src/stat.cc +++ b/src/stat.cc @@ -10,6 +10,7 @@ #include "squid.h" #include "AccessLogEntry.h" +#include "async/Event.h" #include "CacheDigest.h" #include "CachePeer.h" #include "CachePeers.h" @@ -17,7 +18,6 @@ #include "client_side_request.h" #include "comm/Connection.h" #include "comm/Loops.h" -#include "event.h" #include "fde.h" #include "format/Token.h" #include "globals.h" diff --git a/src/store.cc b/src/store.cc index 97d2e87c610..2a3e56c2e84 100644 --- a/src/store.cc +++ b/src/store.cc @@ -9,7 +9,7 @@ /* DEBUG: section 20 Storage Manager */ #include "squid.h" -#include "base/AsyncCbdataCalls.h" +#include "async/AsyncCbdataCalls.h" #include "base/IoManip.h" #include "base/PackableStream.h" #include "base/TextException.h" @@ -22,8 +22,8 @@ #if HAVE_DISKIO_MODULE_IPCIO #include "DiskIO/IpcIo/IpcIoFile.h" #endif +#include "async/Event.h" #include "ETag.h" -#include "event.h" #include "fde.h" #include "globals.h" #include "http.h" diff --git a/src/store_client.cc b/src/store_client.cc index adc3cc1f7c6..18d42786fa6 100644 --- a/src/store_client.cc +++ b/src/store_client.cc @@ -10,9 +10,9 @@ #include "squid.h" #include "acl/FilledChecklist.h" -#include "base/AsyncCbdataCalls.h" +#include "async/AsyncCbdataCalls.h" +#include "async/Event.h" #include "base/CodeContext.h" -#include "event.h" #include "globals.h" #include "HttpReply.h" #include "HttpRequest.h" diff --git a/src/store_digest.cc b/src/store_digest.cc index 3cf348ad4eb..a40711cffed 100644 --- a/src/store_digest.cc +++ b/src/store_digest.cc @@ -15,8 +15,8 @@ */ #include "squid.h" +#include "async/Event.h" #include "debug/Stream.h" -#include "event.h" #include "globals.h" #include "mgr/Registration.h" #include "store_digest.h" diff --git a/src/store_rebuild.cc b/src/store_rebuild.cc index fa0877d80a5..6ee207f5fff 100644 --- a/src/store_rebuild.cc +++ b/src/store_rebuild.cc @@ -9,8 +9,8 @@ /* DEBUG: section 20 Store Rebuild Routines */ #include "squid.h" +#include "async/Event.h" #include "debug/Messages.h" -#include "event.h" #include "fde.h" #include "globals.h" #include "md5.h" diff --git a/src/tests/stub_comm.cc b/src/tests/stub_comm.cc index f1d59cf71db..dccf9b9908f 100644 --- a/src/tests/stub_comm.cc +++ b/src/tests/stub_comm.cc @@ -22,7 +22,7 @@ // void comm_read(const Comm::ConnectionPointer &, char*, int, AsyncCall::Pointer &) STUB /* should be in stub_libbase */ -#include "base/DelayedAsyncCalls.h" +#include "async/DelayedAsyncCalls.h" void DelayedAsyncCalls::delay(const AsyncCall::Pointer &) STUB void DelayedAsyncCalls::schedule() STUB diff --git a/src/tests/stub_event.cc b/src/tests/stub_event.cc index 97731813544..59331fbf3c2 100644 --- a/src/tests/stub_event.cc +++ b/src/tests/stub_event.cc @@ -7,7 +7,7 @@ */ #include "squid.h" -#include "event.h" +#include "async/Event.h" #define STUB_API "event.cc" #include "tests/STUB.h" diff --git a/src/tests/stub_libcomm.cc b/src/tests/stub_libcomm.cc index 6dd2bf9b61f..613dce20719 100644 --- a/src/tests/stub_libcomm.cc +++ b/src/tests/stub_libcomm.cc @@ -7,7 +7,7 @@ */ #include "squid.h" -#include "base/AsyncJob.h" +#include "async/AsyncJob.h" #define STUB_API "comm/libcomm.la" #include "tests/STUB.h" diff --git a/src/tests/testEvent.cc b/src/tests/testEvent.cc index cdacda932de..730a84859c4 100644 --- a/src/tests/testEvent.cc +++ b/src/tests/testEvent.cc @@ -7,9 +7,9 @@ */ #include "squid.h" -#include "base/AsyncCallQueue.h" +#include "async/AsyncCallQueue.h" +#include "async/Event.h" #include "compat/cppunit.h" -#include "event.h" #include "MemBuf.h" #include "unitTestMain.h" diff --git a/src/tests/testSBuf.cc b/src/tests/testSBuf.cc index e48a32e7270..65d29963ee1 100644 --- a/src/tests/testSBuf.cc +++ b/src/tests/testSBuf.cc @@ -7,10 +7,10 @@ */ #include "squid.h" +#include "async/Event.h" #include "base/CharacterSet.h" #include "base/TextException.h" #include "compat/cppunit.h" -#include "event.h" #include "HttpReply.h" #include "MemObject.h" #include "sbuf/Algorithms.h" diff --git a/src/tests/testStoreSupport.cc b/src/tests/testStoreSupport.cc index ffabd592e67..a35f8b541ed 100644 --- a/src/tests/testStoreSupport.cc +++ b/src/tests/testStoreSupport.cc @@ -7,7 +7,7 @@ */ #include "squid.h" -#include "event.h" +#include "async/Event.h" #include "EventLoop.h" #include "testStoreSupport.h" diff --git a/src/tools.cc b/src/tools.cc index 5c11ddb320d..3a4f3d7dd28 100644 --- a/src/tools.cc +++ b/src/tools.cc @@ -10,7 +10,7 @@ #include "squid.h" #include "anyp/PortCfg.h" -#include "base/Subscription.h" +#include "async/Subscription.h" #include "client_side.h" #include "fatal.h" #include "fde.h" diff --git a/src/tunnel.cc b/src/tunnel.cc index dca34bdc5d4..8d88615c349 100644 --- a/src/tunnel.cc +++ b/src/tunnel.cc @@ -10,9 +10,9 @@ #include "squid.h" #include "acl/FilledChecklist.h" -#include "base/AsyncCallbacks.h" +#include "async/AsyncCallbacks.h" +#include "async/JobWait.h" #include "base/CbcPointer.h" -#include "base/JobWait.h" #include "base/Raw.h" #include "CachePeer.h" #include "cbdata.h" diff --git a/src/wccp.cc b/src/wccp.cc index f73c4af9114..0456dc23039 100644 --- a/src/wccp.cc +++ b/src/wccp.cc @@ -11,10 +11,10 @@ #include "squid.h" #if USE_WCCP +#include "async/Event.h" #include "comm.h" #include "comm/Connection.h" #include "comm/Loops.h" -#include "event.h" #include "fatal.h" #include "SquidConfig.h" #include "wccp.h" diff --git a/src/wccp2.cc b/src/wccp2.cc index d46a5f82647..6944659c763 100644 --- a/src/wccp2.cc +++ b/src/wccp2.cc @@ -12,12 +12,12 @@ #if USE_WCCPv2 +#include "async/Event.h" #include "cache_cf.h" #include "comm.h" #include "comm/Connection.h" #include "comm/Loops.h" #include "ConfigParser.h" -#include "event.h" #include "ip/Address.h" #include "md5.h" #include "Parsing.h"