xiehan
d0b693fa62
Merge pull request #1276 from Barenboim/master
...
Make WFServerBase::create_listen_fd() protected.
2023-05-06 18:31:39 +08:00
Xie Han
b5de13f2fd
Make WFServerBase::create_listen_fd() protected.
2023-05-06 18:23:07 +08:00
xiehan
baba9650f6
Merge pull request #1273 from Barenboim/master
...
Fix URIParser bug.
2023-05-05 20:52:13 +08:00
Xie Han
a1b83adfd0
Fix URIParser bug.
2023-05-05 20:33:13 +08:00
Xie Han
1601c8b352
Just flip some codes.
2023-05-04 20:50:49 +08:00
xiehan
e32170e15b
Merge pull request #1263 from masterX89/docs/README
...
docs: update README_cn
2023-04-23 21:27:15 +08:00
masterX89
95f425aa27
docs: update README_cn
2023-04-23 21:25:59 +08:00
xiehan
115425ec2d
Merge pull request #1260 from Barenboim/master
...
PD_OP_RECV_MESSAGE->PD_OP_RECVFROM
2023-04-21 23:04:08 +08:00
XieHan
6e3572df2f
PD_OP_RECV_MESSAGE->PD_OP_RECVFROM
2023-04-21 19:56:26 +08:00
xiehan
2283695b11
Merge pull request #1254 from kedixa/dev
...
kafka bugfix: cannot fetch without group
2023-04-20 16:20:47 +08:00
kedixa
499b3da00c
remove mixed space in tab
2023-04-20 15:59:48 +08:00
kedixa
c7127a9c5f
kafka bugfix: cannot fetch without group
2023-04-20 15:10:08 +08:00
xiehan
61dca8e699
Merge pull request #1247 from Barenboim/master
...
Add PD_OP_RECV_MESSAGE to support UDP server.
2023-04-13 21:22:48 +08:00
XieHan
8d958c895c
PD_OP_TIMER redefined to 0 because timer is special.
2023-04-13 00:50:53 +08:00
XieHan
6bc22aaaeb
Unify naming.
2023-04-13 00:43:17 +08:00
Xie Han
a08610eea3
Refactor. PD_OP_RECVFROM -> PD_OP_RECV_MESSAGE.
2023-04-12 23:48:49 +08:00
Xie Han
a1059519ed
Add PD_OP_RECVFROM for UDP server.
2023-04-11 23:02:24 +08:00
xiehan
ff0abcfe28
Add SeriesWork::get_specific() and get_in_parallel() for tracing.
...
* Add SeriesWork::get_specific()
* Add SeriesWork::get_in_parallel() for task implementations.
* Add const to 'in_parallel'.
* Rename argument.
2023-04-04 20:43:55 +08:00
xiehan
54846b48f3
Update README.md
2023-04-02 01:21:10 +08:00
xiehan
b01d8b2ea8
Create tutorial-11-graph_task.md
2023-04-02 01:17:36 +08:00
xiehan
c5504b486d
Update README_cn.md
2023-04-01 19:34:27 +08:00
xiehan
d92b170030
Merge pull request #1241 from kedixa/dev
...
kafkabugfix: OffsetCommit parse and SyncGroup encode makes bad message
2023-03-31 17:32:47 +08:00
kedixa
9f4a576478
kafak bugfix: no extra bytes in SyncGroup req version 3
2023-03-31 17:05:26 +08:00
kedixa
3c74637bd0
kafkabugfix: OffsetCommit resp version >=3 has throttle_time
2023-03-31 16:43:05 +08:00
xiehan
7bb7a8c5e0
Merge pull request #1239 from kedixa/dev
...
kafka bugfix: heartbeat error not handled when callback
2023-03-30 19:33:36 +08:00
kedixa
ed15dcb344
kafka bugfix: heartbeat error not handled when callback
...
In order to remove parallel write of cgroup,
we set another cgroup instance in task's response,
and handle resp->cgroup()->get_error() in callback.
But in __ComplexKafkaTask::finish_once, resp's cgroup
is overwriten by req's cgroup, so callback cannot handle
this error.
2023-03-30 18:05:09 +08:00
xiehan
e80b437287
Merge pull request #1235 from Barenboim/master
...
'listen()' backlog at least 4096.
2023-03-28 19:05:07 +08:00
Xie Han
388452f391
'listen()' backlog at least 4096.
2023-03-28 18:24:22 +08:00
xiehan
820acfb4bb
Update README_cn.md
2023-03-25 23:04:11 +08:00
xiehan
3426759fe9
Update README.md
2023-03-25 23:03:43 +08:00
xiehan
b6073c68ae
Update README.md
2023-03-25 17:25:05 +08:00
xiehan
980767dda1
Update README_cn.md
2023-03-25 16:30:21 +08:00
Xie Han
891b31e437
Update tests
2023-03-24 17:44:00 +08:00
Xie Han
9a2ebdb06e
Test cases use github.com.
2023-03-24 17:37:03 +08:00
xiehan
202f0abd98
Merge pull request #1225 from Barenboim/master
...
Simplify WFMailboxTask.
2023-03-23 03:34:54 +08:00
Xie Han
057b19ff2f
Use www.example.com
2023-03-23 03:30:30 +08:00
Xie Han
8d57c8ba64
Simplify WFMailboxTask.
2023-03-23 02:54:19 +08:00
xiehan
b8e24193a6
Merge pull request #1219 from Barenboim/master
...
Remove topic_cnt checking
2023-03-17 14:22:51 +08:00
Xie Han
cbb645a4cd
Remove topic_cnt checking
2023-03-17 13:28:39 +08:00
xiehan
fd2d6b074a
Merge pull request #1218 from Barenboim/master
...
Fix kafka commit request EBADMSG problem.
2023-03-16 17:37:53 +08:00
Xie Han
b962a78fd2
Fix kafka commit request EBADMSG problem.
2023-03-16 17:29:48 +08:00
xiehan
0423bf3495
0.10.6->0.10.7
2023-03-16 16:44:16 +08:00
xiehan
77f6a316f2
Update CMakeLists.txt
2023-03-16 15:35:50 +08:00
xiehan
c4c3e3eb4c
Remove KafkaMessage api_mver_map
2023-03-15 19:43:48 +08:00
kedixa
7585d03e92
kafka bugfix, cgroup may be concurrently write by more than one task
...
* kafka bugfix, cgroup may be concurrently write by more than one task
* code format
* format code
2023-03-15 19:42:47 +08:00
xiehan
615bbec2be
Merge pull request #1211 from Kevin-Ren97/master
...
fix tutorial-10-user_defined_protocol when append multiple times
2023-03-09 21:02:27 +08:00
kedixa
d39f15770b
kafka bugfix for infinite wait for meta counter ( #1210 )
...
* kafka bugfix, KafkaClientTask::get_meta_status may return META_DOING
when bote META_UNINIT and META_DOING in this->meta_list, without request
for meta data, causing infinite wait for meta counter.
* make code format better
* make code format better
* Construct KafkaMetaList only when necessary
2023-03-09 20:35:50 +08:00
Kevin-Ren97
20bee02891
fix tutorial-10-user_defined_protocol when append multiple times
2023-03-09 20:28:28 +08:00
xiehan
a44010091e
Increase linux aio max events. ( #1207 )
2023-03-09 03:20:18 +08:00
xiehan
25edec09b1
Update README_cn.md
2023-03-06 17:30:14 +08:00
