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
d50f3fa9
Commit
d50f3fa9
authored
Sep 01, 2020
by
wxf
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
rename restful_mapped_only to allow_default_url
parent
ca66d1fe
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
13 additions
and
11 deletions
+13
-11
http_rpc_protocol.cpp
src/brpc/policy/http_rpc_protocol.cpp
+1
-1
server.cpp
src/brpc/server.cpp
+7
-5
server.h
src/brpc/server.h
+5
-5
No files found.
src/brpc/policy/http_rpc_protocol.cpp
View file @
d50f3fa9
...
@@ -1011,7 +1011,7 @@ FindMethodPropertyByURI(const std::string& uri_path, const Server* server,
...
@@ -1011,7 +1011,7 @@ FindMethodPropertyByURI(const std::string& uri_path, const Server* server,
const
Server
::
MethodProperty
*
mp
=
const
Server
::
MethodProperty
*
mp
=
FindMethodPropertyByURIImpl
(
uri_path
,
server
,
unresolved_path
);
FindMethodPropertyByURIImpl
(
uri_path
,
server
,
unresolved_path
);
if
(
mp
!=
NULL
)
{
if
(
mp
!=
NULL
)
{
if
(
mp
->
http_url
!=
NULL
&&
mp
->
restful_mapped_only
)
{
if
(
mp
->
http_url
!=
NULL
&&
!
mp
->
params
.
allow_default_url
)
{
// the restful method is accessed from its
// the restful method is accessed from its
// default url (SERVICE/METHOD) which should be rejected.
// default url (SERVICE/METHOD) which should be rejected.
return
NULL
;
return
NULL
;
...
...
src/brpc/server.cpp
View file @
d50f3fa9
...
@@ -155,6 +155,7 @@ ServerSSLOptions* ServerOptions::mutable_ssl_options() {
...
@@ -155,6 +155,7 @@ ServerSSLOptions* ServerOptions::mutable_ssl_options() {
Server
::
MethodProperty
::
OpaqueParams
::
OpaqueParams
()
Server
::
MethodProperty
::
OpaqueParams
::
OpaqueParams
()
:
is_tabbed
(
false
)
:
is_tabbed
(
false
)
,
allow_default_url
(
false
)
,
allow_http_body_to_pb
(
true
)
,
allow_http_body_to_pb
(
true
)
,
pb_bytes_to_base64
(
false
)
{
,
pb_bytes_to_base64
(
false
)
{
}
}
...
@@ -1207,6 +1208,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
...
@@ -1207,6 +1208,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
mp
.
is_builtin_service
=
is_builtin_service
;
mp
.
is_builtin_service
=
is_builtin_service
;
mp
.
own_method_status
=
true
;
mp
.
own_method_status
=
true
;
mp
.
params
.
is_tabbed
=
!!
tabbed
;
mp
.
params
.
is_tabbed
=
!!
tabbed
;
mp
.
params
.
allow_default_url
=
svc_opt
.
allow_default_url
;
mp
.
params
.
allow_http_body_to_pb
=
svc_opt
.
allow_http_body_to_pb
;
mp
.
params
.
allow_http_body_to_pb
=
svc_opt
.
allow_http_body_to_pb
;
mp
.
params
.
pb_bytes_to_base64
=
svc_opt
.
pb_bytes_to_base64
;
mp
.
params
.
pb_bytes_to_base64
=
svc_opt
.
pb_bytes_to_base64
;
mp
.
service
=
service
;
mp
.
service
=
service
;
...
@@ -1293,6 +1295,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
...
@@ -1293,6 +1295,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
}
}
MethodProperty
::
OpaqueParams
params
;
MethodProperty
::
OpaqueParams
params
;
params
.
is_tabbed
=
!!
tabbed
;
params
.
is_tabbed
=
!!
tabbed
;
params
.
allow_default_url
=
svc_opt
.
allow_default_url
;
params
.
allow_http_body_to_pb
=
svc_opt
.
allow_http_body_to_pb
;
params
.
allow_http_body_to_pb
=
svc_opt
.
allow_http_body_to_pb
;
params
.
pb_bytes_to_base64
=
svc_opt
.
pb_bytes_to_base64
;
params
.
pb_bytes_to_base64
=
svc_opt
.
pb_bytes_to_base64
;
if
(
!
_global_restful_map
->
AddMethod
(
if
(
!
_global_restful_map
->
AddMethod
(
...
@@ -1305,7 +1308,6 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
...
@@ -1305,7 +1308,6 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
}
}
if
(
mp
->
http_url
==
NULL
)
{
if
(
mp
->
http_url
==
NULL
)
{
mp
->
http_url
=
new
std
::
string
(
mappings
[
i
].
path
.
to_string
());
mp
->
http_url
=
new
std
::
string
(
mappings
[
i
].
path
.
to_string
());
mp
->
restful_mapped_only
=
svc_opt
.
restful_mapped_only
;
}
else
{
}
else
{
if
(
!
mp
->
http_url
->
empty
())
{
if
(
!
mp
->
http_url
->
empty
())
{
mp
->
http_url
->
append
(
" @"
);
mp
->
http_url
->
append
(
" @"
);
...
@@ -1331,6 +1333,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
...
@@ -1331,6 +1333,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
}
}
MethodProperty
::
OpaqueParams
params
;
MethodProperty
::
OpaqueParams
params
;
params
.
is_tabbed
=
!!
tabbed
;
params
.
is_tabbed
=
!!
tabbed
;
params
.
allow_default_url
=
svc_opt
.
allow_default_url
;
params
.
allow_http_body_to_pb
=
svc_opt
.
allow_http_body_to_pb
;
params
.
allow_http_body_to_pb
=
svc_opt
.
allow_http_body_to_pb
;
params
.
pb_bytes_to_base64
=
svc_opt
.
pb_bytes_to_base64
;
params
.
pb_bytes_to_base64
=
svc_opt
.
pb_bytes_to_base64
;
if
(
!
m
->
AddMethod
(
mappings
[
i
].
path
,
service
,
params
,
if
(
!
m
->
AddMethod
(
mappings
[
i
].
path
,
service
,
params
,
...
@@ -1346,7 +1349,6 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
...
@@ -1346,7 +1349,6 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
}
}
if
(
mp
->
http_url
==
NULL
)
{
if
(
mp
->
http_url
==
NULL
)
{
mp
->
http_url
=
new
std
::
string
(
mappings
[
i
].
path
.
to_string
());
mp
->
http_url
=
new
std
::
string
(
mappings
[
i
].
path
.
to_string
());
mp
->
restful_mapped_only
=
svc_opt
.
restful_mapped_only
;
}
else
{
}
else
{
if
(
!
mp
->
http_url
->
empty
())
{
if
(
!
mp
->
http_url
->
empty
())
{
mp
->
http_url
->
append
(
" @"
);
mp
->
http_url
->
append
(
" @"
);
...
@@ -1386,7 +1388,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
...
@@ -1386,7 +1388,7 @@ int Server::AddServiceInternal(google::protobuf::Service* service,
ServiceOptions
::
ServiceOptions
()
ServiceOptions
::
ServiceOptions
()
:
ownership
(
SERVER_DOESNT_OWN_SERVICE
)
:
ownership
(
SERVER_DOESNT_OWN_SERVICE
)
,
restful_mapped_only
(
tru
e
)
,
allow_default_url
(
fals
e
)
,
allow_http_body_to_pb
(
true
)
,
allow_http_body_to_pb
(
true
)
#ifdef BAIDU_INTERNAL
#ifdef BAIDU_INTERNAL
,
pb_bytes_to_base64
(
false
)
,
pb_bytes_to_base64
(
false
)
...
@@ -1405,12 +1407,12 @@ int Server::AddService(google::protobuf::Service* service,
...
@@ -1405,12 +1407,12 @@ int Server::AddService(google::protobuf::Service* service,
int
Server
::
AddService
(
google
::
protobuf
::
Service
*
service
,
int
Server
::
AddService
(
google
::
protobuf
::
Service
*
service
,
ServiceOwnership
ownership
,
ServiceOwnership
ownership
,
const
butil
::
StringPiece
&
restful_mappings
,
const
butil
::
StringPiece
&
restful_mappings
,
bool
restful_mapped_only
)
{
bool
allow_default_url
)
{
ServiceOptions
options
;
ServiceOptions
options
;
options
.
ownership
=
ownership
;
options
.
ownership
=
ownership
;
// TODO: This is weird
// TODO: This is weird
options
.
restful_mappings
=
restful_mappings
.
as_string
();
options
.
restful_mappings
=
restful_mappings
.
as_string
();
options
.
restful_mapped_only
=
restful_mapped_only
;
options
.
allow_default_url
=
allow_default_url
;
return
AddServiceInternal
(
service
,
false
,
options
);
return
AddServiceInternal
(
service
,
false
,
options
);
}
}
...
...
src/brpc/server.h
View file @
d50f3fa9
...
@@ -277,10 +277,10 @@ struct ServiceOptions {
...
@@ -277,10 +277,10 @@ struct ServiceOptions {
// Default: empty
// Default: empty
std
::
string
restful_mappings
;
std
::
string
restful_mappings
;
// Work with restful_mappings, if this flag is
tru
e, reject methods accessed
// Work with restful_mappings, if this flag is
fals
e, reject methods accessed
// from default urls (SERVICE/METHOD).
// from default urls (SERVICE/METHOD).
// Default:
tru
e
// Default:
fals
e
bool
restful_mapped_only
;
bool
allow_default_url
;
// [ Not recommended to change this option ]
// [ Not recommended to change this option ]
// If this flag is true, the service will convert http body to protobuf
// If this flag is true, the service will convert http body to protobuf
...
@@ -339,11 +339,11 @@ public:
...
@@ -339,11 +339,11 @@ public:
struct
MethodProperty
{
struct
MethodProperty
{
bool
is_builtin_service
;
bool
is_builtin_service
;
bool
own_method_status
;
bool
own_method_status
;
bool
restful_mapped_only
;
// Parameters which have nothing to do with management of services, but
// Parameters which have nothing to do with management of services, but
// will be used when the service is queried.
// will be used when the service is queried.
struct
OpaqueParams
{
struct
OpaqueParams
{
bool
is_tabbed
;
bool
is_tabbed
;
bool
allow_default_url
;
bool
allow_http_body_to_pb
;
bool
allow_http_body_to_pb
;
bool
pb_bytes_to_base64
;
bool
pb_bytes_to_base64
;
OpaqueParams
();
OpaqueParams
();
...
@@ -421,7 +421,7 @@ public:
...
@@ -421,7 +421,7 @@ public:
int
AddService
(
google
::
protobuf
::
Service
*
service
,
int
AddService
(
google
::
protobuf
::
Service
*
service
,
ServiceOwnership
ownership
,
ServiceOwnership
ownership
,
const
butil
::
StringPiece
&
restful_mappings
,
const
butil
::
StringPiece
&
restful_mappings
,
bool
restful_mapped_only
=
tru
e
);
bool
allow_default_url
=
fals
e
);
int
AddService
(
google
::
protobuf
::
Service
*
service
,
int
AddService
(
google
::
protobuf
::
Service
*
service
,
const
ServiceOptions
&
options
);
const
ServiceOptions
&
options
);
...
...
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