Skip to content
Toggle navigation
P
Projects
G
Groups
S
Snippets
Help
ipgallery.common.cpp
/
Microservice
This project
Loading...
Sign in
Toggle navigation
Go to a project
Project
Repository
Registry
Issues
0
Merge Requests
0
Pipelines
Wiki
Settings
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Commit
1717d020
authored
Apr 20, 2017
by
amir
Browse files
Options
_('Browse Files')
Download
Email Patches
Plain Diff
Get base logger
parent
f17d6738
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
2 additions
and
2 deletions
src/impl/clients/MSICommandClientZmqImpl.cpp
src/impl/clients/MSICommandClientZmqImpl.h
src/impl/clients/MSICommandClientZmqImpl.cpp
View file @
1717d020
...
@@ -129,7 +129,7 @@ void MSICommandClientZmqImpl::GetMetrics(std::map<std::string, long> &metrics_ma
...
@@ -129,7 +129,7 @@ void MSICommandClientZmqImpl::GetMetrics(std::map<std::string, long> &metrics_ma
}
}
MSICommandClientZmqImpl
::
MSICommandClientZmqImpl
(
const
Microservice_ZMQRestClientParams
&
params
)
:
params_
(
params
){
MSICommandClientZmqImpl
::
MSICommandClientZmqImpl
(
const
Microservice_ZMQRestClientParams
&
params
)
:
params_
(
params
){
p_logger_
=
Microservice_App
::
GetInstance
()
->
GetLogger
();
p_responseCacheClient_
=
new
Microservice_ICacheClientPocoImpl
<
std
::
uint64_t
,
CacheEntry
>
(
CACHE_EXPIRATION
);
p_responseCacheClient_
=
new
Microservice_ICacheClientPocoImpl
<
std
::
uint64_t
,
CacheEntry
>
(
CACHE_EXPIRATION
);
p_requestWorkParams_
=
new
RequestWorkParams
();
p_requestWorkParams_
=
new
RequestWorkParams
();
serverBindAddr_
=
params_
.
GetServer
().
bindAddress
();
serverBindAddr_
=
params_
.
GetServer
().
bindAddress
();
...
@@ -188,6 +188,7 @@ void MSICommandClientZmqImpl::HandleResponse(MSICommandClientZmqImpl::ResponseWo
...
@@ -188,6 +188,7 @@ void MSICommandClientZmqImpl::HandleResponse(MSICommandClientZmqImpl::ResponseWo
cacheEntry
.
onResponseFunc
(
receiveMsg
->
response
()
->
c_str
(),
cacheEntry
.
onResponseFunc
(
receiveMsg
->
response
()
->
c_str
(),
receiveMsg
->
response
()
->
size
(),
receiveMsg
->
response
()
->
size
(),
cacheEntry
.
cmid
);
cacheEntry
.
cmid
);
p_responseCacheClient_
->
del
(
rcid
);
}
else
{
}
else
{
p_logger_
->
info
(
"received response to exired Request id: %u "
,
rcid
);
p_logger_
->
info
(
"received response to exired Request id: %u "
,
rcid
);
}
}
...
...
src/impl/clients/MSICommandClientZmqImpl.h
View file @
1717d020
...
@@ -75,7 +75,6 @@ private:
...
@@ -75,7 +75,6 @@ private:
std
::
string
serverBindAddr_
;
std
::
string
serverBindAddr_
;
zmqpp
::
context
context_
;
zmqpp
::
context
context_
;
ILogger
*
p_logger_
;
ResponseCacheClient
*
p_responseCacheClient_
;
ResponseCacheClient
*
p_responseCacheClient_
;
RequestWorkParams
*
p_requestWorkParams_
;
RequestWorkParams
*
p_requestWorkParams_
;
...
...
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