|
|
@ -1089,8 +1089,8 @@ static int redis_sfds(struct call *c, struct redis_list *sfds) { |
|
|
sock = g_queue_pop_head(&q); |
|
|
sock = g_queue_pop_head(&q); |
|
|
if (!sock) |
|
|
if (!sock) |
|
|
goto err; |
|
|
goto err; |
|
|
|
|
|
set_tos(sock, c->tos); |
|
|
sfd = stream_fd_new(sock, c, loc); |
|
|
sfd = stream_fd_new(sock, c, loc); |
|
|
// XXX tos |
|
|
|
|
|
|
|
|
|
|
|
sfds->ptrs[i] = sfd; |
|
|
sfds->ptrs[i] = sfd; |
|
|
} |
|
|
} |
|
|
|