mirror of
https://github.com/morgan9e/FreeRDP
synced 2026-04-14 00:14:11 +09:00
[winpr,return] improve return value checks
propagate error conditions up the call chain
This commit is contained in:
@@ -263,7 +263,10 @@ int MessageQueue_Peek(wMessageQueue* queue, wMessage* message, BOOL remove)
|
||||
queue->size--;
|
||||
|
||||
if (queue->size < 1)
|
||||
(void)ResetEvent(queue->event);
|
||||
{
|
||||
if (ResetEvent(queue->event))
|
||||
status = -1;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -346,7 +349,8 @@ int MessageQueue_Clear(wMessageQueue* queue)
|
||||
queue->head = (queue->head + 1) % queue->capacity;
|
||||
queue->size--;
|
||||
}
|
||||
(void)ResetEvent(queue->event);
|
||||
if (!ResetEvent(queue->event))
|
||||
status = -1;
|
||||
queue->closed = FALSE;
|
||||
|
||||
LeaveCriticalSection(&queue->lock);
|
||||
|
||||
@@ -278,7 +278,10 @@ BOOL Queue_Enqueue(wQueue* queue, const void* obj)
|
||||
queue->size++;
|
||||
|
||||
if (signalSet)
|
||||
(void)SetEvent(queue->event);
|
||||
{
|
||||
if (!SetEvent(queue->event))
|
||||
goto out;
|
||||
}
|
||||
}
|
||||
out:
|
||||
|
||||
|
||||
@@ -95,14 +95,18 @@ static BOOL WLog_UdpAppender_WriteMessage(wLog* log, wLogAppender* appender,
|
||||
char prefix[WLOG_MAX_PREFIX_SIZE] = WINPR_C_ARRAY_INIT;
|
||||
WLog_Layout_GetMessagePrefix(log, appender->Layout, cmessage, prefix, sizeof(prefix));
|
||||
|
||||
(void)_sendto(udpAppender->sock, prefix, (int)strnlen(prefix, ARRAYSIZE(prefix)), 0,
|
||||
&udpAppender->targetAddr, udpAppender->targetAddrLen);
|
||||
(void)_sendto(udpAppender->sock, cmessage->TextString,
|
||||
(int)strnlen(cmessage->TextString, INT_MAX), 0, &udpAppender->targetAddr,
|
||||
udpAppender->targetAddrLen);
|
||||
(void)_sendto(udpAppender->sock, "\n", 1, 0, &udpAppender->targetAddr,
|
||||
udpAppender->targetAddrLen);
|
||||
return TRUE;
|
||||
BOOL res = TRUE;
|
||||
if (_sendto(udpAppender->sock, prefix, (int)strnlen(prefix, ARRAYSIZE(prefix)), 0,
|
||||
&udpAppender->targetAddr, udpAppender->targetAddrLen) < 0)
|
||||
res = FALSE;
|
||||
if (_sendto(udpAppender->sock, cmessage->TextString,
|
||||
(int)strnlen(cmessage->TextString, INT_MAX), 0, &udpAppender->targetAddr,
|
||||
udpAppender->targetAddrLen) < 0)
|
||||
res = FALSE;
|
||||
if (_sendto(udpAppender->sock, "\n", 1, 0, &udpAppender->targetAddr,
|
||||
udpAppender->targetAddrLen) < 0)
|
||||
res = FALSE;
|
||||
return res;
|
||||
}
|
||||
|
||||
static BOOL WLog_UdpAppender_WriteDataMessage(wLog* log, wLogAppender* appender,
|
||||
|
||||
Reference in New Issue
Block a user