From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from [87.239.111.99] (localhost [127.0.0.1]) by dev.tarantool.org (Postfix) with ESMTP id C4FEA71211; Thu, 5 Aug 2021 21:17:48 +0300 (MSK) DKIM-Filter: OpenDKIM Filter v2.11.0 dev.tarantool.org C4FEA71211 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=tarantool.org; s=dev; t=1628187468; bh=FcJCeTkReInzzQvDpr7ya8R5ovyu9sz8LXjcf+vHiIU=; h=To:Cc:Date:Subject:List-Id:List-Unsubscribe:List-Archive: List-Post:List-Help:List-Subscribe:From:Reply-To:From; b=KIRWMjC0Y0ealMB6RMrBJys8zvetB+4vrhIJb7iIsJL0vZmNFaJslQ42c8/au58jx YXX2/ecppwdlIK9QsOBrBG+uB+c/V1kzwWf1rqY5AIA8OviBLnLGqFRQd/EuLpnB3q 2AwAa0ZndHvbRvWX/Mys7EXwndsHKH9v9LKRS8C0= Received: from smtp53.i.mail.ru (smtp53.i.mail.ru [94.100.177.113]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by dev.tarantool.org (Postfix) with ESMTPS id AD16971211 for ; Thu, 5 Aug 2021 21:17:47 +0300 (MSK) DKIM-Filter: OpenDKIM Filter v2.11.0 dev.tarantool.org AD16971211 Received: by smtp53.i.mail.ru with esmtpa (envelope-from ) id 1mBhwA-0005CS-Fv; Thu, 05 Aug 2021 21:17:47 +0300 To: v.shpilevoy@tarantool.org, vdavydov@tarantool.org Cc: tarantool-patches@dev.tarantool.org, mechanik20051988 Date: Thu, 5 Aug 2021 21:17:38 +0300 Message-Id: X-Mailer: git-send-email 2.20.1 MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-7564579A: 646B95376F6C166E X-77F55803: 4F1203BC0FB41BD92087353F0EC44DD9BCE6B93DE0C6C3914462CDB1732D383C182A05F538085040011E7814E98EFD5B3F71A2474823AC032049AA47F9AFF574A2B9A04E6D3F38BE X-7FA49CB5: FF5795518A3D127A4AD6D5ED66289B5278DA827A17800CE77633BACAB33B9508C2099A533E45F2D0395957E7521B51C2CFCAF695D4D8E9FCEA1F7E6F0F101C6778DA827A17800CE782A779A89F7D69B28F08D7030A58E5AD1A62830130A00468AEEEE3FBA3A834EE7353EFBB5533756630CE973C7F71088DD8F68E55EB63D25B0BE2E759DA9F5683A471835C12D1D9774AD6D5ED66289B5278DA827A17800CE77FFCE1C639F4728C9FA2833FD35BB23D2EF20D2F80756B5F868A13BD56FB6657A471835C12D1D977725E5C173C3A84C353FA85A707D24CADCC7F00164DA146DA6F5DAA56C3B73B237318B6A418E8EAB8D32BA5DBAC0009BE9E8FC8737B5C2249497E75563ED2C4F476E601842F6C81A12EF20D2F80756B5F7E9C4E3C761E06A776E601842F6C81A127C277FBC8AE2E8B0D5522F3974E31783AA81AA40904B5D9DBF02ECDB25306B2201CA6A4E26CD07C3BBE47FD9DD3FB595F5C1EE8F4F765FC72CEEB2601E22B093A03B725D353964B0B7D0EA88DDEDAC722CA9DD8327EE493B89ED3C7A6281781444A83B712AC0148C4224003CC83647689D4C264860C145E X-C1DE0DAB: C20DE7B7AB408E4181F030C43753B8183A4AFAF3EA6BDC44C234C8B12C006B7A4A556CA68DC7B18038F0602F476F567B9925E1209B7B2AFEB1881A6453793CE9C32612AADDFBE061F7708837730DFF529510FB958DCE06DB6ED91DBE5ABE359AC8952F428387DEC069F8FEF10F1C2C2993EDB24507CE13387DFF0A840B692CF8 X-C8649E89: 4E36BF7865823D7055A7F0CF078B5EC49A30900B95165D34DA1FE609583D493C2D7052E6AA40353249080BF1622B93A98686F58961B489590024AAF317BD9CF61D7E09C32AA3244CAD6875A939BE1CE72BDA1BE3F4EFD20E60759606DA2E136A927AC6DF5659F194 X-D57D3AED: 3ZO7eAau8CL7WIMRKs4sN3D3tLDjz0dLbV79QFUyzQ2Ujvy7cMT6pYYqY16iZVKkSc3dCLJ7zSJH7+u4VD18S7Vl4ZUrpaVfd2+vE6kuoey4m4VkSEu530nj6fImhcD4MUrOEAnl0W826KZ9Q+tr5ycPtXkTV4k65bRjmOUUP8cvGozZ33TWg5HZplvhhXbhDGzqmQDTd6OAevLeAnq3Ra9uf7zvY2zzsIhlcp/Y7m53TZgf2aB4JOg4gkr2biojbL9S8ysBdXicHBMa/R0efedd/KGhzbnP X-Mailru-Sender: 583F1D7ACE8F49BD29FC049B2A5BF963272C3B768E89E9F14558CB1A6F9742AB667B1B35C898C542B79567116EAC6FCF4E830D9205DBEA545646F0D3C63A617F27ACC94E9A535D22112434F685709FCF0DA7A0AF5A3A8387 X-Mras: Ok Subject: [Tarantool-patches] [PATCH 0/7] implement iproto streams X-BeenThere: tarantool-patches@dev.tarantool.org X-Mailman-Version: 2.1.34 Precedence: list List-Id: Tarantool development patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , From: mechanik20051988 via Tarantool-patches Reply-To: mechanik20051988 Errors-To: tarantool-patches-bounces@dev.tarantool.org Sender: "Tarantool-patches" From: mechanik20051988 branch: https://github.com/tarantool/tarantool/tree/mechanik20051988/gh-5860-iproto-streams-v1 pullrequest: https://github.com/tarantool/tarantool/pull/6139 issue: https://github.com/tarantool/tarantool/issues/5860 mechanik20051988 (7): iproto: implement stream id in binary iproto protocol salad: fix segfault in case when mhash table allocation failure txn: detach transaction from fiber. iproto: implement streams in iproto net.box: add stream support to net.box iproto: implement interactive transactions over iproto streams net.box: add interactive transaction support in net.box .../gh-5860-implement-streams-in-iproto.md | 28 + src/box/call.c | 10 +- src/box/errcode.h | 2 + src/box/iproto.cc | 459 ++- src/box/iproto_constants.c | 10 +- src/box/iproto_constants.h | 11 +- src/box/lua/net_box.c | 152 +- src/box/lua/net_box.lua | 241 +- src/box/txn.c | 29 +- src/box/txn.h | 11 + src/box/xrow.c | 8 + src/box/xrow.h | 5 + src/lib/core/errinj.h | 2 + src/lib/salad/mhash.h | 99 +- test/box-tap/feedback_daemon.test.lua | 2 +- test/box/access.result | 6 +- test/box/access.test.lua | 6 +- test/box/errinj.result | 2 + test/box/error.result | 2 + test/box/misc.result | 5 +- ...net.box_console_connections_gh-2677.result | 2 +- ...t.box_console_connections_gh-2677.test.lua | 2 +- .../net.box_incorrect_iterator_gh-841.result | 4 +- ...net.box_incorrect_iterator_gh-841.test.lua | 4 +- test/box/net.box_iproto_hangs_gh-3464.result | 2 +- .../box/net.box_iproto_hangs_gh-3464.test.lua | 2 +- .../net.box_long-poll_input_gh-3400.result | 8 +- .../net.box_long-poll_input_gh-3400.test.lua | 8 +- test/box/stream.lua | 13 + test/box/stream.result | 3589 +++++++++++++++++ test/box/stream.test.lua | 1408 +++++++ test/box/suite.ini | 2 +- test/unit/mhash_body.c | 4 +- test/unit/xrow.cc | 7 +- test/unit/xrow.result | 168 +- 35 files changed, 6065 insertions(+), 248 deletions(-) create mode 100644 changelogs/unreleased/gh-5860-implement-streams-in-iproto.md create mode 100644 test/box/stream.lua create mode 100644 test/box/stream.result create mode 100644 test/box/stream.test.lua -- 2.20.1