breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity
1,871 Commits 4 Branches 43 Tags
036e00feb94a4c9dcb805cbd07d6245a79219aa0
Commit Graph

1871 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
XieHan
036e00feb9 Remove include WFAlgoTaskFactory.h from WFTaskFactory.h. 2023-06-04 02:35:42 +08:00
XieHan
6fbcbe7fcf Add WFRmoveTask and WFUniqueTask. 2023-06-04 02:35:26 +08:00
Xie Han
ca8812f6a5 Add WFShuffleTask. 2023-06-03 00:20:44 +08:00
xiehan
36429e548b Remove the usage of std::random_device. (#1288) 2023-06-02 21:16:45 +08:00
xiehan
0e2c12115a Global settings add fio_max_events. (#1284) 
* Global settings add fio_max_events.

* Make 'fio_max_events' effects on thread aio too.

* Update about-config.md

* Update about-config.md

* Update about-config.md
 2023-05-23 23:13:14 +08:00
kedixa
0d0c6d2d9d move DnsRoutine to WFDnsResolver (#1282) 
* move DnsRoutine to WFDnsResolver

* remove unused constructor

* use global __ai_hints
 2023-05-17 18:01:43 +08:00
xiehan
df53c97a97 Merge pull request #1280 from Barenboim/master 
Enable users to subclass WFHttpServerTask
 2023-05-11 23:25:57 +08:00
Xie Han
77a3ced876 Enable users to subclass WFHttpServerTask 2023-05-11 20:47:28 +08:00
Xie Han
a22b7aca6f 0.10.7->0.10.8 2023-05-11 20:23:23 +08:00
xiehan
e74cd49062 Update tutorial-13-kafka_cli.md 2023-05-09 22:50:52 +08:00
xiehan
13aae187f8 Update tutorial-13-kafka_cli.md 2023-05-09 22:50:25 +08:00
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.
v0.10.7 		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