790 Commits

Author SHA1 Message Date
Cloud Wu
5ec02a4a2c Add a rare case 2023-09-28 20:15:29 +08:00
Cloud Wu
f3f7e725e8 check session == nil 2023-09-28 14:40:02 +08:00
云风
172278bc8f check conflict (#1798)
* rewind check conflict

* Use auxsend instead of c.send
2023-09-28 13:48:35 +08:00
Cloud Wu
c178c398b9 don't report error when session == 0 2023-07-31 21:31:21 +08:00
华仔
bb90b64c3f websocket添加is_close方法 (#1781)
* websocket添加is_close方法

* 代码优化
2023-07-19 20:01:41 +08:00
Whislly
c6a8976bc3 findOne优化 (#1772)
1、直接调用runCommand方法
2、增加"limit": 1参数,限制只返回一条数据
2023-07-10 12:29:16 +08:00
Whislly
074426e273 pipline方法优化 (#1771)
1、增加sort_statge、skip_statge、limit_statge、count_statge替换临时table
2、改成for i = 1, 2 do self.__pipeline[len + i] = nil end清除老数据
2023-07-07 20:11:36 +08:00
Whislly
b402837628 聚合方法返回游标对象 (#1769)
* 聚合方法返回游标对象

* 使用table.move()替换for循环拷贝

* 改成使用类似继承的方法

1、返回aggregate_cursor不修改mongo_cursor,直接拷贝mongo_cursor的sort、skip、limit、next、close方法
2、修改了mongo_cursor:count,不再使用unpack
3、aggregate_cursor:count和aggregate_cursor:hasNext方法里options为nil时,不使用unpack
4、mongo_collection:aggregate方法里拷贝了pipeline和options
2023-07-07 15:14:37 +08:00
yzj
272af34736 修改delete使用send_command (#1770)
Co-authored-by: xingfan.yzj <xingfan.yzj@alibaba-inc.com>
2023-07-06 17:44:02 +08:00
Cloud Wu
a5af5f6ba7 Overload socket_read(), See #1750 2023-05-16 15:59:43 +08:00
子熏
1e45d4a9be 添加get_protocol接口 (#1712)
* 添加get_protocol接口

* 添加_proto字段

---------

Co-authored-by: zixun <lb151450@alibaba-inc.com>
2023-03-15 12:44:08 +08:00
丁大龙
6fe520a7cb cluster.open添加maxclient参数 (#1705) 2023-02-18 00:57:39 +08:00
丁大龙
f344a49755 修复client_number计数错误 (#1704) 2023-02-17 14:36:32 +08:00
learno
ae35b3c4e8 bugfix: mongo getMore command field batchSize cannot replace with limit (#1666) 2022-10-19 17:04:49 +08:00
子云
1a1d8abd2e read 'x-real-ip' header from nginx in websocket lib. (#1665)
* read 'x-real-ip' header from nginx in websocket lib.

* change default real_ip value to nil
2022-10-17 19:29:33 +08:00
ykxpb
bc4800f326 修复 mongo 游标没有数据 hasNext 返回 true,以及无效关闭游标的问题 (#1653)
Co-authored-by: yy151474 <yy151474@alibaba-inc.com>
2022-09-24 08:41:37 +08:00
ykxpb
44e2583dc2 mongodb 交互协议调整为 OP_MSG (#1649)
* mongodb 交互协议调整为 OP_MSG

* Update

Co-authored-by: yy151474 <yy151474@alibaba-inc.com>
2022-09-20 10:56:33 +08:00
Cloud Wu
2d5e4ae528 cluster.open returns addr, port 2022-09-04 14:32:31 +08:00
Cloud Wu
b61daaccf1 watchdog returns addr,port 2022-09-04 14:22:13 +08:00
Cloud Wu
01314de8e1 Add assert 2022-09-04 00:20:38 +08:00
Cloud Wu
c8197328a4 socket.listen returns addr,port 2022-09-04 00:13:49 +08:00
Cloud Wu
800a3376d6 Revert "Update the return values of socket.listen, also return the real port bind to zero (#1638)"
This reverts commit c1eeba215d.
2022-09-03 22:03:11 +08:00
zaxbbun
c1eeba215d Update the return values of socket.listen, also return the real port bind to zero (#1638) 2022-09-03 07:19:03 +08:00
yfy
1b54306509 http请求头host字段改为Host (#1623) 2022-08-05 10:02:11 +08:00
dxb218
fad27d7775 Update interface.lua (#1612)
string.format语法错误
2022-06-11 20:22:22 +08:00
Cloud Wu
e98378e874 Fix #1609 2022-06-09 08:05:26 +08:00
子熏
389146167f export queryproto (#1605)
Co-authored-by: zixun <lb151450@alibaba-inc.com>
2022-05-30 23:18:08 +08:00
caiyiheng
013cb42122 feat: add mongo safe batch delete (#1577) 2022-04-15 16:20:00 +08:00
IAN.Z
6ad379b7a7 feat: add mongo safe batch update (#1575)
Co-authored-by: zhuyin.zhu <zhuyin.zhu@alibaba-inc.com>
2022-04-14 12:35:54 +08:00
JTrancender
b555aa19e7 feat: add cluster.unregister (#1563) 2022-04-02 12:17:47 +08:00
t0350
5d48c02725 see #1554, handle nomore message after skynet.exit (#1556)
Co-authored-by: jietao.cjt <jietao.cjt@alibaba-inc.com>
2022-03-23 09:38:20 +08:00
子熏
fad62566dc #1544 fix playload_len (#1553)
Co-authored-by: zixun <lvzxiun@gmail.com>
2022-03-21 13:23:03 +08:00
JTrancender
eaba8f969c perf: add sharetable queryall default behavior(all share data) (#1537) 2022-02-16 11:22:59 +08:00
JTrancender
40ee98b40e feat: add sharetable queryall (#1536)
Co-authored-by: Jason <jie-email@jie-trancender.org>
2022-02-15 21:01:54 +08:00
xjdrew
6d6be8dec6 skynet.service: add close (#1526)
Co-authored-by: drew.zxj <drew.zxj@alibaba-inc.com>
2022-01-21 10:34:00 +08:00
Cloud Wu
9d3edae797 Check self.__sock before dispatch, See #1513 2021-12-14 17:01:50 +08:00
Cloud Wu
208be03a6f Disconnected during auth, See #1513 2021-12-10 20:56:18 +08:00
Cloud Wu
3b54b3bd80 Revert "raise socket error during auth"
This reverts commit 839975415d.
2021-12-10 20:26:46 +08:00
Cloud Wu
839975415d raise socket error during auth 2021-12-10 19:31:36 +08:00
zhuilang
53292d1c93 update mysql (#1507) 2021-11-18 18:42:33 +08:00
Cloud Wu
1e2ed7e6ff Use table.pack to support nil in table, See #1505 2021-11-17 15:55:14 +08:00
Cloud Wu
350248a7cc fix #1504 2021-11-17 13:11:10 +08:00
子熏
e35cad3053 fix #1494 socket read阻塞问题 (#1495)
* fix #1494 socket read阻塞问题

* 优化readfunc

Co-authored-by: zixun <lb151450@alibaba-inc.com>
2021-10-29 13:55:54 +08:00
yxt945
8f7e19310c add json support (#1493) 2021-10-27 21:00:25 +08:00
云风
c008476417 Support string address, see #1490 (#1491) 2021-10-22 17:43:07 +08:00
Cloud Wu
599181ceaf bugfix 2021-10-22 10:14:33 +08:00
zhuilang
987bb3df47 modify from http folder (#1470)
* delete unused var and add used arg

* use interface from stream
2021-09-01 07:12:27 +08:00
云风
54e733a76f Request stream (#1463)
* split request/response

* stream api

* fix: global variable (#1464)

* fix global variable

* fix global variable

* Add httpc.head

Co-authored-by: JTrancender <jie-email@jie-trancender.org>
2021-08-30 10:00:57 +08:00
colin
6ee8d23ac4 ssl request support sni(Server Name Indication) (#1460)
* ssl support sni(Server Name Indication)

* ssl support sni(Server Name Indication)
2021-08-23 16:54:01 +08:00
JTrancender
fdc4b35281 feat: add mongo self batch insert (#1456)
* feat: add mongo self batch insert

* perf: add safe batch insert test

* perf: modify some words
2021-08-18 15:11:40 +08:00