*/
static int AFPSynchronizeStart(AFPThreadVars *ptv, uint64_t *discarded_pkts)
{
- int r;
struct timeval synctv;
struct pollfd fds;
synctv.tv_usec = 0xffffffff;
while (1) {
- r = poll(&fds, 1, POLL_TIMEOUT);
+ int r = poll(&fds, 1, POLL_TIMEOUT);
if (r > 0 &&
(fds.revents & (POLLHUP|POLLRDHUP|POLLERR|POLLNVAL))) {
SCLogWarning(SC_ERR_AFP_READ, "poll failed %02x",
*/
static int AFPTryReopen(AFPThreadVars *ptv)
{
- int afp_activate_r;
-
ptv->down_count++;
/* Don't reconnect till we have packet that did not release data */
return -1;
}
- afp_activate_r = AFPCreateSocket(ptv, ptv->iface, 0);
+ int afp_activate_r = AFPCreateSocket(ptv, ptv->iface, 0);
if (afp_activate_r != 0) {
if (ptv->down_count % AFP_DOWN_COUNTER_INTERVAL == 0) {
SCLogWarning(SC_ERR_AFP_CREATE, "Can not open iface '%s'",