Home
last modified time | relevance | path

Searched refs:EThread (Results 1 – 25 of 95) sorted by relevance

1234

/trafficserver/iocore/eventsystem/
H A DUnixEventProcessor.cc79 EThread::EventMetrics summary[EThread::N_EVENT_TIMESCALES]; in EventMetricStatSync()
88 …for (int ts_idx = 0; ts_idx < EThread::N_EVENT_TIMESCALES; ++ts_idx, id += EThread::N_EVENT_STATS)… in EventMetricStatSync()
89 EThread::EventMetrics *m = summary + ts_idx; in EventMetricStatSync()
131 void (*f)(EThread *) = reinterpret_cast<void (*)(EThread *)>(ev->cookie); in invoke()
189 EThread *t = this_ethread(); in set_affinity()
374 EThread *t = new EThread(REGULAR, n_ethreads + i); in spawn_event_threads()
403 EventProcessor::initThreadState(EThread *t) in initThreadState()
442 …RecRawStatBlock *rsb = RecAllocateRawStatBlock(EThread::N_EVENT_STATS * EThread::N_EVENT_TIMESCALE… in start()
447 … snprintf(name, sizeof(name), "%s.%ds", EThread::STAT_NAME[id], EThread::SAMPLE_COUNT[ts_idx]); in start()
487 e->ethread = new EThread(DEDICATED, e); in spawn_thread()
[all …]
H A DP_UnixEThread.h39 EThread::schedule_imm(Continuation *cont, int callback_event, void *cookie) in schedule_imm()
79 EThread::schedule(Event *e) in schedule()
99 EThread::schedule_imm_local(Continuation *cont, int callback_event, void *cookie) in schedule_imm_local()
139 EThread::schedule_local(Event *e) in schedule_local()
162 EThread::schedule_spawn(Continuation *c, int ev, void *cookie) in schedule_spawn()
177 TS_INLINE EThread *
180 return static_cast<EThread *>(this_thread()); in this_ethread()
183 TS_INLINE EThread *
186 EThread *ethread = this_ethread(); in this_event_thread()
195 EThread::free_event(Event *e) in free_event()
[all …]
H A DUnixEThread.cc54 EThread::EThread() in EThread() function in EThread
59 EThread::EThread(ThreadType att, int anid) : id(anid), tt(att) in EThread() function in EThread
87 EThread::EThread(ThreadType att, Event *e) : tt(att), start_event(e) in EThread() function in EThread
95 EThread::~EThread() {} in ~EThread()
98 EThread::is_event_type(EventType et) in is_event_type()
104 EThread::set_event_type(EventType et) in set_event_type()
110 EThread::process_event(Event *e, int calling_code) in process_event()
193 EThread::execute_regular() in execute_regular()
315 EThread::execute() in execute()
351 EThread::EventMetrics &
[all …]
H A DI_EThread.h83 class EThread : public Thread class
295 EThread();
296 EThread(ThreadType att, int anid);
297 EThread(ThreadType att, Event *e);
298 EThread(const EThread &) = delete;
299 EThread &operator=(const EThread &) = delete;
300 ~EThread() override;
379 friend class EThread;
475 extern EThread *this_ethread();
H A DI_EventProcessor.h44 class EThread;
241 Event *schedule_spawn(void (*f)(EThread *), EventType ev_type);
286 EThread *all_ethreads[MAX_EVENT_THREADS];
306 EThread *_thread[MAX_THREADS_IN_EACH_TYPE] = {}; ///< The actual threads in this group.
331 EThread *assign_thread(EventType etype);
332 EThread *assign_affinity_by_type(Continuation *cont, EventType etype);
334 EThread *all_dthreads[MAX_EVENT_THREADS];
341 using iterator = EThread *const *; ///< Internal iterator type, pointer to array element.
384 void initThreadState(EThread *);
412 void thread_started(EThread *);
H A DI_Lock.h125 class EThread;
126 typedef EThread *EThreadPtr;
259 ProxyMutex *m, EThread *t) in Mutex_trylock()
303 Ptr<ProxyMutex> &m, EThread *t) in Mutex_trylock()
317 ProxyMutex *m, EThread *t) in Mutex_lock()
349 Ptr<ProxyMutex> &m, EThread *t) in Mutex_lock()
399 Ptr<ProxyMutex> &am, EThread *t) in WeakMutexLock()
436 Ptr<ProxyMutex> &am, EThread *t) in MutexLock()
471 Ptr<ProxyMutex> &am, EThread *t) in WeakMutexTryLock()
496 acquire(EThread *t) in acquire()
[all …]
H A DI_Continuation.h47 class EThread;
50 extern EThread *this_ethread();
51 extern EThread *this_event_thread();
148 EThread *thread_affinity = nullptr;
151 setThreadAffinity(EThread *ethread) in setThreadAffinity()
160 EThread *
H A DP_UnixEventProcessor.h36 static off_t start = INK_ALIGN(offsetof(EThread, thread_private), 16); in allocate()
37 static off_t loss = start - offsetof(EThread, thread_private); in allocate()
51 TS_INLINE EThread *
73 TS_INLINE EThread *
76 EThread *ethread = cont->mutex->thread_holding; in assign_affinity_by_type()
100 EThread *ethread = e->continuation->getThreadAffinity(); in schedule()
H A DThread.cc53 MUTEX_TAKE_LOCK(mutex, static_cast<EThread *>(this)); in Thread()
59 ink_release_assert(mutex->thread_holding == static_cast<EThread *>(this)); in ~Thread()
68 MUTEX_UNTAKE_LOCK(mutex, static_cast<EThread *>(this)); in ~Thread()
H A DProtectedQueue.cc50 EThread *e_ethread = e->ethread; in enqueue()
55 EThread *inserting_thread = this_ethread(); in enqueue()
H A DI_PriorityEventQueue.h33 class EThread;
108 void check_ready(ink_hrtime now, EThread *t);
/trafficserver/lib/records/
H A DI_RecProcess.h82 inline int RecIncrRawStat(RecRawStatBlock *rsb, EThread *ethread, int id, int64_t incr = 1);
83 inline int RecIncrRawStatSum(RecRawStatBlock *rsb, EThread *ethread, int id, int64_t incr = 1);
84 inline int RecIncrRawStatCount(RecRawStatBlock *rsb, EThread *ethread, int id, int64_t incr = 1);
115 raw_stat_get_tlp(RecRawStatBlock *rsb, int id, EThread *ethread) in raw_stat_get_tlp()
125 RecIncrRawStat(RecRawStatBlock *rsb, EThread *ethread, int id, int64_t incr) in RecIncrRawStat()
134 RecDecrRawStat(RecRawStatBlock *rsb, EThread *ethread, int id, int64_t decr) in RecDecrRawStat()
143 RecIncrRawStatSum(RecRawStatBlock *rsb, EThread *ethread, int id, int64_t incr) in RecIncrRawStatSum()
151 RecIncrRawStatCount(RecRawStatBlock *rsb, EThread *ethread, int id, int64_t incr) in RecIncrRawStatCount()
H A DRecRawStats.cc36 thread_stat(EThread *et, RecRawStatBlock *rsb, int id) in thread_stat()
53 for (EThread *et : eventProcessor.active_ethreads()) { in raw_stat_get_total()
59 for (EThread *et : eventProcessor.active_dthreads()) { in raw_stat_get_total()
84 for (EThread *et : eventProcessor.active_ethreads()) { in raw_stat_sync_to_global()
90 for (EThread *et : eventProcessor.active_dthreads()) { in raw_stat_sync_to_global()
139 for (EThread *et : eventProcessor.active_ethreads()) { in raw_stat_clear()
145 for (EThread *et : eventProcessor.active_dthreads()) { in raw_stat_clear()
171 for (EThread *et : eventProcessor.active_ethreads()) { in raw_stat_clear_sum()
176 for (EThread *et : eventProcessor.active_dthreads()) { in raw_stat_clear_sum()
201 for (EThread *et : eventProcessor.active_ethreads()) { in raw_stat_clear_count()
[all …]
/trafficserver/iocore/net/
H A DP_UnixNetVConnection.h221 virtual void net_read_io(NetHandler *nh, EThread *lthread) override;
222 virtual void net_write_io(NetHandler *nh, EThread *lthread) override;
223 virtual void free(EThread *t) override;
235 virtual EThread *
266 void netActivity(EThread *lthread);
272 UnixNetVConnection *migrateToCurrentThread(Continuation *c, EThread *t);
292 virtual int connectUp(EThread *t, int fd);
311 friend void write_to_net_io(NetHandler *, UnixNetVConnection *, EThread *);
433 void write_to_net(NetHandler *nh, UnixNetVConnection *vc, EThread *thread);
434 void write_to_net_io(NetHandler *nh, UnixNetVConnection *vc, EThread *thread);
[all …]
H A DNetEvent.h38 virtual void net_read_io(NetHandler *nh, EThread *lthread) = 0;
39 virtual void net_write_io(NetHandler *nh, EThread *lthread) = 0;
40 virtual void free(EThread *t) = 0;
51 virtual EThread *get_thread() = 0;
H A DP_UnixNetProcessor.h43 NetVConnection *allocate_vc(EThread *t) override;
56 EThread **netthreads;
72 extern void initialize_thread_for_net(EThread *thread);
H A DP_UDPNet.h38 static inline PollCont *get_UDPPollCont(EThread *);
48 int udp_callback(UDPNetHandler *nh, UDPConnection *uc, EThread *thread);
298 void initialize_thread_for_udp_net(EThread *thread);
300 class UDPNetHandler : public Continuation, public EThread::LoopTailHandler
316 EThread *thread = nullptr;
331 get_UDPPollCont(EThread *t) in get_UDPPollCont()
337 get_UDPNetHandler(EThread *t) in get_UDPNetHandler()
H A DP_UnixUDPConnection.h40 void setEthread(EThread *e);
51 EThread *ethread = nullptr;
82 UnixUDPConnection::setEthread(EThread *e) in setEthread()
H A DQUICClosedConCollector.cc29 EThread *t = this->mutex->thread_holding; in mainEvent()
37 QUICClosedConCollector::_process_closed_connection(EThread *t) in _process_closed_connection()
H A DP_QUICNet.h36 void initialize_thread_for_quic_net(EThread *thread);
71 get_QUICPollCont(EThread *t) in get_QUICPollCont()
/trafficserver/iocore/eventsystem/unit_tests/
H A Dtest_EventSystem.cc48 EThread *e = this_ethread(); in dummy_function()
61 EThread *e = this_ethread(); in kill_function()
96 EThread *main_thread = new EThread; in testRunStarting()
/trafficserver/iocore/net/quic/test/
H A Dmain.cc53 EThread *thread = new EThread(); in testRunStarting()
/trafficserver/iocore/aio/
H A DI_AIO.h85 #define AIO_CALLBACK_THREAD_ANY ((EThread *)0) // any regular event thread
86 #define AIO_CALLBACK_THREAD_AIO ((EThread *)-1)
92 EThread *thread = AIO_CALLBACK_THREAD_ANY;
/trafficserver/doc/developer-guide/
H A Dthreads-and-events.en.rst50 EThread subsection
53 :class:`EThread` is a subclass of :class:`Thread` which provides support for |TS| core operations.
54 It is this class that provides support for using :class:`Continuation` instances. :class:`EThread`
69 :class:`EThread` start continuation controlled by :class:`EventProcessor`. Each thread group (event
74 continuation for the :class:`EThread` executes the continuations on this list for the appropriate
75 thread group and then returns, after which :func:`EThread::execute` loops on processing its event
88 void Group_Thread_Init(EThread*); // function to perform per thread local initialization.
147 .. class:: EThread
186 … single argument of pointer to :class:`EThread` and returns :code:`void`. The argument will be the…
200 .. function:: Event * schedule_spawn(void ( * f) (EThread * ), EventType ev_type)
[all …]
/trafficserver/src/traffic_server/
H A DCoreUtils.h89 class EThread;
161 static void process_EThread(EThread *eth_test);

Completed in 150 milliseconds

1234