123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151 |
- // Licensed to the Apache Software Foundation (ASF) under one
- // or more contributor license agreements. See the NOTICE file
- // distributed with this work for additional information
- // regarding copyright ownership. The ASF licenses this file
- // to you under the Apache License, Version 2.0 (the
- // "License"); you may not use this file except in compliance
- // with the License. You may obtain a copy of the License at
- //
- // http://www.apache.org/licenses/LICENSE-2.0
- //
- // Unless required by applicable law or agreed to in writing,
- // software distributed under the License is distributed on an
- // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- // KIND, either express or implied. See the License for the
- // specific language governing permissions and limitations
- // under the License.
- #include <gtest/gtest.h>
- #include "butil/errno.h"
- #include "butil/endpoint.h"
- #include "butil/logging.h"
- #include "butil/containers/flat_map.h"
- namespace {
- TEST(EndPointTest, comparisons) {
- butil::EndPoint p1(butil::int2ip(1234), 5678);
- butil::EndPoint p2 = p1;
- ASSERT_TRUE(p1 == p2 && !(p1 != p2));
- ASSERT_TRUE(p1 <= p2 && p1 >= p2 && !(p1 < p2 || p1 > p2));
- ++p2.port;
- ASSERT_TRUE(p1 != p2 && !(p1 == p2));
- ASSERT_TRUE(p1 < p2 && p2 > p1 && !(p2 <= p1 || p1 >= p2));
- --p2.port;
- p2.ip = butil::int2ip(butil::ip2int(p2.ip)-1);
- ASSERT_TRUE(p1 != p2 && !(p1 == p2));
- ASSERT_TRUE(p1 > p2 && p2 < p1 && !(p1 <= p2 || p2 >= p1));
- }
- TEST(EndPointTest, ip_t) {
- LOG(INFO) << "INET_ADDRSTRLEN = " << INET_ADDRSTRLEN;
-
- butil::ip_t ip0;
- ASSERT_EQ(0, butil::str2ip("1.1.1.1", &ip0));
- ASSERT_STREQ("1.1.1.1", butil::ip2str(ip0).c_str());
- ASSERT_EQ(-1, butil::str2ip("301.1.1.1", &ip0));
- ASSERT_EQ(-1, butil::str2ip("1.-1.1.1", &ip0));
- ASSERT_EQ(-1, butil::str2ip("1.1.-101.1", &ip0));
- ASSERT_STREQ("1.0.0.0", butil::ip2str(butil::int2ip(1)).c_str());
- butil::ip_t ip1, ip2, ip3;
- ASSERT_EQ(0, butil::str2ip("192.168.0.1", &ip1));
- ASSERT_EQ(0, butil::str2ip("192.168.0.2", &ip2));
- ip3 = ip1;
- ASSERT_LT(ip1, ip2);
- ASSERT_LE(ip1, ip2);
- ASSERT_GT(ip2, ip1);
- ASSERT_GE(ip2, ip1);
- ASSERT_TRUE(ip1 != ip2);
- ASSERT_FALSE(ip1 == ip2);
- ASSERT_TRUE(ip1 == ip3);
- ASSERT_FALSE(ip1 != ip3);
- }
- TEST(EndPointTest, show_local_info) {
- LOG(INFO) << "my_ip is " << butil::my_ip() << std::endl
- << "my_ip_cstr is " << butil::my_ip_cstr() << std::endl
- << "my_hostname is " << butil::my_hostname();
- }
- TEST(EndPointTest, endpoint) {
- butil::EndPoint p1;
- ASSERT_EQ(butil::IP_ANY, p1.ip);
- ASSERT_EQ(0, p1.port);
-
- butil::EndPoint p2(butil::IP_NONE, -1);
- ASSERT_EQ(butil::IP_NONE, p2.ip);
- ASSERT_EQ(-1, p2.port);
- butil::EndPoint p3;
- ASSERT_EQ(-1, butil::str2endpoint(" 127.0.0.1:-1", &p3));
- ASSERT_EQ(-1, butil::str2endpoint(" 127.0.0.1:65536", &p3));
- ASSERT_EQ(0, butil::str2endpoint(" 127.0.0.1:65535", &p3));
- ASSERT_EQ(0, butil::str2endpoint(" 127.0.0.1:0", &p3));
- butil::EndPoint p4;
- ASSERT_EQ(0, butil::str2endpoint(" 127.0.0.1: 289 ", &p4));
- ASSERT_STREQ("127.0.0.1", butil::ip2str(p4.ip).c_str());
- ASSERT_EQ(289, p4.port);
-
- butil::EndPoint p5;
- ASSERT_EQ(-1, hostname2endpoint("localhost:-1", &p5));
- ASSERT_EQ(-1, hostname2endpoint("localhost:65536", &p5));
- ASSERT_EQ(0, hostname2endpoint("localhost:65535", &p5)) << berror();
- ASSERT_EQ(0, hostname2endpoint("localhost:0", &p5));
- #ifdef BAIDU_INTERNAL
- butil::EndPoint p6;
- ASSERT_EQ(0, hostname2endpoint("tc-cm-et21.tc: 289 ", &p6));
- ASSERT_STREQ("10.23.249.73", butil::ip2str(p6.ip).c_str());
- ASSERT_EQ(289, p6.port);
- #endif
- }
- TEST(EndPointTest, hash_table) {
- butil::hash_map<butil::EndPoint, int> m;
- butil::EndPoint ep1(butil::IP_ANY, 123);
- butil::EndPoint ep2(butil::IP_ANY, 456);
- ++m[ep1];
- ASSERT_TRUE(m.find(ep1) != m.end());
- ASSERT_EQ(1, m.find(ep1)->second);
- ASSERT_EQ(1u, m.size());
- ++m[ep1];
- ASSERT_TRUE(m.find(ep1) != m.end());
- ASSERT_EQ(2, m.find(ep1)->second);
- ASSERT_EQ(1u, m.size());
- ++m[ep2];
- ASSERT_TRUE(m.find(ep2) != m.end());
- ASSERT_EQ(1, m.find(ep2)->second);
- ASSERT_EQ(2u, m.size());
- }
- TEST(EndPointTest, flat_map) {
- butil::FlatMap<butil::EndPoint, int> m;
- ASSERT_EQ(0, m.init(1024));
- uint32_t port = 8088;
- butil::EndPoint ep1(butil::IP_ANY, port);
- butil::EndPoint ep2(butil::IP_ANY, port);
- ++m[ep1];
- ++m[ep2];
- ASSERT_EQ(1u, m.size());
- butil::ip_t ip_addr;
- butil::str2ip("10.10.10.10", &ip_addr);
- int ip = butil::ip2int(ip_addr);
- for (int i = 0; i < 1023; ++i) {
- butil::EndPoint ep(butil::int2ip(++ip), port);
- ++m[ep];
- }
- butil::BucketInfo info = m.bucket_info();
- LOG(INFO) << "bucket info max long=" << info.longest_length
- << " avg=" << info.average_length << std::endl;
- ASSERT_LT(info.longest_length, 32ul) << "detect hash collision and it's too large.";
- }
- } // end of namespace
|