ignite-issues mailing list archives

     [ https://issues.apache.org/jira/browse/IGNITE-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Igor Sapego updated IGNITE-10273:
---------------------------------
    Description: 
Reproducer test:

{code:cpp}
BOOST_AUTO_TEST_CASE(CacheClientDefaultDynamicCacheThreeNodes)
{
    StartNode("node1");
    StartNode("node2");

    IgniteClientConfiguration cfg;
    cfg.SetEndPoints("127.0.0.1:11110..11120");

    IgniteClient client = IgniteClient::Start(cfg);

    cache::CacheClient<std::string, int64_t> cache =
        client.CreateCache<std::string, int64_t>("defaultdynamic3");

    cache.RefreshAffinityMapping();

    for (int64_t i = 1; i < 1000; ++i)
        cache.Put(ignite::common::LexicalCast<std::string>(i * 39916801), i * 5039);

    for (int64_t i = 1; i < 1000; ++i)
    {
        int64_t val;
        LocalPeek(cache, ignite::common::LexicalCast<std::string>(i * 39916801), val);

        BOOST_CHECK_EQUAL(val, i * 5039);
    }
}
{code}

  was:
Reproducer test:

{code:cpp}
BOOST_AUTO_TEST_CASE(CacheClientDefaultDynamicCacheThreeNodes)
{
    StartNode("node1");
    StartNode("node2");

    IgniteClientConfiguration cfg;
    cfg.SetEndPoints("127.0.0.1:11110..11120");

    IgniteClient client = IgniteClient::Start(cfg);

    cache::CacheClient<std::string, int64_t> cache =
        client.CreateCache<std::string, int64_t>("defaultdynamic3");

    cache.RefreshAffinityMapping();

    for (int64_t i = 1; i < 1000; ++i)
        cache.Put(ignite::common::LexicalCast<std::string>(i * 39916801), i * 5039);

    for (int64_t i = 1; i < 1000; ++i)
    {
        int64_t val;
        LocalPeek(cache, ignite::common::LexicalCast<std::string>(i * 39916801), val);

        BOOST_CHECK_EQUAL(val, i * 5039);
    }
}
{code:cpp}


> CPP Thin: Client is unable to get affinity mapping in some cases
> ----------------------------------------------------------------
>
>                 Key: IGNITE-10273
>                 URL: https://issues.apache.org/jira/browse/IGNITE-10273
>             Project: Ignite
>          Issue Type: Bug
>          Components: thin client
>            Reporter: Igor Sapego
>            Assignee: Igor Sapego
>            Priority: Major
>              Labels: cpp
>             Fix For: 2.8
>
>
> Reproducer test:
> {code:cpp}
> BOOST_AUTO_TEST_CASE(CacheClientDefaultDynamicCacheThreeNodes)
> {
>     StartNode("node1");
>     StartNode("node2");
>     IgniteClientConfiguration cfg;
>     cfg.SetEndPoints("127.0.0.1:11110..11120");
>     IgniteClient client = IgniteClient::Start(cfg);
>     cache::CacheClient<std::string, int64_t> cache =
>         client.CreateCache<std::string, int64_t>("defaultdynamic3");
>     cache.RefreshAffinityMapping();
>     for (int64_t i = 1; i < 1000; ++i)
>         cache.Put(ignite::common::LexicalCast<std::string>(i * 39916801), i * 5039);
>     for (int64_t i = 1; i < 1000; ++i)
>     {
>         int64_t val;
>         LocalPeek(cache, ignite::common::LexicalCast<std::string>(i * 39916801),
val);
>         BOOST_CHECK_EQUAL(val, i * 5039);
>     }
> }
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)