Skip to content

Commit d27d544

Browse files
committed
Modified the structure of member names to reflect the point made on the thread below.
ros-infrastructure/rep#385 (comment) Signed-off-by: Shoji Morita <[email protected]>
1 parent bfab6e3 commit d27d544

File tree

3 files changed

+29
-29
lines changed

3 files changed

+29
-29
lines changed

include/rcutils/thread_attr.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,8 +58,8 @@ typedef struct rcutils_thread_attr_s
5858
rcutils_thread_scheduling_policy_t scheduling_policy;
5959
/// Thread priority.
6060
int priority;
61-
/// Thread name
62-
char const * name;
61+
/// Thread attribute tag
62+
char const * tag;
6363
} rcutils_thread_attr_t;
6464

6565
/// Hold thread attribute rules.
@@ -148,7 +148,7 @@ rcutils_thread_attrs_copy(
148148
* \param[in] sched_policy thread scheduling policy of adding attribute
149149
* \param[in] core_affinity thread core affinity of adding attribute
150150
* \param[in] priority thread priority of adding attribute
151-
* \param[in] name thread name of adding attribute
151+
* \param[in] tag thread attribute tag of adding attribute
152152
* \return #RCUTILS_RET_OK if the thread attribute was successfully added, or
153153
* \return #RCUTILS_RET_INVALID_ARGUMENT if any function arguments are invalid, or
154154
* \return #RCUTILS_RET_BAD_ALLOC if allocating memory failed, or
@@ -162,7 +162,7 @@ rcutils_thread_attrs_add_attr(
162162
rcutils_thread_scheduling_policy_t sched_policy,
163163
rcutils_thread_core_affinity_t const * core_affinity,
164164
int priority,
165-
char const * name);
165+
char const * tag);
166166

167167
/**
168168
* \brief Return a zero-initialized rcutils_thread_core_affinity_t object.

src/thread_attr.c

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,8 @@ rcutils_thread_attrs_fini(rcutils_thread_attrs_t * thread_attrs)
8383
RCUTILS_CHECK_ALLOCATOR(allocator, return RCUTILS_RET_INVALID_ARGUMENT);
8484
for (size_t i = 0; i < thread_attrs->num_attributes; ++i) {
8585
rcutils_thread_attr_t * attr = thread_attrs->attributes + i;
86-
if (NULL != attr->name) {
87-
allocator->deallocate((char *)attr->name, allocator->state);
86+
if (NULL != attr->tag) {
87+
allocator->deallocate((char *)attr->tag, allocator->state);
8888
}
8989
}
9090
allocator->deallocate(thread_attrs->attributes, allocator->state);
@@ -121,13 +121,13 @@ rcutils_thread_attrs_copy(
121121
}
122122

123123
for (i = 0; i < thread_attrs->num_attributes; ++i) {
124-
char * dup_name = rcutils_strdup(thread_attrs->attributes[i].name, allocator);
125-
if (NULL == dup_name) {
124+
char * dup_tag = rcutils_strdup(thread_attrs->attributes[i].tag, allocator);
125+
if (NULL == dup_tag) {
126126
ret = RCUTILS_RET_BAD_ALLOC;
127127
goto error;
128128
}
129129
new_attrs[i] = thread_attrs->attributes[i];
130-
new_attrs[i].name = dup_name;
130+
new_attrs[i].tag = dup_tag;
131131
}
132132
*out_thread_attrs = *thread_attrs;
133133
out_thread_attrs->attributes = new_attrs;
@@ -137,7 +137,7 @@ rcutils_thread_attrs_copy(
137137
error:
138138
if (NULL != new_attrs) {
139139
for (size_t j = 0; j < i; ++j) {
140-
allocator.deallocate((char *)new_attrs[i].name, allocator.state);
140+
allocator.deallocate((char *)new_attrs[i].tag, allocator.state);
141141
}
142142
allocator.deallocate(new_attrs, allocator.state);
143143
}
@@ -173,14 +173,14 @@ rcutils_thread_attrs_add_attr(
173173
rcutils_thread_scheduling_policy_t sched_policy,
174174
rcutils_thread_core_affinity_t const * core_affinity,
175175
int priority,
176-
char const * name)
176+
char const * tag)
177177
{
178178
RCUTILS_CHECK_ARGUMENT_FOR_NULL(thread_attrs, RCUTILS_RET_INVALID_ARGUMENT);
179-
RCUTILS_CHECK_ARGUMENT_FOR_NULL(name, RCUTILS_RET_INVALID_ARGUMENT);
179+
RCUTILS_CHECK_ARGUMENT_FOR_NULL(tag, RCUTILS_RET_INVALID_ARGUMENT);
180180
RCUTILS_CHECK_ARGUMENT_FOR_NULL(core_affinity, RCUTILS_RET_INVALID_ARGUMENT);
181181

182182
rcutils_ret_t ret;
183-
char const * dup_name = NULL;
183+
char const * dup_tag = NULL;
184184
rcutils_thread_core_affinity_t new_affinity = rcutils_get_zero_initialized_thread_core_affinity();
185185

186186
if (thread_attrs->num_attributes == thread_attrs->capacity_attributes) {
@@ -197,8 +197,8 @@ rcutils_thread_attrs_add_attr(
197197
}
198198
}
199199

200-
dup_name = rcutils_strdup(name, thread_attrs->allocator);
201-
if (NULL == dup_name) {
200+
dup_tag = rcutils_strdup(tag, thread_attrs->allocator);
201+
if (NULL == dup_tag) {
202202
goto error;
203203
}
204204

@@ -213,15 +213,15 @@ rcutils_thread_attrs_add_attr(
213213
attr->scheduling_policy = sched_policy;
214214
attr->core_affinity = new_affinity;
215215
attr->priority = priority;
216-
attr->name = dup_name;
216+
attr->tag = dup_tag;
217217

218218
++thread_attrs->num_attributes;
219219

220220
return RCUTILS_RET_OK;
221221

222222
error:
223-
if (NULL != dup_name) {
224-
thread_attrs->allocator.deallocate((char *)dup_name, thread_attrs->allocator.state);
223+
if (NULL != dup_tag) {
224+
thread_attrs->allocator.deallocate((char *)dup_tag, thread_attrs->allocator.state);
225225
}
226226
if (0 < new_affinity.core_count) {
227227
rcutils_ret_t tmp_ret = rcutils_thread_core_affinity_fini(&new_affinity);

test/test_thread_attr.cpp

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -243,11 +243,11 @@ TEST_F(TestThreadAttrs, add_attribute) {
243243
ret = rcutils_thread_core_affinity_init(&affinity, alloc);
244244
ret = rcutils_thread_core_affinity_set(&affinity, 0xaa);
245245

246-
char thread_name[32];
246+
char attr_tag[32];
247247
for (size_t i = 0; i < 100; ++i) {
248-
snprintf(thread_name, sizeof(thread_name), "thread name %lu", i);
248+
snprintf(attr_tag, sizeof(attr_tag), "attr tag %lu", i);
249249
ret = rcutils_thread_attrs_add_attr(
250-
&attrs, RCUTILS_THREAD_SCHEDULING_POLICY_FIFO, &affinity, 0xbb, thread_name);
250+
&attrs, RCUTILS_THREAD_SCHEDULING_POLICY_FIFO, &affinity, 0xbb, attr_tag);
251251
EXPECT_EQ(RCUTILS_RET_OK, ret);
252252
ASSERT_NE(nullptr, attrs.attributes);
253253
ASSERT_LE(i + 1, attrs.capacity_attributes);
@@ -257,14 +257,14 @@ TEST_F(TestThreadAttrs, add_attribute) {
257257
for (size_t i = 0; i < 100; ++i) {
258258
rcutils_thread_attr_t attr = attrs.attributes[i];
259259

260-
snprintf(thread_name, sizeof(thread_name), "thread name %lu", i);
260+
snprintf(attr_tag, sizeof(attr_tag), "attr tag %lu", i);
261261
EXPECT_EQ(RCUTILS_THREAD_SCHEDULING_POLICY_FIFO, attr.scheduling_policy);
262262
EXPECT_NE(affinity.set, attr.core_affinity.set);
263263
EXPECT_EQ(affinity.core_count, attr.core_affinity.core_count);
264264
EXPECT_EQ(0, memcmp(affinity.set, attr.core_affinity.set, affinity.core_count / CHAR_BIT));
265265
EXPECT_EQ(0xbb, attr.priority);
266-
EXPECT_NE(thread_name, attr.name);
267-
EXPECT_STREQ(thread_name, attr.name);
266+
EXPECT_NE(attr_tag, attr.tag);
267+
EXPECT_STREQ(attr_tag, attr.tag);
268268
}
269269

270270
ret = rcutils_thread_attrs_fini(&attrs);
@@ -277,11 +277,11 @@ TEST_F(TestThreadAttrs, copy) {
277277
ret = rcutils_thread_core_affinity_init(&affinity, alloc);
278278
ret = rcutils_thread_core_affinity_set(&affinity, 0xaa);
279279

280-
char thread_name[32];
280+
char attr_tag[32];
281281
for (size_t i = 0; i < 100; ++i) {
282-
snprintf(thread_name, sizeof(thread_name), "thread name %lu", i);
282+
snprintf(attr_tag, sizeof(attr_tag), "attr tag %lu", i);
283283
ret = rcutils_thread_attrs_add_attr(
284-
&attrs, RCUTILS_THREAD_SCHEDULING_POLICY_FIFO, &affinity, 0xbb, thread_name);
284+
&attrs, RCUTILS_THREAD_SCHEDULING_POLICY_FIFO, &affinity, 0xbb, attr_tag);
285285
ASSERT_EQ(RCUTILS_RET_OK, ret);
286286
}
287287

@@ -296,8 +296,8 @@ TEST_F(TestThreadAttrs, copy) {
296296
EXPECT_EQ(RCUTILS_THREAD_SCHEDULING_POLICY_FIFO, attr.scheduling_policy);
297297
EXPECT_EQ(0, memcmp(affinity.set, attr.core_affinity.set, affinity.core_count / CHAR_BIT));
298298
EXPECT_EQ(0xbb, attr.priority);
299-
EXPECT_NE(attrs.attributes[i].name, attr.name);
300-
EXPECT_STREQ(attrs.attributes[i].name, attr.name);
299+
EXPECT_NE(attrs.attributes[i].tag, attr.tag);
300+
EXPECT_STREQ(attrs.attributes[i].tag, attr.tag);
301301
}
302302

303303
ret = rcutils_thread_attrs_fini(&attrs);

0 commit comments

Comments
 (0)