Lines Matching refs:fq
70 static int ip6_frag_reasm(struct frag_queue *fq, struct sk_buff *skb,
76 struct frag_queue *fq; in ip6_frag_expire() local
78 fq = container_of(frag, struct frag_queue, q); in ip6_frag_expire()
80 ip6frag_expire_frag_queue(fq->q.fqdir->net, fq); in ip6_frag_expire()
106 static int ip6_frag_queue(struct frag_queue *fq, struct sk_buff *skb, in ip6_frag_queue() argument
117 if (fq->q.flags & INET_FRAG_COMPLETE) in ip6_frag_queue()
147 if (end < fq->q.len || in ip6_frag_queue()
148 ((fq->q.flags & INET_FRAG_LAST_IN) && end != fq->q.len)) in ip6_frag_queue()
150 fq->q.flags |= INET_FRAG_LAST_IN; in ip6_frag_queue()
151 fq->q.len = end; in ip6_frag_queue()
163 if (end > fq->q.len) { in ip6_frag_queue()
165 if (fq->q.flags & INET_FRAG_LAST_IN) in ip6_frag_queue()
167 fq->q.len = end; in ip6_frag_queue()
188 prev_tail = fq->q.fragments_tail; in ip6_frag_queue()
189 err = inet_frag_queue_insert(&fq->q, skb, offset, end); in ip6_frag_queue()
194 fq->iif = dev->ifindex; in ip6_frag_queue()
196 fq->q.stamp = skb->tstamp; in ip6_frag_queue()
197 fq->q.meat += skb->len; in ip6_frag_queue()
198 fq->ecn |= ecn; in ip6_frag_queue()
199 add_frag_mem_limit(fq->q.fqdir, skb->truesize); in ip6_frag_queue()
202 if (fragsize > fq->q.max_size) in ip6_frag_queue()
203 fq->q.max_size = fragsize; in ip6_frag_queue()
209 fq->nhoffset = nhoff; in ip6_frag_queue()
210 fq->q.flags |= INET_FRAG_FIRST_IN; in ip6_frag_queue()
213 if (fq->q.flags == (INET_FRAG_FIRST_IN | INET_FRAG_LAST_IN) && in ip6_frag_queue()
214 fq->q.meat == fq->q.len) { in ip6_frag_queue()
218 err = ip6_frag_reasm(fq, skb, prev_tail, dev); in ip6_frag_queue()
235 inet_frag_kill(&fq->q); in ip6_frag_queue()
250 static int ip6_frag_reasm(struct frag_queue *fq, struct sk_buff *skb, in ip6_frag_reasm() argument
253 struct net *net = fq->q.fqdir->net; in ip6_frag_reasm()
259 inet_frag_kill(&fq->q); in ip6_frag_reasm()
261 ecn = ip_frag_ecn_table[fq->ecn]; in ip6_frag_reasm()
265 reasm_data = inet_frag_reasm_prepare(&fq->q, skb, prev_tail); in ip6_frag_reasm()
270 sizeof(struct ipv6hdr) + fq->q.len - in ip6_frag_reasm()
277 nhoff = fq->nhoffset; in ip6_frag_reasm()
287 inet_frag_reasm_finish(&fq->q, skb, reasm_data, true); in ip6_frag_reasm()
294 IP6CB(skb)->frag_max_size = fq->q.max_size; in ip6_frag_reasm()
303 fq->q.rb_fragments = RB_ROOT; in ip6_frag_reasm()
304 fq->q.fragments_tail = NULL; in ip6_frag_reasm()
305 fq->q.last_run_head = NULL; in ip6_frag_reasm()
317 inet_frag_kill(&fq->q); in ip6_frag_reasm()
324 struct frag_queue *fq; in ipv6_frag_rcv() local
374 fq = fq_find(net, fhdr->identification, hdr, iif); in ipv6_frag_rcv()
375 if (fq) { in ipv6_frag_rcv()
379 spin_lock(&fq->q.lock); in ipv6_frag_rcv()
381 fq->iif = iif; in ipv6_frag_rcv()
382 ret = ip6_frag_queue(fq, skb, fhdr, IP6CB(skb)->nhoff, in ipv6_frag_rcv()
385 spin_unlock(&fq->q.lock); in ipv6_frag_rcv()
386 inet_frag_put(&fq->q); in ipv6_frag_rcv()