is $code, 'OK', "auth was sent";
is $c->connector->state, 'ready', 'state';
isnt $sync, 1, 'next_sync';
ok exists $c->connector->_active_sync->{$sync}, 'active sync';
is $code, 'OK', "lua call was sent";
is $c->connector->state, 'ready', 'state';
isnt $sync, 1, 'next_sync';
ok exists $c->connector->_active_sync->{$sync}, 'active sync';
is $code, 'OK', "$_ was send";
is $c->connector->state, 'ready', 'state';
isnt $sync, 1, 'next_sync';
ok exists $c->connector->_active_sync->{$sync}, 'active sync';
, 'state';
});
});
$c->connect(
sub {
my ($code, $message, @args) = @_;
isnt $code => 'OK', 'Can not connect to shutdown tarantool';
}
);
$ti->start;
$c->connect(
s
isnt $c->last_schema, $schema_id, 'schema_id was changed';
}
});
$c->request(ping => sub {
diag explain \@_ unless
is $_[0] => 'OK', 'ping';
isnt $c-
is $code, 'OK', "$_ was send";
is $c->connector->state, 'ready', 'state';
isnt $sync, 1, 'next_sync';
ok exists $c->connector->_active_sync->{$sync}, 'active sync';
is $resp->{SYNC}, $sync, 'sync';
diag explain $resp unless
isnt $resp->{CODE}, $await_code, 'not waited code';
is $resp->{CODE}, 0x806D, 'Code of
is $code, 'OK', "$_ was send";
is $c->connector->state, 'ready', 'state';
isnt $sync, 1, 'next_sync';
ok exists $c->connector->_active_sync->{$sync}, 'active sync';
esp->{SYNC}, $sync, 'sync';
diag explain $resp unless
isnt $resp->{CODE}, $await_code, 'not waited code';
is $resp->{CODE}, 0x806D, 'Cod
d';
is_deeply $tuples => [{ name => 'test', value => undef, tail => [] }], 'tuples';
isnt eval { $c->call_lua(['rettest' => 'test123']); 1 }, 1, 'unknown space';
is $c->last_error->[0
is $c->state, 'ready', 'state';
}
);
$c->request(ping => sub {
is $_[0] => 'OK', 'ping';
isnt scalar(keys %{ $c->_sch }), 0, 'sch is not empty';
});
}
d';
is_deeply $tuples => [{ name => 'test', value => undef, tail => [] }], 'tuples';
isnt eval { $c->call_lua(['rettest' => 'test123']); 1 }, 1, 'unknown space';
is $c->last_error->[0