Skip to content

Commit

Permalink
[libknet] drop knet_handle_new_ex in favour of knet_handle_new
Browse files Browse the repository at this point in the history
Signed-off-by: Fabio M. Di Nitto <fdinitto@redhat.com>
  • Loading branch information
fabbione committed Dec 20, 2018
1 parent aeed093 commit c9b7e5e
Show file tree
Hide file tree
Showing 8 changed files with 18 additions and 37 deletions.
15 changes: 4 additions & 11 deletions libknet/handle.c
Expand Up @@ -533,10 +533,10 @@ static void _stop_threads(knet_handle_t knet_h)
}
}

knet_handle_t knet_handle_new_ex(knet_node_id_t host_id,
int log_fd,
uint8_t default_log_level,
uint64_t flags)
knet_handle_t knet_handle_new(knet_node_id_t host_id,
int log_fd,
uint8_t default_log_level,
uint64_t flags)
{
knet_handle_t knet_h;
int savederrno = 0;
Expand Down Expand Up @@ -708,13 +708,6 @@ knet_handle_t knet_handle_new_ex(knet_node_id_t host_id,
return NULL;
}

knet_handle_t knet_handle_new(knet_node_id_t host_id,
int log_fd,
uint8_t default_log_level)
{
return knet_handle_new_ex(host_id, log_fd, default_log_level, KNET_HANDLE_FLAG_PRIVILEGED);
}

int knet_handle_free(knet_handle_t knet_h)
{
int savederrno = 0;
Expand Down
20 changes: 5 additions & 15 deletions libknet/libknet.h
Expand Up @@ -93,7 +93,7 @@ typedef struct knet_handle *knet_handle_t;
*/

/**
* knet_handle_new_ex
* knet_handle_new
*
* @brief create a new instance of a knet handle
*
Expand All @@ -119,7 +119,7 @@ typedef struct knet_handle *knet_handle_t;
* at default_log_level value. (see logging API)
*
* flags - bitwise OR of some of the following flags:
* KNET_HANDLE_FLAG_PRIVILEGED: use privileged operations setting up the
* KNET_HANDLE_FLAG_PRIVILEGED: use privileged operations setting up the
* communication sockets. If disabled, failure to acquire large
* enough socket buffers is ignored but logged. Inadequate buffers
* lead to poor performance.
Expand All @@ -132,20 +132,10 @@ typedef struct knet_handle *knet_handle_t;
* ERANGE - buffer size readback returned unexpected type
*/

knet_handle_t knet_handle_new_ex(knet_node_id_t host_id,
int log_fd,
uint8_t default_log_level,
uint64_t flags);

/**
* knet_handle_new
*
* @brief knet_handle_new_ex with flags = KNET_HANDLE_FLAG_PRIVILEGED.
*/

knet_handle_t knet_handle_new(knet_node_id_t host_id,
int log_fd,
uint8_t default_log_level);
int log_fd,
uint8_t default_log_level,
uint64_t flags);

/**
* knet_handle_free
Expand Down
1 change: 0 additions & 1 deletion libknet/tests/api-test-coverage
Expand Up @@ -68,7 +68,6 @@ found=0
missing=0

for i in $headerapicalls; do
[ "$i" = knet_handle_new_ex ] && i=knet_handle_new # tested together
numapicalls=$((numapicalls + 1))
if [ -f $srcdir/api_${i}.c ]; then
found=$((found + 1))
Expand Down
10 changes: 5 additions & 5 deletions libknet/tests/api_knet_handle_new.c
Expand Up @@ -29,7 +29,7 @@ static void test(void)

printf("Test knet_handle_new hostid 1, no logging\n");

knet_h = knet_handle_new_ex(1, 0, 0, 0);
knet_h = knet_handle_new(1, 0, 0, 0);
if (!knet_h) {
printf("Unable to init knet_handle! err: %s\n", strerror(errno));
exit(FAIL);
Expand All @@ -42,7 +42,7 @@ static void test(void)

printf("Test knet_handle_new hostid -1, no logging\n");

knet_h = knet_handle_new_ex(-1, 0, 0, 0);
knet_h = knet_handle_new(-1, 0, 0, 0);
if (!knet_h) {
printf("Unable to init knet_handle! err: %s\n", strerror(errno));
exit(FAIL);
Expand Down Expand Up @@ -73,7 +73,7 @@ static void test(void)
*/
printf("Test knet_handle_new hostid 1, incorrect log_fd (-1)\n");

knet_h = knet_handle_new(1, -1, 0);
knet_h = knet_handle_new(1, -1, 0, 0);

if ((!knet_h) && (errno != EINVAL)) {
printf("knet_handle_new returned incorrect errno on incorrect log_fd\n");
Expand All @@ -91,7 +91,7 @@ static void test(void)
*/
printf("Test knet_handle_new hostid 1, incorrect log_fd (max_fd + 1)\n");

knet_h = knet_handle_new(1, (int) cur.rlim_max, 0);
knet_h = knet_handle_new(1, (int) cur.rlim_max, 0, 0);

if ((knet_h) || (errno != EINVAL)) {
printf("knet_handle_new accepted an incorrect (max_fd + 1) log_fd or returned incorrect errno on incorrect log_fd: %s\n", strerror(errno));
Expand All @@ -103,7 +103,7 @@ static void test(void)

printf("Test knet_handle_new hostid 1, proper log_fd, invalid log level (DEBUG + 1)\n");

knet_h = knet_handle_new(1, logfds[1], KNET_LOG_DEBUG + 1);
knet_h = knet_handle_new(1, logfds[1], KNET_LOG_DEBUG + 1 ,0);

if ((knet_h) || (errno != EINVAL)) {
printf("knet_handle_new accepted an incorrect log level or returned incorrect errno on incorrect log level: %s\n", strerror(errno));
Expand Down
4 changes: 2 additions & 2 deletions libknet/tests/api_knet_handle_new_limit.c
Expand Up @@ -31,7 +31,7 @@ static void test(void)

for (idx = 0; idx < UINT8_MAX; idx++) {
printf("Allocating %d\n", idx);
knet_h[idx] = knet_handle_new(1, logfds[1], KNET_LOG_DEBUG);
knet_h[idx] = knet_handle_new(1, logfds[1], KNET_LOG_DEBUG, 0);
if (!knet_h[idx]) {
printf("knet_handle_new[%d] failed: %s\n", idx, strerror(errno));
flush_logs(logfds[0], stdout);
Expand All @@ -42,7 +42,7 @@ static void test(void)
}

printf("forcing UINT8_T MAX\n");
knet_h[UINT8_MAX] = knet_handle_new(1, logfds[1], KNET_LOG_DEBUG);
knet_h[UINT8_MAX] = knet_handle_new(1, logfds[1], KNET_LOG_DEBUG, 0);
if (knet_h[UINT8_MAX]) {
printf("off by one somewhere\n");
knet_handle_free(knet_h[UINT8_MAX]);
Expand Down
2 changes: 1 addition & 1 deletion libknet/tests/knet_bench.c
Expand Up @@ -450,7 +450,7 @@ static void setup_knet(int argc, char *argv[])

logfd = start_logging(stdout);

knet_h = knet_handle_new(thisnodeid, logfd, debug);
knet_h = knet_handle_new(thisnodeid, logfd, debug, 0);
if (!knet_h) {
printf("Unable to knet_handle_new: %s\n", strerror(errno));
exit(FAIL);
Expand Down
2 changes: 1 addition & 1 deletion libknet/tests/test-common.c
Expand Up @@ -353,7 +353,7 @@ int start_logging(FILE *std)

knet_handle_t knet_handle_start(int logfds[2], uint8_t log_level)
{
knet_handle_t knet_h = knet_handle_new_ex(1, logfds[1], log_level, 0);
knet_handle_t knet_h = knet_handle_new(1, logfds[1], log_level, 0);

if (knet_h) {
return knet_h;
Expand Down
1 change: 0 additions & 1 deletion man/Makefile.am
Expand Up @@ -54,7 +54,6 @@ knet_man3_MANS = \
knet_get_transport_name_by_id.3 \
knet_handle_get_transport_reconnect_interval.3 \
knet_handle_new.3 \
knet_handle_new_ex.3 \
knet_handle_pmtud_get.3 \
knet_handle_pmtud_getfreq.3 \
knet_handle_pmtud_setfreq.3 \
Expand Down

0 comments on commit c9b7e5e

Please sign in to comment.