diff for duplicates of <4C07D324.3070304@hp.com> diff --git a/a/1.txt b/N1/1.txt index 5b20704..1831cf3 100644 --- a/a/1.txt +++ b/N1/1.txt @@ -163,10 +163,14 @@ API to set up priorities. > + for (i = 0; i < q->asoc->c.sinit_num_ostreams || hasdata; i++) { > + if (!list_empty(&q->out_chunk_list[internal->rr_ptr])) { > + hasdata = 1; -> + struct list_head *tmp_entry > + q->out_chunk_list[internal->rr_ptr].next; -> + struct sctp_chunk *tmp_ch > + list_entry(tmp_entry, struct sctp_chunk, list); -> + if (tmp_ch->skb->len <> + internal->deficit[internal->rr_ptr]) { -> + internal->deficit[internal->rr_ptr] -> + tmp_ch->skb->len; +> + struct list_head *tmp_entry = +> + q->out_chunk_list[internal->rr_ptr].next; +> + struct sctp_chunk *tmp_ch = +> + list_entry(tmp_entry, struct sctp_chunk, list); +> + if (tmp_ch->skb->len <= +> + internal->deficit[internal->rr_ptr]) { +> + internal->deficit[internal->rr_ptr] -= +> + tmp_ch->skb->len; > + cur = internal->rr_ptr; > + flag = 1; > + break; @@ -176,7 +180,8 @@ API to set up priorities. > + } > + internal->rr_ptr = (internal->rr_ptr + 1) > + % q->asoc->c.sinit_num_ostreams; -> + internal->deficit[internal->rr_ptr] +> + q->asoc->sched_priv[internal->rr_ptr] * quantum; +> + internal->deficit[internal->rr_ptr] += +> + q->asoc->sched_priv[internal->rr_ptr] * quantum; > + } > + > + if (flag) { diff --git a/a/content_digest b/N1/content_digest index 4bc2c42..b80d9a9 100644 --- a/a/content_digest +++ b/N1/content_digest @@ -1,7 +1,7 @@ "ref\0AANLkTilqwskt5fS2Yc2pa32IMA7QgDdn5latnAkyPpvZ@mail.gmail.com\0" "From\0Vlad Yasevich <vladislav.yasevich@hp.com>\0" - "Subject\0Re: [PATCH 6/6] sctp multistream scheduling: a sample weighted fair\0" - "Date\0Thu, 03 Jun 2010 16:07:00 +0000\0" + "Subject\0Re: [PATCH 6/6] sctp multistream scheduling: a sample weighted fair queue \tscheduling module\0" + "Date\0Thu, 03 Jun 2010 12:07:00 -0400\0" "To\0Yaogong Wang <ywang15@ncsu.edu>\0" "Cc\0linux-sctp@vger.kernel.org" Sridhar Samudrala <sri@us.ibm.com> @@ -173,10 +173,14 @@ "> +\tfor (i = 0; i < q->asoc->c.sinit_num_ostreams || hasdata; i++) {\n" "> +\t\tif (!list_empty(&q->out_chunk_list[internal->rr_ptr])) {\n" "> +\t\t\thasdata = 1;\n" - "> +\t\t\tstruct list_head *tmp_entry > +\t\t\t\tq->out_chunk_list[internal->rr_ptr].next;\n" - "> +\t\t\tstruct sctp_chunk *tmp_ch > +\t\t\t\tlist_entry(tmp_entry, struct sctp_chunk, list);\n" - "> +\t\t\tif (tmp_ch->skb->len <> +\t\t\t\tinternal->deficit[internal->rr_ptr]) {\n" - "> +\t\t\t\tinternal->deficit[internal->rr_ptr] -> +\t\t\t\t\ttmp_ch->skb->len;\n" + "> +\t\t\tstruct list_head *tmp_entry =\n" + "> +\t\t\t\tq->out_chunk_list[internal->rr_ptr].next;\n" + "> +\t\t\tstruct sctp_chunk *tmp_ch =\n" + "> +\t\t\t\tlist_entry(tmp_entry, struct sctp_chunk, list);\n" + "> +\t\t\tif (tmp_ch->skb->len <=\n" + "> +\t\t\t\tinternal->deficit[internal->rr_ptr]) {\n" + "> +\t\t\t\tinternal->deficit[internal->rr_ptr] -=\n" + "> +\t\t\t\t\ttmp_ch->skb->len;\n" "> +\t\t\t\tcur = internal->rr_ptr;\n" "> +\t\t\t\tflag = 1;\n" "> +\t\t\t\tbreak;\n" @@ -186,7 +190,8 @@ "> +\t\t}\n" "> +\t\tinternal->rr_ptr = (internal->rr_ptr + 1)\n" "> +\t\t\t\t\t\t% q->asoc->c.sinit_num_ostreams;\n" - "> +\t\tinternal->deficit[internal->rr_ptr] +> +\t\t\t\tq->asoc->sched_priv[internal->rr_ptr] * quantum;\n" + "> +\t\tinternal->deficit[internal->rr_ptr] +=\n" + "> +\t\t\t\tq->asoc->sched_priv[internal->rr_ptr] * quantum;\n" "> +\t}\n" "> +\n" "> +\tif (flag) {\n" @@ -236,4 +241,4 @@ "> +MODULE_DESCRIPTION(\"SCTP Multistream Scheduling: Weighted Fair Queue\");\n" > -60e91935888067cded160a1e03db6749d8c5803346863b0dd9defc1636bb9ff9 +f2bf0436db8f750b41a165856970bf8368c8d3568ffd057d375518f20ed01a0b
This is an external index of several public inboxes, see mirroring instructions on how to clone and mirror all data and code used by this external index.