Luca Deri
57e6a93065
Improved scheduling algorithm to guarantee minimum service time when number of entries allow
...
Updated (C)
2020-01-06 23:36:36 +01:00
Simone Mainardi
578d96c674
Implements names for thread pool worker threads
2019-12-12 13:02:09 +01:00
Simone Mainardi
9cb566ed41
Computes lua scripts deadlines in C to prevent missing scheduled activities
2019-11-19 13:02:13 +01:00
Luca Deri
84bf948f0f
Reworked thread handling policy
2019-11-01 12:15:08 +01:00
Luca Deri
aee1b3defb
Split threaded activities in high and standard priority tasks
2019-11-01 11:03:56 +01:00
Alfredo Cardigliano
9992179645
Set affinity mask for service threads (implements #3012 )
2019-10-28 15:54:33 +01:00
emanuele-f
6f94f7b132
Add thread names for debugging
2019-02-21 11:51:57 +01:00
Luca Deri
bedff2c8e2
Updated (C)
2019-01-07 19:28:49 +01:00
Simone Mainardi
9f3f56999c
Reworks shutdown to allow graceful periodic activ term
2018-06-01 12:38:31 +02:00
Simone Mainardi
3283d521b2
Fixes memory leaks in ThreadPool
...
==25013== 56 bytes in 4 blocks are definitely lost in loss record 164 of 320
==25013== at 0x4C29BE3: malloc (vg_replace_malloc.c:299)
==25013== by 0x4CAC5D: ThreadPool::ThreadPool(unsigned char) (ThreadPool.cpp:49)
==25013== by 0x4A7AF5: ThreadedActivity::ThreadedActivity(char const*, unsigned int, bool, unsigned char) (ThreadedActivity.cpp:52)
==25013== by 0x4CAAA8: PeriodicActivities::startPeriodicActivitiesLoop() (PeriodicActivities.cpp:108)
==25013== by 0x4B5D30: Ntop::start() (Ntop.cpp:439)
==25013== by 0x44407E: main (main.cpp:405)
2018-04-16 16:50:52 +02:00
Simone Mainardi
6785d7de83
Minor fix to reduce the size of a buffer
2018-04-13 18:37:41 +02:00
Simone Mainardi
078a0df62d
Adds thread names on OS X
2018-04-13 18:35:09 +02:00
Luca Deri
f0c936c368
Updated (C) to 2018
2018-03-22 21:59:42 +01:00
Luca
e1749daa23
Reworked callback scripts to make them concurrent and thus tackle issues related to slow execution on machines with many interfaces
2017-11-23 19:03:46 +01:00
emanuele-f
e1132d2d5a
Fix invalid implementation of condition variables
...
The following issues are addressed:
- Shared state queue_len was not protected by a lock. This could cause thread to block indefinitely.
- Condition variable signal was performed without holding a lock. Again it can cause the thread to block indefinitely.
See https://stackoverflow.com/questions/4544234/calling-pthread-cond-signal-without-locking-mutex
2017-11-20 13:08:27 +01:00
Luca
044fe19677
Reworked nSeries support
...
Added patch for avoiding #1545
2017-11-09 23:55:52 +00:00
Luca Deri
7f8bddcff1
Implemented thread pool to be used for splitting callback scripts
2017-10-18 22:32:00 +02:00
Luca Deri
52b1375353
Implemented thread pool to be used for splitting callback scripts
2017-10-18 22:31:37 +02:00
