Updated Branches: refs/heads/master ba1e9ae62 -> 1686269fb
TS-1356 ground work on the ability to assign threads to a cpu/core Project: http://git-wip-us.apache.org/repos/asf/trafficserver/repo Commit: http://git-wip-us.apache.org/repos/asf/trafficserver/commit/1686269f Tree: http://git-wip-us.apache.org/repos/asf/trafficserver/tree/1686269f Diff: http://git-wip-us.apache.org/repos/asf/trafficserver/diff/1686269f Branch: refs/heads/master Commit: 1686269fb5b6732ff9620388f49e731d8ef6390e Parents: ba1e9ae Author: Bryan Call <[email protected]> Authored: Wed Aug 15 13:01:18 2012 -0700 Committer: Bryan Call <[email protected]> Committed: Wed Aug 15 13:01:18 2012 -0700 ---------------------------------------------------------------------- iocore/eventsystem/I_Thread.h | 2 +- iocore/eventsystem/Thread.cc | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/trafficserver/blob/1686269f/iocore/eventsystem/I_Thread.h ---------------------------------------------------------------------- diff --git a/iocore/eventsystem/I_Thread.h b/iocore/eventsystem/I_Thread.h index 0e0bf77..9aa9a95 100644 --- a/iocore/eventsystem/I_Thread.h +++ b/iocore/eventsystem/I_Thread.h @@ -129,7 +129,7 @@ private: Thread & operator =(const Thread &); public: - void start(const char* name, ThreadFunction f = NULL, void *a = NULL, size_t stacksize = 0); + ink_thread start(const char* name, ThreadFunction f = NULL, void *a = NULL, size_t stacksize = 0); virtual void execute() { } http://git-wip-us.apache.org/repos/asf/trafficserver/blob/1686269f/iocore/eventsystem/Thread.cc ---------------------------------------------------------------------- diff --git a/iocore/eventsystem/Thread.cc b/iocore/eventsystem/Thread.cc index b558516..afb3985 100644 --- a/iocore/eventsystem/Thread.cc +++ b/iocore/eventsystem/Thread.cc @@ -90,7 +90,7 @@ spawn_thread_internal(void *a) return NULL; } -void +ink_thread Thread::start(const char* name, ThreadFunction f, void *a, size_t stacksize) { thread_data_internal *p = (thread_data_internal *)ats_malloc(sizeof(thread_data_internal)); @@ -103,5 +103,7 @@ Thread::start(const char* name, ThreadFunction f, void *a, size_t stacksize) p->me = this; memset(p->name, 0, MAX_THREAD_NAME_LENGTH); ink_strlcpy(p->name, name, MAX_THREAD_NAME_LENGTH); - this->tid = ink_thread_create(spawn_thread_internal, (void *) p, 0, stacksize); + tid = ink_thread_create(spawn_thread_internal, (void *) p, 0, stacksize); + + return tid; }
