Skip to content

Commit 3c2b4bf

Browse files
LeonidVasLeonidVas
committed
add support of a new binary protocol command for "call"
* Added support for a new binary protocol command for "call" (used since tarantool 1.7.2). Unlike the old version, returned data is not converted to tuples (like in case of using "eval"). Default - call_16 mode. * Added options to "call" method. It can be used to force call_16 / call_17 mode. Example: ``` php $c = new Tarantool('localhost', 3301); $c->connect(); $c->call("test_call", array(), array('call_17' => true)); $c->close(); ``` Closes #101
1 parent 6c098be commit 3c2b4bf

File tree

8 files changed

+170
-25
lines changed

8 files changed

+170
-25
lines changed

‎README.md

Lines changed: 25 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ Tarantool {
122122
public array Tarantool::select (mixed $space [, mixed $key = array() [, mixed $index = 0 [, int $limit = PHP_INT_MAX [, int $offset = 0 [, $iterator = Tarantool::ITERATOR_EQ ] ] ] ] ] )
123123
public array Tarantool::insert (mixed $space, array $tuple)
124124
public array Tarantool::replace (mixed $space, array $tuple)
125-
public array Tarantool::call (string $procedure [, mixed args] )
125+
public array Tarantool::call (string $procedure [, mixed args [, array $opts ] ] )
126126
public array Tarantool::evaluate (string $expression [, mixed args] )
127127
public array Tarantool::delete (mixed $space, mixed $key [, mixed $index] )
128128
public array Tarantool::update (mixed $space, mixed $key, array $ops [, number $index] )
@@ -299,27 +299,47 @@ $tnt->replace("test", array(1, 3, "smth completely different"));
299299
### Tarantool::call
300300

301301
``` php
302-
public array Tarantool::call(string $procedure [, mixed args])
302+
public array Tarantool::call(string $procedure [, mixed args [, array $opts]])
303303
```
304304

305305
_**Description**_: Call stored procedure
306306

307307
_**Parameters**_
308308
* `procedure`: String, procedure to call (mandatory)
309-
* `args`: Any value to pass to procdure as arguments (empty by default)
309+
* `args`: Any value to pass to procedure as arguments (empty by default)
310+
* `opts`: Array, options
311+
312+
_**Options**_
313+
* call_17
314+
If true - call_17 mode of "call" will be used
315+
(returned data has an arbitrary structure). Since tarantool 1.7.2.
316+
if false - call_16 mode of "call" will be used
317+
(returned data converted to tuples).
318+
Default - call_16 mode.
319+
```
320+
array(
321+
"call_17" => <bool>
322+
),
323+
```
310324

311325
_**Return Value**_
312326

327+
**BOOL**: False and raises `Exception` in case of error.
328+
329+
call_16 mode (default):
330+
313331
**Array of arrays** in case of success - tuples that were returned by stored
314332
procedure.
315333

316-
**BOOL**: False and raises `Exception` in case of error.
334+
call_17 mode:
335+
336+
**Any value**, that was returned by stored procedure.
317337

318338
#### Example
319339

320340
``` php
321341
$tnt->call("test_2");
322-
$tnt->call("test_3", array(3, 4));
342+
$tnt->call("test_3", array(3, 4), array('call_17' => true));
323343
```
324344

325345
### Tarantool::evaluate

‎src/tarantool.c

Lines changed: 66 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
#include <time.h>
22
#include <stdio.h>
33
#include <limits.h>
4+
#include <string.h>
45

56
#include "php_tarantool.h"
67
#include "tarantool_internal.h"
@@ -14,6 +15,7 @@
1415

1516
#include "utils.h"
1617

18+
1719
static int __tarantool_authenticate(tarantool_connection *obj);
1820
static void tarantool_stream_close(tarantool_connection *obj);
1921

@@ -543,12 +545,19 @@ ZEND_BEGIN_ARG_INFO_EX(arginfo_tarantool_delete, 0, 0, 2)
543545
ZEND_ARG_INFO(0, index)
544546
ZEND_END_ARG_INFO()
545547

546-
/* call, eval */
548+
/* eval */
547549
ZEND_BEGIN_ARG_INFO_EX(arginfo_tarantool_proc_tuple, 0, 0, 1)
548550
ZEND_ARG_INFO(0, proc)
549551
ZEND_ARG_INFO(0, tuple)
550552
ZEND_END_ARG_INFO()
551553

554+
/* call */
555+
ZEND_BEGIN_ARG_INFO_EX(arginfo_tarantool_proc_call, 0, 0, 1)
556+
ZEND_ARG_INFO(0, proc)
557+
ZEND_ARG_INFO(0, tuple)
558+
ZEND_ARG_INFO(0, opts)
559+
ZEND_END_ARG_INFO()
560+
552561
ZEND_BEGIN_ARG_INFO_EX(arginfo_tarantool_update, 0, 0, 3)
553562
ZEND_ARG_INFO(0, space)
554563
ZEND_ARG_INFO(0, key)
@@ -575,7 +584,7 @@ const zend_function_entry Tarantool_methods[] = {
575584
TNT_MEP(select, arginfo_tarantool_select )
576585
TNT_MEP(insert, arginfo_tarantool_space_tuple )
577586
TNT_MEP(replace, arginfo_tarantool_space_tuple )
578-
TNT_MEP(call, arginfo_tarantool_proc_tuple )
587+
TNT_MEP(call, arginfo_tarantool_proc_call )
579588
TNT_MEP(eval, arginfo_tarantool_proc_tuple )
580589
TNT_MEP(delete, arginfo_tarantool_delete )
581590
TNT_MEP(update, arginfo_tarantool_update )
@@ -1166,6 +1175,7 @@ PHP_METHOD(Tarantool, __construct) {
11661175
}
11671176
zend_string_release(plist_id);
11681177
}
1178+
11691179
t_obj->obj = obj;
11701180
t_obj->is_persistent = is_persistent;
11711181
return;
@@ -1457,17 +1467,69 @@ PHP_METHOD(Tarantool, delete) {
14571467
TARANTOOL_RETURN_DATA(&body, &header, &body);
14581468
}
14591469

1470+
/**
1471+
* "call" options.
1472+
*/
1473+
struct call_opts {
1474+
bool call_17;
1475+
};
1476+
1477+
/**
1478+
* Initialization value for "call" options.
1479+
*/
1480+
static const struct call_opts call_opts_def = {
1481+
.call_17 = false
1482+
};
1483+
1484+
static int parse_call_opts(zval *opts, struct call_opts *res) {
1485+
HashTable *ht = HASH_OF(opts);
1486+
if (ht == NULL) {
1487+
THROW_EXC("call(): bad type of \"options\"."
1488+
" Should be an array.");
1489+
return FAILURE;
1490+
}
1491+
1492+
zval *call_17_zval = zend_hash_str_find(ht, "call_17",
1493+
strlen("call_17"));
1494+
if (call_17_zval != NULL) {
1495+
if (Z_TYPE_P(call_17_zval) == IS_TRUE) {
1496+
res->call_17 = true;
1497+
} else if (Z_TYPE_P(call_17_zval) == IS_FALSE) {
1498+
res->call_17 = false;
1499+
} else {
1500+
THROW_EXC("call(): bad type of call_17 option."
1501+
" Should be a boolean.");
1502+
return FAILURE;
1503+
}
1504+
}
1505+
1506+
return SUCCESS;
1507+
}
1508+
14601509
PHP_METHOD(Tarantool, call) {
14611510
char *proc; size_t proc_len;
14621511
zval *tuple = NULL, tuple_new;
1512+
zval *opts = NULL;
14631513

1464-
TARANTOOL_FUNCTION_BEGIN(obj, id, "s|z", &proc, &proc_len, &tuple);
1514+
TARANTOOL_FUNCTION_BEGIN(obj, id, "s|zz", &proc, &proc_len,
1515+
&tuple, &opts);
14651516
TARANTOOL_CONNECT_ON_DEMAND(obj);
14661517

1518+
struct call_opts call_opts = call_opts_def;
1519+
if (opts != NULL && parse_call_opts(opts, &call_opts) == FAILURE) {
1520+
RETURN_FALSE;
1521+
}
1522+
14671523
pack_key(tuple, 1, &tuple_new);
14681524

14691525
long sync = TARANTOOL_G(sync_counter)++;
1470-
php_tp_encode_call(obj->value, sync, proc, proc_len, &tuple_new);
1526+
if (call_opts.call_17) {
1527+
php_tp_encode_call(obj->value, sync, proc, proc_len,
1528+
&tuple_new);
1529+
} else {
1530+
php_tp_encode_call_16(obj->value, sync, proc, proc_len,
1531+
&tuple_new);
1532+
}
14711533
zval_ptr_dtor(&tuple_new);
14721534
if (tarantool_stream_send(obj) == FAILURE)
14731535
RETURN_FALSE;

‎src/tarantool_proto.c

Lines changed: 18 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -172,29 +172,39 @@ void php_tp_encode_delete(smart_string *str, uint32_t sync,
172172
php_mp_pack(str, tuple);
173173
}
174174

175-
size_t php_tp_sizeof_call(uint32_t sync,
176-
uint32_t proc_len, zval *tuple) {
177-
return php_tp_sizeof_header(TNT_CALL, sync) +
175+
static size_t php_tp_sizeof_call(uint32_t sync, uint32_t proc_len,
176+
enum tnt_request_type type, zval *tuple) {
177+
return php_tp_sizeof_header(type, sync) +
178178
php_mp_sizeof_hash(2) +
179179
php_mp_sizeof_long(TNT_FUNCTION) +
180180
php_mp_sizeof_string(proc_len) +
181181
php_mp_sizeof_long(TNT_TUPLE) +
182182
php_mp_sizeof(tuple) ;
183183
}
184184

185-
void php_tp_encode_call(smart_string *str, uint32_t sync,
186-
char *proc, uint32_t proc_len, zval *tuple) {
187-
size_t packet_size = php_tp_sizeof_call(sync,
188-
proc_len, tuple);
185+
static void php_tp_encode_call_impl(smart_string *str, uint32_t sync,
186+
char *proc, uint32_t proc_len,
187+
enum tnt_request_type type, zval *tuple) {
188+
size_t packet_size = php_tp_sizeof_call(sync, proc_len, type, tuple);
189189
smart_string_ensure(str, packet_size + 5);
190-
php_tp_pack_header(str, packet_size, TNT_CALL, sync);
190+
php_tp_pack_header(str, packet_size, type, sync);
191191
php_mp_pack_hash(str, 2);
192192
php_mp_pack_long(str, TNT_FUNCTION);
193193
php_mp_pack_string(str, proc, proc_len);
194194
php_mp_pack_long(str, TNT_TUPLE);
195195
php_mp_pack(str, tuple);
196196
}
197197

198+
void php_tp_encode_call(smart_string *str, uint32_t sync, char *proc,
199+
uint32_t proc_len, zval *tuple) {
200+
php_tp_encode_call_impl(str,sync, proc, proc_len, TNT_CALL, tuple);
201+
}
202+
203+
void php_tp_encode_call_16(smart_string *str, uint32_t sync, char *proc,
204+
uint32_t proc_len, zval *tuple) {
205+
php_tp_encode_call_impl(str,sync, proc, proc_len, TNT_CALL_16, tuple);
206+
}
207+
198208
size_t php_tp_sizeof_eval(uint32_t sync,
199209
uint32_t proc_len, zval *tuple) {
200210
return php_tp_sizeof_header(TNT_EVAL, sync) +

‎src/tarantool_proto.h

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,10 +85,11 @@ enum tnt_request_type {
8585
TNT_REPLACE = 0x03,
8686
TNT_UPDATE = 0x04,
8787
TNT_DELETE = 0x05,
88-
TNT_CALL = 0x06,
88+
TNT_CALL_16 = 0x06,
8989
TNT_AUTH = 0x07,
9090
TNT_EVAL = 0x08,
9191
TNT_UPSERT = 0x09,
92+
TNT_CALL = 0x0a,
9293
TNT_PING = 0x40
9394
};
9495

@@ -136,6 +137,8 @@ void php_tp_encode_delete(smart_string *str, uint32_t sync, uint32_t space_no,
136137
uint32_t index_no, zval *tuple);
137138
void php_tp_encode_call(smart_string *str, uint32_t sync, char *proc,
138139
uint32_t proc_len, zval *tuple);
140+
void php_tp_encode_call_16(smart_string *str, uint32_t sync, char *proc,
141+
uint32_t proc_len, zval *tuple);
139142
void php_tp_encode_eval(smart_string *str, uint32_t sync, char *proc,
140143
uint32_t proc_len, zval *tuple);
141144

‎test/DMLTest.php

Lines changed: 22 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -235,18 +235,37 @@ public function test_11_update_error() {
235235
}
236236

237237
public function test_12_call() {
238-
$result = self::$tarantool->call("test_6", array(true, false, false));
238+
$result = self::$tarantool->call("test_6", array(true, false, false),
239+
array('call_17' => false));
239240
$this->assertEquals(array(array(true), array(false), array(false)), $result);
240241
$this->assertEquals(
241242
array(
242243
'0' => array(
243244
'0' => array('k1' => 'v2', 'k2' => 'v')
244245
)
245246
),
246-
self::$tarantool->call("test_2")
247+
self::$tarantool->call("test_2", array(), array('call_17' => false))
247248
);
248249
$this->assertEquals(
249-
self::$tarantool->call("test_3", array(3, 4)), array('0' => array('0' => 7)));
250+
self::$tarantool->call("test_3", array(3, 4), array('call_17' => false)),
251+
array('0' => array('0' => 7))
252+
);
253+
254+
$check_call_17 = self::$tarantool->call('tarantool_version_at_least',
255+
array(1, 7, 2, 0));
256+
if ($check_call_17[0][0]) {
257+
$result = self::$tarantool->call("test_6", array(true, false, false),
258+
array('call_17' => true));
259+
$this->assertEquals(array(true, false, false), $result);
260+
$this->assertEquals(
261+
array('0' => array('k1' => 'v2', 'k2' => 'v')),
262+
self::$tarantool->call("test_2", array(), array('call_17' => true))
263+
);
264+
$this->assertEquals(
265+
self::$tarantool->call("test_3", array(3, 4), array('call_17' => true)),
266+
array('0' => 7)
267+
);
268+
}
250269
}
251270

252271
public function test_13_eval() {

‎test/MsgPackTest.php

Lines changed: 20 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,14 +22,31 @@ public function test_00_msgpack_call() {
2222
'4TL2tLIXqMqyGQm_kiE7mRrS96I5E8nqU', 'B627', 0, [
2323
'browser_stats_first_session_hits' => 1
2424
]
25-
]);
25+
], ['call_17' => false]);
2626
$this->assertEquals($resp[0][0], 2);
2727
$resp = self::$tarantool->call('test_4', [
2828
'4TL2tLIXqMqyGQm_kiE7mRrS96I5E8nqU', 'B627', 0, [
2929
'browser_stats_first_session_hit' => 1
3030
]
31-
]);
31+
], ['call_17' => false]);
3232
$this->assertEquals($resp[0][0], 2);
33+
34+
$check_call_17 = self::$tarantool->call('tarantool_version_at_least',
35+
array(1,7,2,0));
36+
if ($check_call_17[0][0]) {
37+
$resp = self::$tarantool->call('test_4', [
38+
'4TL2tLIXqMqyGQm_kiE7mRrS96I5E8nqU', 'B627', 0, [
39+
'browser_stats_first_session_hits' => 1
40+
]
41+
], ['call_17' => true]);
42+
$this->assertEquals($resp[0], 2);
43+
$resp = self::$tarantool->call('test_4', [
44+
'4TL2tLIXqMqyGQm_kiE7mRrS96I5E8nqU', 'B627', 0, [
45+
'browser_stats_first_session_hit' => 1
46+
]
47+
], ['call_17' => true]);
48+
$this->assertEquals($resp[0], 2);
49+
}
3350
}
3451

3552
public function test_01_msgpack_array_key() {
@@ -81,6 +98,6 @@ public function test_05_msgpack_string_keys() {
8198
public function test_06_msgpack_array_reference() {
8299
$data = array('key1' => 'value1');
83100
$link = &$data['key1'];
84-
self::$tarantool->call('test_4', [$data]);
101+
self::$tarantool->call('test_4', [$data], ['call_17' => false]);
85102
}
86103
}

‎test/RandomTest.php

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,9 +42,20 @@ public function test_02_very_big_response() {
4242

4343
public function test_03_another_big_response() {
4444
for ($i = 100; $i <= 5200; $i += 100) {
45-
$result = self::$tarantool->call('test_5', array($i));
45+
$result = self::$tarantool->call('test_5', array($i),
46+
array('call_17' => false));
4647
$this->assertEquals($i, count($result));
4748
}
49+
50+
$check_call_17 = self::$tarantool->call('tarantool_version_at_least',
51+
array(1,7,2,0));
52+
if ($check_call_17[0][0]) {
53+
for ($i = 100; $i <= 5200; $i += 100) {
54+
$result = self::$tarantool->call('test_5', array($i),
55+
array('call_17' => true));
56+
$this->assertEquals($i, count($result[0]));
57+
}
58+
}
4859
}
4960

5061
/**

‎test/shared/box.lua

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -180,5 +180,8 @@ function test_6(...)
180180
return ...
181181
end
182182

183+
-- export tarantool_version_at_least function
184+
_G.tarantool_version_at_least = tarantool_version_at_least
185+
183186
require('console').listen(os.getenv('ADMIN_PORT'))
184187

0 commit comments

Comments
 (0)