You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafficserver.apache.org by so...@apache.org on 2016/05/31 15:54:47 UTC

[trafficserver] 02/09: TS-4485 schedule HostDBSyncer in ET_TASK threads instead of ET_NET threads

This is an automated email from the ASF dual-hosted git repository.

sorber pushed a commit to branch 6.2.x
in repository https://git-dual.apache.org/repos/asf/trafficserver.git

commit 202051c8d19516dcafaac6c4152c06e837ea14d7
Author: Thomas Jackson <ja...@gmail.com>
AuthorDate: Wed May 25 22:36:21 2016 -0700

    TS-4485 schedule HostDBSyncer in ET_TASK threads instead of ET_NET threads
    
    (cherry picked from commit be315479d3d33d7452a90ecc1aa2f9f7664d443d)
---
 iocore/hostdb/HostDB.cc     | 7 ++++---
 iocore/hostdb/MultiCache.cc | 4 ++--
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/iocore/hostdb/HostDB.cc b/iocore/hostdb/HostDB.cc
index b83ddff..10c0111 100644
--- a/iocore/hostdb/HostDB.cc
+++ b/iocore/hostdb/HostDB.cc
@@ -394,9 +394,9 @@ HostDBSyncer::wait_event(int, void *)
 
   SET_HANDLER(&HostDBSyncer::sync_event);
   if (next_sync > HRTIME_MSECONDS(100))
-    mutex->thread_holding->schedule_in_local(this, next_sync);
+    eventProcessor.schedule_in(this, next_sync, ET_TASK);
   else
-    mutex->thread_holding->schedule_imm_local(this);
+    eventProcessor.schedule_imm(this, ET_TASK);
   return EVENT_DONE;
 }
 
@@ -526,7 +526,8 @@ HostDBProcessor::start(int, size_t)
   // Sync HostDB, if we've asked for it.
   //
   if (hostdb_sync_frequency > 0)
-    eventProcessor.schedule_imm(new HostDBSyncer);
+    eventProcessor.schedule_imm(new HostDBSyncer, ET_TASK);
+
   return 0;
 }
 
diff --git a/iocore/hostdb/MultiCache.cc b/iocore/hostdb/MultiCache.cc
index 2e6951a..1105fb0 100644
--- a/iocore/hostdb/MultiCache.cc
+++ b/iocore/hostdb/MultiCache.cc
@@ -1177,9 +1177,9 @@ MultiCacheBase::sync_partitions(Continuation *cont)
   // don't try to sync if we were not correctly initialized
   if (data && mapped_header) {
     if (heap_used[heap_halfspace] > halfspace_size() * MULTI_CACHE_HEAP_HIGH_WATER)
-      eventProcessor.schedule_imm(new MultiCacheHeapGC(cont, this), ET_CALL);
+      eventProcessor.schedule_imm(new MultiCacheHeapGC(cont, this), ET_TASK);
     else
-      eventProcessor.schedule_imm(new MultiCacheSync(cont, this), ET_CALL);
+      eventProcessor.schedule_imm(new MultiCacheSync(cont, this), ET_TASK);
   }
 }
 

-- 
To stop receiving notification emails like this one, please contact
"commits@trafficserver.apache.org" <co...@trafficserver.apache.org>.