Skip to content
Projects
Groups
Snippets
Help
Loading...
Sign in / Register
Toggle navigation
B
brpc
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Packages
Packages
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
submodule
brpc
Commits
dcc7e003
Commit
dcc7e003
authored
6 years ago
by
cdjgit
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix for ci comments
parent
8b919c4d
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
12 additions
and
11 deletions
+12
-11
load_balancer.h
src/brpc/load_balancer.h
+11
-10
consistent_hashing_load_balancer.cpp
src/brpc/policy/consistent_hashing_load_balancer.cpp
+1
-1
No files found.
src/brpc/load_balancer.h
View file @
dcc7e003
...
@@ -104,21 +104,12 @@ public:
...
@@ -104,21 +104,12 @@ public:
// Caller is responsible for Destroy() the instance after usage.
// Caller is responsible for Destroy() the instance after usage.
virtual
LoadBalancer
*
New
()
const
=
0
;
virtual
LoadBalancer
*
New
()
const
=
0
;
// Config user passed parameters to lb after constrction which
// Config user passed parameters to lb after constr
u
ction which
// make lb function more flexible.
// make lb function more flexible.
virtual
bool
SetParameters
(
const
butil
::
StringPiece
&
params
)
{
return
true
;
}
virtual
bool
SetParameters
(
const
butil
::
StringPiece
&
params
)
{
return
true
;
}
protected
:
protected
:
virtual
~
LoadBalancer
()
{
}
virtual
~
LoadBalancer
()
{
}
static
bool
SplitParameters
(
const
butil
::
StringPiece
&
params
,
butil
::
StringPairs
*
param_vec
)
{
std
::
string
params_str
(
params
.
data
(),
params
.
size
());
if
(
!
butil
::
SplitStringIntoKeyValuePairs
(
params_str
,
'='
,
' '
,
param_vec
))
{
param_vec
->
clear
();
return
false
;
}
return
true
;
}
};
};
DECLARE_bool
(
show_lb_in_vars
);
DECLARE_bool
(
show_lb_in_vars
);
...
@@ -197,6 +188,16 @@ inline Extension<const LoadBalancer>* LoadBalancerExtension() {
...
@@ -197,6 +188,16 @@ inline Extension<const LoadBalancer>* LoadBalancerExtension() {
return
Extension
<
const
LoadBalancer
>::
instance
();
return
Extension
<
const
LoadBalancer
>::
instance
();
}
}
inline
bool
SplitLoadBalancerParameters
(
const
butil
::
StringPiece
&
params
,
butil
::
StringPairs
*
param_vec
)
{
std
::
string
params_str
(
params
.
data
(),
params
.
size
());
if
(
!
butil
::
SplitStringIntoKeyValuePairs
(
params_str
,
'='
,
' '
,
param_vec
))
{
param_vec
->
clear
();
return
false
;
}
return
true
;
}
}
// namespace brpc
}
// namespace brpc
...
...
This diff is collapsed.
Click to expand it.
src/brpc/policy/consistent_hashing_load_balancer.cpp
View file @
dcc7e003
...
@@ -361,7 +361,7 @@ void ConsistentHashingLoadBalancer::GetLoads(
...
@@ -361,7 +361,7 @@ void ConsistentHashingLoadBalancer::GetLoads(
bool
ConsistentHashingLoadBalancer
::
SetParameters
(
const
butil
::
StringPiece
&
params
)
{
bool
ConsistentHashingLoadBalancer
::
SetParameters
(
const
butil
::
StringPiece
&
params
)
{
butil
::
StringPairs
param_vec
;
butil
::
StringPairs
param_vec
;
if
(
!
SplitParameters
(
params
,
&
param_vec
))
{
if
(
!
Split
LoadBalancer
Parameters
(
params
,
&
param_vec
))
{
return
false
;
return
false
;
}
}
for
(
const
std
::
pair
<
std
::
string
,
std
::
string
>&
param
:
param_vec
)
{
for
(
const
std
::
pair
<
std
::
string
,
std
::
string
>&
param
:
param_vec
)
{
...
...
This diff is collapsed.
Click to expand it.
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment