Skip to content

Commit 35c51b0

Browse files
authored
vine: round up sizes when converting bytes to other types (#4088)
1 parent 4e82ce1 commit 35c51b0

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

dttools/src/macros.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ See the file COPYING for details.
3939
#define TERABYTE TERA
4040
#define PETABYTE PETA
4141

42-
#define BYTES_TO_STORAGE_UNIT(x, unit) (((double) x) / unit)
42+
#define BYTES_TO_STORAGE_UNIT(x, unit) (ceil(((double) x) / unit))
4343
#define BYTES_TO_KILOBYTES(x) BYTES_TO_STORAGE_UNIT(x, KILOBYTE)
4444
#define BYTES_TO_MEGABYTES(x) BYTES_TO_STORAGE_UNIT(x, MEGABYTE)
4545
#define BYTES_TO_GIGABYTES(x) BYTES_TO_STORAGE_UNIT(x, GIGABYTE)

taskvine/src/manager/vine_file_replica_table.c

+2-2
Original file line numberDiff line numberDiff line change
@@ -31,10 +31,10 @@ int vine_file_replica_table_insert(struct vine_manager *m, struct vine_worker_in
3131
w->inuse_cache += replica->size;
3232
hash_table_insert(w->current_files, cachename, replica);
3333

34-
double prev_available = w->resources->disk.total - ceil(BYTES_TO_MEGABYTES(w->inuse_cache + replica->size));
34+
double prev_available = w->resources->disk.total - BYTES_TO_MEGABYTES(w->inuse_cache + replica->size);
3535
if (prev_available >= m->current_max_worker->disk) {
3636
/* the current worker may have been the one with the maximum available space, so we update it. */
37-
m->current_max_worker->disk = w->resources->disk.total - ceil(BYTES_TO_MEGABYTES(w->inuse_cache));
37+
m->current_max_worker->disk = w->resources->disk.total - BYTES_TO_MEGABYTES(w->inuse_cache);
3838
}
3939

4040
struct set *workers = hash_table_lookup(m->file_worker_table, cachename);

taskvine/src/manager/vine_manager.c

+2-2
Original file line numberDiff line numberDiff line change
@@ -2881,7 +2881,7 @@ static void count_worker_resources(struct vine_manager *q, struct vine_worker_in
28812881
w->resources->gpus.inuse += box->gpus;
28822882
}
28832883

2884-
w->resources->disk.inuse += ceil(BYTES_TO_MEGABYTES(w->inuse_cache));
2884+
w->resources->disk.inuse += BYTES_TO_MEGABYTES(w->inuse_cache);
28852885
}
28862886

28872887
static void update_max_worker(struct vine_manager *q, struct vine_worker_info *w)
@@ -5995,7 +5995,7 @@ static void aggregate_workers_resources(
59955995
}
59965996

59975997
// vine_stats wants MB
5998-
*inuse_cache = (int64_t)ceil(BYTES_TO_MEGABYTES(*inuse_cache));
5998+
*inuse_cache = (int64_t)BYTES_TO_MEGABYTES(*inuse_cache);
59995999
}
60006000

60016001
/* This simple wrapper function allows us to hide the debug.h interface from the end user. */

0 commit comments

Comments
 (0)