mirror of
https://github.com/wpilibsuite/allwpilib
synced 2026-06-20 00:51:42 +00:00
CMake Changes
This is the changes made by Patrick Plenefisch converting the native code to use CMake and the CMake Maven Plugin, as opposed to the native Maven plugin. This is to allow for compatibility with newer versions of the GCC toolchain. All the cpp sources were moved from maven style directories to cpp style directories for CMake. Change-Id: I67f5e3608948f37c83b0990d232105a3784f8593
This commit is contained in:
129
networktables/cpp/lib/share/networktables2/WriteManager.cpp
Normal file
129
networktables/cpp/lib/share/networktables2/WriteManager.cpp
Normal file
@@ -0,0 +1,129 @@
|
||||
/*
|
||||
* WriteManager.cpp
|
||||
*
|
||||
* Created on: Sep 25, 2012
|
||||
* Author: Mitchell Wills
|
||||
*/
|
||||
|
||||
#include "networktables2/WriteManager.h"
|
||||
#include "networktables2/util/System.h"
|
||||
#include "networktables2/AbstractNetworkTableEntryStore.h"
|
||||
#include <iostream>
|
||||
|
||||
|
||||
|
||||
WriteManager::WriteManager(FlushableOutgoingEntryReceiver& _receiver, NTThreadManager& _threadManager, AbstractNetworkTableEntryStore& _entryStore, unsigned long _keepAliveDelay)
|
||||
: receiver(_receiver), threadManager(_threadManager), entryStore(_entryStore), keepAliveDelay(_keepAliveDelay){
|
||||
|
||||
thread = NULL;
|
||||
lastWrite = 0;
|
||||
|
||||
incomingAssignmentQueue = new std::queue<NetworkTableEntry*>();
|
||||
incomingUpdateQueue = new std::queue<NetworkTableEntry*>();
|
||||
outgoingAssignmentQueue = new std::queue<NetworkTableEntry*>();
|
||||
outgoingUpdateQueue = new std::queue<NetworkTableEntry*>();
|
||||
}
|
||||
|
||||
WriteManager::~WriteManager(){
|
||||
stop();
|
||||
|
||||
//Note: this must occur after stop() to avoid deadlock
|
||||
transactionsLock.take();
|
||||
|
||||
delete incomingAssignmentQueue;
|
||||
delete incomingUpdateQueue;
|
||||
delete outgoingAssignmentQueue;
|
||||
delete outgoingUpdateQueue;
|
||||
}
|
||||
|
||||
void WriteManager::start(){
|
||||
if(thread!=NULL)
|
||||
stop();
|
||||
lastWrite = currentTimeMillis();
|
||||
thread = threadManager.newBlockingPeriodicThread(this, "Write Manager Thread");
|
||||
}
|
||||
|
||||
void WriteManager::stop(){
|
||||
if(thread!=NULL){
|
||||
thread->stop();
|
||||
delete thread;
|
||||
thread = NULL;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void WriteManager::offerOutgoingAssignment(NetworkTableEntry* entry) {
|
||||
{
|
||||
NTSynchronized sync(transactionsLock);
|
||||
((std::queue<NetworkTableEntry*>*)incomingAssignmentQueue)->push(entry);
|
||||
|
||||
if(((std::queue<NetworkTableEntry*>*)incomingAssignmentQueue)->size()>=queueSize){
|
||||
run();
|
||||
writeWarning("assignment queue overflowed. decrease the rate at which you create new entries or increase the write buffer size");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void WriteManager::offerOutgoingUpdate(NetworkTableEntry* entry) {
|
||||
{
|
||||
NTSynchronized sync(transactionsLock);
|
||||
((std::queue<NetworkTableEntry*>*)incomingUpdateQueue)->push(entry);
|
||||
if(((std::queue<NetworkTableEntry*>*)incomingUpdateQueue)->size()>=queueSize){
|
||||
run();
|
||||
writeWarning("update queue overflowed. decrease the rate at which you update entries or increase the write buffer size");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
void WriteManager::run() {
|
||||
{
|
||||
NTSynchronized sync(transactionsLock);
|
||||
//swap the assignment and update queue
|
||||
volatile std::queue<NetworkTableEntry*>* tmp = incomingAssignmentQueue;
|
||||
incomingAssignmentQueue = outgoingAssignmentQueue;
|
||||
outgoingAssignmentQueue = tmp;
|
||||
|
||||
tmp = incomingUpdateQueue;
|
||||
incomingUpdateQueue = outgoingUpdateQueue;
|
||||
outgoingUpdateQueue = tmp;
|
||||
}
|
||||
|
||||
bool wrote = false;
|
||||
NetworkTableEntry* entry;
|
||||
|
||||
while(!((std::queue<NetworkTableEntry*>*)outgoingAssignmentQueue)->empty()){
|
||||
entry = ((std::queue<NetworkTableEntry*>*)outgoingAssignmentQueue)->front();
|
||||
((std::queue<NetworkTableEntry*>*)outgoingAssignmentQueue)->pop();
|
||||
{
|
||||
NTSynchronized sync(entryStore.LOCK);
|
||||
entry->MakeClean();
|
||||
wrote = true;
|
||||
receiver.offerOutgoingAssignment(entry);
|
||||
}
|
||||
}
|
||||
|
||||
while(!((std::queue<NetworkTableEntry*>*)outgoingUpdateQueue)->empty()){
|
||||
entry = ((std::queue<NetworkTableEntry*>*)outgoingUpdateQueue)->front();
|
||||
((std::queue<NetworkTableEntry*>*)outgoingUpdateQueue)->pop();
|
||||
{
|
||||
NTSynchronized sync(entryStore.LOCK);
|
||||
entry->MakeClean();
|
||||
wrote = true;
|
||||
receiver.offerOutgoingUpdate(entry);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
if(wrote){
|
||||
receiver.flush();
|
||||
lastWrite = currentTimeMillis();
|
||||
}
|
||||
else if(currentTimeMillis()-lastWrite>keepAliveDelay)
|
||||
receiver.ensureAlive();
|
||||
|
||||
sleep_ms(20);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user