1 | The following changes since commit cda4a338c4243fa3bff4498b935340ac7121cc76: | 1 | The following changes since commit 32c7e0ab755745e961f1772e95cac381cc68769d: |
---|---|---|---|
2 | 2 | ||
3 | tcg/tci: Add TCG_TARGET_DEFAULT_MO (2017-09-07 18:57:34 +0100) | 3 | Merge remote-tracking branch 'remotes/juanquintela/tags/migration/20170421' into staging (2017-04-21 15:59:27 +0100) |
4 | 4 | ||
5 | are available in the git repository at: | 5 | are available in the git repository at: |
6 | 6 | ||
7 | https://github.com/jasowang/qemu.git tags/net-pull-request | 7 | https://github.com/jasowang/qemu.git tags/net-pull-request |
8 | 8 | ||
9 | for you to fetch changes up to 861d51e62bb197b43606f888dbefbabebaf0d854: | 9 | for you to fetch changes up to 0fc8aec7de64f2bf83a274a2a38b938ce03425d2: |
10 | 10 | ||
11 | colo-compare: Update the COLO document to add the IOThread configuration (2017-09-08 09:34:40 +0800) | 11 | COLO-compare: Optimize tcp compare trace event (2017-04-25 19:17:25 +0800) |
12 | 12 | ||
13 | ---------------------------------------------------------------- | 13 | ---------------------------------------------------------------- |
14 | 14 | ||
15 | Changes from V1: | ||
16 | - Fix clang warnings | ||
17 | |||
15 | ---------------------------------------------------------------- | 18 | ---------------------------------------------------------------- |
16 | Kamil Rytarowski (1): | 19 | Cédric Le Goater (5): |
17 | e1000: Rename the SEC symbol to SEQEC | 20 | hw/net: add MII definitions |
21 | net: add FTGMAC100 support | ||
22 | net/ftgmac100: add a 'aspeed' property | ||
23 | aspeed: add a FTGMAC100 nic | ||
24 | slirp: add a fake NC-SI backend | ||
18 | 25 | ||
19 | Mao Zhongyi (8): | 26 | Zhang Chen (3): |
20 | net/rocker: Remove the dead error handling | 27 | colo-compare: Fix old packet check bug. |
21 | net/rocker: Plug memory leak in pci_rocker_init() | 28 | COLO-compare: Optimize tcp compare for option field |
22 | net/rocker: Convert to realize() | 29 | COLO-compare: Optimize tcp compare trace event |
23 | net/rocker: Fix the unusual macro name | ||
24 | net/socket: Don't treat odd socket type as SOCK_STREAM | ||
25 | net/socket: Convert several helper functions to Error | ||
26 | net/net: Convert parse_host_port() to Error | ||
27 | net/socket: Improve -net socket error reporting | ||
28 | 30 | ||
29 | Matt Parker (1): | 31 | default-configs/arm-softmmu.mak | 1 + |
30 | net: rtl8139: do not use old_mmio accesses | 32 | hw/arm/aspeed_soc.c | 21 + |
31 | 33 | hw/net/Makefile.objs | 1 + | |
32 | Wang Yong (3): | 34 | hw/net/ftgmac100.c | 1016 +++++++++++++++++++++++++++++++++++++++ |
33 | qemu-iothread: IOThread supports the GMainContext event loop | 35 | include/hw/arm/aspeed_soc.h | 2 + |
34 | colo-compare: Use IOThread to Check old packet regularly and Process pactkets of the primary | 36 | include/hw/net/ftgmac100.h | 64 +++ |
35 | colo-compare: Update the COLO document to add the IOThread configuration | 37 | include/hw/net/mii.h | 71 ++- |
36 | 38 | include/net/eth.h | 1 + | |
37 | Zhang Chen (5): | 39 | net/colo-compare.c | 69 ++- |
38 | net/filter-rewriter.c: Fix rewirter checksum bug when use virtio-net | 40 | net/trace-events | 3 +- |
39 | MAINTAINERS: Update mail address for COLO Proxy | 41 | slirp/Makefile.objs | 2 +- |
40 | net/colo-compare.c: Optimize unpredictable tcp options comparison | 42 | slirp/ncsi-pkt.h | 419 ++++++++++++++++ |
41 | net/colo-compare.c: Adjust net queue pop order for performance | 43 | slirp/ncsi.c | 130 +++++ |
42 | net/colo-compare.c: Fix comments and scheme | 44 | slirp/slirp.c | 4 + |
43 | 45 | slirp/slirp.h | 3 + | |
44 | MAINTAINERS | 2 +- | 46 | 15 files changed, 1770 insertions(+), 37 deletions(-) |
45 | docs/colo-proxy.txt | 3 +- | 47 | create mode 100644 hw/net/ftgmac100.c |
46 | hw/net/e1000.c | 4 +- | 48 | create mode 100644 include/hw/net/ftgmac100.h |
47 | hw/net/e1000_regs.h | 2 +- | 49 | create mode 100644 slirp/ncsi-pkt.h |
48 | hw/net/e1000e_core.c | 2 +- | 50 | create mode 100644 slirp/ncsi.c |
49 | hw/net/e1000x_common.h | 2 +- | ||
50 | hw/net/rocker/rocker.c | 94 ++++++---------------- | ||
51 | hw/net/rocker/rocker_desc.c | 10 --- | ||
52 | hw/net/rocker/rocker_fp.c | 4 - | ||
53 | hw/net/rocker/rocker_of_dpa.c | 20 ----- | ||
54 | hw/net/rocker/rocker_world.c | 12 ++- | ||
55 | hw/net/rtl8139.c | 53 +----------- | ||
56 | include/qemu/sockets.h | 3 +- | ||
57 | include/sysemu/iothread.h | 4 + | ||
58 | iothread.c | 45 +++++++++++ | ||
59 | net/colo-compare.c | 183 ++++++++++++++++++++++++------------------ | ||
60 | net/filter-rewriter.c | 6 +- | ||
61 | net/net.c | 22 +++-- | ||
62 | net/socket.c | 156 +++++++++++++++++++---------------- | ||
63 | 19 files changed, 304 insertions(+), 323 deletions(-) | ||
64 | 51 | ||
65 | 52 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | ||
2 | 1 | ||
3 | Because vnet_hdr have a offset to net packet, we must add it when use | ||
4 | virtio-net. | ||
5 | |||
6 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | ||
7 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
8 | --- | ||
9 | net/filter-rewriter.c | 6 ++++-- | ||
10 | 1 file changed, 4 insertions(+), 2 deletions(-) | ||
11 | |||
12 | diff --git a/net/filter-rewriter.c b/net/filter-rewriter.c | ||
13 | index XXXXXXX..XXXXXXX 100644 | ||
14 | --- a/net/filter-rewriter.c | ||
15 | +++ b/net/filter-rewriter.c | ||
16 | @@ -XXX,XX +XXX,XX @@ static int handle_primary_tcp_pkt(NetFilterState *nf, | ||
17 | /* handle packets to the secondary from the primary */ | ||
18 | tcp_pkt->th_ack = htonl(ntohl(tcp_pkt->th_ack) + conn->offset); | ||
19 | |||
20 | - net_checksum_calculate((uint8_t *)pkt->data, pkt->size); | ||
21 | + net_checksum_calculate((uint8_t *)pkt->data + pkt->vnet_hdr_len, | ||
22 | + pkt->size - pkt->vnet_hdr_len); | ||
23 | } | ||
24 | } | ||
25 | |||
26 | @@ -XXX,XX +XXX,XX @@ static int handle_secondary_tcp_pkt(NetFilterState *nf, | ||
27 | /* handle packets to the primary from the secondary*/ | ||
28 | tcp_pkt->th_seq = htonl(ntohl(tcp_pkt->th_seq) - conn->offset); | ||
29 | |||
30 | - net_checksum_calculate((uint8_t *)pkt->data, pkt->size); | ||
31 | + net_checksum_calculate((uint8_t *)pkt->data + pkt->vnet_hdr_len, | ||
32 | + pkt->size - pkt->vnet_hdr_len); | ||
33 | } | ||
34 | } | ||
35 | |||
36 | -- | ||
37 | 2.7.4 | ||
38 | |||
39 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
2 | 1 | ||
3 | Memory allocation functions like world_alloc, desc_ring_alloc etc, | ||
4 | they are all wrappers around g_malloc, g_new etc. But g_malloc and | ||
5 | similar functions doesn't return null. Because they ignore the fact | ||
6 | that g_malloc() of 0 bytes returns null. So error checks for these | ||
7 | allocation failure are superfluous. Now, remove them entirely. | ||
8 | |||
9 | Cc: jasowang@redhat.com | ||
10 | Cc: jiri@resnulli.us | ||
11 | Cc: armbru@redhat.com | ||
12 | Cc: f4bug@amsat.org | ||
13 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
14 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
15 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
16 | --- | ||
17 | hw/net/rocker/rocker.c | 47 +------------------------------------------ | ||
18 | hw/net/rocker/rocker_desc.c | 10 --------- | ||
19 | hw/net/rocker/rocker_fp.c | 4 ---- | ||
20 | hw/net/rocker/rocker_of_dpa.c | 20 ------------------ | ||
21 | hw/net/rocker/rocker_world.c | 12 +++++------ | ||
22 | 5 files changed, 6 insertions(+), 87 deletions(-) | ||
23 | |||
24 | diff --git a/hw/net/rocker/rocker.c b/hw/net/rocker/rocker.c | ||
25 | index XXXXXXX..XXXXXXX 100644 | ||
26 | --- a/hw/net/rocker/rocker.c | ||
27 | +++ b/hw/net/rocker/rocker.c | ||
28 | @@ -XXX,XX +XXX,XX @@ static int tx_consume(Rocker *r, DescInfo *info) | ||
29 | } | ||
30 | iov[iovcnt].iov_len = frag_len; | ||
31 | iov[iovcnt].iov_base = g_malloc(frag_len); | ||
32 | - if (!iov[iovcnt].iov_base) { | ||
33 | - err = -ROCKER_ENOMEM; | ||
34 | - goto err_no_mem; | ||
35 | - } | ||
36 | |||
37 | pci_dma_read(dev, frag_addr, iov[iovcnt].iov_base, | ||
38 | iov[iovcnt].iov_len); | ||
39 | @@ -XXX,XX +XXX,XX @@ static int tx_consume(Rocker *r, DescInfo *info) | ||
40 | err = fp_port_eg(r->fp_port[port], iov, iovcnt); | ||
41 | |||
42 | err_too_many_frags: | ||
43 | -err_no_mem: | ||
44 | err_bad_attr: | ||
45 | for (i = 0; i < ROCKER_TX_FRAGS_MAX; i++) { | ||
46 | g_free(iov[i].iov_base); | ||
47 | @@ -XXX,XX +XXX,XX @@ int rx_produce(World *world, uint32_t pport, | ||
48 | */ | ||
49 | |||
50 | data = g_malloc(data_size); | ||
51 | - if (!data) { | ||
52 | - err = -ROCKER_ENOMEM; | ||
53 | - goto out; | ||
54 | - } | ||
55 | + | ||
56 | iov_to_buf(iov, iovcnt, 0, data, data_size); | ||
57 | pci_dma_write(dev, frag_addr, data, data_size); | ||
58 | g_free(data); | ||
59 | @@ -XXX,XX +XXX,XX @@ static void rocker_test_dma_ctrl(Rocker *r, uint32_t val) | ||
60 | |||
61 | buf = g_malloc(r->test_dma_size); | ||
62 | |||
63 | - if (!buf) { | ||
64 | - DPRINTF("test dma buffer alloc failed"); | ||
65 | - return; | ||
66 | - } | ||
67 | - | ||
68 | switch (val) { | ||
69 | case ROCKER_TEST_DMA_CTRL_CLEAR: | ||
70 | memset(buf, 0, r->test_dma_size); | ||
71 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
72 | |||
73 | r->worlds[ROCKER_WORLD_TYPE_OF_DPA] = of_dpa_world_alloc(r); | ||
74 | |||
75 | - for (i = 0; i < ROCKER_WORLD_TYPE_MAX; i++) { | ||
76 | - if (!r->worlds[i]) { | ||
77 | - err = -ENOMEM; | ||
78 | - goto err_world_alloc; | ||
79 | - } | ||
80 | - } | ||
81 | - | ||
82 | if (!r->world_name) { | ||
83 | r->world_name = g_strdup(world_name(r->worlds[ROCKER_WORLD_TYPE_OF_DPA])); | ||
84 | } | ||
85 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
86 | } | ||
87 | |||
88 | r->rings = g_new(DescRing *, rocker_pci_ring_count(r)); | ||
89 | - if (!r->rings) { | ||
90 | - goto err_rings_alloc; | ||
91 | - } | ||
92 | |||
93 | /* Rings are ordered like this: | ||
94 | * - command ring | ||
95 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
96 | * ..... | ||
97 | */ | ||
98 | |||
99 | - err = -ENOMEM; | ||
100 | for (i = 0; i < rocker_pci_ring_count(r); i++) { | ||
101 | DescRing *ring = desc_ring_alloc(r, i); | ||
102 | |||
103 | - if (!ring) { | ||
104 | - goto err_ring_alloc; | ||
105 | - } | ||
106 | - | ||
107 | if (i == ROCKER_RING_CMD) { | ||
108 | desc_ring_set_consume(ring, cmd_consume, ROCKER_MSIX_VEC_CMD); | ||
109 | } else if (i == ROCKER_RING_EVENT) { | ||
110 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
111 | fp_port_alloc(r, r->name, &r->fp_start_macaddr, | ||
112 | i, &r->fp_ports_peers[i]); | ||
113 | |||
114 | - if (!port) { | ||
115 | - goto err_port_alloc; | ||
116 | - } | ||
117 | - | ||
118 | r->fp_port[i] = port; | ||
119 | fp_port_set_world(port, r->world_dflt); | ||
120 | } | ||
121 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
122 | |||
123 | return 0; | ||
124 | |||
125 | -err_port_alloc: | ||
126 | - for (--i; i >= 0; i--) { | ||
127 | - FpPort *port = r->fp_port[i]; | ||
128 | - fp_port_free(port); | ||
129 | - } | ||
130 | - i = rocker_pci_ring_count(r); | ||
131 | -err_ring_alloc: | ||
132 | - for (--i; i >= 0; i--) { | ||
133 | - desc_ring_free(r->rings[i]); | ||
134 | - } | ||
135 | - g_free(r->rings); | ||
136 | -err_rings_alloc: | ||
137 | err_duplicate: | ||
138 | rocker_msix_uninit(r); | ||
139 | err_msix_init: | ||
140 | object_unparent(OBJECT(&r->msix_bar)); | ||
141 | object_unparent(OBJECT(&r->mmio)); | ||
142 | err_world_type_by_name: | ||
143 | -err_world_alloc: | ||
144 | for (i = 0; i < ROCKER_WORLD_TYPE_MAX; i++) { | ||
145 | if (r->worlds[i]) { | ||
146 | world_free(r->worlds[i]); | ||
147 | diff --git a/hw/net/rocker/rocker_desc.c b/hw/net/rocker/rocker_desc.c | ||
148 | index XXXXXXX..XXXXXXX 100644 | ||
149 | --- a/hw/net/rocker/rocker_desc.c | ||
150 | +++ b/hw/net/rocker/rocker_desc.c | ||
151 | @@ -XXX,XX +XXX,XX @@ char *desc_get_buf(DescInfo *info, bool read_only) | ||
152 | info->buf_size = size; | ||
153 | } | ||
154 | |||
155 | - if (!info->buf) { | ||
156 | - return NULL; | ||
157 | - } | ||
158 | - | ||
159 | pci_dma_read(dev, le64_to_cpu(info->desc.buf_addr), info->buf, size); | ||
160 | |||
161 | return info->buf; | ||
162 | @@ -XXX,XX +XXX,XX @@ bool desc_ring_set_size(DescRing *ring, uint32_t size) | ||
163 | ring->head = ring->tail = 0; | ||
164 | |||
165 | ring->info = g_renew(DescInfo, ring->info, size); | ||
166 | - if (!ring->info) { | ||
167 | - return false; | ||
168 | - } | ||
169 | |||
170 | memset(ring->info, 0, size * sizeof(DescInfo)); | ||
171 | |||
172 | @@ -XXX,XX +XXX,XX @@ DescRing *desc_ring_alloc(Rocker *r, int index) | ||
173 | DescRing *ring; | ||
174 | |||
175 | ring = g_new0(DescRing, 1); | ||
176 | - if (!ring) { | ||
177 | - return NULL; | ||
178 | - } | ||
179 | |||
180 | ring->r = r; | ||
181 | ring->index = index; | ||
182 | diff --git a/hw/net/rocker/rocker_fp.c b/hw/net/rocker/rocker_fp.c | ||
183 | index XXXXXXX..XXXXXXX 100644 | ||
184 | --- a/hw/net/rocker/rocker_fp.c | ||
185 | +++ b/hw/net/rocker/rocker_fp.c | ||
186 | @@ -XXX,XX +XXX,XX @@ FpPort *fp_port_alloc(Rocker *r, char *sw_name, | ||
187 | { | ||
188 | FpPort *port = g_new0(FpPort, 1); | ||
189 | |||
190 | - if (!port) { | ||
191 | - return NULL; | ||
192 | - } | ||
193 | - | ||
194 | port->r = r; | ||
195 | port->index = index; | ||
196 | port->pport = index + 1; | ||
197 | diff --git a/hw/net/rocker/rocker_of_dpa.c b/hw/net/rocker/rocker_of_dpa.c | ||
198 | index XXXXXXX..XXXXXXX 100644 | ||
199 | --- a/hw/net/rocker/rocker_of_dpa.c | ||
200 | +++ b/hw/net/rocker/rocker_of_dpa.c | ||
201 | @@ -XXX,XX +XXX,XX @@ static OfDpaFlow *of_dpa_flow_alloc(uint64_t cookie) | ||
202 | int64_t now = qemu_clock_get_ms(QEMU_CLOCK_VIRTUAL) / 1000; | ||
203 | |||
204 | flow = g_new0(OfDpaFlow, 1); | ||
205 | - if (!flow) { | ||
206 | - return NULL; | ||
207 | - } | ||
208 | |||
209 | flow->cookie = cookie; | ||
210 | flow->mask.tbl_id = 0xffffffff; | ||
211 | @@ -XXX,XX +XXX,XX @@ static OfDpaGroup *of_dpa_group_alloc(uint32_t id) | ||
212 | { | ||
213 | OfDpaGroup *group = g_new0(OfDpaGroup, 1); | ||
214 | |||
215 | - if (!group) { | ||
216 | - return NULL; | ||
217 | - } | ||
218 | - | ||
219 | group->id = id; | ||
220 | |||
221 | return group; | ||
222 | @@ -XXX,XX +XXX,XX @@ static int of_dpa_cmd_flow_add(OfDpa *of_dpa, uint64_t cookie, | ||
223 | } | ||
224 | |||
225 | flow = of_dpa_flow_alloc(cookie); | ||
226 | - if (!flow) { | ||
227 | - return -ROCKER_ENOMEM; | ||
228 | - } | ||
229 | |||
230 | err = of_dpa_cmd_flow_add_mod(of_dpa, flow, flow_tlvs); | ||
231 | if (err) { | ||
232 | @@ -XXX,XX +XXX,XX @@ static int of_dpa_cmd_add_l2_flood(OfDpa *of_dpa, OfDpaGroup *group, | ||
233 | rocker_tlv_get_le16(group_tlvs[ROCKER_TLV_OF_DPA_GROUP_COUNT]); | ||
234 | |||
235 | tlvs = g_new0(RockerTlv *, group->l2_flood.group_count + 1); | ||
236 | - if (!tlvs) { | ||
237 | - return -ROCKER_ENOMEM; | ||
238 | - } | ||
239 | |||
240 | g_free(group->l2_flood.group_ids); | ||
241 | group->l2_flood.group_ids = | ||
242 | g_new0(uint32_t, group->l2_flood.group_count); | ||
243 | - if (!group->l2_flood.group_ids) { | ||
244 | - err = -ROCKER_ENOMEM; | ||
245 | - goto err_out; | ||
246 | - } | ||
247 | |||
248 | rocker_tlv_parse_nested(tlvs, group->l2_flood.group_count, | ||
249 | group_tlvs[ROCKER_TLV_OF_DPA_GROUP_IDS]); | ||
250 | @@ -XXX,XX +XXX,XX @@ static int of_dpa_cmd_group_add(OfDpa *of_dpa, uint32_t group_id, | ||
251 | } | ||
252 | |||
253 | group = of_dpa_group_alloc(group_id); | ||
254 | - if (!group) { | ||
255 | - return -ROCKER_ENOMEM; | ||
256 | - } | ||
257 | |||
258 | err = of_dpa_cmd_group_do(of_dpa, group_id, group, group_tlvs); | ||
259 | if (err) { | ||
260 | diff --git a/hw/net/rocker/rocker_world.c b/hw/net/rocker/rocker_world.c | ||
261 | index XXXXXXX..XXXXXXX 100644 | ||
262 | --- a/hw/net/rocker/rocker_world.c | ||
263 | +++ b/hw/net/rocker/rocker_world.c | ||
264 | @@ -XXX,XX +XXX,XX @@ World *world_alloc(Rocker *r, size_t sizeof_private, | ||
265 | { | ||
266 | World *w = g_malloc0(sizeof(World) + sizeof_private); | ||
267 | |||
268 | - if (w) { | ||
269 | - w->r = r; | ||
270 | - w->type = type; | ||
271 | - w->ops = ops; | ||
272 | - if (w->ops->init) { | ||
273 | - w->ops->init(w); | ||
274 | - } | ||
275 | + w->r = r; | ||
276 | + w->type = type; | ||
277 | + w->ops = ops; | ||
278 | + if (w->ops->init) { | ||
279 | + w->ops->init(w); | ||
280 | } | ||
281 | |||
282 | return w; | ||
283 | -- | ||
284 | 2.7.4 | ||
285 | |||
286 | diff view generated by jsdifflib |
1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | 1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> |
---|---|---|---|
2 | |||
3 | If colo-compare find one old packet,we can notify colo-frame | ||
4 | do checkpoint, no need continue find more old packet here. | ||
2 | 5 | ||
3 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | 6 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> |
4 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 7 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
5 | --- | 8 | --- |
6 | net/colo-compare.c | 59 ++++++++++++++++++++++++++++-------------------------- | 9 | net/colo-compare.c | 15 +++++++++++---- |
7 | 1 file changed, 31 insertions(+), 28 deletions(-) | 10 | 1 file changed, 11 insertions(+), 4 deletions(-) |
8 | 11 | ||
9 | diff --git a/net/colo-compare.c b/net/colo-compare.c | 12 | diff --git a/net/colo-compare.c b/net/colo-compare.c |
10 | index XXXXXXX..XXXXXXX 100644 | 13 | index XXXXXXX..XXXXXXX 100644 |
11 | --- a/net/colo-compare.c | 14 | --- a/net/colo-compare.c |
12 | +++ b/net/colo-compare.c | 15 | +++ b/net/colo-compare.c |
13 | @@ -XXX,XX +XXX,XX @@ | 16 | @@ -XXX,XX +XXX,XX @@ static int colo_old_packet_check_one(Packet *pkt, int64_t *check_time) |
14 | #define REGULAR_PACKET_CHECK_MS 3000 | 17 | } |
18 | } | ||
19 | |||
20 | -static void colo_old_packet_check_one_conn(void *opaque, | ||
21 | - void *user_data) | ||
22 | +static int colo_old_packet_check_one_conn(Connection *conn, | ||
23 | + void *user_data) | ||
24 | { | ||
25 | - Connection *conn = opaque; | ||
26 | GList *result = NULL; | ||
27 | int64_t check_time = REGULAR_PACKET_CHECK_MS; | ||
28 | |||
29 | @@ -XXX,XX +XXX,XX @@ static void colo_old_packet_check_one_conn(void *opaque, | ||
30 | if (result) { | ||
31 | /* do checkpoint will flush old packet */ | ||
32 | /* TODO: colo_notify_checkpoint();*/ | ||
33 | + return 0; | ||
34 | } | ||
35 | + | ||
36 | + return 1; | ||
37 | } | ||
15 | 38 | ||
16 | /* | 39 | /* |
17 | - + CompareState ++ | 40 | @@ -XXX,XX +XXX,XX @@ static void colo_old_packet_check(void *opaque) |
18 | - | | | 41 | { |
19 | - +---------------+ +---------------+ +---------------+ | 42 | CompareState *s = opaque; |
20 | - |conn list +--->conn +--------->conn | | 43 | |
21 | - +---------------+ +---------------+ +---------------+ | 44 | - g_queue_foreach(&s->conn_list, colo_old_packet_check_one_conn, NULL); |
22 | - | | | | | | | ||
23 | - +---------------+ +---v----+ +---v----+ +---v----+ +---v----+ | ||
24 | - |primary | |secondary |primary | |secondary | ||
25 | - |packet | |packet + |packet | |packet + | ||
26 | - +--------+ +--------+ +--------+ +--------+ | ||
27 | - | | | | | ||
28 | - +---v----+ +---v----+ +---v----+ +---v----+ | ||
29 | - |primary | |secondary |primary | |secondary | ||
30 | - |packet | |packet + |packet | |packet + | ||
31 | - +--------+ +--------+ +--------+ +--------+ | ||
32 | - | | | | | ||
33 | - +---v----+ +---v----+ +---v----+ +---v----+ | ||
34 | - |primary | |secondary |primary | |secondary | ||
35 | - |packet | |packet + |packet | |packet + | ||
36 | - +--------+ +--------+ +--------+ +--------+ | ||
37 | -*/ | ||
38 | + * + CompareState ++ | ||
39 | + * | | | ||
40 | + * +---------------+ +---------------+ +---------------+ | ||
41 | + * | conn list + - > conn + ------- > conn + -- > ...... | ||
42 | + * +---------------+ +---------------+ +---------------+ | ||
43 | + * | | | | | | | ||
44 | + * +---------------+ +---v----+ +---v----+ +---v----+ +---v----+ | ||
45 | + * |primary | |secondary |primary | |secondary | ||
46 | + * |packet | |packet + |packet | |packet + | ||
47 | + * +--------+ +--------+ +--------+ +--------+ | ||
48 | + * | | | | | ||
49 | + * +---v----+ +---v----+ +---v----+ +---v----+ | ||
50 | + * |primary | |secondary |primary | |secondary | ||
51 | + * |packet | |packet + |packet | |packet + | ||
52 | + * +--------+ +--------+ +--------+ +--------+ | ||
53 | + * | | | | | ||
54 | + * +---v----+ +---v----+ +---v----+ +---v----+ | ||
55 | + * |primary | |secondary |primary | |secondary | ||
56 | + * |packet | |packet + |packet | |packet + | ||
57 | + * +--------+ +--------+ +--------+ +--------+ | ||
58 | + */ | ||
59 | typedef struct CompareState { | ||
60 | Object parent; | ||
61 | |||
62 | @@ -XXX,XX +XXX,XX @@ typedef struct CompareState { | ||
63 | SocketReadState sec_rs; | ||
64 | bool vnet_hdr; | ||
65 | |||
66 | - /* connection list: the connections belonged to this NIC could be found | ||
67 | - * in this list. | ||
68 | - * element type: Connection | ||
69 | + /* | 45 | + /* |
70 | + * Record the connection that through the NIC | 46 | + * If we find one old packet, stop finding job and notify |
71 | + * Element type: Connection | 47 | + * COLO frame do checkpoint. |
72 | */ | 48 | + */ |
73 | GQueue conn_list; | 49 | + g_queue_find_custom(&s->conn_list, NULL, |
74 | - /* hashtable to save connection */ | 50 | + (GCompareFunc)colo_old_packet_check_one_conn); |
75 | + /* Record the connection without repetition */ | 51 | } |
76 | GHashTable *connection_track_table; | 52 | |
77 | - /* compare thread, a thread for each NIC */ | 53 | /* |
78 | + /* This thread just do packet compare job */ | ||
79 | QemuThread thread; | ||
80 | |||
81 | GMainContext *worker_context; | ||
82 | @@ -XXX,XX +XXX,XX @@ static int colo_old_packet_check_one_conn(Connection *conn, | ||
83 | (GCompareFunc)colo_old_packet_check_one); | ||
84 | |||
85 | if (result) { | ||
86 | - /* do checkpoint will flush old packet */ | ||
87 | - /* TODO: colo_notify_checkpoint();*/ | ||
88 | + /* Do checkpoint will flush old packet */ | ||
89 | + /* | ||
90 | + * TODO: Notify colo frame to do checkpoint. | ||
91 | + * colo_compare_inconsistent_notify(); | ||
92 | + */ | ||
93 | return 0; | ||
94 | } | ||
95 | |||
96 | -- | 54 | -- |
97 | 2.7.4 | 55 | 2.7.4 |
98 | 56 | ||
99 | 57 | diff view generated by jsdifflib |
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | 1 | From: Cédric Le Goater <clg@kaod.org> |
---|---|---|---|
2 | 2 | ||
3 | pci_rocker_init() leaks a World when the name more than 9 chars, | 3 | This adds comments on the Basic mode control and status registers bit |
4 | then return a negative value directly, doesn't make a correct | 4 | definitions. It also adds a couple of bits for 1000BASE-T and the |
5 | cleanup. So add a new goto label to fix it. | 5 | RealTek 8211E PHY for the FTGMAC100 model to use. |
6 | 6 | ||
7 | Cc: jasowang@redhat.com | 7 | Signed-off-by: Cédric Le Goater <clg@kaod.org> |
8 | Cc: jiri@resnulli.us | ||
9 | Cc: armbru@redhat.com | ||
10 | Cc: f4bug@amsat.org | ||
11 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
12 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
13 | Reviewed-by: Philippe Mathieu-Daudé <f4bug@amsat.org> | 8 | Reviewed-by: Philippe Mathieu-Daudé <f4bug@amsat.org> |
14 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 9 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
15 | --- | 10 | --- |
16 | hw/net/rocker/rocker.c | 4 +++- | 11 | include/hw/net/mii.h | 71 +++++++++++++++++++++++++++++++++++++++------------- |
17 | 1 file changed, 3 insertions(+), 1 deletion(-) | 12 | 1 file changed, 53 insertions(+), 18 deletions(-) |
18 | 13 | ||
19 | diff --git a/hw/net/rocker/rocker.c b/hw/net/rocker/rocker.c | 14 | diff --git a/include/hw/net/mii.h b/include/hw/net/mii.h |
20 | index XXXXXXX..XXXXXXX 100644 | 15 | index XXXXXXX..XXXXXXX 100644 |
21 | --- a/hw/net/rocker/rocker.c | 16 | --- a/include/hw/net/mii.h |
22 | +++ b/hw/net/rocker/rocker.c | 17 | +++ b/include/hw/net/mii.h |
23 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | 18 | @@ -XXX,XX +XXX,XX @@ |
24 | fprintf(stderr, | 19 | #define MII_H |
25 | "rocker: name too long; please shorten to at most %d chars\n", | 20 | |
26 | MAX_ROCKER_NAME_LEN); | 21 | /* PHY registers */ |
27 | - return -EINVAL; | 22 | -#define MII_BMCR 0 |
28 | + err = -EINVAL; | 23 | -#define MII_BMSR 1 |
29 | + goto err_name_too_long; | 24 | -#define MII_PHYID1 2 |
30 | } | 25 | -#define MII_PHYID2 3 |
31 | 26 | -#define MII_ANAR 4 | |
32 | if (memcmp(&r->fp_start_macaddr, &zero, sizeof(zero)) == 0) { | 27 | -#define MII_ANLPAR 5 |
33 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | 28 | -#define MII_ANER 6 |
34 | 29 | +#define MII_BMCR 0 /* Basic mode control register */ | |
35 | return 0; | 30 | +#define MII_BMSR 1 /* Basic mode status register */ |
36 | 31 | +#define MII_PHYID1 2 /* ID register 1 */ | |
37 | +err_name_too_long: | 32 | +#define MII_PHYID2 3 /* ID register 2 */ |
38 | err_duplicate: | 33 | +#define MII_ANAR 4 /* Autonegotiation advertisement */ |
39 | rocker_msix_uninit(r); | 34 | +#define MII_ANLPAR 5 /* Autonegotiation lnk partner abilities */ |
40 | err_msix_init: | 35 | +#define MII_ANER 6 /* Autonegotiation expansion */ |
36 | +#define MII_ANNP 7 /* Autonegotiation next page */ | ||
37 | +#define MII_ANLPRNP 8 /* Autonegotiation link partner rx next page */ | ||
38 | +#define MII_CTRL1000 9 /* 1000BASE-T control */ | ||
39 | +#define MII_STAT1000 10 /* 1000BASE-T status */ | ||
40 | +#define MII_MDDACR 13 /* MMD access control */ | ||
41 | +#define MII_MDDAADR 14 /* MMD access address data */ | ||
42 | +#define MII_EXTSTAT 15 /* Extended Status */ | ||
43 | #define MII_NSR 16 | ||
44 | #define MII_LBREMR 17 | ||
45 | #define MII_REC 18 | ||
46 | @@ -XXX,XX +XXX,XX @@ | ||
47 | /* PHY registers fields */ | ||
48 | #define MII_BMCR_RESET (1 << 15) | ||
49 | #define MII_BMCR_LOOPBACK (1 << 14) | ||
50 | -#define MII_BMCR_SPEED (1 << 13) | ||
51 | -#define MII_BMCR_AUTOEN (1 << 12) | ||
52 | -#define MII_BMCR_FD (1 << 8) | ||
53 | +#define MII_BMCR_SPEED100 (1 << 13) /* LSB of Speed (100) */ | ||
54 | +#define MII_BMCR_SPEED MII_BMCR_SPEED100 | ||
55 | +#define MII_BMCR_AUTOEN (1 << 12) /* Autonegotiation enable */ | ||
56 | +#define MII_BMCR_PDOWN (1 << 11) /* Enable low power state */ | ||
57 | +#define MII_BMCR_ISOLATE (1 << 10) /* Isolate data paths from MII */ | ||
58 | +#define MII_BMCR_ANRESTART (1 << 9) /* Auto negotiation restart */ | ||
59 | +#define MII_BMCR_FD (1 << 8) /* Set duplex mode */ | ||
60 | +#define MII_BMCR_CTST (1 << 7) /* Collision test */ | ||
61 | +#define MII_BMCR_SPEED1000 (1 << 6) /* MSB of Speed (1000) */ | ||
62 | |||
63 | -#define MII_BMSR_100TX_FD (1 << 14) | ||
64 | -#define MII_BMSR_100TX_HD (1 << 13) | ||
65 | -#define MII_BMSR_10T_FD (1 << 12) | ||
66 | -#define MII_BMSR_10T_HD (1 << 11) | ||
67 | -#define MII_BMSR_MFPS (1 << 6) | ||
68 | -#define MII_BMSR_AN_COMP (1 << 5) | ||
69 | -#define MII_BMSR_AUTONEG (1 << 3) | ||
70 | -#define MII_BMSR_LINK_ST (1 << 2) | ||
71 | +#define MII_BMSR_100TX_FD (1 << 14) /* Can do 100mbps, full-duplex */ | ||
72 | +#define MII_BMSR_100TX_HD (1 << 13) /* Can do 100mbps, half-duplex */ | ||
73 | +#define MII_BMSR_10T_FD (1 << 12) /* Can do 10mbps, full-duplex */ | ||
74 | +#define MII_BMSR_10T_HD (1 << 11) /* Can do 10mbps, half-duplex */ | ||
75 | +#define MII_BMSR_100T2_FD (1 << 10) /* Can do 100mbps T2, full-duplex */ | ||
76 | +#define MII_BMSR_100T2_HD (1 << 9) /* Can do 100mbps T2, half-duplex */ | ||
77 | +#define MII_BMSR_EXTSTAT (1 << 8) /* Extended status in register 15 */ | ||
78 | +#define MII_BMSR_MFPS (1 << 6) /* MII Frame Preamble Suppression */ | ||
79 | +#define MII_BMSR_AN_COMP (1 << 5) /* Auto-negotiation complete */ | ||
80 | +#define MII_BMSR_RFAULT (1 << 4) /* Remote fault */ | ||
81 | +#define MII_BMSR_AUTONEG (1 << 3) /* Able to do auto-negotiation */ | ||
82 | +#define MII_BMSR_LINK_ST (1 << 2) /* Link status */ | ||
83 | +#define MII_BMSR_JABBER (1 << 1) /* Jabber detected */ | ||
84 | +#define MII_BMSR_EXTCAP (1 << 0) /* Ext-reg capability */ | ||
85 | |||
86 | +#define MII_ANAR_PAUSE_ASYM (1 << 11) /* Try for asymetric pause */ | ||
87 | +#define MII_ANAR_PAUSE (1 << 10) /* Try for pause */ | ||
88 | #define MII_ANAR_TXFD (1 << 8) | ||
89 | #define MII_ANAR_TX (1 << 7) | ||
90 | #define MII_ANAR_10FD (1 << 6) | ||
91 | @@ -XXX,XX +XXX,XX @@ | ||
92 | #define MII_ANAR_CSMACD (1 << 0) | ||
93 | |||
94 | #define MII_ANLPAR_ACK (1 << 14) | ||
95 | +#define MII_ANLPAR_PAUSEASY (1 << 11) /* can pause asymmetrically */ | ||
96 | +#define MII_ANLPAR_PAUSE (1 << 10) /* can pause */ | ||
97 | #define MII_ANLPAR_TXFD (1 << 8) | ||
98 | #define MII_ANLPAR_TX (1 << 7) | ||
99 | #define MII_ANLPAR_10FD (1 << 6) | ||
100 | #define MII_ANLPAR_10 (1 << 5) | ||
101 | #define MII_ANLPAR_CSMACD (1 << 0) | ||
102 | |||
103 | +#define MII_ANER_NWAY (1 << 0) /* Can do N-way auto-nego */ | ||
104 | + | ||
105 | +#define MII_CTRL1000_FULL (1 << 9) /* 1000BASE-T full duplex */ | ||
106 | +#define MII_CTRL1000_HALF (1 << 8) /* 1000BASE-T half duplex */ | ||
107 | + | ||
108 | +#define MII_STAT1000_FULL (1 << 11) /* 1000BASE-T full duplex */ | ||
109 | +#define MII_STAT1000_HALF (1 << 10) /* 1000BASE-T half duplex */ | ||
110 | + | ||
111 | /* List of vendor identifiers */ | ||
112 | /* RealTek 8201 */ | ||
113 | #define RTL8201CP_PHYID1 0x0000 | ||
114 | #define RTL8201CP_PHYID2 0x8201 | ||
115 | |||
116 | +/* RealTek 8211E */ | ||
117 | +#define RTL8211E_PHYID1 0x001c | ||
118 | +#define RTL8211E_PHYID2 0xc915 | ||
119 | + | ||
120 | /* National Semiconductor DP83848 */ | ||
121 | #define DP83848_PHYID1 0x2000 | ||
122 | #define DP83848_PHYID2 0x5c90 | ||
41 | -- | 123 | -- |
42 | 2.7.4 | 124 | 2.7.4 |
43 | 125 | ||
44 | 126 | diff view generated by jsdifflib |
1 | From: Wang Yong <wang.yong155@zte.com.cn> | 1 | From: Cédric Le Goater <clg@kaod.org> |
---|---|---|---|
2 | 2 | ||
3 | Update colo-proxy.txt,add IOThread configuration. | 3 | The FTGMAC100 device is an Ethernet controller with DMA function that |
4 | Later we have to configure IOThread,if not COLO can not work. | 4 | can be found on Aspeed SoCs (which include NCSI). |
5 | 5 | ||
6 | Reviewed-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | 6 | It is fully compliant with IEEE 802.3 specification for 10/100 Mbps |
7 | Signed-off-by: Wang Yong <wang.yong155@zte.com.cn> | 7 | Ethernet and IEEE 802.3z specification for 1000 Mbps Ethernet and |
8 | Signed-off-by: Wang Guang <wang.guang55@zte.com.cn> | 8 | includes Reduced Media Independent Interface (RMII) and Reduced |
9 | Gigabit Media Independent Interface (RGMII) interfaces. It adopts an | ||
10 | AHB bus interface and integrates a link list DMA engine with direct | ||
11 | M-Bus accesses for transmitting and receiving packets. It has | ||
12 | independent TX/RX fifos, supports half and full duplex (1000 Mbps mode | ||
13 | only supports full duplex), flow control for full duplex and | ||
14 | backpressure for half duplex. | ||
15 | |||
16 | The FTGMAC100 also implements IP, TCP, UDP checksum offloads and | ||
17 | supports IEEE 802.1Q VLAN tag insertion and removal. It offers | ||
18 | high-priority transmit queue for QoS and CoS applications | ||
19 | |||
20 | This model is backed with a RealTek 8211E PHY which is the chip found | ||
21 | on the AST2500 EVB. It is complete enough to satisfy two different | ||
22 | Linux drivers and a U-Boot driver. Not supported features are : | ||
23 | |||
24 | - IEEE 802.1Q VLAN | ||
25 | - High Priority Transmit Queue | ||
26 | - Wake-On-LAN functions | ||
27 | |||
28 | The code is based on the Coldfire Fast Ethernet Controller model. | ||
29 | |||
30 | Signed-off-by: Cédric Le Goater <clg@kaod.org> | ||
9 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 31 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
10 | --- | 32 | --- |
11 | docs/colo-proxy.txt | 3 ++- | 33 | default-configs/arm-softmmu.mak | 1 + |
12 | 1 file changed, 2 insertions(+), 1 deletion(-) | 34 | hw/net/Makefile.objs | 1 + |
35 | hw/net/ftgmac100.c | 1003 +++++++++++++++++++++++++++++++++++++++ | ||
36 | include/hw/net/ftgmac100.h | 60 +++ | ||
37 | 4 files changed, 1065 insertions(+) | ||
38 | create mode 100644 hw/net/ftgmac100.c | ||
39 | create mode 100644 include/hw/net/ftgmac100.h | ||
13 | 40 | ||
14 | diff --git a/docs/colo-proxy.txt b/docs/colo-proxy.txt | 41 | diff --git a/default-configs/arm-softmmu.mak b/default-configs/arm-softmmu.mak |
15 | index XXXXXXX..XXXXXXX 100644 | 42 | index XXXXXXX..XXXXXXX 100644 |
16 | --- a/docs/colo-proxy.txt | 43 | --- a/default-configs/arm-softmmu.mak |
17 | +++ b/docs/colo-proxy.txt | 44 | +++ b/default-configs/arm-softmmu.mak |
18 | @@ -XXX,XX +XXX,XX @@ Primary(ip:3.3.3.3): | 45 | @@ -XXX,XX +XXX,XX @@ CONFIG_LAN9118=y |
19 | -chardev socket,id=compare0-0,host=3.3.3.3,port=9001 | 46 | CONFIG_SMC91C111=y |
20 | -chardev socket,id=compare_out,host=3.3.3.3,port=9005,server,nowait | 47 | CONFIG_ALLWINNER_EMAC=y |
21 | -chardev socket,id=compare_out0,host=3.3.3.3,port=9005 | 48 | CONFIG_IMX_FEC=y |
22 | +-object iothread,id=iothread1 | 49 | +CONFIG_FTGMAC100=y |
23 | -object filter-mirror,id=m0,netdev=hn0,queue=tx,outdev=mirror0 | 50 | CONFIG_DS1338=y |
24 | -object filter-redirector,netdev=hn0,id=redire0,queue=rx,indev=compare_out | 51 | CONFIG_PFLASH_CFI01=y |
25 | -object filter-redirector,netdev=hn0,id=redire1,queue=rx,outdev=compare0 | 52 | CONFIG_PFLASH_CFI02=y |
26 | --object colo-compare,id=comp0,primary_in=compare0-0,secondary_in=compare1,outdev=compare_out0 | 53 | diff --git a/hw/net/Makefile.objs b/hw/net/Makefile.objs |
27 | +-object colo-compare,id=comp0,primary_in=compare0-0,secondary_in=compare1,outdev=compare_out0,iothread=iothread1 | 54 | index XXXXXXX..XXXXXXX 100644 |
28 | 55 | --- a/hw/net/Makefile.objs | |
29 | Secondary(ip:3.3.3.8): | 56 | +++ b/hw/net/Makefile.objs |
30 | -netdev tap,id=hn0,vhost=off,script=/etc/qemu-ifup,down script=/etc/qemu-ifdown | 57 | @@ -XXX,XX +XXX,XX @@ common-obj-$(CONFIG_IMX_FEC) += imx_fec.o |
58 | common-obj-$(CONFIG_CADENCE) += cadence_gem.o | ||
59 | common-obj-$(CONFIG_STELLARIS_ENET) += stellaris_enet.o | ||
60 | common-obj-$(CONFIG_LANCE) += lance.o | ||
61 | +common-obj-$(CONFIG_FTGMAC100) += ftgmac100.o | ||
62 | |||
63 | obj-$(CONFIG_ETRAXFS) += etraxfs_eth.o | ||
64 | obj-$(CONFIG_COLDFIRE) += mcf_fec.o | ||
65 | diff --git a/hw/net/ftgmac100.c b/hw/net/ftgmac100.c | ||
66 | new file mode 100644 | ||
67 | index XXXXXXX..XXXXXXX | ||
68 | --- /dev/null | ||
69 | +++ b/hw/net/ftgmac100.c | ||
70 | @@ -XXX,XX +XXX,XX @@ | ||
71 | +/* | ||
72 | + * Faraday FTGMAC100 Gigabit Ethernet | ||
73 | + * | ||
74 | + * Copyright (C) 2016-2017, IBM Corporation. | ||
75 | + * | ||
76 | + * Based on Coldfire Fast Ethernet Controller emulation. | ||
77 | + * | ||
78 | + * Copyright (c) 2007 CodeSourcery. | ||
79 | + * | ||
80 | + * This code is licensed under the GPL version 2 or later. See the | ||
81 | + * COPYING file in the top-level directory. | ||
82 | + */ | ||
83 | + | ||
84 | +#include "qemu/osdep.h" | ||
85 | +#include "hw/net/ftgmac100.h" | ||
86 | +#include "sysemu/dma.h" | ||
87 | +#include "qemu/log.h" | ||
88 | +#include "net/checksum.h" | ||
89 | +#include "net/eth.h" | ||
90 | +#include "hw/net/mii.h" | ||
91 | + | ||
92 | +/* For crc32 */ | ||
93 | +#include <zlib.h> | ||
94 | + | ||
95 | +/* | ||
96 | + * FTGMAC100 registers | ||
97 | + */ | ||
98 | +#define FTGMAC100_ISR 0x00 | ||
99 | +#define FTGMAC100_IER 0x04 | ||
100 | +#define FTGMAC100_MAC_MADR 0x08 | ||
101 | +#define FTGMAC100_MAC_LADR 0x0c | ||
102 | +#define FTGMAC100_MATH0 0x10 | ||
103 | +#define FTGMAC100_MATH1 0x14 | ||
104 | +#define FTGMAC100_NPTXPD 0x18 | ||
105 | +#define FTGMAC100_RXPD 0x1C | ||
106 | +#define FTGMAC100_NPTXR_BADR 0x20 | ||
107 | +#define FTGMAC100_RXR_BADR 0x24 | ||
108 | +#define FTGMAC100_HPTXPD 0x28 | ||
109 | +#define FTGMAC100_HPTXR_BADR 0x2c | ||
110 | +#define FTGMAC100_ITC 0x30 | ||
111 | +#define FTGMAC100_APTC 0x34 | ||
112 | +#define FTGMAC100_DBLAC 0x38 | ||
113 | +#define FTGMAC100_REVR 0x40 | ||
114 | +#define FTGMAC100_FEAR1 0x44 | ||
115 | +#define FTGMAC100_RBSR 0x4c | ||
116 | +#define FTGMAC100_TPAFCR 0x48 | ||
117 | + | ||
118 | +#define FTGMAC100_MACCR 0x50 | ||
119 | +#define FTGMAC100_MACSR 0x54 | ||
120 | +#define FTGMAC100_PHYCR 0x60 | ||
121 | +#define FTGMAC100_PHYDATA 0x64 | ||
122 | +#define FTGMAC100_FCR 0x68 | ||
123 | + | ||
124 | +/* | ||
125 | + * Interrupt status register & interrupt enable register | ||
126 | + */ | ||
127 | +#define FTGMAC100_INT_RPKT_BUF (1 << 0) | ||
128 | +#define FTGMAC100_INT_RPKT_FIFO (1 << 1) | ||
129 | +#define FTGMAC100_INT_NO_RXBUF (1 << 2) | ||
130 | +#define FTGMAC100_INT_RPKT_LOST (1 << 3) | ||
131 | +#define FTGMAC100_INT_XPKT_ETH (1 << 4) | ||
132 | +#define FTGMAC100_INT_XPKT_FIFO (1 << 5) | ||
133 | +#define FTGMAC100_INT_NO_NPTXBUF (1 << 6) | ||
134 | +#define FTGMAC100_INT_XPKT_LOST (1 << 7) | ||
135 | +#define FTGMAC100_INT_AHB_ERR (1 << 8) | ||
136 | +#define FTGMAC100_INT_PHYSTS_CHG (1 << 9) | ||
137 | +#define FTGMAC100_INT_NO_HPTXBUF (1 << 10) | ||
138 | + | ||
139 | +/* | ||
140 | + * Automatic polling timer control register | ||
141 | + */ | ||
142 | +#define FTGMAC100_APTC_RXPOLL_CNT(x) ((x) & 0xf) | ||
143 | +#define FTGMAC100_APTC_RXPOLL_TIME_SEL (1 << 4) | ||
144 | +#define FTGMAC100_APTC_TXPOLL_CNT(x) (((x) >> 8) & 0xf) | ||
145 | +#define FTGMAC100_APTC_TXPOLL_TIME_SEL (1 << 12) | ||
146 | + | ||
147 | +/* | ||
148 | + * PHY control register | ||
149 | + */ | ||
150 | +#define FTGMAC100_PHYCR_MIIRD (1 << 26) | ||
151 | +#define FTGMAC100_PHYCR_MIIWR (1 << 27) | ||
152 | + | ||
153 | +#define FTGMAC100_PHYCR_DEV(x) (((x) >> 16) & 0x1f) | ||
154 | +#define FTGMAC100_PHYCR_REG(x) (((x) >> 21) & 0x1f) | ||
155 | + | ||
156 | +/* | ||
157 | + * PHY data register | ||
158 | + */ | ||
159 | +#define FTGMAC100_PHYDATA_MIIWDATA(x) ((x) & 0xffff) | ||
160 | +#define FTGMAC100_PHYDATA_MIIRDATA(x) (((x) >> 16) & 0xffff) | ||
161 | + | ||
162 | +/* | ||
163 | + * Feature Register | ||
164 | + */ | ||
165 | +#define FTGMAC100_REVR_NEW_MDIO_INTERFACE (1 << 31) | ||
166 | + | ||
167 | +/* | ||
168 | + * MAC control register | ||
169 | + */ | ||
170 | +#define FTGMAC100_MACCR_TXDMA_EN (1 << 0) | ||
171 | +#define FTGMAC100_MACCR_RXDMA_EN (1 << 1) | ||
172 | +#define FTGMAC100_MACCR_TXMAC_EN (1 << 2) | ||
173 | +#define FTGMAC100_MACCR_RXMAC_EN (1 << 3) | ||
174 | +#define FTGMAC100_MACCR_RM_VLAN (1 << 4) | ||
175 | +#define FTGMAC100_MACCR_HPTXR_EN (1 << 5) | ||
176 | +#define FTGMAC100_MACCR_LOOP_EN (1 << 6) | ||
177 | +#define FTGMAC100_MACCR_ENRX_IN_HALFTX (1 << 7) | ||
178 | +#define FTGMAC100_MACCR_FULLDUP (1 << 8) | ||
179 | +#define FTGMAC100_MACCR_GIGA_MODE (1 << 9) | ||
180 | +#define FTGMAC100_MACCR_CRC_APD (1 << 10) /* not needed */ | ||
181 | +#define FTGMAC100_MACCR_RX_RUNT (1 << 12) | ||
182 | +#define FTGMAC100_MACCR_JUMBO_LF (1 << 13) | ||
183 | +#define FTGMAC100_MACCR_RX_ALL (1 << 14) | ||
184 | +#define FTGMAC100_MACCR_HT_MULTI_EN (1 << 15) | ||
185 | +#define FTGMAC100_MACCR_RX_MULTIPKT (1 << 16) | ||
186 | +#define FTGMAC100_MACCR_RX_BROADPKT (1 << 17) | ||
187 | +#define FTGMAC100_MACCR_DISCARD_CRCERR (1 << 18) | ||
188 | +#define FTGMAC100_MACCR_FAST_MODE (1 << 19) | ||
189 | +#define FTGMAC100_MACCR_SW_RST (1 << 31) | ||
190 | + | ||
191 | +/* | ||
192 | + * Transmit descriptor | ||
193 | + */ | ||
194 | +#define FTGMAC100_TXDES0_TXBUF_SIZE(x) ((x) & 0x3fff) | ||
195 | +#define FTGMAC100_TXDES0_EDOTR (1 << 15) | ||
196 | +#define FTGMAC100_TXDES0_CRC_ERR (1 << 19) | ||
197 | +#define FTGMAC100_TXDES0_LTS (1 << 28) | ||
198 | +#define FTGMAC100_TXDES0_FTS (1 << 29) | ||
199 | +#define FTGMAC100_TXDES0_TXDMA_OWN (1 << 31) | ||
200 | + | ||
201 | +#define FTGMAC100_TXDES1_VLANTAG_CI(x) ((x) & 0xffff) | ||
202 | +#define FTGMAC100_TXDES1_INS_VLANTAG (1 << 16) | ||
203 | +#define FTGMAC100_TXDES1_TCP_CHKSUM (1 << 17) | ||
204 | +#define FTGMAC100_TXDES1_UDP_CHKSUM (1 << 18) | ||
205 | +#define FTGMAC100_TXDES1_IP_CHKSUM (1 << 19) | ||
206 | +#define FTGMAC100_TXDES1_LLC (1 << 22) | ||
207 | +#define FTGMAC100_TXDES1_TX2FIC (1 << 30) | ||
208 | +#define FTGMAC100_TXDES1_TXIC (1 << 31) | ||
209 | + | ||
210 | +/* | ||
211 | + * Receive descriptor | ||
212 | + */ | ||
213 | +#define FTGMAC100_RXDES0_VDBC 0x3fff | ||
214 | +#define FTGMAC100_RXDES0_EDORR (1 << 15) | ||
215 | +#define FTGMAC100_RXDES0_MULTICAST (1 << 16) | ||
216 | +#define FTGMAC100_RXDES0_BROADCAST (1 << 17) | ||
217 | +#define FTGMAC100_RXDES0_RX_ERR (1 << 18) | ||
218 | +#define FTGMAC100_RXDES0_CRC_ERR (1 << 19) | ||
219 | +#define FTGMAC100_RXDES0_FTL (1 << 20) | ||
220 | +#define FTGMAC100_RXDES0_RUNT (1 << 21) | ||
221 | +#define FTGMAC100_RXDES0_RX_ODD_NB (1 << 22) | ||
222 | +#define FTGMAC100_RXDES0_FIFO_FULL (1 << 23) | ||
223 | +#define FTGMAC100_RXDES0_PAUSE_OPCODE (1 << 24) | ||
224 | +#define FTGMAC100_RXDES0_PAUSE_FRAME (1 << 25) | ||
225 | +#define FTGMAC100_RXDES0_LRS (1 << 28) | ||
226 | +#define FTGMAC100_RXDES0_FRS (1 << 29) | ||
227 | +#define FTGMAC100_RXDES0_RXPKT_RDY (1 << 31) | ||
228 | + | ||
229 | +#define FTGMAC100_RXDES1_VLANTAG_CI 0xffff | ||
230 | +#define FTGMAC100_RXDES1_PROT_MASK (0x3 << 20) | ||
231 | +#define FTGMAC100_RXDES1_PROT_NONIP (0x0 << 20) | ||
232 | +#define FTGMAC100_RXDES1_PROT_IP (0x1 << 20) | ||
233 | +#define FTGMAC100_RXDES1_PROT_TCPIP (0x2 << 20) | ||
234 | +#define FTGMAC100_RXDES1_PROT_UDPIP (0x3 << 20) | ||
235 | +#define FTGMAC100_RXDES1_LLC (1 << 22) | ||
236 | +#define FTGMAC100_RXDES1_DF (1 << 23) | ||
237 | +#define FTGMAC100_RXDES1_VLANTAG_AVAIL (1 << 24) | ||
238 | +#define FTGMAC100_RXDES1_TCP_CHKSUM_ERR (1 << 25) | ||
239 | +#define FTGMAC100_RXDES1_UDP_CHKSUM_ERR (1 << 26) | ||
240 | +#define FTGMAC100_RXDES1_IP_CHKSUM_ERR (1 << 27) | ||
241 | + | ||
242 | +/* | ||
243 | + * Receive and transmit Buffer Descriptor | ||
244 | + */ | ||
245 | +typedef struct { | ||
246 | + uint32_t des0; | ||
247 | + uint32_t des1; | ||
248 | + uint32_t des2; /* not used by HW */ | ||
249 | + uint32_t des3; | ||
250 | +} FTGMAC100Desc; | ||
251 | + | ||
252 | +/* | ||
253 | + * Specific RTL8211E MII Registers | ||
254 | + */ | ||
255 | +#define RTL8211E_MII_PHYCR 16 /* PHY Specific Control */ | ||
256 | +#define RTL8211E_MII_PHYSR 17 /* PHY Specific Status */ | ||
257 | +#define RTL8211E_MII_INER 18 /* Interrupt Enable */ | ||
258 | +#define RTL8211E_MII_INSR 19 /* Interrupt Status */ | ||
259 | +#define RTL8211E_MII_RXERC 24 /* Receive Error Counter */ | ||
260 | +#define RTL8211E_MII_LDPSR 27 /* Link Down Power Saving */ | ||
261 | +#define RTL8211E_MII_EPAGSR 30 /* Extension Page Select */ | ||
262 | +#define RTL8211E_MII_PAGSEL 31 /* Page Select */ | ||
263 | + | ||
264 | +/* | ||
265 | + * RTL8211E Interrupt Status | ||
266 | + */ | ||
267 | +#define PHY_INT_AUTONEG_ERROR (1 << 15) | ||
268 | +#define PHY_INT_PAGE_RECV (1 << 12) | ||
269 | +#define PHY_INT_AUTONEG_COMPLETE (1 << 11) | ||
270 | +#define PHY_INT_LINK_STATUS (1 << 10) | ||
271 | +#define PHY_INT_ERROR (1 << 9) | ||
272 | +#define PHY_INT_DOWN (1 << 8) | ||
273 | +#define PHY_INT_JABBER (1 << 0) | ||
274 | + | ||
275 | +/* | ||
276 | + * Max frame size for the receiving buffer | ||
277 | + */ | ||
278 | +#define FTGMAC100_MAX_FRAME_SIZE 10240 | ||
279 | + | ||
280 | +/* Limits depending on the type of the frame | ||
281 | + * | ||
282 | + * 9216 for Jumbo frames (+ 4 for VLAN) | ||
283 | + * 1518 for other frames (+ 4 for VLAN) | ||
284 | + */ | ||
285 | +static int ftgmac100_max_frame_size(FTGMAC100State *s) | ||
286 | +{ | ||
287 | + return (s->maccr & FTGMAC100_MACCR_JUMBO_LF ? 9216 : 1518) + 4; | ||
288 | +} | ||
289 | + | ||
290 | +static void ftgmac100_update_irq(FTGMAC100State *s) | ||
291 | +{ | ||
292 | + qemu_set_irq(s->irq, s->isr & s->ier); | ||
293 | +} | ||
294 | + | ||
295 | +/* | ||
296 | + * The MII phy could raise a GPIO to the processor which in turn | ||
297 | + * could be handled as an interrpt by the OS. | ||
298 | + * For now we don't handle any GPIO/interrupt line, so the OS will | ||
299 | + * have to poll for the PHY status. | ||
300 | + */ | ||
301 | +static void phy_update_irq(FTGMAC100State *s) | ||
302 | +{ | ||
303 | + ftgmac100_update_irq(s); | ||
304 | +} | ||
305 | + | ||
306 | +static void phy_update_link(FTGMAC100State *s) | ||
307 | +{ | ||
308 | + /* Autonegotiation status mirrors link status. */ | ||
309 | + if (qemu_get_queue(s->nic)->link_down) { | ||
310 | + s->phy_status &= ~(MII_BMSR_LINK_ST | MII_BMSR_AN_COMP); | ||
311 | + s->phy_int |= PHY_INT_DOWN; | ||
312 | + } else { | ||
313 | + s->phy_status |= (MII_BMSR_LINK_ST | MII_BMSR_AN_COMP); | ||
314 | + s->phy_int |= PHY_INT_AUTONEG_COMPLETE; | ||
315 | + } | ||
316 | + phy_update_irq(s); | ||
317 | +} | ||
318 | + | ||
319 | +static void ftgmac100_set_link(NetClientState *nc) | ||
320 | +{ | ||
321 | + phy_update_link(FTGMAC100(qemu_get_nic_opaque(nc))); | ||
322 | +} | ||
323 | + | ||
324 | +static void phy_reset(FTGMAC100State *s) | ||
325 | +{ | ||
326 | + s->phy_status = (MII_BMSR_100TX_FD | MII_BMSR_100TX_HD | MII_BMSR_10T_FD | | ||
327 | + MII_BMSR_10T_HD | MII_BMSR_EXTSTAT | MII_BMSR_MFPS | | ||
328 | + MII_BMSR_AN_COMP | MII_BMSR_AUTONEG | MII_BMSR_LINK_ST | | ||
329 | + MII_BMSR_EXTCAP); | ||
330 | + s->phy_control = (MII_BMCR_AUTOEN | MII_BMCR_FD | MII_BMCR_SPEED1000); | ||
331 | + s->phy_advertise = (MII_ANAR_PAUSE_ASYM | MII_ANAR_PAUSE | MII_ANAR_TXFD | | ||
332 | + MII_ANAR_TX | MII_ANAR_10FD | MII_ANAR_10 | | ||
333 | + MII_ANAR_CSMACD); | ||
334 | + s->phy_int_mask = 0; | ||
335 | + s->phy_int = 0; | ||
336 | +} | ||
337 | + | ||
338 | +static uint32_t do_phy_read(FTGMAC100State *s, int reg) | ||
339 | +{ | ||
340 | + uint32_t val; | ||
341 | + | ||
342 | + switch (reg) { | ||
343 | + case MII_BMCR: /* Basic Control */ | ||
344 | + val = s->phy_control; | ||
345 | + break; | ||
346 | + case MII_BMSR: /* Basic Status */ | ||
347 | + val = s->phy_status; | ||
348 | + break; | ||
349 | + case MII_PHYID1: /* ID1 */ | ||
350 | + val = RTL8211E_PHYID1; | ||
351 | + break; | ||
352 | + case MII_PHYID2: /* ID2 */ | ||
353 | + val = RTL8211E_PHYID2; | ||
354 | + break; | ||
355 | + case MII_ANAR: /* Auto-neg advertisement */ | ||
356 | + val = s->phy_advertise; | ||
357 | + break; | ||
358 | + case MII_ANLPAR: /* Auto-neg Link Partner Ability */ | ||
359 | + val = (MII_ANLPAR_ACK | MII_ANLPAR_PAUSE | MII_ANLPAR_TXFD | | ||
360 | + MII_ANLPAR_TX | MII_ANLPAR_10FD | MII_ANLPAR_10 | | ||
361 | + MII_ANLPAR_CSMACD); | ||
362 | + break; | ||
363 | + case MII_ANER: /* Auto-neg Expansion */ | ||
364 | + val = MII_ANER_NWAY; | ||
365 | + break; | ||
366 | + case MII_CTRL1000: /* 1000BASE-T control */ | ||
367 | + val = (MII_CTRL1000_HALF | MII_CTRL1000_FULL); | ||
368 | + break; | ||
369 | + case MII_STAT1000: /* 1000BASE-T status */ | ||
370 | + val = MII_STAT1000_FULL; | ||
371 | + break; | ||
372 | + case RTL8211E_MII_INSR: /* Interrupt status. */ | ||
373 | + val = s->phy_int; | ||
374 | + s->phy_int = 0; | ||
375 | + phy_update_irq(s); | ||
376 | + break; | ||
377 | + case RTL8211E_MII_INER: /* Interrupt enable */ | ||
378 | + val = s->phy_int_mask; | ||
379 | + break; | ||
380 | + case RTL8211E_MII_PHYCR: | ||
381 | + case RTL8211E_MII_PHYSR: | ||
382 | + case RTL8211E_MII_RXERC: | ||
383 | + case RTL8211E_MII_LDPSR: | ||
384 | + case RTL8211E_MII_EPAGSR: | ||
385 | + case RTL8211E_MII_PAGSEL: | ||
386 | + qemu_log_mask(LOG_UNIMP, "%s: reg %d not implemented\n", | ||
387 | + __func__, reg); | ||
388 | + val = 0; | ||
389 | + break; | ||
390 | + default: | ||
391 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: Bad address at offset %d\n", | ||
392 | + __func__, reg); | ||
393 | + val = 0; | ||
394 | + break; | ||
395 | + } | ||
396 | + | ||
397 | + return val; | ||
398 | +} | ||
399 | + | ||
400 | +#define MII_BMCR_MASK (MII_BMCR_LOOPBACK | MII_BMCR_SPEED100 | \ | ||
401 | + MII_BMCR_SPEED | MII_BMCR_AUTOEN | MII_BMCR_PDOWN | \ | ||
402 | + MII_BMCR_FD | MII_BMCR_CTST) | ||
403 | +#define MII_ANAR_MASK 0x2d7f | ||
404 | + | ||
405 | +static void do_phy_write(FTGMAC100State *s, int reg, uint32_t val) | ||
406 | +{ | ||
407 | + switch (reg) { | ||
408 | + case MII_BMCR: /* Basic Control */ | ||
409 | + if (val & MII_BMCR_RESET) { | ||
410 | + phy_reset(s); | ||
411 | + } else { | ||
412 | + s->phy_control = val & MII_BMCR_MASK; | ||
413 | + /* Complete autonegotiation immediately. */ | ||
414 | + if (val & MII_BMCR_AUTOEN) { | ||
415 | + s->phy_status |= MII_BMSR_AN_COMP; | ||
416 | + } | ||
417 | + } | ||
418 | + break; | ||
419 | + case MII_ANAR: /* Auto-neg advertisement */ | ||
420 | + s->phy_advertise = (val & MII_ANAR_MASK) | MII_ANAR_TX; | ||
421 | + break; | ||
422 | + case RTL8211E_MII_INER: /* Interrupt enable */ | ||
423 | + s->phy_int_mask = val & 0xff; | ||
424 | + phy_update_irq(s); | ||
425 | + break; | ||
426 | + case RTL8211E_MII_PHYCR: | ||
427 | + case RTL8211E_MII_PHYSR: | ||
428 | + case RTL8211E_MII_RXERC: | ||
429 | + case RTL8211E_MII_LDPSR: | ||
430 | + case RTL8211E_MII_EPAGSR: | ||
431 | + case RTL8211E_MII_PAGSEL: | ||
432 | + qemu_log_mask(LOG_UNIMP, "%s: reg %d not implemented\n", | ||
433 | + __func__, reg); | ||
434 | + break; | ||
435 | + default: | ||
436 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: Bad address at offset %d\n", | ||
437 | + __func__, reg); | ||
438 | + break; | ||
439 | + } | ||
440 | +} | ||
441 | + | ||
442 | +static int ftgmac100_read_bd(FTGMAC100Desc *bd, dma_addr_t addr) | ||
443 | +{ | ||
444 | + if (dma_memory_read(&address_space_memory, addr, bd, sizeof(*bd))) { | ||
445 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: failed to read descriptor @ 0x%" | ||
446 | + HWADDR_PRIx "\n", __func__, addr); | ||
447 | + return -1; | ||
448 | + } | ||
449 | + bd->des0 = le32_to_cpu(bd->des0); | ||
450 | + bd->des1 = le32_to_cpu(bd->des1); | ||
451 | + bd->des2 = le32_to_cpu(bd->des2); | ||
452 | + bd->des3 = le32_to_cpu(bd->des3); | ||
453 | + return 0; | ||
454 | +} | ||
455 | + | ||
456 | +static int ftgmac100_write_bd(FTGMAC100Desc *bd, dma_addr_t addr) | ||
457 | +{ | ||
458 | + FTGMAC100Desc lebd; | ||
459 | + | ||
460 | + lebd.des0 = cpu_to_le32(bd->des0); | ||
461 | + lebd.des1 = cpu_to_le32(bd->des1); | ||
462 | + lebd.des2 = cpu_to_le32(bd->des2); | ||
463 | + lebd.des3 = cpu_to_le32(bd->des3); | ||
464 | + if (dma_memory_write(&address_space_memory, addr, &lebd, sizeof(lebd))) { | ||
465 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: failed to write descriptor @ 0x%" | ||
466 | + HWADDR_PRIx "\n", __func__, addr); | ||
467 | + return -1; | ||
468 | + } | ||
469 | + return 0; | ||
470 | +} | ||
471 | + | ||
472 | +static void ftgmac100_do_tx(FTGMAC100State *s, uint32_t tx_ring, | ||
473 | + uint32_t tx_descriptor) | ||
474 | +{ | ||
475 | + int frame_size = 0; | ||
476 | + uint8_t *ptr = s->frame; | ||
477 | + uint32_t addr = tx_descriptor; | ||
478 | + uint32_t flags = 0; | ||
479 | + int max_frame_size = ftgmac100_max_frame_size(s); | ||
480 | + | ||
481 | + while (1) { | ||
482 | + FTGMAC100Desc bd; | ||
483 | + int len; | ||
484 | + | ||
485 | + if (ftgmac100_read_bd(&bd, addr) || | ||
486 | + ((bd.des0 & FTGMAC100_TXDES0_TXDMA_OWN) == 0)) { | ||
487 | + /* Run out of descriptors to transmit. */ | ||
488 | + s->isr |= FTGMAC100_INT_NO_NPTXBUF; | ||
489 | + break; | ||
490 | + } | ||
491 | + | ||
492 | + /* record transmit flags as they are valid only on the first | ||
493 | + * segment */ | ||
494 | + if (bd.des0 & FTGMAC100_TXDES0_FTS) { | ||
495 | + flags = bd.des1; | ||
496 | + } | ||
497 | + | ||
498 | + len = bd.des0 & 0x3FFF; | ||
499 | + if (frame_size + len > max_frame_size) { | ||
500 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: frame too big : %d bytes\n", | ||
501 | + __func__, len); | ||
502 | + len = max_frame_size - frame_size; | ||
503 | + } | ||
504 | + | ||
505 | + if (dma_memory_read(&address_space_memory, bd.des3, ptr, len)) { | ||
506 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: failed to read packet @ 0x%x\n", | ||
507 | + __func__, bd.des3); | ||
508 | + s->isr |= FTGMAC100_INT_NO_NPTXBUF; | ||
509 | + break; | ||
510 | + } | ||
511 | + | ||
512 | + ptr += len; | ||
513 | + frame_size += len; | ||
514 | + if (bd.des0 & FTGMAC100_TXDES0_LTS) { | ||
515 | + if (flags & FTGMAC100_TXDES1_IP_CHKSUM) { | ||
516 | + net_checksum_calculate(s->frame, frame_size); | ||
517 | + } | ||
518 | + /* Last buffer in frame. */ | ||
519 | + qemu_send_packet(qemu_get_queue(s->nic), s->frame, frame_size); | ||
520 | + ptr = s->frame; | ||
521 | + frame_size = 0; | ||
522 | + if (flags & FTGMAC100_TXDES1_TXIC) { | ||
523 | + s->isr |= FTGMAC100_INT_XPKT_ETH; | ||
524 | + } | ||
525 | + } | ||
526 | + | ||
527 | + if (flags & FTGMAC100_TXDES1_TX2FIC) { | ||
528 | + s->isr |= FTGMAC100_INT_XPKT_FIFO; | ||
529 | + } | ||
530 | + bd.des0 &= ~FTGMAC100_TXDES0_TXDMA_OWN; | ||
531 | + | ||
532 | + /* Write back the modified descriptor. */ | ||
533 | + ftgmac100_write_bd(&bd, addr); | ||
534 | + /* Advance to the next descriptor. */ | ||
535 | + if (bd.des0 & FTGMAC100_TXDES0_EDOTR) { | ||
536 | + addr = tx_ring; | ||
537 | + } else { | ||
538 | + addr += sizeof(FTGMAC100Desc); | ||
539 | + } | ||
540 | + } | ||
541 | + | ||
542 | + s->tx_descriptor = addr; | ||
543 | + | ||
544 | + ftgmac100_update_irq(s); | ||
545 | +} | ||
546 | + | ||
547 | +static int ftgmac100_can_receive(NetClientState *nc) | ||
548 | +{ | ||
549 | + FTGMAC100State *s = FTGMAC100(qemu_get_nic_opaque(nc)); | ||
550 | + FTGMAC100Desc bd; | ||
551 | + | ||
552 | + if ((s->maccr & (FTGMAC100_MACCR_RXDMA_EN | FTGMAC100_MACCR_RXMAC_EN)) | ||
553 | + != (FTGMAC100_MACCR_RXDMA_EN | FTGMAC100_MACCR_RXMAC_EN)) { | ||
554 | + return 0; | ||
555 | + } | ||
556 | + | ||
557 | + if (ftgmac100_read_bd(&bd, s->rx_descriptor)) { | ||
558 | + return 0; | ||
559 | + } | ||
560 | + return !(bd.des0 & FTGMAC100_RXDES0_RXPKT_RDY); | ||
561 | +} | ||
562 | + | ||
563 | +/* | ||
564 | + * This is purely informative. The HW can poll the RW (and RX) ring | ||
565 | + * buffers for available descriptors but we don't need to trigger a | ||
566 | + * timer for that in qemu. | ||
567 | + */ | ||
568 | +static uint32_t ftgmac100_rxpoll(FTGMAC100State *s) | ||
569 | +{ | ||
570 | + /* Polling times : | ||
571 | + * | ||
572 | + * Speed TIME_SEL=0 TIME_SEL=1 | ||
573 | + * | ||
574 | + * 10 51.2 ms 819.2 ms | ||
575 | + * 100 5.12 ms 81.92 ms | ||
576 | + * 1000 1.024 ms 16.384 ms | ||
577 | + */ | ||
578 | + static const int div[] = { 20, 200, 1000 }; | ||
579 | + | ||
580 | + uint32_t cnt = 1024 * FTGMAC100_APTC_RXPOLL_CNT(s->aptcr); | ||
581 | + uint32_t speed = (s->maccr & FTGMAC100_MACCR_FAST_MODE) ? 1 : 0; | ||
582 | + uint32_t period; | ||
583 | + | ||
584 | + if (s->aptcr & FTGMAC100_APTC_RXPOLL_TIME_SEL) { | ||
585 | + cnt <<= 4; | ||
586 | + } | ||
587 | + | ||
588 | + if (s->maccr & FTGMAC100_MACCR_GIGA_MODE) { | ||
589 | + speed = 2; | ||
590 | + } | ||
591 | + | ||
592 | + period = cnt / div[speed]; | ||
593 | + | ||
594 | + return period; | ||
595 | +} | ||
596 | + | ||
597 | +static void ftgmac100_reset(DeviceState *d) | ||
598 | +{ | ||
599 | + FTGMAC100State *s = FTGMAC100(d); | ||
600 | + | ||
601 | + /* Reset the FTGMAC100 */ | ||
602 | + s->isr = 0; | ||
603 | + s->ier = 0; | ||
604 | + s->rx_enabled = 0; | ||
605 | + s->rx_ring = 0; | ||
606 | + s->rbsr = 0x640; | ||
607 | + s->rx_descriptor = 0; | ||
608 | + s->tx_ring = 0; | ||
609 | + s->tx_descriptor = 0; | ||
610 | + s->math[0] = 0; | ||
611 | + s->math[1] = 0; | ||
612 | + s->itc = 0; | ||
613 | + s->aptcr = 1; | ||
614 | + s->dblac = 0x00022f00; | ||
615 | + s->revr = 0; | ||
616 | + s->fear1 = 0; | ||
617 | + s->tpafcr = 0xf1; | ||
618 | + | ||
619 | + s->maccr = 0; | ||
620 | + s->phycr = 0; | ||
621 | + s->phydata = 0; | ||
622 | + s->fcr = 0x400; | ||
623 | + | ||
624 | + /* and the PHY */ | ||
625 | + phy_reset(s); | ||
626 | +} | ||
627 | + | ||
628 | +static uint64_t ftgmac100_read(void *opaque, hwaddr addr, unsigned size) | ||
629 | +{ | ||
630 | + FTGMAC100State *s = FTGMAC100(opaque); | ||
631 | + | ||
632 | + switch (addr & 0xff) { | ||
633 | + case FTGMAC100_ISR: | ||
634 | + return s->isr; | ||
635 | + case FTGMAC100_IER: | ||
636 | + return s->ier; | ||
637 | + case FTGMAC100_MAC_MADR: | ||
638 | + return (s->conf.macaddr.a[0] << 8) | s->conf.macaddr.a[1]; | ||
639 | + case FTGMAC100_MAC_LADR: | ||
640 | + return ((uint32_t) s->conf.macaddr.a[2] << 24) | | ||
641 | + (s->conf.macaddr.a[3] << 16) | (s->conf.macaddr.a[4] << 8) | | ||
642 | + s->conf.macaddr.a[5]; | ||
643 | + case FTGMAC100_MATH0: | ||
644 | + return s->math[0]; | ||
645 | + case FTGMAC100_MATH1: | ||
646 | + return s->math[1]; | ||
647 | + case FTGMAC100_ITC: | ||
648 | + return s->itc; | ||
649 | + case FTGMAC100_DBLAC: | ||
650 | + return s->dblac; | ||
651 | + case FTGMAC100_REVR: | ||
652 | + return s->revr; | ||
653 | + case FTGMAC100_FEAR1: | ||
654 | + return s->fear1; | ||
655 | + case FTGMAC100_TPAFCR: | ||
656 | + return s->tpafcr; | ||
657 | + case FTGMAC100_FCR: | ||
658 | + return s->fcr; | ||
659 | + case FTGMAC100_MACCR: | ||
660 | + return s->maccr; | ||
661 | + case FTGMAC100_PHYCR: | ||
662 | + return s->phycr; | ||
663 | + case FTGMAC100_PHYDATA: | ||
664 | + return s->phydata; | ||
665 | + | ||
666 | + /* We might want to support these one day */ | ||
667 | + case FTGMAC100_HPTXPD: /* High Priority Transmit Poll Demand */ | ||
668 | + case FTGMAC100_HPTXR_BADR: /* High Priority Transmit Ring Base Address */ | ||
669 | + case FTGMAC100_MACSR: /* MAC Status Register (MACSR) */ | ||
670 | + qemu_log_mask(LOG_UNIMP, "%s: read to unimplemented register 0x%" | ||
671 | + HWADDR_PRIx "\n", __func__, addr); | ||
672 | + return 0; | ||
673 | + default: | ||
674 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: Bad address at offset 0x%" | ||
675 | + HWADDR_PRIx "\n", __func__, addr); | ||
676 | + return 0; | ||
677 | + } | ||
678 | +} | ||
679 | + | ||
680 | +static void ftgmac100_write(void *opaque, hwaddr addr, | ||
681 | + uint64_t value, unsigned size) | ||
682 | +{ | ||
683 | + FTGMAC100State *s = FTGMAC100(opaque); | ||
684 | + int reg; | ||
685 | + | ||
686 | + switch (addr & 0xff) { | ||
687 | + case FTGMAC100_ISR: /* Interrupt status */ | ||
688 | + s->isr &= ~value; | ||
689 | + break; | ||
690 | + case FTGMAC100_IER: /* Interrupt control */ | ||
691 | + s->ier = value; | ||
692 | + break; | ||
693 | + case FTGMAC100_MAC_MADR: /* MAC */ | ||
694 | + s->conf.macaddr.a[0] = value >> 8; | ||
695 | + s->conf.macaddr.a[1] = value; | ||
696 | + break; | ||
697 | + case FTGMAC100_MAC_LADR: | ||
698 | + s->conf.macaddr.a[2] = value >> 24; | ||
699 | + s->conf.macaddr.a[3] = value >> 16; | ||
700 | + s->conf.macaddr.a[4] = value >> 8; | ||
701 | + s->conf.macaddr.a[5] = value; | ||
702 | + break; | ||
703 | + case FTGMAC100_MATH0: /* Multicast Address Hash Table 0 */ | ||
704 | + s->math[0] = value; | ||
705 | + break; | ||
706 | + case FTGMAC100_MATH1: /* Multicast Address Hash Table 1 */ | ||
707 | + s->math[1] = value; | ||
708 | + break; | ||
709 | + case FTGMAC100_ITC: /* TODO: Interrupt Timer Control */ | ||
710 | + s->itc = value; | ||
711 | + break; | ||
712 | + case FTGMAC100_RXR_BADR: /* Ring buffer address */ | ||
713 | + s->rx_ring = value; | ||
714 | + s->rx_descriptor = s->rx_ring; | ||
715 | + break; | ||
716 | + | ||
717 | + case FTGMAC100_RBSR: /* DMA buffer size */ | ||
718 | + s->rbsr = value; | ||
719 | + break; | ||
720 | + | ||
721 | + case FTGMAC100_NPTXR_BADR: /* Transmit buffer address */ | ||
722 | + s->tx_ring = value; | ||
723 | + s->tx_descriptor = s->tx_ring; | ||
724 | + break; | ||
725 | + | ||
726 | + case FTGMAC100_NPTXPD: /* Trigger transmit */ | ||
727 | + if ((s->maccr & (FTGMAC100_MACCR_TXDMA_EN | FTGMAC100_MACCR_TXMAC_EN)) | ||
728 | + == (FTGMAC100_MACCR_TXDMA_EN | FTGMAC100_MACCR_TXMAC_EN)) { | ||
729 | + /* TODO: high priority tx ring */ | ||
730 | + ftgmac100_do_tx(s, s->tx_ring, s->tx_descriptor); | ||
731 | + } | ||
732 | + if (ftgmac100_can_receive(qemu_get_queue(s->nic))) { | ||
733 | + qemu_flush_queued_packets(qemu_get_queue(s->nic)); | ||
734 | + } | ||
735 | + break; | ||
736 | + | ||
737 | + case FTGMAC100_RXPD: /* Receive Poll Demand Register */ | ||
738 | + if (ftgmac100_can_receive(qemu_get_queue(s->nic))) { | ||
739 | + qemu_flush_queued_packets(qemu_get_queue(s->nic)); | ||
740 | + } | ||
741 | + break; | ||
742 | + | ||
743 | + case FTGMAC100_APTC: /* Automatic polling */ | ||
744 | + s->aptcr = value; | ||
745 | + | ||
746 | + if (FTGMAC100_APTC_RXPOLL_CNT(s->aptcr)) { | ||
747 | + ftgmac100_rxpoll(s); | ||
748 | + } | ||
749 | + | ||
750 | + if (FTGMAC100_APTC_TXPOLL_CNT(s->aptcr)) { | ||
751 | + qemu_log_mask(LOG_UNIMP, "%s: no transmit polling\n", __func__); | ||
752 | + } | ||
753 | + break; | ||
754 | + | ||
755 | + case FTGMAC100_MACCR: /* MAC Device control */ | ||
756 | + s->maccr = value; | ||
757 | + if (value & FTGMAC100_MACCR_SW_RST) { | ||
758 | + ftgmac100_reset(DEVICE(s)); | ||
759 | + } | ||
760 | + | ||
761 | + if (ftgmac100_can_receive(qemu_get_queue(s->nic))) { | ||
762 | + qemu_flush_queued_packets(qemu_get_queue(s->nic)); | ||
763 | + } | ||
764 | + break; | ||
765 | + | ||
766 | + case FTGMAC100_PHYCR: /* PHY Device control */ | ||
767 | + reg = FTGMAC100_PHYCR_REG(value); | ||
768 | + s->phycr = value; | ||
769 | + if (value & FTGMAC100_PHYCR_MIIWR) { | ||
770 | + do_phy_write(s, reg, s->phydata & 0xffff); | ||
771 | + s->phycr &= ~FTGMAC100_PHYCR_MIIWR; | ||
772 | + } else { | ||
773 | + s->phydata = do_phy_read(s, reg) << 16; | ||
774 | + s->phycr &= ~FTGMAC100_PHYCR_MIIRD; | ||
775 | + } | ||
776 | + break; | ||
777 | + case FTGMAC100_PHYDATA: | ||
778 | + s->phydata = value & 0xffff; | ||
779 | + break; | ||
780 | + case FTGMAC100_DBLAC: /* DMA Burst Length and Arbitration Control */ | ||
781 | + s->dblac = value; | ||
782 | + break; | ||
783 | + case FTGMAC100_REVR: /* Feature Register */ | ||
784 | + /* TODO: Only Old MDIO interface is supported */ | ||
785 | + s->revr = value & ~FTGMAC100_REVR_NEW_MDIO_INTERFACE; | ||
786 | + break; | ||
787 | + case FTGMAC100_FEAR1: /* Feature Register 1 */ | ||
788 | + s->fear1 = value; | ||
789 | + break; | ||
790 | + case FTGMAC100_TPAFCR: /* Transmit Priority Arbitration and FIFO Control */ | ||
791 | + s->tpafcr = value; | ||
792 | + break; | ||
793 | + case FTGMAC100_FCR: /* Flow Control */ | ||
794 | + s->fcr = value; | ||
795 | + break; | ||
796 | + | ||
797 | + case FTGMAC100_HPTXPD: /* High Priority Transmit Poll Demand */ | ||
798 | + case FTGMAC100_HPTXR_BADR: /* High Priority Transmit Ring Base Address */ | ||
799 | + case FTGMAC100_MACSR: /* MAC Status Register (MACSR) */ | ||
800 | + qemu_log_mask(LOG_UNIMP, "%s: write to unimplemented register 0x%" | ||
801 | + HWADDR_PRIx "\n", __func__, addr); | ||
802 | + break; | ||
803 | + default: | ||
804 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: Bad address at offset 0x%" | ||
805 | + HWADDR_PRIx "\n", __func__, addr); | ||
806 | + break; | ||
807 | + } | ||
808 | + | ||
809 | + ftgmac100_update_irq(s); | ||
810 | +} | ||
811 | + | ||
812 | +static int ftgmac100_filter(FTGMAC100State *s, const uint8_t *buf, size_t len) | ||
813 | +{ | ||
814 | + unsigned mcast_idx; | ||
815 | + | ||
816 | + if (s->maccr & FTGMAC100_MACCR_RX_ALL) { | ||
817 | + return 1; | ||
818 | + } | ||
819 | + | ||
820 | + switch (get_eth_packet_type(PKT_GET_ETH_HDR(buf))) { | ||
821 | + case ETH_PKT_BCAST: | ||
822 | + if (!(s->maccr & FTGMAC100_MACCR_RX_BROADPKT)) { | ||
823 | + return 0; | ||
824 | + } | ||
825 | + break; | ||
826 | + case ETH_PKT_MCAST: | ||
827 | + if (!(s->maccr & FTGMAC100_MACCR_RX_MULTIPKT)) { | ||
828 | + if (!(s->maccr & FTGMAC100_MACCR_HT_MULTI_EN)) { | ||
829 | + return 0; | ||
830 | + } | ||
831 | + | ||
832 | + /* TODO: this does not seem to work for ftgmac100 */ | ||
833 | + mcast_idx = compute_mcast_idx(buf); | ||
834 | + if (!(s->math[mcast_idx / 32] & (1 << (mcast_idx % 32)))) { | ||
835 | + return 0; | ||
836 | + } | ||
837 | + } | ||
838 | + break; | ||
839 | + case ETH_PKT_UCAST: | ||
840 | + if (memcmp(s->conf.macaddr.a, buf, 6)) { | ||
841 | + return 0; | ||
842 | + } | ||
843 | + break; | ||
844 | + } | ||
845 | + | ||
846 | + return 1; | ||
847 | +} | ||
848 | + | ||
849 | +static ssize_t ftgmac100_receive(NetClientState *nc, const uint8_t *buf, | ||
850 | + size_t len) | ||
851 | +{ | ||
852 | + FTGMAC100State *s = FTGMAC100(qemu_get_nic_opaque(nc)); | ||
853 | + FTGMAC100Desc bd; | ||
854 | + uint32_t flags = 0; | ||
855 | + uint32_t addr; | ||
856 | + uint32_t crc; | ||
857 | + uint32_t buf_addr; | ||
858 | + uint8_t *crc_ptr; | ||
859 | + uint32_t buf_len; | ||
860 | + size_t size = len; | ||
861 | + uint32_t first = FTGMAC100_RXDES0_FRS; | ||
862 | + int max_frame_size = ftgmac100_max_frame_size(s); | ||
863 | + | ||
864 | + if ((s->maccr & (FTGMAC100_MACCR_RXDMA_EN | FTGMAC100_MACCR_RXMAC_EN)) | ||
865 | + != (FTGMAC100_MACCR_RXDMA_EN | FTGMAC100_MACCR_RXMAC_EN)) { | ||
866 | + return -1; | ||
867 | + } | ||
868 | + | ||
869 | + /* TODO : Pad to minimum Ethernet frame length */ | ||
870 | + /* handle small packets. */ | ||
871 | + if (size < 10) { | ||
872 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: dropped frame of %zd bytes\n", | ||
873 | + __func__, size); | ||
874 | + return size; | ||
875 | + } | ||
876 | + | ||
877 | + if (size < 64 && !(s->maccr & FTGMAC100_MACCR_RX_RUNT)) { | ||
878 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: dropped runt frame of %zd bytes\n", | ||
879 | + __func__, size); | ||
880 | + return size; | ||
881 | + } | ||
882 | + | ||
883 | + if (!ftgmac100_filter(s, buf, size)) { | ||
884 | + return size; | ||
885 | + } | ||
886 | + | ||
887 | + /* 4 bytes for the CRC. */ | ||
888 | + size += 4; | ||
889 | + crc = cpu_to_be32(crc32(~0, buf, size)); | ||
890 | + crc_ptr = (uint8_t *) &crc; | ||
891 | + | ||
892 | + /* Huge frames are truncated. */ | ||
893 | + if (size > max_frame_size) { | ||
894 | + size = max_frame_size; | ||
895 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: frame too big : %zd bytes\n", | ||
896 | + __func__, size); | ||
897 | + flags |= FTGMAC100_RXDES0_FTL; | ||
898 | + } | ||
899 | + | ||
900 | + switch (get_eth_packet_type(PKT_GET_ETH_HDR(buf))) { | ||
901 | + case ETH_PKT_BCAST: | ||
902 | + flags |= FTGMAC100_RXDES0_BROADCAST; | ||
903 | + break; | ||
904 | + case ETH_PKT_MCAST: | ||
905 | + flags |= FTGMAC100_RXDES0_MULTICAST; | ||
906 | + break; | ||
907 | + case ETH_PKT_UCAST: | ||
908 | + break; | ||
909 | + } | ||
910 | + | ||
911 | + addr = s->rx_descriptor; | ||
912 | + while (size > 0) { | ||
913 | + if (!ftgmac100_can_receive(nc)) { | ||
914 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: Unexpected packet\n", __func__); | ||
915 | + return -1; | ||
916 | + } | ||
917 | + | ||
918 | + if (ftgmac100_read_bd(&bd, addr) || | ||
919 | + (bd.des0 & FTGMAC100_RXDES0_RXPKT_RDY)) { | ||
920 | + /* No descriptors available. Bail out. */ | ||
921 | + qemu_log_mask(LOG_GUEST_ERROR, "%s: Lost end of frame\n", | ||
922 | + __func__); | ||
923 | + s->isr |= FTGMAC100_INT_NO_RXBUF; | ||
924 | + break; | ||
925 | + } | ||
926 | + buf_len = (size <= s->rbsr) ? size : s->rbsr; | ||
927 | + bd.des0 |= buf_len & 0x3fff; | ||
928 | + size -= buf_len; | ||
929 | + | ||
930 | + /* The last 4 bytes are the CRC. */ | ||
931 | + if (size < 4) { | ||
932 | + buf_len += size - 4; | ||
933 | + } | ||
934 | + buf_addr = bd.des3; | ||
935 | + dma_memory_write(&address_space_memory, buf_addr, buf, buf_len); | ||
936 | + buf += buf_len; | ||
937 | + if (size < 4) { | ||
938 | + dma_memory_write(&address_space_memory, buf_addr + buf_len, | ||
939 | + crc_ptr, 4 - size); | ||
940 | + crc_ptr += 4 - size; | ||
941 | + } | ||
942 | + | ||
943 | + bd.des0 |= first | FTGMAC100_RXDES0_RXPKT_RDY; | ||
944 | + first = 0; | ||
945 | + if (size == 0) { | ||
946 | + /* Last buffer in frame. */ | ||
947 | + bd.des0 |= flags | FTGMAC100_RXDES0_LRS; | ||
948 | + s->isr |= FTGMAC100_INT_RPKT_BUF; | ||
949 | + } else { | ||
950 | + s->isr |= FTGMAC100_INT_RPKT_FIFO; | ||
951 | + } | ||
952 | + ftgmac100_write_bd(&bd, addr); | ||
953 | + if (bd.des0 & FTGMAC100_RXDES0_EDORR) { | ||
954 | + addr = s->rx_ring; | ||
955 | + } else { | ||
956 | + addr += sizeof(FTGMAC100Desc); | ||
957 | + } | ||
958 | + } | ||
959 | + s->rx_descriptor = addr; | ||
960 | + | ||
961 | + ftgmac100_update_irq(s); | ||
962 | + return len; | ||
963 | +} | ||
964 | + | ||
965 | +static const MemoryRegionOps ftgmac100_ops = { | ||
966 | + .read = ftgmac100_read, | ||
967 | + .write = ftgmac100_write, | ||
968 | + .valid.min_access_size = 4, | ||
969 | + .valid.max_access_size = 4, | ||
970 | + .endianness = DEVICE_LITTLE_ENDIAN, | ||
971 | +}; | ||
972 | + | ||
973 | +static void ftgmac100_cleanup(NetClientState *nc) | ||
974 | +{ | ||
975 | + FTGMAC100State *s = FTGMAC100(qemu_get_nic_opaque(nc)); | ||
976 | + | ||
977 | + s->nic = NULL; | ||
978 | +} | ||
979 | + | ||
980 | +static NetClientInfo net_ftgmac100_info = { | ||
981 | + .type = NET_CLIENT_DRIVER_NIC, | ||
982 | + .size = sizeof(NICState), | ||
983 | + .can_receive = ftgmac100_can_receive, | ||
984 | + .receive = ftgmac100_receive, | ||
985 | + .cleanup = ftgmac100_cleanup, | ||
986 | + .link_status_changed = ftgmac100_set_link, | ||
987 | +}; | ||
988 | + | ||
989 | +static void ftgmac100_realize(DeviceState *dev, Error **errp) | ||
990 | +{ | ||
991 | + FTGMAC100State *s = FTGMAC100(dev); | ||
992 | + SysBusDevice *sbd = SYS_BUS_DEVICE(dev); | ||
993 | + | ||
994 | + memory_region_init_io(&s->iomem, OBJECT(dev), &ftgmac100_ops, s, | ||
995 | + TYPE_FTGMAC100, 0x2000); | ||
996 | + sysbus_init_mmio(sbd, &s->iomem); | ||
997 | + sysbus_init_irq(sbd, &s->irq); | ||
998 | + qemu_macaddr_default_if_unset(&s->conf.macaddr); | ||
999 | + | ||
1000 | + s->conf.peers.ncs[0] = nd_table[0].netdev; | ||
1001 | + | ||
1002 | + s->nic = qemu_new_nic(&net_ftgmac100_info, &s->conf, | ||
1003 | + object_get_typename(OBJECT(dev)), DEVICE(dev)->id, | ||
1004 | + s); | ||
1005 | + qemu_format_nic_info_str(qemu_get_queue(s->nic), s->conf.macaddr.a); | ||
1006 | + | ||
1007 | + s->frame = g_malloc(FTGMAC100_MAX_FRAME_SIZE); | ||
1008 | +} | ||
1009 | + | ||
1010 | +static const VMStateDescription vmstate_ftgmac100 = { | ||
1011 | + .name = TYPE_FTGMAC100, | ||
1012 | + .version_id = 1, | ||
1013 | + .minimum_version_id = 1, | ||
1014 | + .fields = (VMStateField[]) { | ||
1015 | + VMSTATE_UINT32(irq_state, FTGMAC100State), | ||
1016 | + VMSTATE_UINT32(isr, FTGMAC100State), | ||
1017 | + VMSTATE_UINT32(ier, FTGMAC100State), | ||
1018 | + VMSTATE_UINT32(rx_enabled, FTGMAC100State), | ||
1019 | + VMSTATE_UINT32(rx_ring, FTGMAC100State), | ||
1020 | + VMSTATE_UINT32(rbsr, FTGMAC100State), | ||
1021 | + VMSTATE_UINT32(tx_ring, FTGMAC100State), | ||
1022 | + VMSTATE_UINT32(rx_descriptor, FTGMAC100State), | ||
1023 | + VMSTATE_UINT32(tx_descriptor, FTGMAC100State), | ||
1024 | + VMSTATE_UINT32_ARRAY(math, FTGMAC100State, 2), | ||
1025 | + VMSTATE_UINT32(itc, FTGMAC100State), | ||
1026 | + VMSTATE_UINT32(aptcr, FTGMAC100State), | ||
1027 | + VMSTATE_UINT32(dblac, FTGMAC100State), | ||
1028 | + VMSTATE_UINT32(revr, FTGMAC100State), | ||
1029 | + VMSTATE_UINT32(fear1, FTGMAC100State), | ||
1030 | + VMSTATE_UINT32(tpafcr, FTGMAC100State), | ||
1031 | + VMSTATE_UINT32(maccr, FTGMAC100State), | ||
1032 | + VMSTATE_UINT32(phycr, FTGMAC100State), | ||
1033 | + VMSTATE_UINT32(phydata, FTGMAC100State), | ||
1034 | + VMSTATE_UINT32(fcr, FTGMAC100State), | ||
1035 | + VMSTATE_UINT32(phy_status, FTGMAC100State), | ||
1036 | + VMSTATE_UINT32(phy_control, FTGMAC100State), | ||
1037 | + VMSTATE_UINT32(phy_advertise, FTGMAC100State), | ||
1038 | + VMSTATE_UINT32(phy_int, FTGMAC100State), | ||
1039 | + VMSTATE_UINT32(phy_int_mask, FTGMAC100State), | ||
1040 | + VMSTATE_END_OF_LIST() | ||
1041 | + } | ||
1042 | +}; | ||
1043 | + | ||
1044 | +static Property ftgmac100_properties[] = { | ||
1045 | + DEFINE_NIC_PROPERTIES(FTGMAC100State, conf), | ||
1046 | + DEFINE_PROP_END_OF_LIST(), | ||
1047 | +}; | ||
1048 | + | ||
1049 | +static void ftgmac100_class_init(ObjectClass *klass, void *data) | ||
1050 | +{ | ||
1051 | + DeviceClass *dc = DEVICE_CLASS(klass); | ||
1052 | + | ||
1053 | + dc->vmsd = &vmstate_ftgmac100; | ||
1054 | + dc->reset = ftgmac100_reset; | ||
1055 | + dc->props = ftgmac100_properties; | ||
1056 | + set_bit(DEVICE_CATEGORY_NETWORK, dc->categories); | ||
1057 | + dc->realize = ftgmac100_realize; | ||
1058 | + dc->desc = "Faraday FTGMAC100 Gigabit Ethernet emulation"; | ||
1059 | +} | ||
1060 | + | ||
1061 | +static const TypeInfo ftgmac100_info = { | ||
1062 | + .name = TYPE_FTGMAC100, | ||
1063 | + .parent = TYPE_SYS_BUS_DEVICE, | ||
1064 | + .instance_size = sizeof(FTGMAC100State), | ||
1065 | + .class_init = ftgmac100_class_init, | ||
1066 | +}; | ||
1067 | + | ||
1068 | +static void ftgmac100_register_types(void) | ||
1069 | +{ | ||
1070 | + type_register_static(&ftgmac100_info); | ||
1071 | +} | ||
1072 | + | ||
1073 | +type_init(ftgmac100_register_types) | ||
1074 | diff --git a/include/hw/net/ftgmac100.h b/include/hw/net/ftgmac100.h | ||
1075 | new file mode 100644 | ||
1076 | index XXXXXXX..XXXXXXX | ||
1077 | --- /dev/null | ||
1078 | +++ b/include/hw/net/ftgmac100.h | ||
1079 | @@ -XXX,XX +XXX,XX @@ | ||
1080 | +/* | ||
1081 | + * Faraday FTGMAC100 Gigabit Ethernet | ||
1082 | + * | ||
1083 | + * Copyright (C) 2016-2017, IBM Corporation. | ||
1084 | + * | ||
1085 | + * This code is licensed under the GPL version 2 or later. See the | ||
1086 | + * COPYING file in the top-level directory. | ||
1087 | + */ | ||
1088 | + | ||
1089 | +#ifndef FTGMAC100_H | ||
1090 | +#define FTGMAC100_H | ||
1091 | + | ||
1092 | +#define TYPE_FTGMAC100 "ftgmac100" | ||
1093 | +#define FTGMAC100(obj) OBJECT_CHECK(FTGMAC100State, (obj), TYPE_FTGMAC100) | ||
1094 | + | ||
1095 | +#include "hw/sysbus.h" | ||
1096 | +#include "net/net.h" | ||
1097 | + | ||
1098 | +typedef struct FTGMAC100State { | ||
1099 | + /*< private >*/ | ||
1100 | + SysBusDevice parent_obj; | ||
1101 | + | ||
1102 | + /*< public >*/ | ||
1103 | + NICState *nic; | ||
1104 | + NICConf conf; | ||
1105 | + qemu_irq irq; | ||
1106 | + MemoryRegion iomem; | ||
1107 | + | ||
1108 | + uint8_t *frame; | ||
1109 | + | ||
1110 | + uint32_t irq_state; | ||
1111 | + uint32_t isr; | ||
1112 | + uint32_t ier; | ||
1113 | + uint32_t rx_enabled; | ||
1114 | + uint32_t rx_ring; | ||
1115 | + uint32_t rx_descriptor; | ||
1116 | + uint32_t tx_ring; | ||
1117 | + uint32_t tx_descriptor; | ||
1118 | + uint32_t math[2]; | ||
1119 | + uint32_t rbsr; | ||
1120 | + uint32_t itc; | ||
1121 | + uint32_t aptcr; | ||
1122 | + uint32_t dblac; | ||
1123 | + uint32_t revr; | ||
1124 | + uint32_t fear1; | ||
1125 | + uint32_t tpafcr; | ||
1126 | + uint32_t maccr; | ||
1127 | + uint32_t phycr; | ||
1128 | + uint32_t phydata; | ||
1129 | + uint32_t fcr; | ||
1130 | + | ||
1131 | + | ||
1132 | + uint32_t phy_status; | ||
1133 | + uint32_t phy_control; | ||
1134 | + uint32_t phy_advertise; | ||
1135 | + uint32_t phy_int; | ||
1136 | + uint32_t phy_int_mask; | ||
1137 | +} FTGMAC100State; | ||
1138 | + | ||
1139 | +#endif | ||
31 | -- | 1140 | -- |
32 | 2.7.4 | 1141 | 2.7.4 |
33 | 1142 | ||
34 | 1143 | diff view generated by jsdifflib |
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | 1 | From: Cédric Le Goater <clg@kaod.org> |
---|---|---|---|
2 | 2 | ||
3 | Cc: jasowang@redhat.com | 3 | The Aspeed SoCs have a different definition of the end of the ring |
4 | Cc: jiri@resnulli.us | 4 | buffer bit. Add a property to specify which set of bits should be used |
5 | Cc: armbru@redhat.com | 5 | by the NIC. |
6 | Cc: f4bug@amsat.org | 6 | |
7 | Suggested-by: Markus Armbruster <armbru@redhat.com> | 7 | Signed-off-by: Cédric Le Goater <clg@kaod.org> |
8 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
9 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
10 | Reviewed-by: Philippe Mathieu-Daudé <f4bug@amsat.org> | ||
11 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 8 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
12 | --- | 9 | --- |
13 | hw/net/rocker/rocker.c | 18 +++++++++--------- | 10 | hw/net/ftgmac100.c | 17 +++++++++++++++-- |
14 | 1 file changed, 9 insertions(+), 9 deletions(-) | 11 | include/hw/net/ftgmac100.h | 4 ++++ |
12 | 2 files changed, 19 insertions(+), 2 deletions(-) | ||
15 | 13 | ||
16 | diff --git a/hw/net/rocker/rocker.c b/hw/net/rocker/rocker.c | 14 | diff --git a/hw/net/ftgmac100.c b/hw/net/ftgmac100.c |
17 | index XXXXXXX..XXXXXXX 100644 | 15 | index XXXXXXX..XXXXXXX 100644 |
18 | --- a/hw/net/rocker/rocker.c | 16 | --- a/hw/net/ftgmac100.c |
19 | +++ b/hw/net/rocker/rocker.c | 17 | +++ b/hw/net/ftgmac100.c |
20 | @@ -XXX,XX +XXX,XX @@ struct rocker { | 18 | @@ -XXX,XX +XXX,XX @@ |
21 | QLIST_ENTRY(rocker) next; | 19 | #define FTGMAC100_TXDES0_CRC_ERR (1 << 19) |
20 | #define FTGMAC100_TXDES0_LTS (1 << 28) | ||
21 | #define FTGMAC100_TXDES0_FTS (1 << 29) | ||
22 | +#define FTGMAC100_TXDES0_EDOTR_ASPEED (1 << 30) | ||
23 | #define FTGMAC100_TXDES0_TXDMA_OWN (1 << 31) | ||
24 | |||
25 | #define FTGMAC100_TXDES1_VLANTAG_CI(x) ((x) & 0xffff) | ||
26 | @@ -XXX,XX +XXX,XX @@ | ||
27 | #define FTGMAC100_RXDES0_PAUSE_FRAME (1 << 25) | ||
28 | #define FTGMAC100_RXDES0_LRS (1 << 28) | ||
29 | #define FTGMAC100_RXDES0_FRS (1 << 29) | ||
30 | +#define FTGMAC100_RXDES0_EDORR_ASPEED (1 << 30) | ||
31 | #define FTGMAC100_RXDES0_RXPKT_RDY (1 << 31) | ||
32 | |||
33 | #define FTGMAC100_RXDES1_VLANTAG_CI 0xffff | ||
34 | @@ -XXX,XX +XXX,XX @@ static void ftgmac100_do_tx(FTGMAC100State *s, uint32_t tx_ring, | ||
35 | /* Write back the modified descriptor. */ | ||
36 | ftgmac100_write_bd(&bd, addr); | ||
37 | /* Advance to the next descriptor. */ | ||
38 | - if (bd.des0 & FTGMAC100_TXDES0_EDOTR) { | ||
39 | + if (bd.des0 & s->txdes0_edotr) { | ||
40 | addr = tx_ring; | ||
41 | } else { | ||
42 | addr += sizeof(FTGMAC100Desc); | ||
43 | @@ -XXX,XX +XXX,XX @@ static ssize_t ftgmac100_receive(NetClientState *nc, const uint8_t *buf, | ||
44 | s->isr |= FTGMAC100_INT_RPKT_FIFO; | ||
45 | } | ||
46 | ftgmac100_write_bd(&bd, addr); | ||
47 | - if (bd.des0 & FTGMAC100_RXDES0_EDORR) { | ||
48 | + if (bd.des0 & s->rxdes0_edorr) { | ||
49 | addr = s->rx_ring; | ||
50 | } else { | ||
51 | addr += sizeof(FTGMAC100Desc); | ||
52 | @@ -XXX,XX +XXX,XX @@ static void ftgmac100_realize(DeviceState *dev, Error **errp) | ||
53 | FTGMAC100State *s = FTGMAC100(dev); | ||
54 | SysBusDevice *sbd = SYS_BUS_DEVICE(dev); | ||
55 | |||
56 | + if (s->aspeed) { | ||
57 | + s->txdes0_edotr = FTGMAC100_TXDES0_EDOTR_ASPEED; | ||
58 | + s->rxdes0_edorr = FTGMAC100_RXDES0_EDORR_ASPEED; | ||
59 | + } else { | ||
60 | + s->txdes0_edotr = FTGMAC100_TXDES0_EDOTR; | ||
61 | + s->rxdes0_edorr = FTGMAC100_RXDES0_EDORR; | ||
62 | + } | ||
63 | + | ||
64 | memory_region_init_io(&s->iomem, OBJECT(dev), &ftgmac100_ops, s, | ||
65 | TYPE_FTGMAC100, 0x2000); | ||
66 | sysbus_init_mmio(sbd, &s->iomem); | ||
67 | @@ -XXX,XX +XXX,XX @@ static const VMStateDescription vmstate_ftgmac100 = { | ||
68 | VMSTATE_UINT32(phy_advertise, FTGMAC100State), | ||
69 | VMSTATE_UINT32(phy_int, FTGMAC100State), | ||
70 | VMSTATE_UINT32(phy_int_mask, FTGMAC100State), | ||
71 | + VMSTATE_UINT32(txdes0_edotr, FTGMAC100State), | ||
72 | + VMSTATE_UINT32(rxdes0_edorr, FTGMAC100State), | ||
73 | VMSTATE_END_OF_LIST() | ||
74 | } | ||
22 | }; | 75 | }; |
23 | 76 | ||
24 | -#define ROCKER "rocker" | 77 | static Property ftgmac100_properties[] = { |
25 | +#define TYPE_ROCKER "rocker" | 78 | + DEFINE_PROP_BOOL("aspeed", FTGMAC100State, aspeed, false), |
26 | 79 | DEFINE_NIC_PROPERTIES(FTGMAC100State, conf), | |
27 | -#define to_rocker(obj) \ | 80 | DEFINE_PROP_END_OF_LIST(), |
28 | - OBJECT_CHECK(Rocker, (obj), ROCKER) | ||
29 | +#define ROCKER(obj) \ | ||
30 | + OBJECT_CHECK(Rocker, (obj), TYPE_ROCKER) | ||
31 | |||
32 | static QLIST_HEAD(, rocker) rockers; | ||
33 | |||
34 | @@ -XXX,XX +XXX,XX @@ static World *rocker_world_type_by_name(Rocker *r, const char *name) | ||
35 | |||
36 | static void pci_rocker_realize(PCIDevice *dev, Error **errp) | ||
37 | { | ||
38 | - Rocker *r = to_rocker(dev); | ||
39 | + Rocker *r = ROCKER(dev); | ||
40 | const MACAddr zero = { .a = { 0, 0, 0, 0, 0, 0 } }; | ||
41 | const MACAddr dflt = { .a = { 0x52, 0x54, 0x00, 0x12, 0x35, 0x01 } }; | ||
42 | static int sw_index; | ||
43 | @@ -XXX,XX +XXX,XX @@ static void pci_rocker_realize(PCIDevice *dev, Error **errp) | ||
44 | /* validate switch properties */ | ||
45 | |||
46 | if (!r->name) { | ||
47 | - r->name = g_strdup(ROCKER); | ||
48 | + r->name = g_strdup(TYPE_ROCKER); | ||
49 | } | ||
50 | |||
51 | if (rocker_find(r->name)) { | ||
52 | @@ -XXX,XX +XXX,XX @@ err_world_type_by_name: | ||
53 | |||
54 | static void pci_rocker_uninit(PCIDevice *dev) | ||
55 | { | ||
56 | - Rocker *r = to_rocker(dev); | ||
57 | + Rocker *r = ROCKER(dev); | ||
58 | int i; | ||
59 | |||
60 | QLIST_REMOVE(r, next); | ||
61 | @@ -XXX,XX +XXX,XX @@ static void pci_rocker_uninit(PCIDevice *dev) | ||
62 | |||
63 | static void rocker_reset(DeviceState *dev) | ||
64 | { | ||
65 | - Rocker *r = to_rocker(dev); | ||
66 | + Rocker *r = ROCKER(dev); | ||
67 | int i; | ||
68 | |||
69 | for (i = 0; i < ROCKER_WORLD_TYPE_MAX; i++) { | ||
70 | @@ -XXX,XX +XXX,XX @@ static Property rocker_properties[] = { | ||
71 | }; | 81 | }; |
72 | 82 | diff --git a/include/hw/net/ftgmac100.h b/include/hw/net/ftgmac100.h | |
73 | static const VMStateDescription rocker_vmsd = { | 83 | index XXXXXXX..XXXXXXX 100644 |
74 | - .name = ROCKER, | 84 | --- a/include/hw/net/ftgmac100.h |
75 | + .name = TYPE_ROCKER, | 85 | +++ b/include/hw/net/ftgmac100.h |
76 | .unmigratable = 1, | 86 | @@ -XXX,XX +XXX,XX @@ typedef struct FTGMAC100State { |
77 | }; | 87 | uint32_t phy_advertise; |
78 | 88 | uint32_t phy_int; | |
79 | @@ -XXX,XX +XXX,XX @@ static void rocker_class_init(ObjectClass *klass, void *data) | 89 | uint32_t phy_int_mask; |
80 | } | 90 | + |
81 | 91 | + bool aspeed; | |
82 | static const TypeInfo rocker_info = { | 92 | + uint32_t txdes0_edotr; |
83 | - .name = ROCKER, | 93 | + uint32_t rxdes0_edorr; |
84 | + .name = TYPE_ROCKER, | 94 | } FTGMAC100State; |
85 | .parent = TYPE_PCI_DEVICE, | 95 | |
86 | .instance_size = sizeof(Rocker), | 96 | #endif |
87 | .class_init = rocker_class_init, | ||
88 | -- | 97 | -- |
89 | 2.7.4 | 98 | 2.7.4 |
90 | 99 | ||
91 | 100 | diff view generated by jsdifflib |
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | 1 | From: Cédric Le Goater <clg@kaod.org> |
---|---|---|---|
2 | 2 | ||
3 | The rocker device still implements the old PCIDeviceClass .init() | 3 | There is a second NIC but we do not use it for the moment. We use the |
4 | instead of the new .realize(). All devices need to be converted to | 4 | 'aspeed' property to tune the definition of the end of ring buffer bit |
5 | .realize(). | 5 | for the Aspeed SoCs. |
6 | 6 | ||
7 | .init() reports errors with fprintf() and return 0 on success, negative | 7 | Signed-off-by: Cédric Le Goater <clg@kaod.org> |
8 | number on failure. Meanwhile, when -device rocker fails, it first report | ||
9 | a specific error, then a generic one, like this: | ||
10 | |||
11 | $ x86_64-softmmu/qemu-system-x86_64 -device rocker,name=qemu-rocker | ||
12 | rocker: name too long; please shorten to at most 9 chars | ||
13 | qemu-system-x86_64: -device rocker,name=qemu-rocker: Device initialization failed | ||
14 | |||
15 | Now, convert it to .realize() that passes errors to its callers via its | ||
16 | errp argument. Also avoid the superfluous second error message. After | ||
17 | the patch, effect like this: | ||
18 | |||
19 | $ x86_64-softmmu/qemu-system-x86_64 -device rocker,name=qemu-rocker | ||
20 | qemu-system-x86_64: -device rocker,name=qemu-rocker: name too long; please shorten to at most 9 chars | ||
21 | |||
22 | Cc: jasowang@redhat.com | ||
23 | Cc: jiri@resnulli.us | ||
24 | Cc: armbru@redhat.com | ||
25 | Cc: f4bug@amsat.org | ||
26 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
27 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
28 | Reviewed-by: Philippe Mathieu-Daudé <f4bug@amsat.org> | ||
29 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 8 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
30 | --- | 9 | --- |
31 | hw/net/rocker/rocker.c | 27 +++++++++++---------------- | 10 | hw/arm/aspeed_soc.c | 21 +++++++++++++++++++++ |
32 | 1 file changed, 11 insertions(+), 16 deletions(-) | 11 | include/hw/arm/aspeed_soc.h | 2 ++ |
12 | 2 files changed, 23 insertions(+) | ||
33 | 13 | ||
34 | diff --git a/hw/net/rocker/rocker.c b/hw/net/rocker/rocker.c | 14 | diff --git a/hw/arm/aspeed_soc.c b/hw/arm/aspeed_soc.c |
35 | index XXXXXXX..XXXXXXX 100644 | 15 | index XXXXXXX..XXXXXXX 100644 |
36 | --- a/hw/net/rocker/rocker.c | 16 | --- a/hw/arm/aspeed_soc.c |
37 | +++ b/hw/net/rocker/rocker.c | 17 | +++ b/hw/arm/aspeed_soc.c |
38 | @@ -XXX,XX +XXX,XX @@ rollback: | 18 | @@ -XXX,XX +XXX,XX @@ |
39 | return err; | 19 | #include "hw/char/serial.h" |
20 | #include "qemu/log.h" | ||
21 | #include "hw/i2c/aspeed_i2c.h" | ||
22 | +#include "net/net.h" | ||
23 | |||
24 | #define ASPEED_SOC_UART_5_BASE 0x00184000 | ||
25 | #define ASPEED_SOC_IOMEM_SIZE 0x00200000 | ||
26 | @@ -XXX,XX +XXX,XX @@ | ||
27 | #define ASPEED_SOC_TIMER_BASE 0x1E782000 | ||
28 | #define ASPEED_SOC_WDT_BASE 0x1E785000 | ||
29 | #define ASPEED_SOC_I2C_BASE 0x1E78A000 | ||
30 | +#define ASPEED_SOC_ETH1_BASE 0x1E660000 | ||
31 | +#define ASPEED_SOC_ETH2_BASE 0x1E680000 | ||
32 | |||
33 | static const int uart_irqs[] = { 9, 32, 33, 34, 10 }; | ||
34 | static const int timer_irqs[] = { 16, 17, 18, 35, 36, 37, 38, 39, }; | ||
35 | @@ -XXX,XX +XXX,XX @@ static void aspeed_soc_init(Object *obj) | ||
36 | object_initialize(&s->wdt, sizeof(s->wdt), TYPE_ASPEED_WDT); | ||
37 | object_property_add_child(obj, "wdt", OBJECT(&s->wdt), NULL); | ||
38 | qdev_set_parent_bus(DEVICE(&s->wdt), sysbus_get_default()); | ||
39 | + | ||
40 | + object_initialize(&s->ftgmac100, sizeof(s->ftgmac100), TYPE_FTGMAC100); | ||
41 | + object_property_add_child(obj, "ftgmac100", OBJECT(&s->ftgmac100), NULL); | ||
42 | + qdev_set_parent_bus(DEVICE(&s->ftgmac100), sysbus_get_default()); | ||
40 | } | 43 | } |
41 | 44 | ||
42 | -static int rocker_msix_init(Rocker *r) | 45 | static void aspeed_soc_realize(DeviceState *dev, Error **errp) |
43 | +static int rocker_msix_init(Rocker *r, Error **errp) | 46 | @@ -XXX,XX +XXX,XX @@ static void aspeed_soc_realize(DeviceState *dev, Error **errp) |
44 | { | 47 | return; |
45 | PCIDevice *dev = PCI_DEVICE(r); | ||
46 | int err; | ||
47 | - Error *local_err = NULL; | ||
48 | |||
49 | err = msix_init(dev, ROCKER_MSIX_VEC_COUNT(r->fp_ports), | ||
50 | &r->msix_bar, | ||
51 | ROCKER_PCI_MSIX_BAR_IDX, ROCKER_PCI_MSIX_TABLE_OFFSET, | ||
52 | &r->msix_bar, | ||
53 | ROCKER_PCI_MSIX_BAR_IDX, ROCKER_PCI_MSIX_PBA_OFFSET, | ||
54 | - 0, &local_err); | ||
55 | + 0, errp); | ||
56 | if (err) { | ||
57 | - error_report_err(local_err); | ||
58 | return err; | ||
59 | } | 48 | } |
60 | 49 | sysbus_mmio_map(SYS_BUS_DEVICE(&s->wdt), 0, ASPEED_SOC_WDT_BASE); | |
61 | @@ -XXX,XX +XXX,XX @@ static World *rocker_world_type_by_name(Rocker *r, const char *name) | 50 | + |
62 | return NULL; | 51 | + /* Net */ |
52 | + qdev_set_nic_properties(DEVICE(&s->ftgmac100), &nd_table[0]); | ||
53 | + object_property_set_bool(OBJECT(&s->ftgmac100), true, "aspeed", &err); | ||
54 | + object_property_set_bool(OBJECT(&s->ftgmac100), true, "realized", | ||
55 | + &local_err); | ||
56 | + error_propagate(&err, local_err); | ||
57 | + if (err) { | ||
58 | + error_propagate(errp, err); | ||
59 | + return; | ||
60 | + } | ||
61 | + sysbus_mmio_map(SYS_BUS_DEVICE(&s->ftgmac100), 0, ASPEED_SOC_ETH1_BASE); | ||
62 | + sysbus_connect_irq(SYS_BUS_DEVICE(&s->ftgmac100), 0, | ||
63 | + qdev_get_gpio_in(DEVICE(&s->vic), 2)); | ||
63 | } | 64 | } |
64 | 65 | ||
65 | -static int pci_rocker_init(PCIDevice *dev) | 66 | static void aspeed_soc_class_init(ObjectClass *oc, void *data) |
66 | +static void pci_rocker_realize(PCIDevice *dev, Error **errp) | 67 | diff --git a/include/hw/arm/aspeed_soc.h b/include/hw/arm/aspeed_soc.h |
67 | { | 68 | index XXXXXXX..XXXXXXX 100644 |
68 | Rocker *r = to_rocker(dev); | 69 | --- a/include/hw/arm/aspeed_soc.h |
69 | const MACAddr zero = { .a = { 0, 0, 0, 0, 0, 0 } }; | 70 | +++ b/include/hw/arm/aspeed_soc.h |
70 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | 71 | @@ -XXX,XX +XXX,XX @@ |
71 | 72 | #include "hw/i2c/aspeed_i2c.h" | |
72 | r->world_dflt = rocker_world_type_by_name(r, r->world_name); | 73 | #include "hw/ssi/aspeed_smc.h" |
73 | if (!r->world_dflt) { | 74 | #include "hw/watchdog/wdt_aspeed.h" |
74 | - fprintf(stderr, | 75 | +#include "hw/net/ftgmac100.h" |
75 | - "rocker: requested world \"%s\" does not exist\n", | 76 | |
76 | + error_setg(errp, | 77 | #define ASPEED_SPIS_NUM 2 |
77 | + "invalid argument requested world %s does not exist", | 78 | |
78 | r->world_name); | 79 | @@ -XXX,XX +XXX,XX @@ typedef struct AspeedSoCState { |
79 | - err = -EINVAL; | 80 | AspeedSMCState spi[ASPEED_SPIS_NUM]; |
80 | goto err_world_type_by_name; | 81 | AspeedSDMCState sdmc; |
81 | } | 82 | AspeedWDTState wdt; |
82 | 83 | + FTGMAC100State ftgmac100; | |
83 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | 84 | } AspeedSoCState; |
84 | 85 | ||
85 | /* MSI-X init */ | 86 | #define TYPE_ASPEED_SOC "aspeed-soc" |
86 | |||
87 | - err = rocker_msix_init(r); | ||
88 | + err = rocker_msix_init(r, errp); | ||
89 | if (err) { | ||
90 | goto err_msix_init; | ||
91 | } | ||
92 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
93 | } | ||
94 | |||
95 | if (rocker_find(r->name)) { | ||
96 | - err = -EEXIST; | ||
97 | + error_setg(errp, "%s already exists", r->name); | ||
98 | goto err_duplicate; | ||
99 | } | ||
100 | |||
101 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
102 | #define ROCKER_IFNAMSIZ 16 | ||
103 | #define MAX_ROCKER_NAME_LEN (ROCKER_IFNAMSIZ - 1 - 3 - 3) | ||
104 | if (strlen(r->name) > MAX_ROCKER_NAME_LEN) { | ||
105 | - fprintf(stderr, | ||
106 | - "rocker: name too long; please shorten to at most %d chars\n", | ||
107 | + error_setg(errp, | ||
108 | + "name too long; please shorten to at most %d chars", | ||
109 | MAX_ROCKER_NAME_LEN); | ||
110 | - err = -EINVAL; | ||
111 | goto err_name_too_long; | ||
112 | } | ||
113 | |||
114 | @@ -XXX,XX +XXX,XX @@ static int pci_rocker_init(PCIDevice *dev) | ||
115 | |||
116 | QLIST_INSERT_HEAD(&rockers, r, next); | ||
117 | |||
118 | - return 0; | ||
119 | + return; | ||
120 | |||
121 | err_name_too_long: | ||
122 | err_duplicate: | ||
123 | @@ -XXX,XX +XXX,XX @@ err_world_type_by_name: | ||
124 | world_free(r->worlds[i]); | ||
125 | } | ||
126 | } | ||
127 | - return err; | ||
128 | } | ||
129 | |||
130 | static void pci_rocker_uninit(PCIDevice *dev) | ||
131 | @@ -XXX,XX +XXX,XX @@ static void rocker_class_init(ObjectClass *klass, void *data) | ||
132 | DeviceClass *dc = DEVICE_CLASS(klass); | ||
133 | PCIDeviceClass *k = PCI_DEVICE_CLASS(klass); | ||
134 | |||
135 | - k->init = pci_rocker_init; | ||
136 | + k->realize = pci_rocker_realize; | ||
137 | k->exit = pci_rocker_uninit; | ||
138 | k->vendor_id = PCI_VENDOR_ID_REDHAT; | ||
139 | k->device_id = PCI_DEVICE_ID_REDHAT_ROCKER; | ||
140 | -- | 87 | -- |
141 | 2.7.4 | 88 | 2.7.4 |
142 | 89 | ||
143 | 90 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Matt Parker <mtparkr@gmail.com> | ||
2 | 1 | ||
3 | Both io and memory use the same mmio functions in the rtl8139 device. | ||
4 | This patch removes the separate MemoryRegionOps and old_mmio accessors | ||
5 | for memory, and replaces it with an alias to the io memory region. | ||
6 | |||
7 | Signed-off-by: Matt Parker <mtparkr@gmail.com> | ||
8 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
9 | --- | ||
10 | hw/net/rtl8139.c | 53 +++-------------------------------------------------- | ||
11 | 1 file changed, 3 insertions(+), 50 deletions(-) | ||
12 | |||
13 | diff --git a/hw/net/rtl8139.c b/hw/net/rtl8139.c | ||
14 | index XXXXXXX..XXXXXXX 100644 | ||
15 | --- a/hw/net/rtl8139.c | ||
16 | +++ b/hw/net/rtl8139.c | ||
17 | @@ -XXX,XX +XXX,XX @@ static uint32_t rtl8139_io_readl(void *opaque, uint8_t addr) | ||
18 | |||
19 | /* */ | ||
20 | |||
21 | -static void rtl8139_mmio_writeb(void *opaque, hwaddr addr, uint32_t val) | ||
22 | -{ | ||
23 | - rtl8139_io_writeb(opaque, addr & 0xFF, val); | ||
24 | -} | ||
25 | - | ||
26 | -static void rtl8139_mmio_writew(void *opaque, hwaddr addr, uint32_t val) | ||
27 | -{ | ||
28 | - rtl8139_io_writew(opaque, addr & 0xFF, val); | ||
29 | -} | ||
30 | - | ||
31 | -static void rtl8139_mmio_writel(void *opaque, hwaddr addr, uint32_t val) | ||
32 | -{ | ||
33 | - rtl8139_io_writel(opaque, addr & 0xFF, val); | ||
34 | -} | ||
35 | - | ||
36 | -static uint32_t rtl8139_mmio_readb(void *opaque, hwaddr addr) | ||
37 | -{ | ||
38 | - return rtl8139_io_readb(opaque, addr & 0xFF); | ||
39 | -} | ||
40 | - | ||
41 | -static uint32_t rtl8139_mmio_readw(void *opaque, hwaddr addr) | ||
42 | -{ | ||
43 | - uint32_t val = rtl8139_io_readw(opaque, addr & 0xFF); | ||
44 | - return val; | ||
45 | -} | ||
46 | - | ||
47 | -static uint32_t rtl8139_mmio_readl(void *opaque, hwaddr addr) | ||
48 | -{ | ||
49 | - uint32_t val = rtl8139_io_readl(opaque, addr & 0xFF); | ||
50 | - return val; | ||
51 | -} | ||
52 | - | ||
53 | static int rtl8139_post_load(void *opaque, int version_id) | ||
54 | { | ||
55 | RTL8139State* s = opaque; | ||
56 | @@ -XXX,XX +XXX,XX @@ static const MemoryRegionOps rtl8139_io_ops = { | ||
57 | .endianness = DEVICE_LITTLE_ENDIAN, | ||
58 | }; | ||
59 | |||
60 | -static const MemoryRegionOps rtl8139_mmio_ops = { | ||
61 | - .old_mmio = { | ||
62 | - .read = { | ||
63 | - rtl8139_mmio_readb, | ||
64 | - rtl8139_mmio_readw, | ||
65 | - rtl8139_mmio_readl, | ||
66 | - }, | ||
67 | - .write = { | ||
68 | - rtl8139_mmio_writeb, | ||
69 | - rtl8139_mmio_writew, | ||
70 | - rtl8139_mmio_writel, | ||
71 | - }, | ||
72 | - }, | ||
73 | - .endianness = DEVICE_LITTLE_ENDIAN, | ||
74 | -}; | ||
75 | - | ||
76 | static void rtl8139_timer(void *opaque) | ||
77 | { | ||
78 | RTL8139State *s = opaque; | ||
79 | @@ -XXX,XX +XXX,XX @@ static void pci_rtl8139_realize(PCIDevice *dev, Error **errp) | ||
80 | |||
81 | memory_region_init_io(&s->bar_io, OBJECT(s), &rtl8139_io_ops, s, | ||
82 | "rtl8139", 0x100); | ||
83 | - memory_region_init_io(&s->bar_mem, OBJECT(s), &rtl8139_mmio_ops, s, | ||
84 | - "rtl8139", 0x100); | ||
85 | + memory_region_init_alias(&s->bar_mem, OBJECT(s), "rtl8139-mem", &s->bar_io, | ||
86 | + 0, 0x100); | ||
87 | + | ||
88 | pci_register_bar(dev, 0, PCI_BASE_ADDRESS_SPACE_IO, &s->bar_io); | ||
89 | pci_register_bar(dev, 1, PCI_BASE_ADDRESS_SPACE_MEMORY, &s->bar_mem); | ||
90 | |||
91 | -- | ||
92 | 2.7.4 | ||
93 | |||
94 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | ||
2 | 1 | ||
3 | My Fujitsu mail account will be disabled soon, update the mail info | ||
4 | to my private mail. | ||
5 | |||
6 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | ||
7 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
8 | --- | ||
9 | MAINTAINERS | 2 +- | ||
10 | 1 file changed, 1 insertion(+), 1 deletion(-) | ||
11 | |||
12 | diff --git a/MAINTAINERS b/MAINTAINERS | ||
13 | index XXXXXXX..XXXXXXX 100644 | ||
14 | --- a/MAINTAINERS | ||
15 | +++ b/MAINTAINERS | ||
16 | @@ -XXX,XX +XXX,XX @@ F: include/migration/failover.h | ||
17 | F: docs/COLO-FT.txt | ||
18 | |||
19 | COLO Proxy | ||
20 | -M: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | ||
21 | +M: Zhang Chen <zhangckid@gmail.com> | ||
22 | M: Li Zhijian <lizhijian@cn.fujitsu.com> | ||
23 | S: Supported | ||
24 | F: docs/colo-proxy.txt | ||
25 | -- | ||
26 | 2.7.4 | ||
27 | |||
28 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
2 | 1 | ||
3 | In net_socket_fd_init(), the 'default' case is odd: it warns, | ||
4 | then continues as if the socket type was SOCK_STREAM. The | ||
5 | comment explains "this could be a eg. a pty", but that makes | ||
6 | no sense. If @fd really was a pty, getsockopt() would fail | ||
7 | with ENOTSOCK. If @fd was a socket, but neither SOCK_DGRAM nor | ||
8 | SOCK_STREAM. It should not be treated as if it was SOCK_STREAM. | ||
9 | |||
10 | Turn this case into an Error. If there is a genuine reason to | ||
11 | support something like SOCK_RAW, it should be explicitly | ||
12 | handled. | ||
13 | |||
14 | Cc: jasowang@redhat.com | ||
15 | Cc: armbru@redhat.com | ||
16 | Cc: berrange@redhat.com | ||
17 | Cc: armbru@redhat.com | ||
18 | Cc: eblake@redhat.com | ||
19 | Suggested-by: Markus Armbruster <armbru@redhat.com> | ||
20 | Suggested-by: Daniel P. Berrange <berrange@redhat.com> | ||
21 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
22 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
23 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
24 | --- | ||
25 | net/socket.c | 6 +++--- | ||
26 | 1 file changed, 3 insertions(+), 3 deletions(-) | ||
27 | |||
28 | diff --git a/net/socket.c b/net/socket.c | ||
29 | index XXXXXXX..XXXXXXX 100644 | ||
30 | --- a/net/socket.c | ||
31 | +++ b/net/socket.c | ||
32 | @@ -XXX,XX +XXX,XX @@ static NetSocketState *net_socket_fd_init(NetClientState *peer, | ||
33 | case SOCK_STREAM: | ||
34 | return net_socket_fd_init_stream(peer, model, name, fd, is_connected); | ||
35 | default: | ||
36 | - /* who knows ... this could be a eg. a pty, do warn and continue as stream */ | ||
37 | - fprintf(stderr, "qemu: warning: socket type=%d for fd=%d is not SOCK_DGRAM or SOCK_STREAM\n", so_type, fd); | ||
38 | - return net_socket_fd_init_stream(peer, model, name, fd, is_connected); | ||
39 | + error_report("socket type=%d for fd=%d must be either" | ||
40 | + " SOCK_DGRAM or SOCK_STREAM", so_type, fd); | ||
41 | + closesocket(fd); | ||
42 | } | ||
43 | return NULL; | ||
44 | } | ||
45 | -- | ||
46 | 2.7.4 | ||
47 | |||
48 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
2 | 1 | ||
3 | Currently, net_socket_mcast_create(), net_socket_fd_init_dgram() and | ||
4 | net_socket_fd_init() use the function such as fprintf(), perror() to | ||
5 | report an error message. | ||
6 | |||
7 | Now, convert these functions to Error. | ||
8 | |||
9 | Cc: jasowang@redhat.com | ||
10 | Cc: armbru@redhat.com | ||
11 | Cc: berrange@redhat.com | ||
12 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
13 | Reviewed-by: Daniel P. Berrange <berrange@redhat.com> | ||
14 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
15 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
16 | --- | ||
17 | net/socket.c | 82 ++++++++++++++++++++++++++++++++++++------------------------ | ||
18 | 1 file changed, 50 insertions(+), 32 deletions(-) | ||
19 | |||
20 | diff --git a/net/socket.c b/net/socket.c | ||
21 | index XXXXXXX..XXXXXXX 100644 | ||
22 | --- a/net/socket.c | ||
23 | +++ b/net/socket.c | ||
24 | @@ -XXX,XX +XXX,XX @@ static void net_socket_send_dgram(void *opaque) | ||
25 | } | ||
26 | } | ||
27 | |||
28 | -static int net_socket_mcast_create(struct sockaddr_in *mcastaddr, struct in_addr *localaddr) | ||
29 | +static int net_socket_mcast_create(struct sockaddr_in *mcastaddr, | ||
30 | + struct in_addr *localaddr, | ||
31 | + Error **errp) | ||
32 | { | ||
33 | struct ip_mreq imr; | ||
34 | int fd; | ||
35 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_create(struct sockaddr_in *mcastaddr, struct in_addr | ||
36 | #endif | ||
37 | |||
38 | if (!IN_MULTICAST(ntohl(mcastaddr->sin_addr.s_addr))) { | ||
39 | - fprintf(stderr, "qemu: error: specified mcastaddr \"%s\" (0x%08x) " | ||
40 | - "does not contain a multicast address\n", | ||
41 | - inet_ntoa(mcastaddr->sin_addr), | ||
42 | - (int)ntohl(mcastaddr->sin_addr.s_addr)); | ||
43 | + error_setg(errp, "specified mcastaddr %s (0x%08x) " | ||
44 | + "does not contain a multicast address", | ||
45 | + inet_ntoa(mcastaddr->sin_addr), | ||
46 | + (int)ntohl(mcastaddr->sin_addr.s_addr)); | ||
47 | return -1; | ||
48 | - | ||
49 | } | ||
50 | + | ||
51 | fd = qemu_socket(PF_INET, SOCK_DGRAM, 0); | ||
52 | if (fd < 0) { | ||
53 | - perror("socket(PF_INET, SOCK_DGRAM)"); | ||
54 | + error_setg_errno(errp, errno, "can't create datagram socket"); | ||
55 | return -1; | ||
56 | } | ||
57 | |||
58 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_create(struct sockaddr_in *mcastaddr, struct in_addr | ||
59 | val = 1; | ||
60 | ret = qemu_setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val)); | ||
61 | if (ret < 0) { | ||
62 | - perror("setsockopt(SOL_SOCKET, SO_REUSEADDR)"); | ||
63 | + error_setg_errno(errp, errno, | ||
64 | + "can't set socket option SO_REUSEADDR"); | ||
65 | goto fail; | ||
66 | } | ||
67 | |||
68 | ret = bind(fd, (struct sockaddr *)mcastaddr, sizeof(*mcastaddr)); | ||
69 | if (ret < 0) { | ||
70 | - perror("bind"); | ||
71 | + error_setg_errno(errp, errno, "can't bind ip=%s to socket", | ||
72 | + inet_ntoa(mcastaddr->sin_addr)); | ||
73 | goto fail; | ||
74 | } | ||
75 | |||
76 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_create(struct sockaddr_in *mcastaddr, struct in_addr | ||
77 | ret = qemu_setsockopt(fd, IPPROTO_IP, IP_ADD_MEMBERSHIP, | ||
78 | &imr, sizeof(struct ip_mreq)); | ||
79 | if (ret < 0) { | ||
80 | - perror("setsockopt(IP_ADD_MEMBERSHIP)"); | ||
81 | + error_setg_errno(errp, errno, | ||
82 | + "can't add socket to multicast group %s", | ||
83 | + inet_ntoa(imr.imr_multiaddr)); | ||
84 | goto fail; | ||
85 | } | ||
86 | |||
87 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_create(struct sockaddr_in *mcastaddr, struct in_addr | ||
88 | ret = qemu_setsockopt(fd, IPPROTO_IP, IP_MULTICAST_LOOP, | ||
89 | &loop, sizeof(loop)); | ||
90 | if (ret < 0) { | ||
91 | - perror("setsockopt(SOL_IP, IP_MULTICAST_LOOP)"); | ||
92 | + error_setg_errno(errp, errno, | ||
93 | + "can't force multicast message to loopback"); | ||
94 | goto fail; | ||
95 | } | ||
96 | |||
97 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_create(struct sockaddr_in *mcastaddr, struct in_addr | ||
98 | ret = qemu_setsockopt(fd, IPPROTO_IP, IP_MULTICAST_IF, | ||
99 | localaddr, sizeof(*localaddr)); | ||
100 | if (ret < 0) { | ||
101 | - perror("setsockopt(IP_MULTICAST_IF)"); | ||
102 | + error_setg_errno(errp, errno, | ||
103 | + "can't set the default network send interface"); | ||
104 | goto fail; | ||
105 | } | ||
106 | } | ||
107 | @@ -XXX,XX +XXX,XX @@ static NetSocketState *net_socket_fd_init_dgram(NetClientState *peer, | ||
108 | const char *model, | ||
109 | const char *name, | ||
110 | int fd, int is_connected, | ||
111 | - const char *mcast) | ||
112 | + const char *mcast, | ||
113 | + Error **errp) | ||
114 | { | ||
115 | struct sockaddr_in saddr; | ||
116 | int newfd; | ||
117 | @@ -XXX,XX +XXX,XX @@ static NetSocketState *net_socket_fd_init_dgram(NetClientState *peer, | ||
118 | |||
119 | if (is_connected && mcast != NULL) { | ||
120 | if (parse_host_port(&saddr, mcast) < 0) { | ||
121 | - fprintf(stderr, | ||
122 | - "qemu: error: init_dgram: fd=%d failed parse_host_port()\n", | ||
123 | - fd); | ||
124 | + error_setg(errp, "fd=%d failed parse_host_port()", fd); | ||
125 | goto err; | ||
126 | } | ||
127 | /* must be bound */ | ||
128 | if (saddr.sin_addr.s_addr == 0) { | ||
129 | - fprintf(stderr, "qemu: error: init_dgram: fd=%d unbound, " | ||
130 | - "cannot setup multicast dst addr\n", fd); | ||
131 | + error_setg(errp, "can't setup multicast destination address"); | ||
132 | goto err; | ||
133 | } | ||
134 | /* clone dgram socket */ | ||
135 | - newfd = net_socket_mcast_create(&saddr, NULL); | ||
136 | + newfd = net_socket_mcast_create(&saddr, NULL, errp); | ||
137 | if (newfd < 0) { | ||
138 | - /* error already reported by net_socket_mcast_create() */ | ||
139 | goto err; | ||
140 | } | ||
141 | /* clone newfd to fd, close newfd */ | ||
142 | @@ -XXX,XX +XXX,XX @@ static NetSocketState *net_socket_fd_init_stream(NetClientState *peer, | ||
143 | |||
144 | static NetSocketState *net_socket_fd_init(NetClientState *peer, | ||
145 | const char *model, const char *name, | ||
146 | - int fd, int is_connected, const char *mc) | ||
147 | + int fd, int is_connected, | ||
148 | + const char *mc, Error **errp) | ||
149 | { | ||
150 | int so_type = -1, optlen=sizeof(so_type); | ||
151 | |||
152 | if(getsockopt(fd, SOL_SOCKET, SO_TYPE, (char *)&so_type, | ||
153 | (socklen_t *)&optlen)< 0) { | ||
154 | - fprintf(stderr, "qemu: error: getsockopt(SO_TYPE) for fd=%d failed\n", | ||
155 | - fd); | ||
156 | + error_setg(errp, "can't get socket option SO_TYPE"); | ||
157 | closesocket(fd); | ||
158 | return NULL; | ||
159 | } | ||
160 | switch(so_type) { | ||
161 | case SOCK_DGRAM: | ||
162 | - return net_socket_fd_init_dgram(peer, model, name, fd, is_connected, mc); | ||
163 | + return net_socket_fd_init_dgram(peer, model, name, fd, is_connected, | ||
164 | + mc, errp); | ||
165 | case SOCK_STREAM: | ||
166 | return net_socket_fd_init_stream(peer, model, name, fd, is_connected); | ||
167 | default: | ||
168 | @@ -XXX,XX +XXX,XX @@ static int net_socket_connect_init(NetClientState *peer, | ||
169 | NetSocketState *s; | ||
170 | int fd, connected, ret; | ||
171 | struct sockaddr_in saddr; | ||
172 | + Error *err = NULL; | ||
173 | |||
174 | if (parse_host_port(&saddr, host_str) < 0) | ||
175 | return -1; | ||
176 | @@ -XXX,XX +XXX,XX @@ static int net_socket_connect_init(NetClientState *peer, | ||
177 | break; | ||
178 | } | ||
179 | } | ||
180 | - s = net_socket_fd_init(peer, model, name, fd, connected, NULL); | ||
181 | - if (!s) | ||
182 | + s = net_socket_fd_init(peer, model, name, fd, connected, NULL, &err); | ||
183 | + if (!s) { | ||
184 | + error_report_err(err); | ||
185 | return -1; | ||
186 | + } | ||
187 | + | ||
188 | snprintf(s->nc.info_str, sizeof(s->nc.info_str), | ||
189 | "socket: connect to %s:%d", | ||
190 | inet_ntoa(saddr.sin_addr), ntohs(saddr.sin_port)); | ||
191 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_init(NetClientState *peer, | ||
192 | int fd; | ||
193 | struct sockaddr_in saddr; | ||
194 | struct in_addr localaddr, *param_localaddr; | ||
195 | + Error *err = NULL; | ||
196 | |||
197 | if (parse_host_port(&saddr, host_str) < 0) | ||
198 | return -1; | ||
199 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_init(NetClientState *peer, | ||
200 | param_localaddr = NULL; | ||
201 | } | ||
202 | |||
203 | - fd = net_socket_mcast_create(&saddr, param_localaddr); | ||
204 | - if (fd < 0) | ||
205 | + fd = net_socket_mcast_create(&saddr, param_localaddr, &err); | ||
206 | + if (fd < 0) { | ||
207 | + error_report_err(err); | ||
208 | return -1; | ||
209 | + } | ||
210 | |||
211 | - s = net_socket_fd_init(peer, model, name, fd, 0, NULL); | ||
212 | - if (!s) | ||
213 | + s = net_socket_fd_init(peer, model, name, fd, 0, NULL, &err); | ||
214 | + if (!s) { | ||
215 | + error_report_err(err); | ||
216 | return -1; | ||
217 | + } | ||
218 | |||
219 | s->dgram_dst = saddr; | ||
220 | |||
221 | @@ -XXX,XX +XXX,XX @@ static int net_socket_udp_init(NetClientState *peer, | ||
222 | NetSocketState *s; | ||
223 | int fd, ret; | ||
224 | struct sockaddr_in laddr, raddr; | ||
225 | + Error *err = NULL; | ||
226 | |||
227 | if (parse_host_port(&laddr, lhost) < 0) { | ||
228 | return -1; | ||
229 | @@ -XXX,XX +XXX,XX @@ static int net_socket_udp_init(NetClientState *peer, | ||
230 | } | ||
231 | qemu_set_nonblock(fd); | ||
232 | |||
233 | - s = net_socket_fd_init(peer, model, name, fd, 0, NULL); | ||
234 | + s = net_socket_fd_init(peer, model, name, fd, 0, NULL, &err); | ||
235 | if (!s) { | ||
236 | + error_report_err(err); | ||
237 | return -1; | ||
238 | } | ||
239 | |||
240 | @@ -XXX,XX +XXX,XX @@ int net_init_socket(const Netdev *netdev, const char *name, | ||
241 | return -1; | ||
242 | } | ||
243 | qemu_set_nonblock(fd); | ||
244 | - if (!net_socket_fd_init(peer, "socket", name, fd, 1, sock->mcast)) { | ||
245 | + if (!net_socket_fd_init(peer, "socket", name, fd, 1, sock->mcast, | ||
246 | + errp)) { | ||
247 | return -1; | ||
248 | } | ||
249 | return 0; | ||
250 | -- | ||
251 | 2.7.4 | ||
252 | |||
253 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
2 | 1 | ||
3 | Cc: berrange@redhat.com | ||
4 | Cc: kraxel@redhat.com | ||
5 | Cc: pbonzini@redhat.com | ||
6 | Cc: jasowang@redhat.com | ||
7 | Cc: armbru@redhat.com | ||
8 | Cc: eblake@redhat.com | ||
9 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
10 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
11 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
12 | --- | ||
13 | include/qemu/sockets.h | 3 ++- | ||
14 | net/net.c | 22 +++++++++++++++++----- | ||
15 | net/socket.c | 22 +++++++++++++++------- | ||
16 | 3 files changed, 34 insertions(+), 13 deletions(-) | ||
17 | |||
18 | diff --git a/include/qemu/sockets.h b/include/qemu/sockets.h | ||
19 | index XXXXXXX..XXXXXXX 100644 | ||
20 | --- a/include/qemu/sockets.h | ||
21 | +++ b/include/qemu/sockets.h | ||
22 | @@ -XXX,XX +XXX,XX @@ void socket_listen_cleanup(int fd, Error **errp); | ||
23 | int socket_dgram(SocketAddress *remote, SocketAddress *local, Error **errp); | ||
24 | |||
25 | /* Old, ipv4 only bits. Don't use for new code. */ | ||
26 | -int parse_host_port(struct sockaddr_in *saddr, const char *str); | ||
27 | +int parse_host_port(struct sockaddr_in *saddr, const char *str, | ||
28 | + Error **errp); | ||
29 | int socket_init(void); | ||
30 | |||
31 | /** | ||
32 | diff --git a/net/net.c b/net/net.c | ||
33 | index XXXXXXX..XXXXXXX 100644 | ||
34 | --- a/net/net.c | ||
35 | +++ b/net/net.c | ||
36 | @@ -XXX,XX +XXX,XX @@ static int get_str_sep(char *buf, int buf_size, const char **pp, int sep) | ||
37 | return 0; | ||
38 | } | ||
39 | |||
40 | -int parse_host_port(struct sockaddr_in *saddr, const char *str) | ||
41 | +int parse_host_port(struct sockaddr_in *saddr, const char *str, | ||
42 | + Error **errp) | ||
43 | { | ||
44 | char buf[512]; | ||
45 | struct hostent *he; | ||
46 | @@ -XXX,XX +XXX,XX @@ int parse_host_port(struct sockaddr_in *saddr, const char *str) | ||
47 | int port; | ||
48 | |||
49 | p = str; | ||
50 | - if (get_str_sep(buf, sizeof(buf), &p, ':') < 0) | ||
51 | + if (get_str_sep(buf, sizeof(buf), &p, ':') < 0) { | ||
52 | + error_setg(errp, "host address '%s' doesn't contain ':' " | ||
53 | + "separating host from port", str); | ||
54 | return -1; | ||
55 | + } | ||
56 | saddr->sin_family = AF_INET; | ||
57 | if (buf[0] == '\0') { | ||
58 | saddr->sin_addr.s_addr = 0; | ||
59 | } else { | ||
60 | if (qemu_isdigit(buf[0])) { | ||
61 | - if (!inet_aton(buf, &saddr->sin_addr)) | ||
62 | + if (!inet_aton(buf, &saddr->sin_addr)) { | ||
63 | + error_setg(errp, "host address '%s' is not a valid " | ||
64 | + "IPv4 address", buf); | ||
65 | return -1; | ||
66 | + } | ||
67 | } else { | ||
68 | - if ((he = gethostbyname(buf)) == NULL) | ||
69 | + he = gethostbyname(buf); | ||
70 | + if (he == NULL) { | ||
71 | + error_setg(errp, "can't resolve host address '%s'", buf); | ||
72 | return - 1; | ||
73 | + } | ||
74 | saddr->sin_addr = *(struct in_addr *)he->h_addr; | ||
75 | } | ||
76 | } | ||
77 | port = strtol(p, (char **)&r, 0); | ||
78 | - if (r == p) | ||
79 | + if (r == p) { | ||
80 | + error_setg(errp, "port number '%s' is invalid", p); | ||
81 | return -1; | ||
82 | + } | ||
83 | saddr->sin_port = htons(port); | ||
84 | return 0; | ||
85 | } | ||
86 | diff --git a/net/socket.c b/net/socket.c | ||
87 | index XXXXXXX..XXXXXXX 100644 | ||
88 | --- a/net/socket.c | ||
89 | +++ b/net/socket.c | ||
90 | @@ -XXX,XX +XXX,XX @@ static NetSocketState *net_socket_fd_init_dgram(NetClientState *peer, | ||
91 | */ | ||
92 | |||
93 | if (is_connected && mcast != NULL) { | ||
94 | - if (parse_host_port(&saddr, mcast) < 0) { | ||
95 | - error_setg(errp, "fd=%d failed parse_host_port()", fd); | ||
96 | + if (parse_host_port(&saddr, mcast, errp) < 0) { | ||
97 | goto err; | ||
98 | } | ||
99 | /* must be bound */ | ||
100 | @@ -XXX,XX +XXX,XX @@ static int net_socket_listen_init(NetClientState *peer, | ||
101 | NetSocketState *s; | ||
102 | struct sockaddr_in saddr; | ||
103 | int fd, ret; | ||
104 | + Error *err = NULL; | ||
105 | |||
106 | - if (parse_host_port(&saddr, host_str) < 0) | ||
107 | + if (parse_host_port(&saddr, host_str, &err) < 0) { | ||
108 | + error_report_err(err); | ||
109 | return -1; | ||
110 | + } | ||
111 | |||
112 | fd = qemu_socket(PF_INET, SOCK_STREAM, 0); | ||
113 | if (fd < 0) { | ||
114 | @@ -XXX,XX +XXX,XX @@ static int net_socket_connect_init(NetClientState *peer, | ||
115 | struct sockaddr_in saddr; | ||
116 | Error *err = NULL; | ||
117 | |||
118 | - if (parse_host_port(&saddr, host_str) < 0) | ||
119 | + if (parse_host_port(&saddr, host_str, &err) < 0) { | ||
120 | + error_report_err(err); | ||
121 | return -1; | ||
122 | + } | ||
123 | |||
124 | fd = qemu_socket(PF_INET, SOCK_STREAM, 0); | ||
125 | if (fd < 0) { | ||
126 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_init(NetClientState *peer, | ||
127 | struct in_addr localaddr, *param_localaddr; | ||
128 | Error *err = NULL; | ||
129 | |||
130 | - if (parse_host_port(&saddr, host_str) < 0) | ||
131 | + if (parse_host_port(&saddr, host_str, &err) < 0) { | ||
132 | + error_report_err(err); | ||
133 | return -1; | ||
134 | + } | ||
135 | |||
136 | if (localaddr_str != NULL) { | ||
137 | if (inet_aton(localaddr_str, &localaddr) == 0) | ||
138 | @@ -XXX,XX +XXX,XX @@ static int net_socket_udp_init(NetClientState *peer, | ||
139 | struct sockaddr_in laddr, raddr; | ||
140 | Error *err = NULL; | ||
141 | |||
142 | - if (parse_host_port(&laddr, lhost) < 0) { | ||
143 | + if (parse_host_port(&laddr, lhost, &err) < 0) { | ||
144 | + error_report_err(err); | ||
145 | return -1; | ||
146 | } | ||
147 | |||
148 | - if (parse_host_port(&raddr, rhost) < 0) { | ||
149 | + if (parse_host_port(&raddr, rhost, &err) < 0) { | ||
150 | + error_report_err(err); | ||
151 | return -1; | ||
152 | } | ||
153 | |||
154 | -- | ||
155 | 2.7.4 | ||
156 | |||
157 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
2 | 1 | ||
3 | When -net socket fails, it first reports a specific error, then | ||
4 | a generic one, like this: | ||
5 | |||
6 | $ ./x86_64-softmmu/qemu-system-x86_64 -net socket,mcast=230.0.0.1:1234,listen | ||
7 | qemu-system-x86_64: -net socket,mcast=230.0.0.1:1234,listen: exactly one of listen=, connect=, mcast= or udp= is required | ||
8 | qemu-system-x86_64: -net socket,mcast=230.0.0.1:1234,listen: Device 'socket' could not be initialized | ||
9 | |||
10 | Convert net_socket_*_init() to Error to get rid of the superfluous second | ||
11 | error message. After the patch, the effect like this: | ||
12 | |||
13 | $ ./x86_64-softmmu/qemu-system-x86_64 -net socket,mcast=230.0.0.1:1234,listen | ||
14 | qemu-system-x86_64: -net socket,mcast=230.0.0.1:1234,listen: exactly one of listen=, connect=, mcast= or udp= is requireda | ||
15 | |||
16 | This also fixes a few silent failures to report an error. | ||
17 | |||
18 | Cc: jasowang@redhat.com | ||
19 | Cc: armbru@redhat.com | ||
20 | Cc: berrange@redhat.com | ||
21 | Signed-off-by: Mao Zhongyi <maozy.fnst@cn.fujitsu.com> | ||
22 | Reviewed-by: Markus Armbruster <armbru@redhat.com> | ||
23 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
24 | --- | ||
25 | net/socket.c | 92 +++++++++++++++++++++++++++++------------------------------- | ||
26 | 1 file changed, 44 insertions(+), 48 deletions(-) | ||
27 | |||
28 | diff --git a/net/socket.c b/net/socket.c | ||
29 | index XXXXXXX..XXXXXXX 100644 | ||
30 | --- a/net/socket.c | ||
31 | +++ b/net/socket.c | ||
32 | @@ -XXX,XX +XXX,XX @@ static void net_socket_accept(void *opaque) | ||
33 | static int net_socket_listen_init(NetClientState *peer, | ||
34 | const char *model, | ||
35 | const char *name, | ||
36 | - const char *host_str) | ||
37 | + const char *host_str, | ||
38 | + Error **errp) | ||
39 | { | ||
40 | NetClientState *nc; | ||
41 | NetSocketState *s; | ||
42 | struct sockaddr_in saddr; | ||
43 | int fd, ret; | ||
44 | - Error *err = NULL; | ||
45 | |||
46 | - if (parse_host_port(&saddr, host_str, &err) < 0) { | ||
47 | - error_report_err(err); | ||
48 | + if (parse_host_port(&saddr, host_str, errp) < 0) { | ||
49 | return -1; | ||
50 | } | ||
51 | |||
52 | fd = qemu_socket(PF_INET, SOCK_STREAM, 0); | ||
53 | if (fd < 0) { | ||
54 | - perror("socket"); | ||
55 | + error_setg_errno(errp, errno, "can't create stream socket"); | ||
56 | return -1; | ||
57 | } | ||
58 | qemu_set_nonblock(fd); | ||
59 | @@ -XXX,XX +XXX,XX @@ static int net_socket_listen_init(NetClientState *peer, | ||
60 | |||
61 | ret = bind(fd, (struct sockaddr *)&saddr, sizeof(saddr)); | ||
62 | if (ret < 0) { | ||
63 | - perror("bind"); | ||
64 | + error_setg_errno(errp, errno, "can't bind ip=%s to socket", | ||
65 | + inet_ntoa(saddr.sin_addr)); | ||
66 | closesocket(fd); | ||
67 | return -1; | ||
68 | } | ||
69 | ret = listen(fd, 0); | ||
70 | if (ret < 0) { | ||
71 | - perror("listen"); | ||
72 | + error_setg_errno(errp, errno, "can't listen on socket"); | ||
73 | closesocket(fd); | ||
74 | return -1; | ||
75 | } | ||
76 | @@ -XXX,XX +XXX,XX @@ static int net_socket_listen_init(NetClientState *peer, | ||
77 | static int net_socket_connect_init(NetClientState *peer, | ||
78 | const char *model, | ||
79 | const char *name, | ||
80 | - const char *host_str) | ||
81 | + const char *host_str, | ||
82 | + Error **errp) | ||
83 | { | ||
84 | NetSocketState *s; | ||
85 | int fd, connected, ret; | ||
86 | struct sockaddr_in saddr; | ||
87 | - Error *err = NULL; | ||
88 | |||
89 | - if (parse_host_port(&saddr, host_str, &err) < 0) { | ||
90 | - error_report_err(err); | ||
91 | + if (parse_host_port(&saddr, host_str, errp) < 0) { | ||
92 | return -1; | ||
93 | } | ||
94 | |||
95 | fd = qemu_socket(PF_INET, SOCK_STREAM, 0); | ||
96 | if (fd < 0) { | ||
97 | - perror("socket"); | ||
98 | + error_setg_errno(errp, errno, "can't create stream socket"); | ||
99 | return -1; | ||
100 | } | ||
101 | qemu_set_nonblock(fd); | ||
102 | @@ -XXX,XX +XXX,XX @@ static int net_socket_connect_init(NetClientState *peer, | ||
103 | errno == EINVAL) { | ||
104 | break; | ||
105 | } else { | ||
106 | - perror("connect"); | ||
107 | + error_setg_errno(errp, errno, "can't connect socket"); | ||
108 | closesocket(fd); | ||
109 | return -1; | ||
110 | } | ||
111 | @@ -XXX,XX +XXX,XX @@ static int net_socket_connect_init(NetClientState *peer, | ||
112 | break; | ||
113 | } | ||
114 | } | ||
115 | - s = net_socket_fd_init(peer, model, name, fd, connected, NULL, &err); | ||
116 | + s = net_socket_fd_init(peer, model, name, fd, connected, NULL, errp); | ||
117 | if (!s) { | ||
118 | - error_report_err(err); | ||
119 | return -1; | ||
120 | } | ||
121 | |||
122 | @@ -XXX,XX +XXX,XX @@ static int net_socket_mcast_init(NetClientState *peer, | ||
123 | const char *model, | ||
124 | const char *name, | ||
125 | const char *host_str, | ||
126 | - const char *localaddr_str) | ||
127 | + const char *localaddr_str, | ||
128 | + Error **errp) | ||
129 | { | ||
130 | NetSocketState *s; | ||
131 | int fd; | ||
132 | struct sockaddr_in saddr; | ||
133 | struct in_addr localaddr, *param_localaddr; | ||
134 | - Error *err = NULL; | ||
135 | |||
136 | - if (parse_host_port(&saddr, host_str, &err) < 0) { | ||
137 | - error_report_err(err); | ||
138 | + if (parse_host_port(&saddr, host_str, errp) < 0) { | ||
139 | return -1; | ||
140 | } | ||
141 | |||
142 | if (localaddr_str != NULL) { | ||
143 | - if (inet_aton(localaddr_str, &localaddr) == 0) | ||
144 | + if (inet_aton(localaddr_str, &localaddr) == 0) { | ||
145 | + error_setg(errp, "localaddr '%s' is not a valid IPv4 address", | ||
146 | + localaddr_str); | ||
147 | return -1; | ||
148 | + } | ||
149 | param_localaddr = &localaddr; | ||
150 | } else { | ||
151 | param_localaddr = NULL; | ||
152 | } | ||
153 | |||
154 | - fd = net_socket_mcast_create(&saddr, param_localaddr, &err); | ||
155 | + fd = net_socket_mcast_create(&saddr, param_localaddr, errp); | ||
156 | if (fd < 0) { | ||
157 | - error_report_err(err); | ||
158 | return -1; | ||
159 | } | ||
160 | |||
161 | - s = net_socket_fd_init(peer, model, name, fd, 0, NULL, &err); | ||
162 | + s = net_socket_fd_init(peer, model, name, fd, 0, NULL, errp); | ||
163 | if (!s) { | ||
164 | - error_report_err(err); | ||
165 | return -1; | ||
166 | } | ||
167 | |||
168 | @@ -XXX,XX +XXX,XX @@ static int net_socket_udp_init(NetClientState *peer, | ||
169 | const char *model, | ||
170 | const char *name, | ||
171 | const char *rhost, | ||
172 | - const char *lhost) | ||
173 | + const char *lhost, | ||
174 | + Error **errp) | ||
175 | { | ||
176 | NetSocketState *s; | ||
177 | int fd, ret; | ||
178 | struct sockaddr_in laddr, raddr; | ||
179 | - Error *err = NULL; | ||
180 | |||
181 | - if (parse_host_port(&laddr, lhost, &err) < 0) { | ||
182 | - error_report_err(err); | ||
183 | + if (parse_host_port(&laddr, lhost, errp) < 0) { | ||
184 | return -1; | ||
185 | } | ||
186 | |||
187 | - if (parse_host_port(&raddr, rhost, &err) < 0) { | ||
188 | - error_report_err(err); | ||
189 | + if (parse_host_port(&raddr, rhost, errp) < 0) { | ||
190 | return -1; | ||
191 | } | ||
192 | |||
193 | fd = qemu_socket(PF_INET, SOCK_DGRAM, 0); | ||
194 | if (fd < 0) { | ||
195 | - perror("socket(PF_INET, SOCK_DGRAM)"); | ||
196 | + error_setg_errno(errp, errno, "can't create datagram socket"); | ||
197 | return -1; | ||
198 | } | ||
199 | |||
200 | ret = socket_set_fast_reuse(fd); | ||
201 | if (ret < 0) { | ||
202 | + error_setg_errno(errp, errno, | ||
203 | + "can't set socket option SO_REUSEADDR"); | ||
204 | closesocket(fd); | ||
205 | return -1; | ||
206 | } | ||
207 | ret = bind(fd, (struct sockaddr *)&laddr, sizeof(laddr)); | ||
208 | if (ret < 0) { | ||
209 | - perror("bind"); | ||
210 | + error_setg_errno(errp, errno, "can't bind ip=%s to socket", | ||
211 | + inet_ntoa(laddr.sin_addr)); | ||
212 | closesocket(fd); | ||
213 | return -1; | ||
214 | } | ||
215 | qemu_set_nonblock(fd); | ||
216 | |||
217 | - s = net_socket_fd_init(peer, model, name, fd, 0, NULL, &err); | ||
218 | + s = net_socket_fd_init(peer, model, name, fd, 0, NULL, errp); | ||
219 | if (!s) { | ||
220 | - error_report_err(err); | ||
221 | return -1; | ||
222 | } | ||
223 | |||
224 | @@ -XXX,XX +XXX,XX @@ static int net_socket_udp_init(NetClientState *peer, | ||
225 | int net_init_socket(const Netdev *netdev, const char *name, | ||
226 | NetClientState *peer, Error **errp) | ||
227 | { | ||
228 | - /* FIXME error_setg(errp, ...) on failure */ | ||
229 | - Error *err = NULL; | ||
230 | const NetdevSocketOptions *sock; | ||
231 | |||
232 | assert(netdev->type == NET_CLIENT_DRIVER_SOCKET); | ||
233 | @@ -XXX,XX +XXX,XX @@ int net_init_socket(const Netdev *netdev, const char *name, | ||
234 | |||
235 | if (sock->has_listen + sock->has_connect + sock->has_mcast + | ||
236 | sock->has_udp > 1) { | ||
237 | - error_report("exactly one of listen=, connect=, mcast= or udp=" | ||
238 | - " is required"); | ||
239 | + error_setg(errp, "exactly one of listen=, connect=, mcast= or udp=" | ||
240 | + " is required"); | ||
241 | return -1; | ||
242 | } | ||
243 | |||
244 | if (sock->has_localaddr && !sock->has_mcast && !sock->has_udp) { | ||
245 | - error_report("localaddr= is only valid with mcast= or udp="); | ||
246 | + error_setg(errp, "localaddr= is only valid with mcast= or udp="); | ||
247 | return -1; | ||
248 | } | ||
249 | |||
250 | if (sock->has_fd) { | ||
251 | int fd; | ||
252 | |||
253 | - fd = monitor_fd_param(cur_mon, sock->fd, &err); | ||
254 | + fd = monitor_fd_param(cur_mon, sock->fd, errp); | ||
255 | if (fd == -1) { | ||
256 | - error_report_err(err); | ||
257 | return -1; | ||
258 | } | ||
259 | qemu_set_nonblock(fd); | ||
260 | @@ -XXX,XX +XXX,XX @@ int net_init_socket(const Netdev *netdev, const char *name, | ||
261 | } | ||
262 | |||
263 | if (sock->has_listen) { | ||
264 | - if (net_socket_listen_init(peer, "socket", name, sock->listen) == -1) { | ||
265 | + if (net_socket_listen_init(peer, "socket", name, sock->listen, errp) | ||
266 | + < 0) { | ||
267 | return -1; | ||
268 | } | ||
269 | return 0; | ||
270 | } | ||
271 | |||
272 | if (sock->has_connect) { | ||
273 | - if (net_socket_connect_init(peer, "socket", name, sock->connect) == | ||
274 | - -1) { | ||
275 | + if (net_socket_connect_init(peer, "socket", name, sock->connect, errp) | ||
276 | + < 0) { | ||
277 | return -1; | ||
278 | } | ||
279 | return 0; | ||
280 | @@ -XXX,XX +XXX,XX @@ int net_init_socket(const Netdev *netdev, const char *name, | ||
281 | /* if sock->localaddr is missing, it has been initialized to "all bits | ||
282 | * zero" */ | ||
283 | if (net_socket_mcast_init(peer, "socket", name, sock->mcast, | ||
284 | - sock->localaddr) == -1) { | ||
285 | + sock->localaddr, errp) < 0) { | ||
286 | return -1; | ||
287 | } | ||
288 | return 0; | ||
289 | @@ -XXX,XX +XXX,XX @@ int net_init_socket(const Netdev *netdev, const char *name, | ||
290 | |||
291 | assert(sock->has_udp); | ||
292 | if (!sock->has_localaddr) { | ||
293 | - error_report("localaddr= is mandatory with udp="); | ||
294 | + error_setg(errp, "localaddr= is mandatory with udp="); | ||
295 | return -1; | ||
296 | } | ||
297 | - if (net_socket_udp_init(peer, "socket", name, sock->udp, sock->localaddr) == | ||
298 | - -1) { | ||
299 | + if (net_socket_udp_init(peer, "socket", name, sock->udp, sock->localaddr, | ||
300 | + errp) < 0) { | ||
301 | return -1; | ||
302 | } | ||
303 | return 0; | ||
304 | -- | ||
305 | 2.7.4 | ||
306 | |||
307 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Kamil Rytarowski <n54@gmx.com> | ||
2 | 1 | ||
3 | SunOS defines SEC in <sys/time.h> as 1 (commonly used time symbols). | ||
4 | |||
5 | This fixes build on SmartOS (Joyent). | ||
6 | |||
7 | Patch cherry-picked from pkgsrc by jperkin (Joyent). | ||
8 | |||
9 | Signed-off-by: Kamil Rytarowski <n54@gmx.com> | ||
10 | Reviewed-by: Dmitry Fleytman <dmitry@daynix.com> | ||
11 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
12 | --- | ||
13 | hw/net/e1000.c | 4 ++-- | ||
14 | hw/net/e1000_regs.h | 2 +- | ||
15 | hw/net/e1000e_core.c | 2 +- | ||
16 | hw/net/e1000x_common.h | 2 +- | ||
17 | 4 files changed, 5 insertions(+), 5 deletions(-) | ||
18 | |||
19 | diff --git a/hw/net/e1000.c b/hw/net/e1000.c | ||
20 | index XXXXXXX..XXXXXXX 100644 | ||
21 | --- a/hw/net/e1000.c | ||
22 | +++ b/hw/net/e1000.c | ||
23 | @@ -XXX,XX +XXX,XX @@ static uint32_t (*macreg_readops[])(E1000State *, int) = { | ||
24 | getreg(TADV), getreg(ITR), getreg(FCRUC), getreg(IPAV), | ||
25 | getreg(WUC), getreg(WUS), getreg(SCC), getreg(ECOL), | ||
26 | getreg(MCC), getreg(LATECOL), getreg(COLC), getreg(DC), | ||
27 | - getreg(TNCRS), getreg(SEC), getreg(CEXTERR), getreg(RLEC), | ||
28 | + getreg(TNCRS), getreg(SEQEC), getreg(CEXTERR), getreg(RLEC), | ||
29 | getreg(XONRXC), getreg(XONTXC), getreg(XOFFRXC), getreg(XOFFTXC), | ||
30 | getreg(RFC), getreg(RJC), getreg(RNBC), getreg(TSCTFC), | ||
31 | getreg(MGTPRC), getreg(MGTPDC), getreg(MGTPTC), getreg(GORCL), | ||
32 | @@ -XXX,XX +XXX,XX @@ static const uint8_t mac_reg_access[0x8000] = { | ||
33 | [FFLT] = markflag(MAC), [FFMT] = markflag(MAC), | ||
34 | [SCC] = markflag(MAC), [FCRUC] = markflag(MAC), | ||
35 | [LATECOL] = markflag(MAC), [COLC] = markflag(MAC), | ||
36 | - [SEC] = markflag(MAC), [CEXTERR] = markflag(MAC), | ||
37 | + [SEQEC] = markflag(MAC), [CEXTERR] = markflag(MAC), | ||
38 | [XONTXC] = markflag(MAC), [XOFFRXC] = markflag(MAC), | ||
39 | [RJC] = markflag(MAC), [RNBC] = markflag(MAC), | ||
40 | [MGTPDC] = markflag(MAC), [MGTPTC] = markflag(MAC), | ||
41 | diff --git a/hw/net/e1000_regs.h b/hw/net/e1000_regs.h | ||
42 | index XXXXXXX..XXXXXXX 100644 | ||
43 | --- a/hw/net/e1000_regs.h | ||
44 | +++ b/hw/net/e1000_regs.h | ||
45 | @@ -XXX,XX +XXX,XX @@ | ||
46 | #define E1000_COLC 0x04028 /* Collision Count - R/clr */ | ||
47 | #define E1000_DC 0x04030 /* Defer Count - R/clr */ | ||
48 | #define E1000_TNCRS 0x04034 /* TX-No CRS - R/clr */ | ||
49 | -#define E1000_SEC 0x04038 /* Sequence Error Count - R/clr */ | ||
50 | +#define E1000_SEQEC 0x04038 /* Sequence Error Count - R/clr */ | ||
51 | #define E1000_CEXTERR 0x0403C /* Carrier Extension Error Count - R/clr */ | ||
52 | #define E1000_RLEC 0x04040 /* Receive Length Error Count - R/clr */ | ||
53 | #define E1000_XONRXC 0x04048 /* XON RX Count - R/clr */ | ||
54 | diff --git a/hw/net/e1000e_core.c b/hw/net/e1000e_core.c | ||
55 | index XXXXXXX..XXXXXXX 100644 | ||
56 | --- a/hw/net/e1000e_core.c | ||
57 | +++ b/hw/net/e1000e_core.c | ||
58 | @@ -XXX,XX +XXX,XX @@ static uint32_t (*e1000e_macreg_readops[])(E1000ECore *, int) = { | ||
59 | e1000e_getreg(RDLEN0), | ||
60 | e1000e_getreg(RDH1), | ||
61 | e1000e_getreg(LATECOL), | ||
62 | - e1000e_getreg(SEC), | ||
63 | + e1000e_getreg(SEQEC), | ||
64 | e1000e_getreg(XONTXC), | ||
65 | e1000e_getreg(WUS), | ||
66 | e1000e_getreg(GORCL), | ||
67 | diff --git a/hw/net/e1000x_common.h b/hw/net/e1000x_common.h | ||
68 | index XXXXXXX..XXXXXXX 100644 | ||
69 | --- a/hw/net/e1000x_common.h | ||
70 | +++ b/hw/net/e1000x_common.h | ||
71 | @@ -XXX,XX +XXX,XX @@ enum { | ||
72 | defreg(VFTA), defreg(VET), defreg(RDTR), defreg(RADV), | ||
73 | defreg(TADV), defreg(ITR), defreg(SCC), defreg(ECOL), | ||
74 | defreg(MCC), defreg(LATECOL), defreg(COLC), defreg(DC), | ||
75 | - defreg(TNCRS), defreg(SEC), defreg(CEXTERR), defreg(RLEC), | ||
76 | + defreg(TNCRS), defreg(SEQEC), defreg(CEXTERR), defreg(RLEC), | ||
77 | defreg(XONRXC), defreg(XONTXC), defreg(XOFFRXC), defreg(XOFFTXC), | ||
78 | defreg(FCRUC), defreg(AIT), defreg(TDFH), defreg(TDFT), | ||
79 | defreg(TDFHS), defreg(TDFTS), defreg(TDFPC), defreg(WUC), | ||
80 | -- | ||
81 | 2.7.4 | ||
82 | |||
83 | diff view generated by jsdifflib |
1 | From: Wang Yong <wang.yong155@zte.com.cn> | 1 | From: Cédric Le Goater <clg@kaod.org> |
---|---|---|---|
2 | 2 | ||
3 | Remove the task which check old packet in the comparing thread, | 3 | NC-SI (Network Controller Sideband Interface) enables a BMC to manage |
4 | then use IOthread context timer to handle it. | 4 | a set of NICs on a system. This model takes the simplest approach and |
5 | reverses the NC-SI packets to pretend a NIC is present and exercise | ||
6 | the Linux driver. | ||
5 | 7 | ||
6 | Process pactkets in the IOThread which arrived over the socket. | 8 | The NCSI header file <ncsi-pkt.h> comes from mainline Linux and was |
7 | we use iothread_get_g_main_context to create a new g_main_loop in | 9 | untabified. |
8 | the IOThread.then the packets from the primary and the secondary | ||
9 | are processed in the IOThread. | ||
10 | 10 | ||
11 | Finally remove the colo-compare thread using the IOThread instead. | 11 | Signed-off-by: Cédric Le Goater <clg@kaod.org> |
12 | 12 | Reviewed-by: Philippe Mathieu-Daudé <f4bug@amsat.org> | |
13 | Reviewed-by: Zhang Chen<zhangchen.fnst@cn.fujitsu.com> | 13 | Acked-by: Samuel Thibault <samuel.thibault@ens-lyon.org> |
14 | Signed-off-by: Wang Yong <wang.yong155@zte.com.cn> | ||
15 | Signed-off-by: Wang Guang <wang.guang55@zte.com.cn> | ||
16 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 14 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
17 | --- | 15 | --- |
18 | net/colo-compare.c | 83 +++++++++++++++++++++++++++++------------------------- | 16 | include/net/eth.h | 1 + |
19 | 1 file changed, 45 insertions(+), 38 deletions(-) | 17 | slirp/Makefile.objs | 2 +- |
18 | slirp/ncsi-pkt.h | 419 ++++++++++++++++++++++++++++++++++++++++++++++++++++ | ||
19 | slirp/ncsi.c | 130 ++++++++++++++++ | ||
20 | slirp/slirp.c | 4 + | ||
21 | slirp/slirp.h | 3 + | ||
22 | 6 files changed, 558 insertions(+), 1 deletion(-) | ||
23 | create mode 100644 slirp/ncsi-pkt.h | ||
24 | create mode 100644 slirp/ncsi.c | ||
20 | 25 | ||
21 | diff --git a/net/colo-compare.c b/net/colo-compare.c | 26 | diff --git a/include/net/eth.h b/include/net/eth.h |
22 | index XXXXXXX..XXXXXXX 100644 | 27 | index XXXXXXX..XXXXXXX 100644 |
23 | --- a/net/colo-compare.c | 28 | --- a/include/net/eth.h |
24 | +++ b/net/colo-compare.c | 29 | +++ b/include/net/eth.h |
30 | @@ -XXX,XX +XXX,XX @@ struct tcp_hdr { | ||
31 | #define ETH_P_IPV6 (0x86dd) | ||
32 | #define ETH_P_VLAN (0x8100) | ||
33 | #define ETH_P_DVLAN (0x88a8) | ||
34 | +#define ETH_P_NCSI (0x88f8) | ||
35 | #define ETH_P_UNKNOWN (0xffff) | ||
36 | #define VLAN_VID_MASK 0x0fff | ||
37 | #define IP_HEADER_VERSION_4 (4) | ||
38 | diff --git a/slirp/Makefile.objs b/slirp/Makefile.objs | ||
39 | index XXXXXXX..XXXXXXX 100644 | ||
40 | --- a/slirp/Makefile.objs | ||
41 | +++ b/slirp/Makefile.objs | ||
42 | @@ -XXX,XX +XXX,XX @@ common-obj-y = cksum.o if.o ip_icmp.o ip6_icmp.o ip6_input.o ip6_output.o \ | ||
43 | ip_input.o ip_output.o dnssearch.o dhcpv6.o | ||
44 | common-obj-y += slirp.o mbuf.o misc.o sbuf.o socket.o tcp_input.o tcp_output.o | ||
45 | common-obj-y += tcp_subr.o tcp_timer.o udp.o udp6.o bootp.o tftp.o arp_table.o \ | ||
46 | - ndp_table.o | ||
47 | + ndp_table.o ncsi.o | ||
48 | diff --git a/slirp/ncsi-pkt.h b/slirp/ncsi-pkt.h | ||
49 | new file mode 100644 | ||
50 | index XXXXXXX..XXXXXXX | ||
51 | --- /dev/null | ||
52 | +++ b/slirp/ncsi-pkt.h | ||
25 | @@ -XXX,XX +XXX,XX @@ | 53 | @@ -XXX,XX +XXX,XX @@ |
26 | #include "qemu/sockets.h" | 54 | +/* |
27 | #include "qapi-visit.h" | 55 | + * Copyright Gavin Shan, IBM Corporation 2016. |
28 | #include "net/colo.h" | 56 | + * |
29 | +#include "sysemu/iothread.h" | 57 | + * This program is free software; you can redistribute it and/or modify |
30 | 58 | + * it under the terms of the GNU General Public License as published by | |
31 | #define TYPE_COLO_COMPARE "colo-compare" | 59 | + * the Free Software Foundation; either version 2 of the License, or |
32 | #define COLO_COMPARE(obj) \ | 60 | + * (at your option) any later version. |
33 | @@ -XXX,XX +XXX,XX @@ typedef struct CompareState { | 61 | + */ |
34 | GQueue conn_list; | 62 | + |
35 | /* Record the connection without repetition */ | 63 | +#ifndef NCSI_PKT_H |
36 | GHashTable *connection_track_table; | 64 | +#define NCSI_PKT_H |
37 | - /* This thread just do packet compare job */ | 65 | + |
38 | - QemuThread thread; | 66 | +/* from linux/net/ncsi/ncsi-pkt.h */ |
39 | 67 | +#define __be32 uint32_t | |
40 | + IOThread *iothread; | 68 | +#define __be16 uint16_t |
41 | GMainContext *worker_context; | 69 | + |
42 | - GMainLoop *compare_loop; | 70 | +struct ncsi_pkt_hdr { |
43 | + QEMUTimer *packet_check_timer; | 71 | + unsigned char mc_id; /* Management controller ID */ |
44 | } CompareState; | 72 | + unsigned char revision; /* NCSI version - 0x01 */ |
45 | 73 | + unsigned char reserved; /* Reserved */ | |
46 | typedef struct CompareClass { | 74 | + unsigned char id; /* Packet sequence number */ |
47 | @@ -XXX,XX +XXX,XX @@ static void compare_sec_chr_in(void *opaque, const uint8_t *buf, int size) | 75 | + unsigned char type; /* Packet type */ |
48 | * Check old packet regularly so it can watch for any packets | 76 | + unsigned char channel; /* Network controller ID */ |
49 | * that the secondary hasn't produced equivalents of. | 77 | + __be16 length; /* Payload length */ |
50 | */ | 78 | + __be32 reserved1[2]; /* Reserved */ |
51 | -static gboolean check_old_packet_regular(void *opaque) | 79 | +}; |
52 | +static void check_old_packet_regular(void *opaque) | 80 | + |
53 | { | 81 | +struct ncsi_cmd_pkt_hdr { |
54 | CompareState *s = opaque; | 82 | + struct ncsi_pkt_hdr common; /* Common NCSI packet header */ |
55 | 83 | +}; | |
56 | /* if have old packet we will notify checkpoint */ | 84 | + |
57 | colo_old_packet_check(s); | 85 | +struct ncsi_rsp_pkt_hdr { |
58 | + timer_mod(s->packet_check_timer, qemu_clock_get_ms(QEMU_CLOCK_VIRTUAL) + | 86 | + struct ncsi_pkt_hdr common; /* Common NCSI packet header */ |
59 | + REGULAR_PACKET_CHECK_MS); | 87 | + __be16 code; /* Response code */ |
88 | + __be16 reason; /* Response reason */ | ||
89 | +}; | ||
90 | + | ||
91 | +struct ncsi_aen_pkt_hdr { | ||
92 | + struct ncsi_pkt_hdr common; /* Common NCSI packet header */ | ||
93 | + unsigned char reserved2[3]; /* Reserved */ | ||
94 | + unsigned char type; /* AEN packet type */ | ||
95 | +}; | ||
96 | + | ||
97 | +/* NCSI common command packet */ | ||
98 | +struct ncsi_cmd_pkt { | ||
99 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
100 | + __be32 checksum; /* Checksum */ | ||
101 | + unsigned char pad[26]; | ||
102 | +}; | ||
103 | + | ||
104 | +struct ncsi_rsp_pkt { | ||
105 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
106 | + __be32 checksum; /* Checksum */ | ||
107 | + unsigned char pad[22]; | ||
108 | +}; | ||
109 | + | ||
110 | +/* Select Package */ | ||
111 | +struct ncsi_cmd_sp_pkt { | ||
112 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
113 | + unsigned char reserved[3]; /* Reserved */ | ||
114 | + unsigned char hw_arbitration; /* HW arbitration */ | ||
115 | + __be32 checksum; /* Checksum */ | ||
116 | + unsigned char pad[22]; | ||
117 | +}; | ||
118 | + | ||
119 | +/* Disable Channel */ | ||
120 | +struct ncsi_cmd_dc_pkt { | ||
121 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
122 | + unsigned char reserved[3]; /* Reserved */ | ||
123 | + unsigned char ald; /* Allow link down */ | ||
124 | + __be32 checksum; /* Checksum */ | ||
125 | + unsigned char pad[22]; | ||
126 | +}; | ||
127 | + | ||
128 | +/* Reset Channel */ | ||
129 | +struct ncsi_cmd_rc_pkt { | ||
130 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
131 | + __be32 reserved; /* Reserved */ | ||
132 | + __be32 checksum; /* Checksum */ | ||
133 | + unsigned char pad[22]; | ||
134 | +}; | ||
135 | + | ||
136 | +/* AEN Enable */ | ||
137 | +struct ncsi_cmd_ae_pkt { | ||
138 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
139 | + unsigned char reserved[3]; /* Reserved */ | ||
140 | + unsigned char mc_id; /* MC ID */ | ||
141 | + __be32 mode; /* AEN working mode */ | ||
142 | + __be32 checksum; /* Checksum */ | ||
143 | + unsigned char pad[18]; | ||
144 | +}; | ||
145 | + | ||
146 | +/* Set Link */ | ||
147 | +struct ncsi_cmd_sl_pkt { | ||
148 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
149 | + __be32 mode; /* Link working mode */ | ||
150 | + __be32 oem_mode; /* OEM link mode */ | ||
151 | + __be32 checksum; /* Checksum */ | ||
152 | + unsigned char pad[18]; | ||
153 | +}; | ||
154 | + | ||
155 | +/* Set VLAN Filter */ | ||
156 | +struct ncsi_cmd_svf_pkt { | ||
157 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
158 | + __be16 reserved; /* Reserved */ | ||
159 | + __be16 vlan; /* VLAN ID */ | ||
160 | + __be16 reserved1; /* Reserved */ | ||
161 | + unsigned char index; /* VLAN table index */ | ||
162 | + unsigned char enable; /* Enable or disable */ | ||
163 | + __be32 checksum; /* Checksum */ | ||
164 | + unsigned char pad[14]; | ||
165 | +}; | ||
166 | + | ||
167 | +/* Enable VLAN */ | ||
168 | +struct ncsi_cmd_ev_pkt { | ||
169 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
170 | + unsigned char reserved[3]; /* Reserved */ | ||
171 | + unsigned char mode; /* VLAN filter mode */ | ||
172 | + __be32 checksum; /* Checksum */ | ||
173 | + unsigned char pad[22]; | ||
174 | +}; | ||
175 | + | ||
176 | +/* Set MAC Address */ | ||
177 | +struct ncsi_cmd_sma_pkt { | ||
178 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
179 | + unsigned char mac[6]; /* MAC address */ | ||
180 | + unsigned char index; /* MAC table index */ | ||
181 | + unsigned char at_e; /* Addr type and operation */ | ||
182 | + __be32 checksum; /* Checksum */ | ||
183 | + unsigned char pad[18]; | ||
184 | +}; | ||
185 | + | ||
186 | +/* Enable Broadcast Filter */ | ||
187 | +struct ncsi_cmd_ebf_pkt { | ||
188 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
189 | + __be32 mode; /* Filter mode */ | ||
190 | + __be32 checksum; /* Checksum */ | ||
191 | + unsigned char pad[22]; | ||
192 | +}; | ||
193 | + | ||
194 | +/* Enable Global Multicast Filter */ | ||
195 | +struct ncsi_cmd_egmf_pkt { | ||
196 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
197 | + __be32 mode; /* Global MC mode */ | ||
198 | + __be32 checksum; /* Checksum */ | ||
199 | + unsigned char pad[22]; | ||
200 | +}; | ||
201 | + | ||
202 | +/* Set NCSI Flow Control */ | ||
203 | +struct ncsi_cmd_snfc_pkt { | ||
204 | + struct ncsi_cmd_pkt_hdr cmd; /* Command header */ | ||
205 | + unsigned char reserved[3]; /* Reserved */ | ||
206 | + unsigned char mode; /* Flow control mode */ | ||
207 | + __be32 checksum; /* Checksum */ | ||
208 | + unsigned char pad[22]; | ||
209 | +}; | ||
210 | + | ||
211 | +/* Get Link Status */ | ||
212 | +struct ncsi_rsp_gls_pkt { | ||
213 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
214 | + __be32 status; /* Link status */ | ||
215 | + __be32 other; /* Other indications */ | ||
216 | + __be32 oem_status; /* OEM link status */ | ||
217 | + __be32 checksum; | ||
218 | + unsigned char pad[10]; | ||
219 | +}; | ||
220 | + | ||
221 | +/* Get Version ID */ | ||
222 | +struct ncsi_rsp_gvi_pkt { | ||
223 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
224 | + __be32 ncsi_version; /* NCSI version */ | ||
225 | + unsigned char reserved[3]; /* Reserved */ | ||
226 | + unsigned char alpha2; /* NCSI version */ | ||
227 | + unsigned char fw_name[12]; /* f/w name string */ | ||
228 | + __be32 fw_version; /* f/w version */ | ||
229 | + __be16 pci_ids[4]; /* PCI IDs */ | ||
230 | + __be32 mf_id; /* Manufacture ID */ | ||
231 | + __be32 checksum; | ||
232 | +}; | ||
233 | + | ||
234 | +/* Get Capabilities */ | ||
235 | +struct ncsi_rsp_gc_pkt { | ||
236 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
237 | + __be32 cap; /* Capabilities */ | ||
238 | + __be32 bc_cap; /* Broadcast cap */ | ||
239 | + __be32 mc_cap; /* Multicast cap */ | ||
240 | + __be32 buf_cap; /* Buffering cap */ | ||
241 | + __be32 aen_cap; /* AEN cap */ | ||
242 | + unsigned char vlan_cnt; /* VLAN filter count */ | ||
243 | + unsigned char mixed_cnt; /* Mix filter count */ | ||
244 | + unsigned char mc_cnt; /* MC filter count */ | ||
245 | + unsigned char uc_cnt; /* UC filter count */ | ||
246 | + unsigned char reserved[2]; /* Reserved */ | ||
247 | + unsigned char vlan_mode; /* VLAN mode */ | ||
248 | + unsigned char channel_cnt; /* Channel count */ | ||
249 | + __be32 checksum; /* Checksum */ | ||
250 | +}; | ||
251 | + | ||
252 | +/* Get Parameters */ | ||
253 | +struct ncsi_rsp_gp_pkt { | ||
254 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
255 | + unsigned char mac_cnt; /* Number of MAC addr */ | ||
256 | + unsigned char reserved[2]; /* Reserved */ | ||
257 | + unsigned char mac_enable; /* MAC addr enable flags */ | ||
258 | + unsigned char vlan_cnt; /* VLAN tag count */ | ||
259 | + unsigned char reserved1; /* Reserved */ | ||
260 | + __be16 vlan_enable; /* VLAN tag enable flags */ | ||
261 | + __be32 link_mode; /* Link setting */ | ||
262 | + __be32 bc_mode; /* BC filter mode */ | ||
263 | + __be32 valid_modes; /* Valid mode parameters */ | ||
264 | + unsigned char vlan_mode; /* VLAN mode */ | ||
265 | + unsigned char fc_mode; /* Flow control mode */ | ||
266 | + unsigned char reserved2[2]; /* Reserved */ | ||
267 | + __be32 aen_mode; /* AEN mode */ | ||
268 | + unsigned char mac[6]; /* Supported MAC addr */ | ||
269 | + __be16 vlan; /* Supported VLAN tags */ | ||
270 | + __be32 checksum; /* Checksum */ | ||
271 | +}; | ||
272 | + | ||
273 | +/* Get Controller Packet Statistics */ | ||
274 | +struct ncsi_rsp_gcps_pkt { | ||
275 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
276 | + __be32 cnt_hi; /* Counter cleared */ | ||
277 | + __be32 cnt_lo; /* Counter cleared */ | ||
278 | + __be32 rx_bytes; /* Rx bytes */ | ||
279 | + __be32 tx_bytes; /* Tx bytes */ | ||
280 | + __be32 rx_uc_pkts; /* Rx UC packets */ | ||
281 | + __be32 rx_mc_pkts; /* Rx MC packets */ | ||
282 | + __be32 rx_bc_pkts; /* Rx BC packets */ | ||
283 | + __be32 tx_uc_pkts; /* Tx UC packets */ | ||
284 | + __be32 tx_mc_pkts; /* Tx MC packets */ | ||
285 | + __be32 tx_bc_pkts; /* Tx BC packets */ | ||
286 | + __be32 fcs_err; /* FCS errors */ | ||
287 | + __be32 align_err; /* Alignment errors */ | ||
288 | + __be32 false_carrier; /* False carrier detection */ | ||
289 | + __be32 runt_pkts; /* Rx runt packets */ | ||
290 | + __be32 jabber_pkts; /* Rx jabber packets */ | ||
291 | + __be32 rx_pause_xon; /* Rx pause XON frames */ | ||
292 | + __be32 rx_pause_xoff; /* Rx XOFF frames */ | ||
293 | + __be32 tx_pause_xon; /* Tx XON frames */ | ||
294 | + __be32 tx_pause_xoff; /* Tx XOFF frames */ | ||
295 | + __be32 tx_s_collision; /* Single collision frames */ | ||
296 | + __be32 tx_m_collision; /* Multiple collision frames */ | ||
297 | + __be32 l_collision; /* Late collision frames */ | ||
298 | + __be32 e_collision; /* Excessive collision frames */ | ||
299 | + __be32 rx_ctl_frames; /* Rx control frames */ | ||
300 | + __be32 rx_64_frames; /* Rx 64-bytes frames */ | ||
301 | + __be32 rx_127_frames; /* Rx 65-127 bytes frames */ | ||
302 | + __be32 rx_255_frames; /* Rx 128-255 bytes frames */ | ||
303 | + __be32 rx_511_frames; /* Rx 256-511 bytes frames */ | ||
304 | + __be32 rx_1023_frames; /* Rx 512-1023 bytes frames */ | ||
305 | + __be32 rx_1522_frames; /* Rx 1024-1522 bytes frames */ | ||
306 | + __be32 rx_9022_frames; /* Rx 1523-9022 bytes frames */ | ||
307 | + __be32 tx_64_frames; /* Tx 64-bytes frames */ | ||
308 | + __be32 tx_127_frames; /* Tx 65-127 bytes frames */ | ||
309 | + __be32 tx_255_frames; /* Tx 128-255 bytes frames */ | ||
310 | + __be32 tx_511_frames; /* Tx 256-511 bytes frames */ | ||
311 | + __be32 tx_1023_frames; /* Tx 512-1023 bytes frames */ | ||
312 | + __be32 tx_1522_frames; /* Tx 1024-1522 bytes frames */ | ||
313 | + __be32 tx_9022_frames; /* Tx 1523-9022 bytes frames */ | ||
314 | + __be32 rx_valid_bytes; /* Rx valid bytes */ | ||
315 | + __be32 rx_runt_pkts; /* Rx error runt packets */ | ||
316 | + __be32 rx_jabber_pkts; /* Rx error jabber packets */ | ||
317 | + __be32 checksum; /* Checksum */ | ||
318 | +}; | ||
319 | + | ||
320 | +/* Get NCSI Statistics */ | ||
321 | +struct ncsi_rsp_gns_pkt { | ||
322 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
323 | + __be32 rx_cmds; /* Rx NCSI commands */ | ||
324 | + __be32 dropped_cmds; /* Dropped commands */ | ||
325 | + __be32 cmd_type_errs; /* Command type errors */ | ||
326 | + __be32 cmd_csum_errs; /* Command checksum errors */ | ||
327 | + __be32 rx_pkts; /* Rx NCSI packets */ | ||
328 | + __be32 tx_pkts; /* Tx NCSI packets */ | ||
329 | + __be32 tx_aen_pkts; /* Tx AEN packets */ | ||
330 | + __be32 checksum; /* Checksum */ | ||
331 | +}; | ||
332 | + | ||
333 | +/* Get NCSI Pass-through Statistics */ | ||
334 | +struct ncsi_rsp_gnpts_pkt { | ||
335 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
336 | + __be32 tx_pkts; /* Tx packets */ | ||
337 | + __be32 tx_dropped; /* Tx dropped packets */ | ||
338 | + __be32 tx_channel_err; /* Tx channel errors */ | ||
339 | + __be32 tx_us_err; /* Tx undersize errors */ | ||
340 | + __be32 rx_pkts; /* Rx packets */ | ||
341 | + __be32 rx_dropped; /* Rx dropped packets */ | ||
342 | + __be32 rx_channel_err; /* Rx channel errors */ | ||
343 | + __be32 rx_us_err; /* Rx undersize errors */ | ||
344 | + __be32 rx_os_err; /* Rx oversize errors */ | ||
345 | + __be32 checksum; /* Checksum */ | ||
346 | +}; | ||
347 | + | ||
348 | +/* Get package status */ | ||
349 | +struct ncsi_rsp_gps_pkt { | ||
350 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
351 | + __be32 status; /* Hardware arbitration status */ | ||
352 | + __be32 checksum; | ||
353 | +}; | ||
354 | + | ||
355 | +/* Get package UUID */ | ||
356 | +struct ncsi_rsp_gpuuid_pkt { | ||
357 | + struct ncsi_rsp_pkt_hdr rsp; /* Response header */ | ||
358 | + unsigned char uuid[16]; /* UUID */ | ||
359 | + __be32 checksum; | ||
360 | +}; | ||
361 | + | ||
362 | +/* AEN: Link State Change */ | ||
363 | +struct ncsi_aen_lsc_pkt { | ||
364 | + struct ncsi_aen_pkt_hdr aen; /* AEN header */ | ||
365 | + __be32 status; /* Link status */ | ||
366 | + __be32 oem_status; /* OEM link status */ | ||
367 | + __be32 checksum; /* Checksum */ | ||
368 | + unsigned char pad[14]; | ||
369 | +}; | ||
370 | + | ||
371 | +/* AEN: Configuration Required */ | ||
372 | +struct ncsi_aen_cr_pkt { | ||
373 | + struct ncsi_aen_pkt_hdr aen; /* AEN header */ | ||
374 | + __be32 checksum; /* Checksum */ | ||
375 | + unsigned char pad[22]; | ||
376 | +}; | ||
377 | + | ||
378 | +/* AEN: Host Network Controller Driver Status Change */ | ||
379 | +struct ncsi_aen_hncdsc_pkt { | ||
380 | + struct ncsi_aen_pkt_hdr aen; /* AEN header */ | ||
381 | + __be32 status; /* Status */ | ||
382 | + __be32 checksum; /* Checksum */ | ||
383 | + unsigned char pad[18]; | ||
384 | +}; | ||
385 | + | ||
386 | +/* NCSI packet revision */ | ||
387 | +#define NCSI_PKT_REVISION 0x01 | ||
388 | + | ||
389 | +/* NCSI packet commands */ | ||
390 | +#define NCSI_PKT_CMD_CIS 0x00 /* Clear Initial State */ | ||
391 | +#define NCSI_PKT_CMD_SP 0x01 /* Select Package */ | ||
392 | +#define NCSI_PKT_CMD_DP 0x02 /* Deselect Package */ | ||
393 | +#define NCSI_PKT_CMD_EC 0x03 /* Enable Channel */ | ||
394 | +#define NCSI_PKT_CMD_DC 0x04 /* Disable Channel */ | ||
395 | +#define NCSI_PKT_CMD_RC 0x05 /* Reset Channel */ | ||
396 | +#define NCSI_PKT_CMD_ECNT 0x06 /* Enable Channel Network Tx */ | ||
397 | +#define NCSI_PKT_CMD_DCNT 0x07 /* Disable Channel Network Tx */ | ||
398 | +#define NCSI_PKT_CMD_AE 0x08 /* AEN Enable */ | ||
399 | +#define NCSI_PKT_CMD_SL 0x09 /* Set Link */ | ||
400 | +#define NCSI_PKT_CMD_GLS 0x0a /* Get Link */ | ||
401 | +#define NCSI_PKT_CMD_SVF 0x0b /* Set VLAN Filter */ | ||
402 | +#define NCSI_PKT_CMD_EV 0x0c /* Enable VLAN */ | ||
403 | +#define NCSI_PKT_CMD_DV 0x0d /* Disable VLAN */ | ||
404 | +#define NCSI_PKT_CMD_SMA 0x0e /* Set MAC address */ | ||
405 | +#define NCSI_PKT_CMD_EBF 0x10 /* Enable Broadcast Filter */ | ||
406 | +#define NCSI_PKT_CMD_DBF 0x11 /* Disable Broadcast Filter */ | ||
407 | +#define NCSI_PKT_CMD_EGMF 0x12 /* Enable Global Multicast Filter */ | ||
408 | +#define NCSI_PKT_CMD_DGMF 0x13 /* Disable Global Multicast Filter */ | ||
409 | +#define NCSI_PKT_CMD_SNFC 0x14 /* Set NCSI Flow Control */ | ||
410 | +#define NCSI_PKT_CMD_GVI 0x15 /* Get Version ID */ | ||
411 | +#define NCSI_PKT_CMD_GC 0x16 /* Get Capabilities */ | ||
412 | +#define NCSI_PKT_CMD_GP 0x17 /* Get Parameters */ | ||
413 | +#define NCSI_PKT_CMD_GCPS 0x18 /* Get Controller Packet Statistics */ | ||
414 | +#define NCSI_PKT_CMD_GNS 0x19 /* Get NCSI Statistics */ | ||
415 | +#define NCSI_PKT_CMD_GNPTS 0x1a /* Get NCSI Pass-throu Statistics */ | ||
416 | +#define NCSI_PKT_CMD_GPS 0x1b /* Get package status */ | ||
417 | +#define NCSI_PKT_CMD_OEM 0x50 /* OEM */ | ||
418 | +#define NCSI_PKT_CMD_PLDM 0x51 /* PLDM request over NCSI over RBT */ | ||
419 | +#define NCSI_PKT_CMD_GPUUID 0x52 /* Get package UUID */ | ||
420 | + | ||
421 | +/* NCSI packet responses */ | ||
422 | +#define NCSI_PKT_RSP_CIS (NCSI_PKT_CMD_CIS + 0x80) | ||
423 | +#define NCSI_PKT_RSP_SP (NCSI_PKT_CMD_SP + 0x80) | ||
424 | +#define NCSI_PKT_RSP_DP (NCSI_PKT_CMD_DP + 0x80) | ||
425 | +#define NCSI_PKT_RSP_EC (NCSI_PKT_CMD_EC + 0x80) | ||
426 | +#define NCSI_PKT_RSP_DC (NCSI_PKT_CMD_DC + 0x80) | ||
427 | +#define NCSI_PKT_RSP_RC (NCSI_PKT_CMD_RC + 0x80) | ||
428 | +#define NCSI_PKT_RSP_ECNT (NCSI_PKT_CMD_ECNT + 0x80) | ||
429 | +#define NCSI_PKT_RSP_DCNT (NCSI_PKT_CMD_DCNT + 0x80) | ||
430 | +#define NCSI_PKT_RSP_AE (NCSI_PKT_CMD_AE + 0x80) | ||
431 | +#define NCSI_PKT_RSP_SL (NCSI_PKT_CMD_SL + 0x80) | ||
432 | +#define NCSI_PKT_RSP_GLS (NCSI_PKT_CMD_GLS + 0x80) | ||
433 | +#define NCSI_PKT_RSP_SVF (NCSI_PKT_CMD_SVF + 0x80) | ||
434 | +#define NCSI_PKT_RSP_EV (NCSI_PKT_CMD_EV + 0x80) | ||
435 | +#define NCSI_PKT_RSP_DV (NCSI_PKT_CMD_DV + 0x80) | ||
436 | +#define NCSI_PKT_RSP_SMA (NCSI_PKT_CMD_SMA + 0x80) | ||
437 | +#define NCSI_PKT_RSP_EBF (NCSI_PKT_CMD_EBF + 0x80) | ||
438 | +#define NCSI_PKT_RSP_DBF (NCSI_PKT_CMD_DBF + 0x80) | ||
439 | +#define NCSI_PKT_RSP_EGMF (NCSI_PKT_CMD_EGMF + 0x80) | ||
440 | +#define NCSI_PKT_RSP_DGMF (NCSI_PKT_CMD_DGMF + 0x80) | ||
441 | +#define NCSI_PKT_RSP_SNFC (NCSI_PKT_CMD_SNFC + 0x80) | ||
442 | +#define NCSI_PKT_RSP_GVI (NCSI_PKT_CMD_GVI + 0x80) | ||
443 | +#define NCSI_PKT_RSP_GC (NCSI_PKT_CMD_GC + 0x80) | ||
444 | +#define NCSI_PKT_RSP_GP (NCSI_PKT_CMD_GP + 0x80) | ||
445 | +#define NCSI_PKT_RSP_GCPS (NCSI_PKT_CMD_GCPS + 0x80) | ||
446 | +#define NCSI_PKT_RSP_GNS (NCSI_PKT_CMD_GNS + 0x80) | ||
447 | +#define NCSI_PKT_RSP_GNPTS (NCSI_PKT_CMD_GNPTS + 0x80) | ||
448 | +#define NCSI_PKT_RSP_GPS (NCSI_PKT_CMD_GPS + 0x80) | ||
449 | +#define NCSI_PKT_RSP_OEM (NCSI_PKT_CMD_OEM + 0x80) | ||
450 | +#define NCSI_PKT_RSP_PLDM (NCSI_PKT_CMD_PLDM + 0x80) | ||
451 | +#define NCSI_PKT_RSP_GPUUID (NCSI_PKT_CMD_GPUUID + 0x80) | ||
452 | + | ||
453 | +/* NCSI response code/reason */ | ||
454 | +#define NCSI_PKT_RSP_C_COMPLETED 0x0000 /* Command Completed */ | ||
455 | +#define NCSI_PKT_RSP_C_FAILED 0x0001 /* Command Failed */ | ||
456 | +#define NCSI_PKT_RSP_C_UNAVAILABLE 0x0002 /* Command Unavailable */ | ||
457 | +#define NCSI_PKT_RSP_C_UNSUPPORTED 0x0003 /* Command Unsupported */ | ||
458 | +#define NCSI_PKT_RSP_R_NO_ERROR 0x0000 /* No Error */ | ||
459 | +#define NCSI_PKT_RSP_R_INTERFACE 0x0001 /* Interface not ready */ | ||
460 | +#define NCSI_PKT_RSP_R_PARAM 0x0002 /* Invalid Parameter */ | ||
461 | +#define NCSI_PKT_RSP_R_CHANNEL 0x0003 /* Channel not Ready */ | ||
462 | +#define NCSI_PKT_RSP_R_PACKAGE 0x0004 /* Package not Ready */ | ||
463 | +#define NCSI_PKT_RSP_R_LENGTH 0x0005 /* Invalid payload length */ | ||
464 | +#define NCSI_PKT_RSP_R_UNKNOWN 0x7fff /* Command type unsupported */ | ||
465 | + | ||
466 | +/* NCSI AEN packet type */ | ||
467 | +#define NCSI_PKT_AEN 0xFF /* AEN Packet */ | ||
468 | +#define NCSI_PKT_AEN_LSC 0x00 /* Link status change */ | ||
469 | +#define NCSI_PKT_AEN_CR 0x01 /* Configuration required */ | ||
470 | +#define NCSI_PKT_AEN_HNCDSC 0x02 /* HNC driver status change */ | ||
471 | + | ||
472 | +#endif /* NCSI_PKT_H */ | ||
473 | diff --git a/slirp/ncsi.c b/slirp/ncsi.c | ||
474 | new file mode 100644 | ||
475 | index XXXXXXX..XXXXXXX | ||
476 | --- /dev/null | ||
477 | +++ b/slirp/ncsi.c | ||
478 | @@ -XXX,XX +XXX,XX @@ | ||
479 | +/* | ||
480 | + * NC-SI (Network Controller Sideband Interface) "echo" model | ||
481 | + * | ||
482 | + * Copyright (C) 2016 IBM Corp. | ||
483 | + * | ||
484 | + * This code is licensed under the GPL version 2 or later. See the | ||
485 | + * COPYING file in the top-level directory. | ||
486 | + */ | ||
487 | +#include "qemu/osdep.h" | ||
488 | +#include "slirp.h" | ||
489 | + | ||
490 | +#include "ncsi-pkt.h" | ||
491 | + | ||
492 | +/* Get Capabilities */ | ||
493 | +static int ncsi_rsp_handler_gc(struct ncsi_rsp_pkt_hdr *rnh) | ||
494 | +{ | ||
495 | + struct ncsi_rsp_gc_pkt *rsp = (struct ncsi_rsp_gc_pkt *) rnh; | ||
496 | + | ||
497 | + rsp->cap = htonl(~0); | ||
498 | + rsp->bc_cap = htonl(~0); | ||
499 | + rsp->mc_cap = htonl(~0); | ||
500 | + rsp->buf_cap = htonl(~0); | ||
501 | + rsp->aen_cap = htonl(~0); | ||
502 | + rsp->vlan_mode = 0xff; | ||
503 | + rsp->uc_cnt = 2; | ||
504 | + return 0; | ||
60 | +} | 505 | +} |
61 | + | 506 | + |
62 | +static void colo_compare_timer_init(CompareState *s) | 507 | +/* Get Link status */ |
508 | +static int ncsi_rsp_handler_gls(struct ncsi_rsp_pkt_hdr *rnh) | ||
63 | +{ | 509 | +{ |
64 | + AioContext *ctx = iothread_get_aio_context(s->iothread); | 510 | + struct ncsi_rsp_gls_pkt *rsp = (struct ncsi_rsp_gls_pkt *) rnh; |
65 | 511 | + | |
66 | - return TRUE; | 512 | + rsp->status = htonl(0x1); |
67 | + s->packet_check_timer = aio_timer_new(ctx, QEMU_CLOCK_VIRTUAL, | 513 | + return 0; |
68 | + SCALE_MS, check_old_packet_regular, | 514 | +} |
69 | + s); | 515 | + |
70 | + timer_mod(s->packet_check_timer, qemu_clock_get_ms(QEMU_CLOCK_VIRTUAL) + | 516 | +static const struct ncsi_rsp_handler { |
71 | + REGULAR_PACKET_CHECK_MS); | 517 | + unsigned char type; |
72 | } | 518 | + int payload; |
73 | 519 | + int (*handler)(struct ncsi_rsp_pkt_hdr *rnh); | |
74 | -static void *colo_compare_thread(void *opaque) | 520 | +} ncsi_rsp_handlers[] = { |
75 | +static void colo_compare_timer_del(CompareState *s) | 521 | + { NCSI_PKT_RSP_CIS, 4, NULL }, |
76 | { | 522 | + { NCSI_PKT_RSP_SP, 4, NULL }, |
77 | - CompareState *s = opaque; | 523 | + { NCSI_PKT_RSP_DP, 4, NULL }, |
78 | - GSource *timeout_source; | 524 | + { NCSI_PKT_RSP_EC, 4, NULL }, |
79 | + if (s->packet_check_timer) { | 525 | + { NCSI_PKT_RSP_DC, 4, NULL }, |
80 | + timer_del(s->packet_check_timer); | 526 | + { NCSI_PKT_RSP_RC, 4, NULL }, |
81 | + timer_free(s->packet_check_timer); | 527 | + { NCSI_PKT_RSP_ECNT, 4, NULL }, |
82 | + s->packet_check_timer = NULL; | 528 | + { NCSI_PKT_RSP_DCNT, 4, NULL }, |
529 | + { NCSI_PKT_RSP_AE, 4, NULL }, | ||
530 | + { NCSI_PKT_RSP_SL, 4, NULL }, | ||
531 | + { NCSI_PKT_RSP_GLS, 16, ncsi_rsp_handler_gls }, | ||
532 | + { NCSI_PKT_RSP_SVF, 4, NULL }, | ||
533 | + { NCSI_PKT_RSP_EV, 4, NULL }, | ||
534 | + { NCSI_PKT_RSP_DV, 4, NULL }, | ||
535 | + { NCSI_PKT_RSP_SMA, 4, NULL }, | ||
536 | + { NCSI_PKT_RSP_EBF, 4, NULL }, | ||
537 | + { NCSI_PKT_RSP_DBF, 4, NULL }, | ||
538 | + { NCSI_PKT_RSP_EGMF, 4, NULL }, | ||
539 | + { NCSI_PKT_RSP_DGMF, 4, NULL }, | ||
540 | + { NCSI_PKT_RSP_SNFC, 4, NULL }, | ||
541 | + { NCSI_PKT_RSP_GVI, 36, NULL }, | ||
542 | + { NCSI_PKT_RSP_GC, 32, ncsi_rsp_handler_gc }, | ||
543 | + { NCSI_PKT_RSP_GP, -1, NULL }, | ||
544 | + { NCSI_PKT_RSP_GCPS, 172, NULL }, | ||
545 | + { NCSI_PKT_RSP_GNS, 172, NULL }, | ||
546 | + { NCSI_PKT_RSP_GNPTS, 172, NULL }, | ||
547 | + { NCSI_PKT_RSP_GPS, 8, NULL }, | ||
548 | + { NCSI_PKT_RSP_OEM, 0, NULL }, | ||
549 | + { NCSI_PKT_RSP_PLDM, 0, NULL }, | ||
550 | + { NCSI_PKT_RSP_GPUUID, 20, NULL } | ||
551 | +}; | ||
552 | + | ||
553 | +/* | ||
554 | + * packet format : ncsi header + payload + checksum | ||
555 | + */ | ||
556 | +#define NCSI_MAX_PAYLOAD 172 | ||
557 | +#define NCSI_MAX_LEN (sizeof(struct ncsi_pkt_hdr) + NCSI_MAX_PAYLOAD + 4) | ||
558 | + | ||
559 | +void ncsi_input(Slirp *slirp, const uint8_t *pkt, int pkt_len) | ||
560 | +{ | ||
561 | + struct ncsi_pkt_hdr *nh = (struct ncsi_pkt_hdr *)(pkt + ETH_HLEN); | ||
562 | + uint8_t ncsi_reply[ETH_HLEN + NCSI_MAX_LEN]; | ||
563 | + struct ethhdr *reh = (struct ethhdr *)ncsi_reply; | ||
564 | + struct ncsi_rsp_pkt_hdr *rnh = (struct ncsi_rsp_pkt_hdr *) | ||
565 | + (ncsi_reply + ETH_HLEN); | ||
566 | + const struct ncsi_rsp_handler *handler = NULL; | ||
567 | + int i; | ||
568 | + | ||
569 | + memset(ncsi_reply, 0, sizeof(ncsi_reply)); | ||
570 | + | ||
571 | + memset(reh->h_dest, 0xff, ETH_ALEN); | ||
572 | + memset(reh->h_source, 0xff, ETH_ALEN); | ||
573 | + reh->h_proto = htons(ETH_P_NCSI); | ||
574 | + | ||
575 | + for (i = 0; i < ARRAY_SIZE(ncsi_rsp_handlers); i++) { | ||
576 | + if (ncsi_rsp_handlers[i].type == nh->type + 0x80) { | ||
577 | + handler = &ncsi_rsp_handlers[i]; | ||
578 | + break; | ||
579 | + } | ||
83 | + } | 580 | + } |
84 | + } | 581 | + |
85 | 582 | + rnh->common.mc_id = nh->mc_id; | |
86 | - s->worker_context = g_main_context_new(); | 583 | + rnh->common.revision = NCSI_PKT_REVISION; |
87 | +static void colo_compare_iothread(CompareState *s) | 584 | + rnh->common.id = nh->id; |
88 | +{ | 585 | + rnh->common.type = nh->type + 0x80; |
89 | + object_ref(OBJECT(s->iothread)); | 586 | + rnh->common.channel = nh->channel; |
90 | + s->worker_context = iothread_get_g_main_context(s->iothread); | 587 | + |
91 | 588 | + if (handler) { | |
92 | qemu_chr_fe_set_handlers(&s->chr_pri_in, compare_chr_can_read, | 589 | + rnh->common.length = htons(handler->payload); |
93 | compare_pri_chr_in, NULL, NULL, | 590 | + rnh->code = htons(NCSI_PKT_RSP_C_COMPLETED); |
94 | @@ -XXX,XX +XXX,XX @@ static void *colo_compare_thread(void *opaque) | 591 | + rnh->reason = htons(NCSI_PKT_RSP_R_NO_ERROR); |
95 | compare_sec_chr_in, NULL, NULL, | 592 | + |
96 | s, s->worker_context, true); | 593 | + if (handler->handler) { |
97 | 594 | + /* TODO: handle errors */ | |
98 | - s->compare_loop = g_main_loop_new(s->worker_context, FALSE); | 595 | + handler->handler(rnh); |
99 | - | 596 | + } |
100 | - /* To kick any packets that the secondary doesn't match */ | 597 | + } else { |
101 | - timeout_source = g_timeout_source_new(REGULAR_PACKET_CHECK_MS); | 598 | + rnh->common.length = 0; |
102 | - g_source_set_callback(timeout_source, | 599 | + rnh->code = htons(NCSI_PKT_RSP_C_UNAVAILABLE); |
103 | - (GSourceFunc)check_old_packet_regular, s, NULL); | 600 | + rnh->reason = htons(NCSI_PKT_RSP_R_UNKNOWN); |
104 | - g_source_attach(timeout_source, s->worker_context); | ||
105 | - | ||
106 | - g_main_loop_run(s->compare_loop); | ||
107 | - | ||
108 | - g_source_unref(timeout_source); | ||
109 | - g_main_loop_unref(s->compare_loop); | ||
110 | - g_main_context_unref(s->worker_context); | ||
111 | - return NULL; | ||
112 | + colo_compare_timer_init(s); | ||
113 | } | ||
114 | |||
115 | static char *compare_get_pri_indev(Object *obj, Error **errp) | ||
116 | @@ -XXX,XX +XXX,XX @@ static void colo_compare_complete(UserCreatable *uc, Error **errp) | ||
117 | { | ||
118 | CompareState *s = COLO_COMPARE(uc); | ||
119 | Chardev *chr; | ||
120 | - char thread_name[64]; | ||
121 | - static int compare_id; | ||
122 | |||
123 | - if (!s->pri_indev || !s->sec_indev || !s->outdev) { | ||
124 | + if (!s->pri_indev || !s->sec_indev || !s->outdev || !s->iothread) { | ||
125 | error_setg(errp, "colo compare needs 'primary_in' ," | ||
126 | - "'secondary_in','outdev' property set"); | ||
127 | + "'secondary_in','outdev','iothread' property set"); | ||
128 | return; | ||
129 | } else if (!strcmp(s->pri_indev, s->outdev) || | ||
130 | !strcmp(s->sec_indev, s->outdev) || | ||
131 | @@ -XXX,XX +XXX,XX @@ static void colo_compare_complete(UserCreatable *uc, Error **errp) | ||
132 | g_free, | ||
133 | connection_destroy); | ||
134 | |||
135 | - sprintf(thread_name, "colo-compare %d", compare_id); | ||
136 | - qemu_thread_create(&s->thread, thread_name, | ||
137 | - colo_compare_thread, s, | ||
138 | - QEMU_THREAD_JOINABLE); | ||
139 | - compare_id++; | ||
140 | - | ||
141 | + colo_compare_iothread(s); | ||
142 | return; | ||
143 | } | ||
144 | |||
145 | @@ -XXX,XX +XXX,XX @@ static void colo_compare_init(Object *obj) | ||
146 | object_property_add_str(obj, "outdev", | ||
147 | compare_get_outdev, compare_set_outdev, | ||
148 | NULL); | ||
149 | + object_property_add_link(obj, "iothread", TYPE_IOTHREAD, | ||
150 | + (Object **)&s->iothread, | ||
151 | + object_property_allow_set_link, | ||
152 | + OBJ_PROP_LINK_UNREF_ON_RELEASE, NULL); | ||
153 | |||
154 | s->vnet_hdr = false; | ||
155 | object_property_add_bool(obj, "vnet_hdr_support", compare_get_vnet_hdr, | ||
156 | @@ -XXX,XX +XXX,XX @@ static void colo_compare_finalize(Object *obj) | ||
157 | qemu_chr_fe_deinit(&s->chr_pri_in, false); | ||
158 | qemu_chr_fe_deinit(&s->chr_sec_in, false); | ||
159 | qemu_chr_fe_deinit(&s->chr_out, false); | ||
160 | - | ||
161 | - g_main_loop_quit(s->compare_loop); | ||
162 | - qemu_thread_join(&s->thread); | ||
163 | - | ||
164 | + if (s->iothread) { | ||
165 | + colo_compare_timer_del(s); | ||
166 | + } | 601 | + } |
167 | /* Release all unhandled packets after compare thead exited */ | 602 | + |
168 | g_queue_foreach(&s->conn_list, colo_flush_packets, s); | 603 | + /* TODO: add a checksum at the end of the frame but the specs |
169 | 604 | + * allows it to be zero */ | |
170 | g_queue_clear(&s->conn_list); | 605 | + |
171 | 606 | + slirp_output(slirp->opaque, ncsi_reply, ETH_HLEN + sizeof(*nh) + | |
172 | - g_hash_table_destroy(s->connection_track_table); | 607 | + (handler ? handler->payload : 0) + 4); |
173 | + if (s->connection_track_table) { | 608 | +} |
174 | + g_hash_table_destroy(s->connection_track_table); | 609 | diff --git a/slirp/slirp.c b/slirp/slirp.c |
175 | + } | 610 | index XXXXXXX..XXXXXXX 100644 |
176 | + | 611 | --- a/slirp/slirp.c |
177 | + if (s->iothread) { | 612 | +++ b/slirp/slirp.c |
178 | + object_unref(OBJECT(s->iothread)); | 613 | @@ -XXX,XX +XXX,XX @@ void slirp_input(Slirp *slirp, const uint8_t *pkt, int pkt_len) |
179 | + } | 614 | } |
180 | g_free(s->pri_indev); | 615 | break; |
181 | g_free(s->sec_indev); | 616 | |
182 | g_free(s->outdev); | 617 | + case ETH_P_NCSI: |
618 | + ncsi_input(slirp, pkt, pkt_len); | ||
619 | + break; | ||
620 | + | ||
621 | default: | ||
622 | break; | ||
623 | } | ||
624 | diff --git a/slirp/slirp.h b/slirp/slirp.h | ||
625 | index XXXXXXX..XXXXXXX 100644 | ||
626 | --- a/slirp/slirp.h | ||
627 | +++ b/slirp/slirp.h | ||
628 | @@ -XXX,XX +XXX,XX @@ extern Slirp *slirp_instance; | ||
629 | |||
630 | void if_start(Slirp *); | ||
631 | |||
632 | +/* ncsi.c */ | ||
633 | +void ncsi_input(Slirp *slirp, const uint8_t *pkt, int pkt_len); | ||
634 | + | ||
635 | #ifndef _WIN32 | ||
636 | #include <netdb.h> | ||
637 | #endif | ||
183 | -- | 638 | -- |
184 | 2.7.4 | 639 | 2.7.4 |
185 | 640 | ||
186 | 641 | diff view generated by jsdifflib |
1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | 1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> |
---|---|---|---|
2 | 2 | ||
3 | When network is busy, some tcp options(like sack) will unpredictable | 3 | In this patch we support packet that have tcp options field. |
4 | occur in primary side or secondary side. it will make packet size | 4 | Add tcp options field check, If the packet have options |
5 | not same, but the two packet's payload is identical. colo just | 5 | field we just skip it and compare tcp payload, |
6 | care about packet payload, so we skip the option field. | 6 | Avoid unnecessary checkpoint, optimize performance. |
7 | 7 | ||
8 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | 8 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> |
9 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 9 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
10 | --- | 10 | --- |
11 | net/colo-compare.c | 39 +++++++++++++++++++++++++++------------ | 11 | net/colo-compare.c | 27 ++++++++++++++++++++++++++- |
12 | 1 file changed, 27 insertions(+), 12 deletions(-) | 12 | 1 file changed, 26 insertions(+), 1 deletion(-) |
13 | 13 | ||
14 | diff --git a/net/colo-compare.c b/net/colo-compare.c | 14 | diff --git a/net/colo-compare.c b/net/colo-compare.c |
15 | index XXXXXXX..XXXXXXX 100644 | 15 | index XXXXXXX..XXXXXXX 100644 |
16 | --- a/net/colo-compare.c | 16 | --- a/net/colo-compare.c |
17 | +++ b/net/colo-compare.c | 17 | +++ b/net/colo-compare.c |
18 | @@ -XXX,XX +XXX,XX @@ static int packet_enqueue(CompareState *s, int mode) | 18 | @@ -XXX,XX +XXX,XX @@ static int colo_packet_compare_tcp(Packet *spkt, Packet *ppkt) |
19 | * return: 0 means packet same | 19 | spkt->ip->ip_sum = ppkt->ip->ip_sum; |
20 | * > 0 || < 0 means packet different | ||
21 | */ | ||
22 | -static int colo_packet_compare_common(Packet *ppkt, Packet *spkt, int offset) | ||
23 | +static int colo_packet_compare_common(Packet *ppkt, | ||
24 | + Packet *spkt, | ||
25 | + int poffset, | ||
26 | + int soffset) | ||
27 | { | ||
28 | if (trace_event_get_state_backends(TRACE_COLO_COMPARE_MISCOMPARE)) { | ||
29 | char pri_ip_src[20], pri_ip_dst[20], sec_ip_src[20], sec_ip_dst[20]; | ||
30 | @@ -XXX,XX +XXX,XX @@ static int colo_packet_compare_common(Packet *ppkt, Packet *spkt, int offset) | ||
31 | sec_ip_src, sec_ip_dst); | ||
32 | } | 20 | } |
33 | 21 | ||
34 | - offset = ppkt->vnet_hdr_len + offset; | 22 | - if (ptcp->th_sum == stcp->th_sum) { |
35 | + poffset = ppkt->vnet_hdr_len + poffset; | 23 | + /* |
36 | + soffset = ppkt->vnet_hdr_len + soffset; | 24 | + * Check tcp header length for tcp option field. |
37 | 25 | + * th_off > 5 means this tcp packet have options field. | |
38 | - if (ppkt->size == spkt->size) { | 26 | + * The tcp options maybe always different. |
39 | - return memcmp(ppkt->data + offset, | 27 | + * for example: |
40 | - spkt->data + offset, | 28 | + * From RFC 7323. |
41 | - spkt->size - offset); | 29 | + * TCP Timestamps option (TSopt): |
42 | + if (ppkt->size - poffset == spkt->size - soffset) { | 30 | + * Kind: 8 |
43 | + return memcmp(ppkt->data + poffset, | 31 | + * |
44 | + spkt->data + soffset, | 32 | + * Length: 10 bytes |
45 | + spkt->size - soffset); | 33 | + * |
46 | } else { | 34 | + * +-------+-------+---------------------+---------------------+ |
47 | trace_colo_compare_main("Net packet size are not the same"); | 35 | + * |Kind=8 | 10 | TS Value (TSval) |TS Echo Reply (TSecr)| |
48 | return -1; | 36 | + * +-------+-------+---------------------+---------------------+ |
49 | @@ -XXX,XX +XXX,XX @@ static int colo_packet_compare_tcp(Packet *spkt, Packet *ppkt) | 37 | + * 1 1 4 4 |
50 | * so we just need skip this field. | 38 | + * |
51 | */ | 39 | + * In this case the primary guest's timestamp always different with |
52 | if (ptcp->th_off > 5) { | 40 | + * the secondary guest's timestamp. COLO just focus on payload, |
53 | - ptrdiff_t tcp_offset; | 41 | + * so we just need skip this field. |
54 | + ptrdiff_t ptcp_offset, stcp_offset; | 42 | + */ |
55 | 43 | + if (ptcp->th_off > 5) { | |
56 | - tcp_offset = ppkt->transport_header - (uint8_t *)ppkt->data | 44 | + ptrdiff_t tcp_offset; |
57 | - + (ptcp->th_off * 4) - ppkt->vnet_hdr_len; | 45 | + tcp_offset = ppkt->transport_header - (uint8_t *)ppkt->data |
58 | - res = colo_packet_compare_common(ppkt, spkt, tcp_offset); | 46 | + + (ptcp->th_off * 4); |
59 | + ptcp_offset = ppkt->transport_header - (uint8_t *)ppkt->data | 47 | + res = colo_packet_compare_common(ppkt, spkt, tcp_offset); |
60 | + + (ptcp->th_off * 4) - ppkt->vnet_hdr_len; | 48 | + } else if (ptcp->th_sum == stcp->th_sum) { |
61 | + stcp_offset = spkt->transport_header - (uint8_t *)spkt->data | 49 | res = colo_packet_compare_common(ppkt, spkt, ETH_HLEN); |
62 | + + (stcp->th_off * 4) - spkt->vnet_hdr_len; | ||
63 | + | ||
64 | + /* | ||
65 | + * When network is busy, some tcp options(like sack) will unpredictable | ||
66 | + * occur in primary side or secondary side. it will make packet size | ||
67 | + * not same, but the two packet's payload is identical. colo just | ||
68 | + * care about packet payload, so we skip the option field. | ||
69 | + */ | ||
70 | + res = colo_packet_compare_common(ppkt, spkt, ptcp_offset, stcp_offset); | ||
71 | } else if (ptcp->th_sum == stcp->th_sum) { | ||
72 | - res = colo_packet_compare_common(ppkt, spkt, ETH_HLEN); | ||
73 | + res = colo_packet_compare_common(ppkt, spkt, ETH_HLEN, ETH_HLEN); | ||
74 | } else { | 50 | } else { |
75 | res = -1; | 51 | res = -1; |
76 | } | ||
77 | @@ -XXX,XX +XXX,XX @@ static int colo_packet_compare_udp(Packet *spkt, Packet *ppkt) | ||
78 | * the ip payload here. | ||
79 | */ | ||
80 | ret = colo_packet_compare_common(ppkt, spkt, | ||
81 | + network_header_length + ETH_HLEN, | ||
82 | network_header_length + ETH_HLEN); | ||
83 | |||
84 | if (ret) { | ||
85 | @@ -XXX,XX +XXX,XX @@ static int colo_packet_compare_icmp(Packet *spkt, Packet *ppkt) | ||
86 | * the ip payload here. | ||
87 | */ | ||
88 | if (colo_packet_compare_common(ppkt, spkt, | ||
89 | + network_header_length + ETH_HLEN, | ||
90 | network_header_length + ETH_HLEN)) { | ||
91 | trace_colo_compare_icmp_miscompare("primary pkt size", | ||
92 | ppkt->size); | ||
93 | @@ -XXX,XX +XXX,XX @@ static int colo_packet_compare_other(Packet *spkt, Packet *ppkt) | ||
94 | sec_ip_src, sec_ip_dst); | ||
95 | } | ||
96 | |||
97 | - return colo_packet_compare_common(ppkt, spkt, 0); | ||
98 | + return colo_packet_compare_common(ppkt, spkt, 0, 0); | ||
99 | } | ||
100 | |||
101 | static int colo_old_packet_check_one(Packet *pkt, int64_t *check_time) | ||
102 | -- | 52 | -- |
103 | 2.7.4 | 53 | 2.7.4 |
104 | 54 | ||
105 | 55 | diff view generated by jsdifflib |
1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | 1 | From: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> |
---|---|---|---|
2 | 2 | ||
3 | The packet_enqueue() use g_queue_push_tail() to | 3 | Optimize two trace events as one, adjust print format make |
4 | enqueue net packet, so it is more efficent way use | 4 | it easy to read. rename trace_colo_compare_pkt_info_src/dst |
5 | g_queue_pop_head() to get packet for compare. | 5 | to trace_colo_compare_tcp_info. |
6 | That will improve the success rate of comparison. | ||
7 | In my test the performance of ftp put 1000M file | ||
8 | will increase 10% | ||
9 | 6 | ||
10 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> | 7 | Signed-off-by: Zhang Chen <zhangchen.fnst@cn.fujitsu.com> |
11 | Signed-off-by: Jason Wang <jasowang@redhat.com> | 8 | Signed-off-by: Jason Wang <jasowang@redhat.com> |
12 | --- | 9 | --- |
13 | net/colo-compare.c | 4 ++-- | 10 | net/colo-compare.c | 29 +++++++++++++++++------------ |
14 | 1 file changed, 2 insertions(+), 2 deletions(-) | 11 | net/trace-events | 3 +-- |
12 | 2 files changed, 18 insertions(+), 14 deletions(-) | ||
15 | 13 | ||
16 | diff --git a/net/colo-compare.c b/net/colo-compare.c | 14 | diff --git a/net/colo-compare.c b/net/colo-compare.c |
17 | index XXXXXXX..XXXXXXX 100644 | 15 | index XXXXXXX..XXXXXXX 100644 |
18 | --- a/net/colo-compare.c | 16 | --- a/net/colo-compare.c |
19 | +++ b/net/colo-compare.c | 17 | +++ b/net/colo-compare.c |
20 | @@ -XXX,XX +XXX,XX @@ static void colo_compare_connection(void *opaque, void *user_data) | 18 | @@ -XXX,XX +XXX,XX @@ static int colo_packet_compare_tcp(Packet *spkt, Packet *ppkt) |
21 | 19 | res = -1; | |
22 | while (!g_queue_is_empty(&conn->primary_list) && | 20 | } |
23 | !g_queue_is_empty(&conn->secondary_list)) { | 21 | |
24 | - pkt = g_queue_pop_tail(&conn->primary_list); | 22 | - if (res != 0 && trace_event_get_state(TRACE_COLO_COMPARE_MISCOMPARE)) { |
25 | + pkt = g_queue_pop_head(&conn->primary_list); | 23 | - trace_colo_compare_pkt_info_src(inet_ntoa(ppkt->ip->ip_src), |
26 | switch (conn->ip_proto) { | 24 | - ntohl(stcp->th_seq), |
27 | case IPPROTO_TCP: | 25 | - ntohl(stcp->th_ack), |
28 | result = g_queue_find_custom(&conn->secondary_list, | 26 | - res, stcp->th_flags, |
29 | @@ -XXX,XX +XXX,XX @@ static void colo_compare_connection(void *opaque, void *user_data) | 27 | - spkt->size); |
30 | * until next comparison. | 28 | - |
31 | */ | 29 | - trace_colo_compare_pkt_info_dst(inet_ntoa(ppkt->ip->ip_dst), |
32 | trace_colo_compare_main("packet different"); | 30 | - ntohl(ptcp->th_seq), |
33 | - g_queue_push_tail(&conn->primary_list, pkt); | 31 | - ntohl(ptcp->th_ack), |
34 | + g_queue_push_head(&conn->primary_list, pkt); | 32 | - res, ptcp->th_flags, |
35 | /* TODO: colo_notify_checkpoint();*/ | 33 | - ppkt->size); |
36 | break; | 34 | + if (res && trace_event_get_state(TRACE_COLO_COMPARE_MISCOMPARE)) { |
37 | } | 35 | + char ip_src[20], ip_dst[20]; |
36 | + | ||
37 | + strcpy(ip_src, inet_ntoa(ppkt->ip->ip_src)); | ||
38 | + strcpy(ip_dst, inet_ntoa(ppkt->ip->ip_dst)); | ||
39 | + | ||
40 | + trace_colo_compare_tcp_info(ip_src, | ||
41 | + ip_dst, | ||
42 | + ntohl(ptcp->th_seq), | ||
43 | + ntohl(stcp->th_seq), | ||
44 | + ntohl(ptcp->th_ack), | ||
45 | + ntohl(stcp->th_ack), | ||
46 | + res, | ||
47 | + ptcp->th_flags, | ||
48 | + stcp->th_flags, | ||
49 | + ppkt->size, | ||
50 | + spkt->size); | ||
51 | |||
52 | qemu_hexdump((char *)ppkt->data, stderr, | ||
53 | "colo-compare ppkt", ppkt->size); | ||
54 | diff --git a/net/trace-events b/net/trace-events | ||
55 | index XXXXXXX..XXXXXXX 100644 | ||
56 | --- a/net/trace-events | ||
57 | +++ b/net/trace-events | ||
58 | @@ -XXX,XX +XXX,XX @@ colo_compare_icmp_miscompare(const char *sta, int size) ": %s = %d" | ||
59 | colo_compare_ip_info(int psize, const char *sta, const char *stb, int ssize, const char *stc, const char *std) "ppkt size = %d, ip_src = %s, ip_dst = %s, spkt size = %d, ip_src = %s, ip_dst = %s" | ||
60 | colo_old_packet_check_found(int64_t old_time) "%" PRId64 | ||
61 | colo_compare_miscompare(void) "" | ||
62 | -colo_compare_pkt_info_src(const char *src, uint32_t sseq, uint32_t sack, int res, uint32_t sflag, int ssize) "src/dst: %s s: seq/ack=%u/%u res=%d flags=%x spkt_size: %d\n" | ||
63 | -colo_compare_pkt_info_dst(const char *dst, uint32_t dseq, uint32_t dack, int res, uint32_t dflag, int dsize) "src/dst: %s d: seq/ack=%u/%u res=%d flags=%x dpkt_size: %d\n" | ||
64 | +colo_compare_tcp_info(const char *src, const char *dst, uint32_t pseq, uint32_t sseq, uint32_t pack, uint32_t sack, int res, uint32_t pflag, uint32_t sflag, int psize, int ssize) "src/dst: %s/%s pseq/sseq:%u/%u pack/sack:%u/%u res=%d pflags/sflag:%x/%x psize/ssize:%d/%d \n" | ||
65 | |||
66 | # net/filter-rewriter.c | ||
67 | colo_filter_rewriter_debug(void) "" | ||
38 | -- | 68 | -- |
39 | 2.7.4 | 69 | 2.7.4 |
40 | 70 | ||
41 | 71 | diff view generated by jsdifflib |
Deleted patch | |||
---|---|---|---|
1 | From: Wang Yong <wang.yong155@zte.com.cn> | ||
2 | 1 | ||
3 | IOThread uses AioContext event loop and does not run a GMainContext. | ||
4 | Therefore,chardev cannot work in IOThread,such as the chardev is | ||
5 | used for colo-compare packets reception. | ||
6 | |||
7 | This patch makes the IOThread run the GMainContext event loop, | ||
8 | chardev and IOThread can work together. | ||
9 | |||
10 | Reviewed-by: Fam Zheng <famz@redhat.com> | ||
11 | Signed-off-by: Wang Yong <wang.yong155@zte.com.cn> | ||
12 | Signed-off-by: Wang Guang <wang.guang55@zte.com.cn> | ||
13 | Signed-off-by: Jason Wang <jasowang@redhat.com> | ||
14 | --- | ||
15 | include/sysemu/iothread.h | 4 ++++ | ||
16 | iothread.c | 45 +++++++++++++++++++++++++++++++++++++++++++++ | ||
17 | 2 files changed, 49 insertions(+) | ||
18 | |||
19 | diff --git a/include/sysemu/iothread.h b/include/sysemu/iothread.h | ||
20 | index XXXXXXX..XXXXXXX 100644 | ||
21 | --- a/include/sysemu/iothread.h | ||
22 | +++ b/include/sysemu/iothread.h | ||
23 | @@ -XXX,XX +XXX,XX @@ typedef struct { | ||
24 | |||
25 | QemuThread thread; | ||
26 | AioContext *ctx; | ||
27 | + GMainContext *worker_context; | ||
28 | + GMainLoop *main_loop; | ||
29 | + GOnce once; | ||
30 | QemuMutex init_done_lock; | ||
31 | QemuCond init_done_cond; /* is thread initialization done? */ | ||
32 | bool stopping; | ||
33 | @@ -XXX,XX +XXX,XX @@ typedef struct { | ||
34 | char *iothread_get_id(IOThread *iothread); | ||
35 | AioContext *iothread_get_aio_context(IOThread *iothread); | ||
36 | void iothread_stop_all(void); | ||
37 | +GMainContext *iothread_get_g_main_context(IOThread *iothread); | ||
38 | |||
39 | #endif /* IOTHREAD_H */ | ||
40 | diff --git a/iothread.c b/iothread.c | ||
41 | index XXXXXXX..XXXXXXX 100644 | ||
42 | --- a/iothread.c | ||
43 | +++ b/iothread.c | ||
44 | @@ -XXX,XX +XXX,XX @@ static void *iothread_run(void *opaque) | ||
45 | |||
46 | while (!atomic_read(&iothread->stopping)) { | ||
47 | aio_poll(iothread->ctx, true); | ||
48 | + | ||
49 | + if (atomic_read(&iothread->worker_context)) { | ||
50 | + GMainLoop *loop; | ||
51 | + | ||
52 | + g_main_context_push_thread_default(iothread->worker_context); | ||
53 | + iothread->main_loop = | ||
54 | + g_main_loop_new(iothread->worker_context, TRUE); | ||
55 | + loop = iothread->main_loop; | ||
56 | + | ||
57 | + g_main_loop_run(iothread->main_loop); | ||
58 | + iothread->main_loop = NULL; | ||
59 | + g_main_loop_unref(loop); | ||
60 | + | ||
61 | + g_main_context_pop_thread_default(iothread->worker_context); | ||
62 | + g_main_context_unref(iothread->worker_context); | ||
63 | + iothread->worker_context = NULL; | ||
64 | + } | ||
65 | } | ||
66 | |||
67 | rcu_unregister_thread(); | ||
68 | @@ -XXX,XX +XXX,XX @@ static int iothread_stop(Object *object, void *opaque) | ||
69 | } | ||
70 | iothread->stopping = true; | ||
71 | aio_notify(iothread->ctx); | ||
72 | + if (atomic_read(&iothread->main_loop)) { | ||
73 | + g_main_loop_quit(iothread->main_loop); | ||
74 | + } | ||
75 | qemu_thread_join(&iothread->thread); | ||
76 | return 0; | ||
77 | } | ||
78 | @@ -XXX,XX +XXX,XX @@ static void iothread_complete(UserCreatable *obj, Error **errp) | ||
79 | |||
80 | qemu_mutex_init(&iothread->init_done_lock); | ||
81 | qemu_cond_init(&iothread->init_done_cond); | ||
82 | + iothread->once = (GOnce) G_ONCE_INIT; | ||
83 | |||
84 | /* This assumes we are called from a thread with useful CPU affinity for us | ||
85 | * to inherit. | ||
86 | @@ -XXX,XX +XXX,XX @@ void iothread_stop_all(void) | ||
87 | |||
88 | object_child_foreach(container, iothread_stop, NULL); | ||
89 | } | ||
90 | + | ||
91 | +static gpointer iothread_g_main_context_init(gpointer opaque) | ||
92 | +{ | ||
93 | + AioContext *ctx; | ||
94 | + IOThread *iothread = opaque; | ||
95 | + GSource *source; | ||
96 | + | ||
97 | + iothread->worker_context = g_main_context_new(); | ||
98 | + | ||
99 | + ctx = iothread_get_aio_context(iothread); | ||
100 | + source = aio_get_g_source(ctx); | ||
101 | + g_source_attach(source, iothread->worker_context); | ||
102 | + g_source_unref(source); | ||
103 | + | ||
104 | + aio_notify(iothread->ctx); | ||
105 | + return NULL; | ||
106 | +} | ||
107 | + | ||
108 | +GMainContext *iothread_get_g_main_context(IOThread *iothread) | ||
109 | +{ | ||
110 | + g_once(&iothread->once, iothread_g_main_context_init, iothread); | ||
111 | + | ||
112 | + return iothread->worker_context; | ||
113 | +} | ||
114 | -- | ||
115 | 2.7.4 | ||
116 | |||
117 | diff view generated by jsdifflib |