Skip to content

Commit f535e22

Browse files
therealbobopoiana
authored andcommitted
fix(libsinsp): address review comments
Signed-off-by: Roberto Scolaro <roberto.scolaro21@gmail.com>
1 parent b140f13 commit f535e22

File tree

10 files changed

+17
-24
lines changed

10 files changed

+17
-24
lines changed

userspace/libsinsp/container.h

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -211,17 +211,11 @@ class sinsp_container_manager : public libsinsp::container_engine::container_cac
211211
*/
212212
void set_lookup_status(const std::string& container_id,
213213
sinsp_container_type ctype,
214-
size_t engine_index,
215-
sinsp_container_lookup::state state) override {
214+
sinsp_container_lookup::state state,
215+
size_t engine_index = 0) override {
216216
m_lookups[container_id][ctype][engine_index] = state;
217217
}
218218

219-
void set_lookup_status(const std::string& container_id,
220-
sinsp_container_type ctype,
221-
sinsp_container_lookup::state state) {
222-
m_lookups[container_id][ctype][0] = state;
223-
}
224-
225219
/**
226220
* \brief do we want to start a new lookup for container metadata?
227221
* @param container_id the container id we want to look up

userspace/libsinsp/container_engine/bpm.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ bool bpm::resolve(sinsp_threadinfo* tinfo, bool query_os_for_missing_info) {
5757
}
5858

5959
tinfo->m_container_id = container_info.m_id;
60-
if(container_cache().should_lookup(container_info.m_id, CT_BPM, 0)) {
60+
if(container_cache().should_lookup(container_info.m_id, CT_BPM)) {
6161
container_info.m_name = container_info.m_id;
6262
container_info.set_lookup_status(sinsp_container_lookup::state::SUCCESSFUL);
6363
container_cache().add_container(std::make_shared<sinsp_container_info>(container_info),

userspace/libsinsp/container_engine/container_cache_interface.h

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,12 +35,12 @@ class container_cache_interface {
3535

3636
virtual bool should_lookup(const std::string& container_id,
3737
sinsp_container_type ctype,
38-
size_t engine_index) = 0;
38+
size_t engine_index = 0) = 0;
3939

4040
virtual void set_lookup_status(const std::string& container_id,
4141
sinsp_container_type ctype,
42-
size_t engine_index,
43-
sinsp_container_lookup::state state) = 0;
42+
sinsp_container_lookup::state state,
43+
size_t engine_index = 0) = 0;
4444

4545
/**
4646
* Get a container from the cache.

userspace/libsinsp/container_engine/containerd.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -339,16 +339,16 @@ bool libsinsp::container_engine::containerd::resolve(sinsp_threadinfo *tinfo,
339339
return true;
340340
}
341341

342-
if(cache->should_lookup(request.container_id, request.container_type, 0)) {
342+
if(cache->should_lookup(request.container_id, request.container_type)) {
343343
libsinsp_logger()->format(sinsp_logger::SEV_DEBUG,
344344
"containerd_async (%s): No existing container info",
345345
request.container_id.c_str());
346346

347347
// give containerd a chance to return metadata for this container
348348
cache->set_lookup_status(request.container_id,
349349
request.container_type,
350-
0,
351-
sinsp_container_lookup::state::STARTED);
350+
sinsp_container_lookup::state::STARTED,
351+
0);
352352
parse_containerd(request, cache);
353353
}
354354
return false;
@@ -375,7 +375,7 @@ bool libsinsp::container_engine::containerd::resolve(sinsp_threadinfo *tinfo,
375375
container.m_cpu_period = limits.m_cpu_period;
376376
container.m_cpuset_cpu_count = limits.m_cpuset_cpu_count;
377377

378-
if(container_cache().should_lookup(container.m_id, CT_CONTAINERD, 0)) {
378+
if(container_cache().should_lookup(container.m_id, CT_CONTAINERD)) {
379379
container.m_name = container.m_id;
380380
container.set_lookup_status(sinsp_container_lookup::state::SUCCESSFUL);
381381
container_cache().add_container(std::make_shared<sinsp_container_info>(container), tinfo);

userspace/libsinsp/container_engine/cri.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -173,8 +173,8 @@ bool cri::resolve(sinsp_threadinfo *tinfo, bool query_os_for_missing_info) {
173173

174174
cache->set_lookup_status(container_id,
175175
get_cri_runtime_type(),
176-
m_engine_index,
177-
sinsp_container_lookup::state::STARTED);
176+
sinsp_container_lookup::state::STARTED,
177+
m_engine_index);
178178

179179
// sinsp_container_lookup is set-up to perform 5 retries at most, with
180180
// an exponential backoff with 2000 ms of maximum wait time.

userspace/libsinsp/container_engine/docker/base.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,15 +34,14 @@ bool docker_base::resolve_impl(sinsp_threadinfo *tinfo,
3434
return true;
3535
}
3636

37-
if(cache->should_lookup(request.container_id, request.container_type, 0)) {
37+
if(cache->should_lookup(request.container_id, request.container_type)) {
3838
libsinsp_logger()->format(sinsp_logger::SEV_DEBUG,
3939
"docker_async (%s): No existing container info",
4040
request.container_id.c_str());
4141

4242
// give docker a chance to return metadata for this container
4343
cache->set_lookup_status(request.container_id,
4444
request.container_type,
45-
0,
4645
sinsp_container_lookup::state::STARTED);
4746
parse_docker(request, cache);
4847
}

userspace/libsinsp/container_engine/libvirt_lxc.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ bool libvirt_lxc::resolve(sinsp_threadinfo* tinfo, bool query_os_for_missing_inf
7878
}
7979

8080
tinfo->m_container_id = container.m_id;
81-
if(container_cache().should_lookup(container.m_id, CT_LIBVIRT_LXC, 0)) {
81+
if(container_cache().should_lookup(container.m_id, CT_LIBVIRT_LXC)) {
8282
container.m_name = container.m_id;
8383
container.set_lookup_status(sinsp_container_lookup::state::SUCCESSFUL);
8484
container_cache().add_container(std::make_shared<sinsp_container_info>(container), tinfo);

userspace/libsinsp/container_engine/lxc.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ bool lxc::resolve(sinsp_threadinfo *tinfo, bool query_os_for_missing_info) {
5555
}
5656

5757
tinfo->m_container_id = container.m_id;
58-
if(container_cache().should_lookup(container.m_id, CT_LXC, 0)) {
58+
if(container_cache().should_lookup(container.m_id, CT_LXC)) {
5959
container.m_name = container.m_id;
6060
container.set_lookup_status(sinsp_container_lookup::state::SUCCESSFUL);
6161
container_cache().add_container(std::make_shared<sinsp_container_info>(container), tinfo);

userspace/libsinsp/container_engine/mesos.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ bool libsinsp::container_engine::mesos::resolve(sinsp_threadinfo* tinfo,
5757
return false;
5858

5959
tinfo->m_container_id = container.m_id;
60-
if(container_cache().should_lookup(container.m_id, CT_MESOS, 0)) {
60+
if(container_cache().should_lookup(container.m_id, CT_MESOS)) {
6161
container.m_name = container.m_id;
6262
container.set_lookup_status(sinsp_container_lookup::state::SUCCESSFUL);
6363
container_cache().add_container(std::make_shared<sinsp_container_info>(container), tinfo);

userspace/libsinsp/container_engine/rkt.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ bool rkt::rkt::resolve(sinsp_threadinfo* tinfo, bool query_os_for_missing_info)
167167
}
168168

169169
tinfo->m_container_id = container.m_id;
170-
if(!query_os_for_missing_info || !cache->should_lookup(container.m_id, CT_RKT, 0)) {
170+
if(!query_os_for_missing_info || !cache->should_lookup(container.m_id, CT_RKT)) {
171171
return true;
172172
}
173173

0 commit comments

Comments
 (0)