smaller tweaks
This commit is contained in:
parent
254aac51ec
commit
5fd7a8c9b7
@ -185,7 +185,7 @@ void TcpTmTcServer::handleServerOperation(socket_t& connSocket) {
|
|||||||
size_t availableReadData = ringBuffer.getAvailableReadData();
|
size_t availableReadData = ringBuffer.getAvailableReadData();
|
||||||
if(availableReadData > lastRingBufferSize) {
|
if(availableReadData > lastRingBufferSize) {
|
||||||
tcAvailable = true;
|
tcAvailable = true;
|
||||||
handleRingBufferData(availableReadData);
|
handleTcRingBufferData(availableReadData);
|
||||||
}
|
}
|
||||||
ReturnValue_t result = handleTmSending(connSocket, tmSent);
|
ReturnValue_t result = handleTmSending(connSocket, tmSent);
|
||||||
if(result == CONN_BROKEN) {
|
if(result == CONN_BROKEN) {
|
||||||
@ -287,7 +287,7 @@ ReturnValue_t TcpTmTcServer::handleTmSending(socket_t connSocket, bool& tmSent)
|
|||||||
return HasReturnvaluesIF::RETURN_OK;
|
return HasReturnvaluesIF::RETURN_OK;
|
||||||
}
|
}
|
||||||
|
|
||||||
ReturnValue_t TcpTmTcServer::handleRingBufferData(size_t availableReadData) {
|
ReturnValue_t TcpTmTcServer::handleTcRingBufferData(size_t availableReadData) {
|
||||||
ReturnValue_t status = HasReturnvaluesIF::RETURN_OK;
|
ReturnValue_t status = HasReturnvaluesIF::RETURN_OK;
|
||||||
ReturnValue_t result = HasReturnvaluesIF::RETURN_OK;
|
ReturnValue_t result = HasReturnvaluesIF::RETURN_OK;
|
||||||
size_t readAmount = availableReadData;
|
size_t readAmount = availableReadData;
|
||||||
|
@ -129,7 +129,7 @@ private:
|
|||||||
void handleServerOperation(socket_t& connSocket);
|
void handleServerOperation(socket_t& connSocket);
|
||||||
ReturnValue_t handleTcReception(uint8_t* spacePacket, size_t packetSize);
|
ReturnValue_t handleTcReception(uint8_t* spacePacket, size_t packetSize);
|
||||||
ReturnValue_t handleTmSending(socket_t connSocket, bool& tmSent);
|
ReturnValue_t handleTmSending(socket_t connSocket, bool& tmSent);
|
||||||
ReturnValue_t handleRingBufferData(size_t availableReadData);
|
ReturnValue_t handleTcRingBufferData(size_t availableReadData);
|
||||||
void handleSocketError(ConstStorageAccessor& accessor);
|
void handleSocketError(ConstStorageAccessor& accessor);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user