Commit Graph

  • 578d60b511 Merge pull request #1327 from Barenboim/master xiehan 2023-07-17 15:23:10 +08:00
  • 4dd82db8ca msgqueue maxlen set to 0 (unlimited). Xie Han 2023-07-17 15:16:42 +08:00
  • 3f7964b9e6 Do not set errno in msgqueue_get(). Xie Han 2023-07-17 15:16:12 +08:00
  • a38446630e Update msgqueue and thrdpool. Xie Han 2023-07-17 03:40:20 +08:00
  • ccc2e5992c Update codes and add WFNetworkTask::closed() for server tasks. Xie Han 2023-07-15 02:40:07 +08:00
  • a2b4e85261 Merge pull request #1323 from Barenboim/master xiehan 2023-07-15 02:32:38 +08:00
  • 37d97c3826 Simplify CommTarget::release(). Xie Han 2023-07-14 04:48:23 +08:00
  • 70eb8bb483 Merge pull request #1322 from Barenboim/master xiehan 2023-07-14 04:11:14 +08:00
  • 440112ffbf Add WFNetworkTask::closed() for checking if the server task's connection is still retained. Xie Han 2023-07-14 03:06:56 +08:00
  • 7dd352ac3d Optimize Kafka client compare_topics Xie Han 2023-07-05 21:10:28 +08:00
  • 9633d58d9a Merge pull request #1312 from kedixa/dev v0.10.8 xiehan 2023-07-05 20:18:41 +08:00
  • 5c7eb21883 websocket: support send_timeout liyingxin 2023-07-03 20:43:09 +08:00
  • 022369b8df websocket: support keep_alive_timeout liyingxin 2023-07-03 20:22:07 +08:00
  • e5f778124e check whether task->topic_set is a subset of this->topic_set kedixa 2023-06-30 17:45:42 +08:00
  • ef886ec430 KafkaClientTask::compare_topics use ordered topic_set kedixa 2023-06-29 20:54:41 +08:00
  • 86ff9fbc1b Optimize Kafka client to make tasks fail fast when servers down. Xie Han 2023-06-27 22:11:26 +08:00
  • a7785020df Fix bugs Xie Han 2023-06-27 20:09:51 +08:00
  • bedb54816b update authors info Xie Han 2023-06-25 20:55:37 +08:00
  • f73248fe9a Add some include headers Xie Han 2023-06-25 20:28:42 +08:00
  • d2bffc4e4c Update kafka cgroup/meta fetching logic. Xie Han 2023-06-25 20:06:34 +08:00
  • 9296964519 Update WFKafkaClient.cc xiehan 2023-06-24 19:02:52 +08:00
  • a409ccd55b Add comparing topics Xie Han 2023-06-24 04:42:27 +08:00
  • 7b9583bbb2 Optimize Kafka client to make tasks fail fast when servers down. Xie Han 2023-06-23 23:07:58 +08:00
  • 6d250c431c Update about-conditional.md xiehan 2023-06-26 17:24:49 +08:00
  • 8a29f9e902 Enable to signal a maximum number of condtional. Xie Han 2023-06-25 20:33:25 +08:00
  • 0233d44f05 Enable to signal a maximum number of condtional. Xie Han 2023-06-24 23:58:06 +08:00
  • ad2aee35f2 Merge pull request #1307 from holmes1412/master xiehan 2023-06-21 18:33:59 +08:00
  • 344fae4884 update docs : nvswrr in about-upstream.md holmes1412 2023-06-21 18:26:25 +08:00
  • caf0d4324d Unify codes Xie Han 2023-06-13 17:34:17 +08:00
  • ec7b16e326 Add virtual destructor for PolicyAddrParams. Xie Han 2023-06-13 17:30:19 +08:00
  • 4c0cafbb31 Merge pull request #1295 from kedixa/dev xiehan 2023-06-13 01:30:42 +08:00
  • e360b7ab0a class PolicyAddrParams needs polymorphism kedixa 2023-06-12 20:39:49 +08:00
  • e40dbb7400 Merge pull request #1289 from Barenboim/master xiehan 2023-06-05 23:19:41 +08:00
  • b0ed99487e Add more algorithm tasks. Xie Han 2023-06-05 23:17:19 +08:00
  • 47e2910eef Add WFReverseTask, WFRotateTask. Xie Han 2023-06-05 22:54:01 +08:00
  • 036e00feb9 Remove include WFAlgoTaskFactory.h from WFTaskFactory.h. XieHan 2023-06-04 02:35:42 +08:00
  • 6fbcbe7fcf Add WFRmoveTask and WFUniqueTask. XieHan 2023-06-04 02:35:26 +08:00
  • ca8812f6a5 Add WFShuffleTask. Xie Han 2023-06-03 00:20:44 +08:00
  • 1b98dd0704 Remove the usage of std::random_device. Xie Han 2023-06-02 21:33:52 +08:00
  • 36429e548b Remove the usage of std::random_device. (#1288) xiehan 2023-06-02 21:16:45 +08:00
  • 0e2c12115a Global settings add fio_max_events. (#1284) xiehan 2023-05-23 23:13:14 +08:00
  • 0d0c6d2d9d move DnsRoutine to WFDnsResolver (#1282) kedixa 2023-05-17 18:01:43 +08:00
  • b233cdcb54 move DnsRoutine to WFDnsResolver (Windows) (#1283) kedixa 2023-05-17 18:01:12 +08:00
  • df53c97a97 Merge pull request #1280 from Barenboim/master xiehan 2023-05-11 23:25:57 +08:00
  • 2aada38be8 Enable users to subclass WFHttpServerTask. Xie Han 2023-05-11 23:25:36 +08:00
  • 9bca11b077 0.10.7->0.10.8 Xie Han 2023-05-11 23:16:43 +08:00
  • 77a3ced876 Enable users to subclass WFHttpServerTask Xie Han 2023-05-11 20:47:28 +08:00
  • a22b7aca6f 0.10.7->0.10.8 Xie Han 2023-05-11 20:23:23 +08:00
  • e74cd49062 Update tutorial-13-kafka_cli.md xiehan 2023-05-09 22:50:52 +08:00
  • 13aae187f8 Update tutorial-13-kafka_cli.md xiehan 2023-05-09 22:50:25 +08:00
  • d0b693fa62 Merge pull request #1276 from Barenboim/master xiehan 2023-05-06 18:31:39 +08:00
  • 7db9f4784a Make WFServerBase::create_listen_fd() protected. Xie Han 2023-05-06 18:30:32 +08:00
  • 13eff60016 0.10.6->0.10.7 v0.10.7-win Xie Han 2023-05-06 18:26:28 +08:00
  • b5de13f2fd Make WFServerBase::create_listen_fd() protected. Xie Han 2023-05-06 18:23:07 +08:00
  • baba9650f6 Merge pull request #1273 from Barenboim/master v0.10.7 xiehan 2023-05-05 20:52:13 +08:00
  • 610e7037f4 Fix URIParser bug. Xie Han 2023-05-05 20:34:34 +08:00
  • a1b83adfd0 Fix URIParser bug. Xie Han 2023-05-05 20:33:13 +08:00
  • 3fe28d1471 Merge branch 'windows' of https://github.com/sogou/workflow into windows Xie Han 2023-05-05 19:45:49 +08:00
  • b4cfd5d991 Fix URIParser bug. Xie Han 2023-05-05 19:45:43 +08:00
  • 1601c8b352 Just flip some codes. Xie Han 2023-05-04 20:50:49 +08:00
  • 7960bbcb14 Merge pull request #1267 from holmes1412/websocket xiehan 2023-04-28 20:41:34 +08:00
  • ae011222a9 Update tutorial-14-websocket_cli.md liyingxin 2023-04-28 09:47:31 +00:00
  • e32170e15b Merge pull request #1263 from masterX89/docs/README xiehan 2023-04-23 21:27:15 +08:00
  • 95f425aa27 docs: update README_cn masterX89 2023-04-23 21:25:59 +08:00
  • 115425ec2d Merge pull request #1260 from Barenboim/master xiehan 2023-04-21 23:04:08 +08:00
  • 6e3572df2f PD_OP_RECV_MESSAGE->PD_OP_RECVFROM XieHan 2023-04-21 19:56:26 +08:00
  • 2283695b11 Merge pull request #1254 from kedixa/dev xiehan 2023-04-20 16:20:47 +08:00
  • c19f90cd01 Merge pull request #1255 from kedixa/dev-win xiehan 2023-04-20 16:20:39 +08:00
  • 856bc734c6 kafka bugfix: cannot fetch without group kedixa 2023-04-20 16:09:41 +08:00
  • 499b3da00c remove mixed space in tab kedixa 2023-04-20 15:59:48 +08:00
  • c7127a9c5f kafka bugfix: cannot fetch without group kedixa 2023-04-20 15:10:08 +08:00
  • df693b54d7 Merge pull request #1251 from holmes1412/websocket xiehan 2023-04-17 14:25:42 +08:00
  • bc3fdf7d34 websocket : fix initialize state and add swith timer to avoid recursive calls liyingxin 2023-04-15 23:46:00 +08:00
  • 61dca8e699 Merge pull request #1247 from Barenboim/master xiehan 2023-04-13 21:22:48 +08:00
  • 4b1544fbc5 Merge pull request #1237 from holmes1412/websocket xiehan 2023-04-13 19:15:37 +08:00
  • 2a1f026cda websocket : update handle_terminate() and client.deinit() codes liyingxin 2023-04-13 13:13:57 +08:00
  • 8d958c895c PD_OP_TIMER redefined to 0 because timer is special. XieHan 2023-04-13 00:50:53 +08:00
  • 6bc22aaaeb Unify naming. XieHan 2023-04-13 00:43:17 +08:00
  • a08610eea3 Refactor. PD_OP_RECVFROM -> PD_OP_RECV_MESSAGE. Xie Han 2023-04-12 23:48:49 +08:00
  • a1059519ed Add PD_OP_RECVFROM for UDP server. Xie Han 2023-04-11 23:02:24 +08:00
  • e103f8521e Add SeriesWork::get_specific(), get_in_parallel for tracing. Xie Han 2023-04-04 20:47:16 +08:00
  • ff0abcfe28 Add SeriesWork::get_specific() and get_in_parallel() for tracing. xiehan 2023-04-04 20:43:55 +08:00
  • 54846b48f3 Update README.md xiehan 2023-04-02 01:21:10 +08:00
  • b01d8b2ea8 Create tutorial-11-graph_task.md xiehan 2023-04-02 01:17:36 +08:00
  • c5504b486d Update README_cn.md xiehan 2023-04-01 19:34:27 +08:00
  • 8c210609ad Merge pull request #1242 from kedixa/dev-win xiehan 2023-03-31 17:37:31 +08:00
  • d92b170030 Merge pull request #1241 from kedixa/dev xiehan 2023-03-31 17:32:47 +08:00
  • d3cdace4c2 kafkabugfix: OffsetCommit parse and SyncGroup encode makes bad message kedixa 2023-03-31 17:31:26 +08:00
  • 9f4a576478 kafak bugfix: no extra bytes in SyncGroup req version 3 kedixa 2023-03-31 17:05:26 +08:00
  • 3c74637bd0 kafkabugfix: OffsetCommit resp version >=3 has throttle_time kedixa 2023-03-31 16:43:05 +08:00
  • 7bb7a8c5e0 Merge pull request #1239 from kedixa/dev xiehan 2023-03-30 19:33:36 +08:00
  • d597423bb7 Fix bug of kafka heartbeat. Xie Han 2023-03-30 19:33:00 +08:00
  • 0c0c51989b Remove unused variable. Xie Han 2023-03-30 19:32:13 +08:00
  • ed15dcb344 kafka bugfix: heartbeat error not handled when callback kedixa 2023-03-30 18:05:09 +08:00
  • 7f4a58546d websocket : add websocket_close_t for WFChannel closed without WebSocketFrameConnectionClose liyingxin 2023-03-30 00:49:27 +08:00
  • 81b5afac55 Merge branch 'windows' of https://github.com/sogou/workflow into windows Xie Han 2023-03-28 19:06:51 +08:00
  • c1c875180a 'listen()' backlog at least 4096. Xie Han 2023-03-28 19:06:41 +08:00
  • e80b437287 Merge pull request #1235 from Barenboim/master xiehan 2023-03-28 19:05:07 +08:00
  • 388452f391 'listen()' backlog at least 4096. Xie Han 2023-03-28 18:24:22 +08:00
  • 820acfb4bb Update README_cn.md xiehan 2023-03-25 23:04:11 +08:00