Skip to content
Snippets Groups Projects
Commit 5d56277f authored by Recolic Keghart's avatar Recolic Keghart
Browse files

debug, and report

parent 8618f013
No related branches found
No related tags found
No related merge requests found
File added
......@@ -550,13 +550,13 @@ void rebalance_batch(SIZE_TYPE level, SIZE_TYPE seg_length, KEY_TYPE *keys, VALU
SIZE_TYPE *update_nodes, KEY_TYPE *update_keys, VALUE_TYPE *update_values, SIZE_TYPE update_size,
SIZE_TYPE *unique_update_nodes, SIZE_TYPE *update_offset, SIZE_TYPE unique_update_size,
SIZE_TYPE lower_bound, SIZE_TYPE upper_bound, SIZE_TYPE *row_offset) {
// TryInsert+ is this function.
SIZE_TYPE update_width = seg_length << level;
if (update_width <= 1024) {
// func pointer for each template
void (*func_arr[10])(SIZE_TYPE, SIZE_TYPE, KEY_TYPE*, VALUE_TYPE*, SIZE_TYPE*, KEY_TYPE*, VALUE_TYPE*,
SIZE_TYPE*, SIZE_TYPE*, SIZE_TYPE, SIZE_TYPE, SIZE_TYPE*);
decltype(block_rebalancing_kernel) func_arr[10];
func_arr[0] = block_rebalancing_kernel<2, 1>;
func_arr[1] = block_rebalancing_kernel<4, 1>;
func_arr[2] = block_rebalancing_kernel<8, 1>;
......
......@@ -279,8 +279,6 @@ void gpma_bfs(KEY_TYPE *keys, VALUE_TYPE *values, SIZE_TYPE *row_offsets,
SIZE_TYPE level = 1;
const SIZE_TYPE THREADS_NUM = 256;
while (true) {
printf("DEBUG: gpma_bfs::ITERATION-\n");
// gather
SIZE_TYPE BLOCKS_NUM = CALC_BLOCKS_NUM(THREADS_NUM, host_num[0]);
host_num[0] = 0;
......
......@@ -76,6 +76,7 @@ int main(int argc, char **argv) {
edge_size, bfs_start_node, RAW_PTR(bfs_result));
int reach_nodes = node_size - thrust::count(bfs_result.begin(), bfs_result.end(), 0);
printf("start from node %d, number of reachable nodes: %d\n", bfs_start_node, reach_nodes);
LOG_TIME_2("===============BEGIN MAIN LOOP==================")
LOG_TIME("before main loop")
for (int i = 0; i < num_slide; i++) {
......@@ -98,6 +99,7 @@ int main(int argc, char **argv) {
update_gpma(gpma, update_keys, update_values);
cudaDeviceSynchronize();
}
LOG_TIME_2("===============END MAIN LOOP==================")
printf("Graph is updated.\n");
LOG_TIME("before second bfs")
......
......@@ -14,7 +14,9 @@ inline int64_t get_time_in_us() {
prev_time = this_time;
return delta_time;
}
#define LOG_TIME(msg) printf("T+%lld - " msg "\n", get_time_in_us());
// #define LOG_TIME(msg) printf("T+%lld - " msg "\n", get_time_in_us());
#define LOG_TIME(msg) {}// printf("T+%lld - " msg "\n", get_time_in_us());
#define LOG_TIME_2(msg) printf("T+%lld - " msg "\n", get_time_in_us());
#endif
File added
File added
File added
File added
#!/bin/bash
remote=152.136.11.140
remote=49.232.74.97
[[ $1 = pull ]] && rsync -avz -zz --progress root@$remote:/root/gpma_bfs/ ./
[[ $1 = push ]] && rsync -avz -zz --progress ./ root@$remote:/root/gpma_bfs/
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment