#include <assert.h>
+#ifdef AFS_PTHREAD_ENV
+
#include "rx.h"
#include "rx_globals.h"
#include "rx_pthread.h"
rxi_Recvmsg(osi_socket socket, struct msghdr *msg_p, int flags)
{
int ret;
-#if defined(HAVE_LINUX_ERRQUEUE_H) && defined(ADAPT_PMTU)
+#ifdef AFS_RXERRQ_ENV
while((rxi_HandleSocketError(socket)) > 0)
;
#endif
struct rx_ts_info_t * rx_ts_info_init(void) {
struct rx_ts_info_t * rx_ts_info;
- rx_ts_info = (rx_ts_info_t *) malloc(sizeof(rx_ts_info_t));
+ rx_ts_info = calloc(1, sizeof(rx_ts_info_t));
osi_Assert(rx_ts_info != NULL && pthread_setspecific(rx_ts_info_key, rx_ts_info) == 0);
- memset(rx_ts_info, 0, sizeof(rx_ts_info_t));
#ifdef RX_ENABLE_TSFPQ
queue_Init(&rx_ts_info->_FPQ);
return threadId;
}
+#endif