-
Notifications
You must be signed in to change notification settings - Fork 23
/
Copy pathConvertToJSON.C
75 lines (70 loc) · 2.61 KB
/
ConvertToJSON.C
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
// This code is part of the project "Ligra: A Lightweight Graph Processing
// Framework for Shared Memory", presented at Principles and Practice of
// Parallel Programming, 2013.
// Copyright (c) 2013 Julian Shun and Guy Blelloch
//
// Permission is hereby granted, free of charge, to any person obtaining a
// copy of this software and associated documentation files (the
// "Software"), to deal in the Software without restriction, including
// without limitation the rights (to use, copy, modify, merge, publish,
// distribute, sublicense, and/or sell copies of the Software, and to
// permit persons to whom the Software is furnished to do so, subject to
// the following conditions:
//
// The above copyright notice and this permission notice shall be included
// in all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
#include "ligra.h"
#include "gettime.h"
#include "math.h"
using namespace std;
#define PAGESIZE (4096)
bool needOutDegree = false;
template <class vertex>
void countDegree(graph<vertex> GA, int numOfShards) {
const intT n = GA.n;
long long totalSize = 0;
for (intT i = 0; i < n; i++) {
if (GA.V[i].getOutDegree() + GA.V[i].getInDegree() <= 0)
continue;
totalSize++;
//printf("%d", i);
/*
for (intT j = 0; j < GA.V[i].getOutDegree(); j++) {
printf("%d\t%d\n", i, GA.V[i].getOutNeighbor(j));
}
*/
//printf("\n");
}
printf("# of nodes: %lld\n", totalSize);
}
int parallel_main(int argc, char* argv[]) {
char* iFile;
bool binary = false;
bool symmetric = false;
needOutDegree = false;
int numOfShards = -1;
if(argc > 1) iFile = argv[1];
if(argc > 2) numOfShards = atoi(argv[2]);
if(argc > 3) if((string) argv[3] == (string) "-outDeg") needOutDegree = true;
if(argc > 4) if((string) argv[4] == (string) "-s") symmetric = true;
if(argc > 5) if((string) argv[5] == (string) "-b") binary = true;
if(symmetric) {
graph<symmetricVertex> G =
readGraph<symmetricVertex>(iFile,symmetric,binary);
countDegree(G, numOfShards);
G.del();
} else {
graph<asymmetricVertex> G =
readGraph<asymmetricVertex>(iFile,symmetric,binary);
countDegree(G, numOfShards);
G.del();
}
}