979 Commits

Author	SHA1	Message	Date
xiehan	3503a4f94e	Merge pull request #1377 from Barenboim/master ... Add encoding for kafka sasl password	2023-09-21 19:57:37 +08:00
Xie Han	6ac1eac884	Add encoding for kafka sasl password	2023-09-21 16:47:17 +08:00
Xie Han	45a55ce2f4	Add ‘private' to class member.	2023-09-16 03:00:37 +08:00
Xie Han	744792a6d5	Simplify WFFacilities::ReplyGuard.	2023-09-15 23:27:34 +08:00
Xie Han	6c27878216	Simplify server task series' cancel logic.	2023-09-15 23:17:25 +08:00
Xie Han	d7ceb85a88	Add class WFFacilities::ReplyGuard	2023-09-11 21:20:21 +08:00
Xie Han	916f7f9454	Make SeriesWork::get_last_task() public for internal usage.	2023-09-11 19:45:01 +08:00
xiehan	b75a39052b	Merge pull request #1368 from Barenboim/master ... Cannot use get_target() if not connected.	2023-09-08 20:18:57 +08:00
Xie Han	491deade4c	Use this->target is better.	2023-09-08 20:12:26 +08:00
Xie Han	9b1a191a43	Fix MySQL connection bug. Cannot use get_target() if not connected.	2023-09-08 20:11:40 +08:00
xiehan	daa6141be7	Merge pull request #1366 from Barenboim/master ... Fix MySQL connection crash.	2023-09-08 17:06:34 +08:00
Xie Han	e01a5ca8ae	Fix MySQL connection crash.	2023-09-08 16:40:56 +08:00
Xie Han	2a6469715a	Fix HttpMessage::get_output_body_blocks bug.	2023-09-01 03:26:59 +08:00
Xie Han	989cf72464	Make mysql parser more tolerant.	2023-08-27 00:44:35 +08:00
Xie Han	87dadd4a2f	MySQL client disable session state tracking.	2023-08-27 00:22:12 +08:00
xiehan	6ebeb786cc	Merge pull request #1362 from Barenboim/master ... Enable HttpMessage getting output body.	2023-08-23 18:38:54 +08:00
Xie Han	6158b23a0b	Enable HttpMessage getting output body.	2023-08-23 03:36:16 +08:00
Xie Han	3d9789df97	Fix MySQL bug when a trasaction's connection reset.	2023-08-19 17:16:01 +08:00
Xie Han	8fb40d67db	MySQL parser parses on each package.	2023-08-17 23:48:30 +08:00
Xie Han	5131d07dcd	Fix mysql parser.	2023-08-17 18:35:50 +08:00
Xie Han	a39bd635fb	MySQL client add CLIENT_SESSION_TRACK.	2023-08-15 23:39:25 +08:00
xiehan	01ae6ade4e	Merge pull request #1353 from holmes1412/dev ... mysql : parse MYSQL_SERVER_SESSION_STATE_CHANGED in OK packet	2023-08-15 20:56:02 +08:00
liyingxin	4d10907fdc	mysql : parse MYSQL_SERVER_SESSION_STATE_CHANGED in OK packet	2023-08-15 20:26:09 +08:00
Xie Han	88758a66d9	Fix mysql decode_string().	2023-08-15 20:18:24 +08:00
Xie Han	a46de73872	Fix mysql parsing.	2023-08-15 18:43:49 +08:00
Xie Han	06ec1a7cad	Fix mysql decode_length_safe	2023-08-15 18:19:12 +08:00
Xie Han	dec2f58f5f	Merge branch 'master' of https://github.com/sogou/workflow	2023-08-15 17:49:28 +08:00
Xie Han	ba442be4fb	Add MYSQL_SERVER_SESSION_STATE_CHANGED	2023-08-15 17:48:59 +08:00
Xie Han	fca72098d6	Update Communicator::shutdown().	2023-08-11 23:39:57 +08:00
Xie Han	e32c7854bd	Avoid using 'sizeof' in macro.	2023-08-11 21:28:56 +08:00
xiehan	cd03ed2f0d	Merge pull request #1342 from Barenboim/master ... Optimize server task's behavior.	2023-08-10 22:44:16 +08:00
Xie Han	1cd4057091	Correct server task's noreply() behavior.	2023-08-10 21:40:42 +08:00
Xie Han	e4b2d200bc	Add Communicator::shutdown() for server task to close connection.	2023-08-10 21:38:53 +08:00
xiehan	c793dd53c1	Merge pull request #1334 from Barenboim/master ... Correct data type	2023-07-27 18:04:19 +08:00
Xie Han	b43078530a	Use std::string::data().	2023-07-27 17:34:09 +08:00
Xie Han	86cabfa6a9	Correct data type.	2023-07-27 17:30:56 +08:00
Xie Han	dd588fc30c	Add include errno.h	2023-07-26 23:49:19 +08:00
Xie Han	930fe5f0fa	Add TLVMessage.	2023-07-26 22:05:56 +08:00
Xie Han	4dd82db8ca	msgqueue maxlen set to 0 (unlimited).	2023-07-17 15:16:42 +08:00
Xie Han	3f7964b9e6	Do not set errno in msgqueue_get().	2023-07-17 15:16:12 +08:00
Xie Han	37d97c3826	Simplify CommTarget::release().	2023-07-14 04:48:23 +08:00
Xie Han	440112ffbf	Add WFNetworkTask::closed() for checking if the server task's connection is still retained.	2023-07-14 03:06:56 +08:00
kedixa	e5f778124e	check whether task->topic_set is a subset of this->topic_set	2023-06-30 17:45:42 +08:00
kedixa	ef886ec430	KafkaClientTask::compare_topics use ordered topic_set	2023-06-29 20:54:41 +08:00
Xie Han	a7785020df	Fix bugs	2023-06-27 20:28:39 +08:00
Xie Han	bedb54816b	update authors info	2023-06-27 20:28:39 +08:00
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