|
|
|
|
@ -431,10 +431,12 @@ void BSDEthernetTap::threadMain()
|
|
|
|
|
// constructing itself.
|
|
|
|
|
Thread::sleep(500); |
|
|
|
|
|
|
|
|
|
bool pinning = _pinning; |
|
|
|
|
|
|
|
|
|
for (unsigned int i = 0; i < _concurrency; ++i) { |
|
|
|
|
_rxThreads.push_back(std::thread([this, i, _pinning] { |
|
|
|
|
_rxThreads.push_back(std::thread([this, i, pinning] { |
|
|
|
|
|
|
|
|
|
if (_pinning) { |
|
|
|
|
if (pinning) { |
|
|
|
|
int pinCore = i % _concurrency; |
|
|
|
|
fprintf(stderr, "Pinning thread %d to core %d\n", i, pinCore); |
|
|
|
|
pthread_t self = pthread_self(); |
|
|
|
|
|