 Xie Han
|
f73248fe9a
|
Add some include headers
|
2023-06-27 20:28:39 +08:00 |
|
|
Xie Han
|
d2bffc4e4c
|
Update kafka cgroup/meta fetching logic.
|
2023-06-27 20:28:39 +08:00 |
|
|
xiehan
|
9296964519
|
Update WFKafkaClient.cc
|
2023-06-27 20:28:39 +08:00 |
|
|
Xie Han
|
a409ccd55b
|
Add comparing topics
|
2023-06-27 20:28:39 +08:00 |
|
|
Xie Han
|
7b9583bbb2
|
Optimize Kafka client to make tasks fail fast when servers down.
|
2023-06-27 20:28:39 +08:00 |
|
|
xiehan
|
6d250c431c
|
Update about-conditional.md
|
2023-06-26 17:24:49 +08:00 |
|
|
Xie Han
|
0233d44f05
|
Enable to signal a maximum number of condtional.
|
2023-06-24 23:58:06 +08:00 |
|
|
xiehan
|
ad2aee35f2
|
Merge pull request #1307 from holmes1412/master
update docs : nvswrr in about-upstream.md
|
2023-06-21 18:33:59 +08:00 |
|
|
holmes1412
|
344fae4884
|
update docs : nvswrr in about-upstream.md
|
2023-06-21 18:26:25 +08:00 |
|
|
Xie Han
|
caf0d4324d
|
Unify codes
|
2023-06-13 17:34:17 +08:00 |
|
|
xiehan
|
4c0cafbb31
|
Merge pull request #1295 from kedixa/dev
class PolicyAddrParams needs polymorphism
|
2023-06-13 01:30:42 +08:00 |
|
|
kedixa
|
e360b7ab0a
|
class PolicyAddrParams needs polymorphism
~PolicyAddrParams called in ~EndpointAddress must destroy derived
classes
|
2023-06-12 20:39:49 +08:00 |
|
|
xiehan
|
e40dbb7400
|
Merge pull request #1289 from Barenboim/master
Add more algorithm tasks.
|
2023-06-05 23:19:41 +08:00 |
|
|
Xie Han
|
47e2910eef
|
Add WFReverseTask, WFRotateTask.
|
2023-06-05 22:54:01 +08:00 |
|
|
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 |
|