forked from apache/brpc
-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathbrpc_extension_unittest.cpp
57 lines (47 loc) · 1.46 KB
/
brpc_extension_unittest.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
// Baidu RPC - A framework to host and access services throughout Baidu.
// Copyright (c) 2014 Baidu, Inc.
// Date: Sun Jul 13 15:04:18 CST 2014
#include <sys/epoll.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <map>
#include <gtest/gtest.h>
#include "butil/time.h"
#include "butil/macros.h"
#include "brpc/extension.h"
class ExtensionTest : public ::testing::Test{
protected:
ExtensionTest(){
};
virtual ~ExtensionTest(){};
virtual void SetUp() {
};
virtual void TearDown() {
};
};
inline brpc::Extension<const int>* ConstIntExtension() {
return brpc::Extension<const int>::instance();
}
inline brpc::Extension<int>* IntExtension() {
return brpc::Extension<int>::instance();
}
const int g_foo = 10;
const int g_bar = 20;
TEST_F(ExtensionTest, basic) {
ConstIntExtension()->Register("foo", NULL);
ConstIntExtension()->Register("foo", &g_foo);
ConstIntExtension()->Register("bar", &g_bar);
int* val1 = new int(0xbeef);
int* val2 = new int(0xdead);
ASSERT_EQ(0, IntExtension()->Register("hello", val1));
ASSERT_EQ(-1, IntExtension()->Register("hello", val1));
IntExtension()->Register("there", val2);
ASSERT_EQ(val1, IntExtension()->Find("hello"));
ASSERT_EQ(val2, IntExtension()->Find("there"));
std::ostringstream os;
IntExtension()->List(os, ':');
ASSERT_EQ("hello:there", os.str());
os.str("");
ConstIntExtension()->List(os, ':');
ASSERT_EQ("bar:foo", os.str());
}