mirror of
https://github.com/cloudwu/skynet.git
synced 2026-07-24 20:23:06 +00:00
bugfix: mongo driver, reply result
This commit is contained in:
@@ -67,8 +67,8 @@ local collection_meta = {
|
|||||||
local function dispatch_reply(so)
|
local function dispatch_reply(so)
|
||||||
local len_reply = so:read(4)
|
local len_reply = so:read(4)
|
||||||
local reply = so:read(driver.length(len_reply))
|
local reply = so:read(driver.length(len_reply))
|
||||||
local result = {}
|
local result = { result = {} }
|
||||||
local succ, reply_id, document, cursor_id, startfrom = driver.reply(reply, result)
|
local succ, reply_id, document, cursor_id, startfrom = driver.reply(reply, result.result)
|
||||||
result.document = document
|
result.document = document
|
||||||
result.cursor_id = cursor_id
|
result.cursor_id = cursor_id
|
||||||
result.startfrom = startfrom
|
result.startfrom = startfrom
|
||||||
@@ -237,8 +237,8 @@ function mongo_cursor:hasNext()
|
|||||||
|
|
||||||
if ok then
|
if ok then
|
||||||
if doc then
|
if doc then
|
||||||
self.__document = doc
|
self.__document = result.result
|
||||||
self.__data = data
|
self.__data = result.data
|
||||||
self.__ptr = 1
|
self.__ptr = 1
|
||||||
self.__cursor = cursor
|
self.__cursor = cursor
|
||||||
return true
|
return true
|
||||||
|
|||||||
Reference in New Issue
Block a user