Mercurial > hg > Members > kono > Cerium

annotate example/word_count_test/ppe/Print.cc @ 667:d753b4f6b129

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
SimpeTask WordCount Worked.
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Thu, 03 Dec 2009 04:23:36 +0900
parents 4615489c5faa
children 4af9d20cf3af
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
1 #include <stdio.h>
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
2 #include <string.h>
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
3 #include "Print.h"
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
4 #include "Func.h"
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
5 #include "WordCount.h"
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
6
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
7 /* これは必須 */
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
8 SchedDefineTask1(Print,run_print);
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
9
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
10 static int
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
11 run_print(SchedTask *s, void *rbuf, void *wbuf)
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
12 {
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
13 #ifdef SIMPLE_TASK
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
14 WordCount *w = *(WordCount**)rbuf;
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
15 unsigned long long *idata = w->o_data;
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
16 // long task_num = w->task_num;
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
17 long status_num = w->status_num;
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
18 int out_task_num = w->out_task_num;
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
19
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
20 /*
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
21 * head_flag
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
22 * o_data[0]
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
23 * o_data[1]
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
24 *
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
25 */
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
26 #else
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
27 int pad = w->pad;
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
28 unsigned long long *idata = (unsigned long long*)s->get_input(rbuf, 0);
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
29 long task_num = (long)s->get_param(0);
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
30 long status_num = (long)s->get_param(1);
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
31 // int out_task_num = (int)s->get_param(2);
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
32 int pad = (int)s->get_param(3);
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
33 #endif
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
34 unsigned long long word_data[2];
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
35
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
36 int flag_cal_sum = 0;
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
37 //printf("pad %d\n",pad);
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
38
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
39
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
40 /* head_tail_flag : task = 2 : 1
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
41 *
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
42 * head_tail_flag[2]
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
43 * ___________ __________
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
44 * | | |
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
45 * | head_flag | tail_fag |
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
46 * |___________|__________|
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
47 * [0] [1]
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
48 *
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
49 * |----------------------|
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
50 * unsigned long long
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
51 * 16byte
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
52 *
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
53 * 配列先頭の head_flag はみない
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
54 * 配列末尾の tail_flag はみない
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
55 * 担当範囲前の末尾文字が「改行と、スペース以外」(tail_flag = 1)で、
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
56 * 担当範囲の先頭文字が「改行とスペース」(head_flag = 0)の場合
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
57 * 単語数を +1 することで、整合性がとれる。
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
58 *
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
59 * ex.
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
60 * task_num 4
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
61 * head_tail_flag[8]
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
62 *
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
63 * 0 1 2 3 4 5 6 7
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
64 * ___ ___ ___ ___ ___ ___ ___ ___
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
65 * | h | t | h | t | h | t | h | t |
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
66 * |___|___|___|___|___|___|___|___|
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
67 * |-------|-------|-------|
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
68 * 比較 比較 比較
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
69 *
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
70 */
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
71
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
72 s->printf("start sum\n");
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
73
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
74 for (int i = 0; i < status_num; i++) {
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
75 word_data[i] = 0;
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
76 }
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
77
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
78 #ifdef SIMPLE_TASK
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
79 for (int i = 0; i < out_task_num ; i++) {
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
80 word_data[0] += idata[i*w->out_size+0];
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
81 word_data[1] += idata[i*w->out_size+1];
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
82 unsigned long long *head_tail_flag =
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
83 &idata[i*w->out_size+2];
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
84 if((i!=out_task_num-1)&&
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
85 (head_tail_flag[1] == 1) && (head_tail_flag[4] == 0)) {
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
86 flag_cal_sum++;
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
87 }
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
88 }
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
89 #else
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
90 for (int i = 1; i < out_task_num * pad - pad; i += pad) {
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
91 //printf("%llu ",head_tail_flag[i]);
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
92 //printf("%llu\n",head_tail_flag[i+1]);
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
93 if((head_tail_flag[i] == 1) && (head_tail_flag[i+1] == 0)) {
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
94 flag_cal_sum++;
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
95 }
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
96 }
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
97
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
98 for (int i = 0; i < out_task_num*status_num; i += status_num) {
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
99 for (int j = 0; j < status_num; j++) {
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
100 word_data[j] += idata[i+j];
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
101 }
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
102 }
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
103 #endif
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
104
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
105 word_data[0] += flag_cal_sum;
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
106
667
d753b4f6b129 SimpeTask WordCount Worked.
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 666
diff changeset
107 for (int i = status_num-1; i >=0; i--) {
661
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
108 s->printf("%llu ",word_data[i]);
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
109 }
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
110
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
111 //printf("j = %d\n",j);
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
112
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
113
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
114 s->printf("\n");
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
115
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
116 return 0;
68f0253f5a71 add word_count_test
yutaka@henri.cr.ie.u-ryukyu.ac.jp
parents:
diff changeset
117 }