| Index: third_party/WebKit/WebCore/dom/GenericWorkerTask.h
|
| ===================================================================
|
| --- third_party/WebKit/WebCore/dom/GenericWorkerTask.h (revision 9118)
|
| +++ third_party/WebKit/WebCore/dom/GenericWorkerTask.h (working copy)
|
| @@ -1,5 +1,5 @@
|
| /*
|
| - * Copyright (c) 2009, Google Inc. All rights reserved.
|
| + * Copyright (C) 2009 Google Inc. All rights reserved.
|
| *
|
| * Redistribution and use in source and binary forms, with or without
|
| * modification, are permitted provided that the following conditions are
|
| @@ -33,40 +33,226 @@
|
|
|
| #if ENABLE(WORKERS)
|
|
|
| -#include "WorkerMessagingProxy.h"
|
| +#include "CrossThreadCopier.h"
|
| #include "ScriptExecutionContext.h"
|
| +#include <memory>
|
| #include <wtf/PassRefPtr.h>
|
| +#include <wtf/TypeTraits.h>
|
|
|
| namespace WebCore {
|
| - class GenericWorkerTaskBase : public ScriptExecutionContext::Task {
|
| - protected:
|
| - GenericWorkerTaskBase(WorkerMessagingProxy* messagingProxy) : m_messagingProxy(messagingProxy)
|
| +
|
| + // Traits for the GenericWorkerTask.
|
| + template<typename T> struct GenericWorkerTaskTraits {
|
| + typedef const T& ParamType;
|
| + };
|
| +
|
| + template<typename T> struct GenericWorkerTaskTraits<T*> {
|
| + typedef T* ParamType;
|
| + };
|
| +
|
| + template<typename T> struct GenericWorkerTaskTraits<std::auto_ptr<T> > {
|
| + typedef std::auto_ptr<T> ParamType;
|
| + };
|
| +
|
| + template<typename T> struct GenericWorkerTaskTraits<PassRefPtr<T> > {
|
| + typedef PassRefPtr<T> ParamType;
|
| + };
|
| +
|
| + template<typename P1, typename MP1>
|
| + class GenericWorkerTask1 : public ScriptExecutionContext::Task {
|
| + public:
|
| + typedef void (*Method)(ScriptExecutionContext*, MP1);
|
| + typedef GenericWorkerTask1<P1, MP1> GenericWorkerTask;
|
| + typedef typename GenericWorkerTaskTraits<P1>::ParamType Param1;
|
| +
|
| + static PassRefPtr<GenericWorkerTask> create(Method method, Param1 parameter1)
|
| {
|
| + return adoptRef(new GenericWorkerTask(method, parameter1));
|
| }
|
|
|
| - bool canPerformTask()
|
| + private:
|
| + GenericWorkerTask1(Method method, Param1 parameter1)
|
| + : m_method(method)
|
| + , m_parameter1(parameter1)
|
| {
|
| - return !m_messagingProxy->askedToTerminate();
|
| }
|
|
|
| - WorkerMessagingProxy* m_messagingProxy;
|
| + virtual void performTask(ScriptExecutionContext* context)
|
| + {
|
| + (*m_method)(context, m_parameter1);
|
| + }
|
| +
|
| + private:
|
| + Method m_method;
|
| + P1 m_parameter1;
|
| };
|
|
|
| + template<typename P1, typename MP1, typename P2, typename MP2>
|
| + class GenericWorkerTask2 : public ScriptExecutionContext::Task {
|
| + public:
|
| + typedef void (*Method)(ScriptExecutionContext*, MP1, MP2);
|
| + typedef GenericWorkerTask2<P1, MP1, P2, MP2> GenericWorkerTask;
|
| + typedef typename GenericWorkerTaskTraits<P1>::ParamType Param1;
|
| + typedef typename GenericWorkerTaskTraits<P2>::ParamType Param2;
|
| +
|
| + static PassRefPtr<GenericWorkerTask> create(Method method, Param1 parameter1, Param2 parameter2)
|
| + {
|
| + return adoptRef(new GenericWorkerTask(method, parameter1, parameter2));
|
| + }
|
| +
|
| + private:
|
| + GenericWorkerTask2(Method method, Param1 parameter1, Param2 parameter2)
|
| + : m_method(method)
|
| + , m_parameter1(parameter1)
|
| + , m_parameter2(parameter2)
|
| + {
|
| + }
|
| +
|
| + virtual void performTask(ScriptExecutionContext* context)
|
| + {
|
| + (*m_method)(context, m_parameter1, m_parameter2);
|
| + }
|
| +
|
| + private:
|
| + Method m_method;
|
| + P1 m_parameter1;
|
| + P2 m_parameter2;
|
| + };
|
| +
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3>
|
| + class GenericWorkerTask3 : public ScriptExecutionContext::Task {
|
| + public:
|
| + typedef void (*Method)(ScriptExecutionContext*, MP1, MP2, MP3);
|
| + typedef GenericWorkerTask3<P1, MP1, P2, MP2, P3, MP3> GenericWorkerTask;
|
| + typedef typename GenericWorkerTaskTraits<P1>::ParamType Param1;
|
| + typedef typename GenericWorkerTaskTraits<P2>::ParamType Param2;
|
| + typedef typename GenericWorkerTaskTraits<P3>::ParamType Param3;
|
| +
|
| + static PassRefPtr<GenericWorkerTask> create(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3)
|
| + {
|
| + return adoptRef(new GenericWorkerTask(method, parameter1, parameter2, parameter3));
|
| + }
|
| +
|
| + private:
|
| + GenericWorkerTask3(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3)
|
| + : m_method(method)
|
| + , m_parameter1(parameter1)
|
| + , m_parameter2(parameter2)
|
| + , m_parameter3(parameter3)
|
| + {
|
| + }
|
| +
|
| + virtual void performTask(ScriptExecutionContext* context)
|
| + {
|
| + (*m_method)(context, m_parameter1, m_parameter2, m_parameter3);
|
| + }
|
| +
|
| + private:
|
| + Method m_method;
|
| + P1 m_parameter1;
|
| + P2 m_parameter2;
|
| + P3 m_parameter3;
|
| + };
|
| +
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4>
|
| + class GenericWorkerTask4 : public ScriptExecutionContext::Task {
|
| + public:
|
| + typedef void (*Method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4);
|
| + typedef GenericWorkerTask4<P1, MP1, P2, MP2, P3, MP3, P4, MP4> GenericWorkerTask;
|
| + typedef typename GenericWorkerTaskTraits<P1>::ParamType Param1;
|
| + typedef typename GenericWorkerTaskTraits<P2>::ParamType Param2;
|
| + typedef typename GenericWorkerTaskTraits<P3>::ParamType Param3;
|
| + typedef typename GenericWorkerTaskTraits<P4>::ParamType Param4;
|
| +
|
| + static PassRefPtr<GenericWorkerTask> create(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4)
|
| + {
|
| + return adoptRef(new GenericWorkerTask(method, parameter1, parameter2, parameter3, parameter4));
|
| + }
|
| +
|
| + private:
|
| + GenericWorkerTask4(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4)
|
| + : m_method(method)
|
| + , m_parameter1(parameter1)
|
| + , m_parameter2(parameter2)
|
| + , m_parameter3(parameter3)
|
| + , m_parameter4(parameter4)
|
| + {
|
| + }
|
| +
|
| + virtual void performTask(ScriptExecutionContext* context)
|
| + {
|
| + (*m_method)(context, m_parameter1, m_parameter2, m_parameter3, m_parameter4);
|
| + }
|
| +
|
| + private:
|
| + Method m_method;
|
| + P1 m_parameter1;
|
| + P2 m_parameter2;
|
| + P3 m_parameter3;
|
| + P4 m_parameter4;
|
| + };
|
| +
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4, typename P5, typename MP5>
|
| + class GenericWorkerTask5 : public ScriptExecutionContext::Task {
|
| + public:
|
| + typedef void (*Method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4, MP5);
|
| + typedef GenericWorkerTask5<P1, MP1, P2, MP2, P3, MP3, P4, MP4, P5, MP5> GenericWorkerTask;
|
| + typedef typename GenericWorkerTaskTraits<P1>::ParamType Param1;
|
| + typedef typename GenericWorkerTaskTraits<P2>::ParamType Param2;
|
| + typedef typename GenericWorkerTaskTraits<P3>::ParamType Param3;
|
| + typedef typename GenericWorkerTaskTraits<P4>::ParamType Param4;
|
| + typedef typename GenericWorkerTaskTraits<P5>::ParamType Param5;
|
| +
|
| + static PassRefPtr<GenericWorkerTask> create(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4, Param5 parameter5)
|
| + {
|
| + return adoptRef(new GenericWorkerTask(method, parameter1, parameter2, parameter3, parameter4, parameter5));
|
| + }
|
| +
|
| + private:
|
| + GenericWorkerTask5(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4, Param5 parameter5)
|
| + : m_method(method)
|
| + , m_parameter1(parameter1)
|
| + , m_parameter2(parameter2)
|
| + , m_parameter3(parameter3)
|
| + , m_parameter4(parameter4)
|
| + , m_parameter5(parameter5)
|
| + {
|
| + }
|
| +
|
| + virtual void performTask(ScriptExecutionContext* context)
|
| + {
|
| + (*m_method)(context, m_parameter1, m_parameter2, m_parameter3, m_parameter4, m_parameter5);
|
| + }
|
| +
|
| + private:
|
| + Method m_method;
|
| + P1 m_parameter1;
|
| + P2 m_parameter2;
|
| + P3 m_parameter3;
|
| + P4 m_parameter4;
|
| + P5 m_parameter5;
|
| + };
|
| +
|
| template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4, typename P5, typename MP5, typename P6, typename MP6>
|
| - class GenericWorkerTask6 : public GenericWorkerTaskBase {
|
| + class GenericWorkerTask6 : public ScriptExecutionContext::Task {
|
| public:
|
| typedef void (*Method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4, MP5, MP6);
|
| typedef GenericWorkerTask6<P1, MP1, P2, MP2, P3, MP3, P4, MP4, P5, MP5, P6, MP6> GenericWorkerTask;
|
| + typedef typename GenericWorkerTaskTraits<P1>::ParamType Param1;
|
| + typedef typename GenericWorkerTaskTraits<P2>::ParamType Param2;
|
| + typedef typename GenericWorkerTaskTraits<P3>::ParamType Param3;
|
| + typedef typename GenericWorkerTaskTraits<P4>::ParamType Param4;
|
| + typedef typename GenericWorkerTaskTraits<P5>::ParamType Param5;
|
| + typedef typename GenericWorkerTaskTraits<P6>::ParamType Param6;
|
|
|
| - static PassRefPtr<GenericWorkerTask> create(WorkerMessagingProxy* messagingProxy, Method method, const P1& parameter1, const P2& parameter2, const P3& parameter3, const P4& parameter4, const P5& parameter5, const P6& parameter6)
|
| + static PassRefPtr<GenericWorkerTask> create(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4, Param5 parameter5, Param6 parameter6)
|
| {
|
| - return adoptRef(new GenericWorkerTask(messagingProxy, method, parameter1, parameter2, parameter3, parameter4, parameter5, parameter6));
|
| + return adoptRef(new GenericWorkerTask(method, parameter1, parameter2, parameter3, parameter4, parameter5, parameter6));
|
| }
|
|
|
| private:
|
| - GenericWorkerTask6(WorkerMessagingProxy* messagingProxy, Method method, const P1& parameter1, const P2& parameter2, const P3& parameter3, const P4& parameter4, const P5& parameter5, const P6& parameter6)
|
| - : GenericWorkerTaskBase(messagingProxy)
|
| - , m_method(method)
|
| + GenericWorkerTask6(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4, Param5 parameter5, Param6 parameter6)
|
| + : m_method(method)
|
| , m_parameter1(parameter1)
|
| , m_parameter2(parameter2)
|
| , m_parameter3(parameter3)
|
| @@ -78,8 +264,6 @@
|
|
|
| virtual void performTask(ScriptExecutionContext* context)
|
| {
|
| - if (!canPerformTask())
|
| - return;
|
| (*m_method)(context, m_parameter1, m_parameter2, m_parameter3, m_parameter4, m_parameter5, m_parameter6);
|
| }
|
|
|
| @@ -93,15 +277,137 @@
|
| P6 m_parameter6;
|
| };
|
|
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4, typename P5, typename MP5, typename P6, typename MP6, typename P7, typename MP7>
|
| + class GenericWorkerTask7 : public ScriptExecutionContext::Task {
|
| + public:
|
| + typedef void (*Method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4, MP5, MP6, MP7);
|
| + typedef GenericWorkerTask7<P1, MP1, P2, MP2, P3, MP3, P4, MP4, P5, MP5, P6, MP6, P7, MP7> GenericWorkerTask;
|
| + typedef typename GenericWorkerTaskTraits<P1>::ParamType Param1;
|
| + typedef typename GenericWorkerTaskTraits<P2>::ParamType Param2;
|
| + typedef typename GenericWorkerTaskTraits<P3>::ParamType Param3;
|
| + typedef typename GenericWorkerTaskTraits<P4>::ParamType Param4;
|
| + typedef typename GenericWorkerTaskTraits<P5>::ParamType Param5;
|
| + typedef typename GenericWorkerTaskTraits<P6>::ParamType Param6;
|
| + typedef typename GenericWorkerTaskTraits<P7>::ParamType Param7;
|
| +
|
| + static PassRefPtr<GenericWorkerTask> create(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4, Param5 parameter5, Param6 parameter6, Param7 parameter7)
|
| + {
|
| + return adoptRef(new GenericWorkerTask(method, parameter1, parameter2, parameter3, parameter4, parameter5, parameter6, parameter7));
|
| + }
|
| +
|
| + private:
|
| + GenericWorkerTask7(Method method, Param1 parameter1, Param2 parameter2, Param3 parameter3, Param4 parameter4, Param5 parameter5, Param6 parameter6, Param7 parameter7)
|
| + : m_method(method)
|
| + , m_parameter1(parameter1)
|
| + , m_parameter2(parameter2)
|
| + , m_parameter3(parameter3)
|
| + , m_parameter4(parameter4)
|
| + , m_parameter5(parameter5)
|
| + , m_parameter6(parameter6)
|
| + , m_parameter7(parameter7)
|
| + {
|
| + }
|
| +
|
| + virtual void performTask(ScriptExecutionContext* context)
|
| + {
|
| + (*m_method)(context, m_parameter1, m_parameter2, m_parameter3, m_parameter4, m_parameter5, m_parameter6, m_parameter7);
|
| + }
|
| +
|
| + private:
|
| + Method m_method;
|
| + P1 m_parameter1;
|
| + P2 m_parameter2;
|
| + P3 m_parameter3;
|
| + P4 m_parameter4;
|
| + P5 m_parameter5;
|
| + P6 m_parameter6;
|
| + P7 m_parameter7;
|
| + };
|
| +
|
| + template<typename P1, typename MP1>
|
| + PassRefPtr<ScriptExecutionContext::Task> createCallbackTask(
|
| + void (*method)(ScriptExecutionContext*, MP1),
|
| + const P1& parameter1)
|
| + {
|
| + return GenericWorkerTask1<typename CrossThreadCopier<P1>::Type, MP1>::create(
|
| + method,
|
| + CrossThreadCopier<P1>::copy(parameter1));
|
| + }
|
| +
|
| + template<typename P1, typename MP1, typename P2, typename MP2>
|
| + PassRefPtr<ScriptExecutionContext::Task> createCallbackTask(
|
| + void (*method)(ScriptExecutionContext*, MP1, MP2),
|
| + const P1& parameter1, const P2& parameter2)
|
| + {
|
| + return GenericWorkerTask2<typename CrossThreadCopier<P1>::Type, MP1, typename CrossThreadCopier<P2>::Type, MP2>::create(
|
| + method,
|
| + CrossThreadCopier<P1>::copy(parameter1), CrossThreadCopier<P2>::copy(parameter2));
|
| + }
|
| +
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3>
|
| + PassRefPtr<ScriptExecutionContext::Task> createCallbackTask(
|
| + void (*method)(ScriptExecutionContext*, MP1, MP2, MP3),
|
| + const P1& parameter1, const P2& parameter2, const P3& parameter3)
|
| + {
|
| + return GenericWorkerTask3<typename CrossThreadCopier<P1>::Type, MP1, typename CrossThreadCopier<P2>::Type, MP2, typename CrossThreadCopier<P3>::Type, MP3>::create(
|
| + method,
|
| + CrossThreadCopier<P1>::copy(parameter1), CrossThreadCopier<P2>::copy(parameter2),
|
| + CrossThreadCopier<P3>::copy(parameter3));
|
| + }
|
| +
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4>
|
| + PassRefPtr<ScriptExecutionContext::Task> createCallbackTask(
|
| + void (*method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4),
|
| + const P1& parameter1, const P2& parameter2, const P3& parameter3, const P4& parameter4)
|
| + {
|
| + return GenericWorkerTask4<typename CrossThreadCopier<P1>::Type, MP1, typename CrossThreadCopier<P2>::Type, MP2, typename CrossThreadCopier<P3>::Type, MP3,
|
| + typename CrossThreadCopier<P4>::Type, MP4>::create(
|
| + method,
|
| + CrossThreadCopier<P1>::copy(parameter1), CrossThreadCopier<P2>::copy(parameter2),
|
| + CrossThreadCopier<P3>::copy(parameter3), CrossThreadCopier<P4>::copy(parameter4));
|
| + }
|
| +
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4, typename P5, typename MP5>
|
| + PassRefPtr<ScriptExecutionContext::Task> createCallbackTask(
|
| + void (*method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4, MP5),
|
| + const P1& parameter1, const P2& parameter2, const P3& parameter3, const P4& parameter4, const P5& parameter5)
|
| + {
|
| + return GenericWorkerTask5<typename CrossThreadCopier<P1>::Type, MP1, typename CrossThreadCopier<P2>::Type, MP2, typename CrossThreadCopier<P3>::Type, MP3,
|
| + typename CrossThreadCopier<P4>::Type, MP4, typename CrossThreadCopier<P5>::Type, MP5>::create(
|
| + method,
|
| + CrossThreadCopier<P1>::copy(parameter1), CrossThreadCopier<P2>::copy(parameter2),
|
| + CrossThreadCopier<P3>::copy(parameter3), CrossThreadCopier<P4>::copy(parameter4),
|
| + CrossThreadCopier<P5>::copy(parameter5));
|
| + }
|
| +
|
| template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4, typename P5, typename MP5, typename P6, typename MP6>
|
| - PassRefPtr<GenericWorkerTask6<P1, MP1, P2, MP2, P3, MP3, P4, MP4, P5, MP5, P6, MP6> > createCallbackTask(
|
| - WorkerMessagingProxy* messagingProxy,
|
| + PassRefPtr<ScriptExecutionContext::Task> createCallbackTask(
|
| void (*method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4, MP5, MP6),
|
| const P1& parameter1, const P2& parameter2, const P3& parameter3, const P4& parameter4, const P5& parameter5, const P6& parameter6)
|
| {
|
| - return GenericWorkerTask6<P1, MP1, P2, MP2, P3, MP3, P4, MP4, P5, MP5, P6, MP6>::create(messagingProxy, method, parameter1, parameter2, parameter3, parameter4, parameter5, parameter6);
|
| + return GenericWorkerTask6<typename CrossThreadCopier<P1>::Type, MP1, typename CrossThreadCopier<P2>::Type, MP2, typename CrossThreadCopier<P3>::Type, MP3,
|
| + typename CrossThreadCopier<P4>::Type, MP4, typename CrossThreadCopier<P5>::Type, MP5, typename CrossThreadCopier<P6>::Type, MP6>::create(
|
| + method,
|
| + CrossThreadCopier<P1>::copy(parameter1), CrossThreadCopier<P2>::copy(parameter2),
|
| + CrossThreadCopier<P3>::copy(parameter3), CrossThreadCopier<P4>::copy(parameter4),
|
| + CrossThreadCopier<P5>::copy(parameter5), CrossThreadCopier<P6>::copy(parameter6));
|
| }
|
|
|
| + template<typename P1, typename MP1, typename P2, typename MP2, typename P3, typename MP3, typename P4, typename MP4, typename P5, typename MP5, typename P6, typename MP6, typename P7, typename MP7>
|
| + PassRefPtr<ScriptExecutionContext::Task> createCallbackTask(
|
| + void (*method)(ScriptExecutionContext*, MP1, MP2, MP3, MP4, MP5, MP6, MP7),
|
| + const P1& parameter1, const P2& parameter2, const P3& parameter3, const P4& parameter4, const P5& parameter5, const P6& parameter6, const P7& parameter7)
|
| + {
|
| + return GenericWorkerTask7<typename CrossThreadCopier<P1>::Type, MP1, typename CrossThreadCopier<P2>::Type, MP2, typename CrossThreadCopier<P3>::Type, MP3,
|
| + typename CrossThreadCopier<P4>::Type, MP4, typename CrossThreadCopier<P5>::Type, MP5, typename CrossThreadCopier<P6>::Type, MP6,
|
| + typename CrossThreadCopier<P7>::Type, MP7>::create(
|
| + method,
|
| + CrossThreadCopier<P1>::copy(parameter1), CrossThreadCopier<P2>::copy(parameter2),
|
| + CrossThreadCopier<P3>::copy(parameter3), CrossThreadCopier<P4>::copy(parameter4),
|
| + CrossThreadCopier<P5>::copy(parameter5), CrossThreadCopier<P6>::copy(parameter6),
|
| + CrossThreadCopier<P7>::copy(parameter7));
|
| + }
|
| +
|
| } // namespace WebCore
|
|
|
| #endif // ENABLE(WORKERS)
|
|
|