Searched refs:sk_receive_queue (Results 1 - 25 of 73) sorted by relevance

123

/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/unix/
H A Dgarbage.c237 spin_lock(&x->sk_receive_queue.lock);
238 skb = skb_peek(&x->sk_receive_queue);
244 while (skb && skb != (struct sk_buff *)&x->sk_receive_queue) {
272 spin_unlock(&x->sk_receive_queue.lock);
285 spin_lock(&s->sk_receive_queue.lock);
286 skb = skb_peek(&s->sk_receive_queue);
288 skb != (struct sk_buff *)&s->sk_receive_queue) {
295 &s->sk_receive_queue);
300 spin_unlock(&s->sk_receive_queue.lock);
H A Daf_unix.c322 if (!skb_queue_empty(&sk->sk_receive_queue)) {
323 skb_queue_purge(&sk->sk_receive_queue);
341 skb_queue_purge(&sk->sk_receive_queue);
392 if (!skb_queue_empty(&sk->sk_receive_queue) || embrion)
406 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) {
555 * bh-unsafe locking for their sk_receive_queue.lock. Split off
575 lockdep_set_class(&sk->sk_receive_queue.lock,
959 (skb_queue_len(&other->sk_receive_queue) >
1033 if (skb_queue_len(&other->sk_receive_queue) >
1125 spin_lock(&other->sk_receive_queue
[all...]
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/core/
H A Ddatagram.c82 if (!skb_queue_empty(&sk->sk_receive_queue))
171 spin_lock_irqsave(&sk->sk_receive_queue.lock,
173 skb = skb_peek(&sk->sk_receive_queue);
176 spin_unlock_irqrestore(&sk->sk_receive_queue.lock,
179 skb = skb_dequeue(&sk->sk_receive_queue);
218 * sk_receive_queue lock. Therefore it must not be used in a
225 spin_lock_bh(&sk->sk_receive_queue.lock);
226 if (skb == skb_peek(&sk->sk_receive_queue)) {
227 __skb_unlink(skb, &sk->sk_receive_queue);
230 spin_unlock_bh(&sk->sk_receive_queue
[all...]
H A Dstream.c264 __skb_queue_purge(&sk->sk_receive_queue);
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/tipc/
H A Dsocket.c126 if ((skb_queue_len(&sock->sk->sk_receive_queue) != 0) ||
150 buf_discard(skb_dequeue(&tsock->sk.sk_receive_queue));
263 buf = skb_dequeue(&sk->sk_receive_queue);
283 while ((buf = skb_dequeue(&sk->sk_receive_queue))) {
484 while ((buf = skb_dequeue(&sock->sk->sk_receive_queue))) {
831 (skb_queue_len(&sock->sk->sk_receive_queue) == 0)))
841 if (unlikely((skb_queue_len(&sock->sk->sk_receive_queue) == 0) &&
849 ((q_len = skb_queue_len(&sock->sk->sk_receive_queue)) ||
864 buf = skb_peek(&sock->sk->sk_receive_queue);
965 if (skb_queue_len(&sock->sk->sk_receive_queue)
[all...]
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/rxrpc/
H A Dar-recvmsg.c85 skb = skb_peek(&rx->sk.sk_receive_queue);
100 if (skb_queue_empty(&rx->sk.sk_receive_queue)) {
123 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)
218 if (skb_dequeue(&rx->sk.sk_receive_queue) !=
238 if (skb == (struct sk_buff *) &rx->sk.sk_receive_queue)
244 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)
271 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)
323 if (skb_dequeue(&rx->sk.sk_receive_queue) != skb)
H A Daf_rxrpc.c593 if (!skb_queue_empty(&sk->sk_receive_queue))
656 rxrpc_purge_queue(&sk->sk_receive_queue);
681 spin_lock_bh(&sk->sk_receive_queue.lock);
683 spin_unlock_bh(&sk->sk_receive_queue.lock);
696 rxrpc_purge_queue(&sk->sk_receive_queue);
H A Dar-input.c84 spin_lock_bh(&sk->sk_receive_queue.lock);
101 spin_unlock_bh(&sk->sk_receive_queue.lock);
111 __skb_queue_tail(&sk->sk_receive_queue, skb);
112 spin_unlock_bh(&sk->sk_receive_queue.lock);
119 spin_unlock_bh(&sk->sk_receive_queue.lock);
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/decnet/netfilter/
H A Ddn_rtmsg.c121 unsigned int qlen = skb_queue_len(&sk->sk_receive_queue);
123 for (; qlen && (skb = skb_dequeue(&sk->sk_receive_queue)); qlen--) {
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/drivers/scsi/
H A Dscsi_netlink.c115 while ((skb = skb_dequeue(&sk->sk_receive_queue))) {
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/atm/
H A Draw.c29 skb_queue_tail(&sk->sk_receive_queue, skb);
H A Dsignaling.c56 skb_queue_tail(&sk_atm(sigd)->sk_receive_queue,skb);
137 skb_queue_tail(&sk->sk_receive_queue, skb);
227 if (skb_peek(&sk_atm(vcc)->sk_receive_queue))
229 skb_queue_purge(&sk_atm(vcc)->sk_receive_queue);
H A Dioctl.c77 skb = skb_peek(&sk->sk_receive_queue);
H A Dsvc.c66 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) {
345 while (!(skb = skb_dequeue(&sk->sk_receive_queue)) &&
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/packet/
H A Daf_packet.c529 spin_lock(&sk->sk_receive_queue.lock);
531 __skb_queue_tail(&sk->sk_receive_queue, skb);
532 spin_unlock(&sk->sk_receive_queue.lock);
537 spin_lock(&sk->sk_receive_queue.lock);
539 spin_unlock(&sk->sk_receive_queue.lock);
618 spin_lock(&sk->sk_receive_queue.lock);
627 __skb_queue_tail(&sk->sk_receive_queue, copy_skb);
631 spin_unlock(&sk->sk_receive_queue.lock);
688 spin_unlock(&sk->sk_receive_queue.lock);
848 skb_queue_purge(&sk->sk_receive_queue);
[all...]
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/sctp/
H A Dulpqueue.c151 sctp_skb_list_tail(&sp->pd_lobby, &sk->sk_receive_queue);
170 __skb_queue_tail(&sk->sk_receive_queue,
224 queue = &sk->sk_receive_queue;
238 queue = &sk->sk_receive_queue;
247 queue = &sk->sk_receive_queue;
268 if (queue == &sk->sk_receive_queue)
965 if (skb_queue_empty(&asoc->base.sk->sk_receive_queue)) {
1004 __skb_queue_tail(&sk->sk_receive_queue, sctp_event2skb(ev));
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/bluetooth/rfcomm/
H A Dsock.c80 skb_queue_tail(&sk->sk_receive_queue, skb);
184 skb_queue_purge(&sk->sk_receive_queue);
615 if (!skb_queue_empty(&sk->sk_receive_queue) ||
658 skb = skb_dequeue(&sk->sk_receive_queue);
683 skb_queue_head(&sk->sk_receive_queue, skb);
696 skb_queue_head(&sk->sk_receive_queue, skb);
703 skb_queue_head(&sk->sk_receive_queue, skb);
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/iucv/
H A Daf_iucv.c115 skb_queue_purge(&sk->sk_receive_queue);
674 skb_queue_empty(&sk->sk_receive_queue))
693 skb_queue_head(&sk->sk_receive_queue, skb);
706 skb_queue_head(&sk->sk_receive_queue, skb);
724 skb_queue_head(&sk->sk_receive_queue, skb);
765 if (!skb_queue_empty(&sk->sk_receive_queue) ||
832 skb_queue_purge(&sk->sk_receive_queue);
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/irda/
H A Daf_irda.c193 // Should be ??? skb_queue_tail(&sk->sk_receive_queue, skb);
291 skb_queue_tail(&sk->sk_receive_queue, skb);
865 skb = skb_dequeue(&sk->sk_receive_queue);
874 skb_peek(&sk->sk_receive_queue));
1200 skb_queue_purge(&sk->sk_receive_queue);
1396 struct sk_buff *skb = skb_dequeue(&sk->sk_receive_queue);
1421 else if (skb_peek(&sk->sk_receive_queue) == NULL)
1437 skb_queue_head(&sk->sk_receive_queue, skb);
1453 skb_queue_head(&sk->sk_receive_queue, skb);
1462 skb_queue_head(&sk->sk_receive_queue, sk
[all...]
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/netlink/
H A Daf_netlink.c150 skb_queue_purge(&sk->sk_receive_queue);
778 skb_queue_tail(&sk->sk_receive_queue, skb);
857 skb_queue_tail(&sk->sk_receive_queue, skb);
1109 if (skb_queue_empty(&sk->sk_receive_queue))
1372 skb_queue_tail(&sk->sk_receive_queue, skb);
1383 skb_queue_tail(&sk->sk_receive_queue, skb);
1542 if (!*qlen || *qlen > skb_queue_len(&sk->sk_receive_queue))
1543 *qlen = skb_queue_len(&sk->sk_receive_queue);
1546 skb = skb_dequeue(&sk->sk_receive_queue);
1549 skb_queue_head(&sk->sk_receive_queue, sk
[all...]
H A Dgenetlink.c37 if (genl_sock && genl_sock->sk_receive_queue.qlen)
359 } while (qlen && genl_sock && genl_sock->sk_receive_queue.qlen);
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/dccp/
H A Dinput.c27 __skb_queue_tail(&sk->sk_receive_queue, skb);
160 __skb_queue_tail(&sk->sk_receive_queue, skb);
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/netfilter/
H A Dnfnetlink.c65 if (nfnl->sk_receive_queue.qlen)
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/x25/
H A Daf_x25.c361 while ((skb = skb_dequeue(&sk->sk_receive_queue)) != NULL) {
770 if (skb_queue_empty(&sk->sk_receive_queue)) {
800 skb = skb_dequeue(&sk->sk_receive_queue);
962 skb_queue_head(&sk->sk_receive_queue, skb);
1266 if ((skb = skb_peek(&sk->sk_receive_queue)) != NULL)
/netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/decnet/
H A Ddn_nsp_in.c331 skb_queue_tail(&sk->sk_receive_queue, skb);
655 if (dn_queue_skb(sk, skb, SIGIO, &sk->sk_receive_queue) == 0) {

Completed in 251 milliseconds

123