Changeset View
Changeset View
Standalone View
Standalone View
java/src/main/java/org/softwareheritage/graph/Entry.java
package org.softwareheritage.graph; | package org.softwareheritage.graph; | ||||
import java.io.*; | import java.io.*; | ||||
import java.util.ArrayList; | import java.util.ArrayList; | ||||
import com.fasterxml.jackson.databind.ObjectMapper; | import com.fasterxml.jackson.databind.ObjectMapper; | ||||
import com.fasterxml.jackson.databind.PropertyNamingStrategy; | import com.fasterxml.jackson.databind.PropertyNamingStrategy; | ||||
public class Entry { | public class Entry { | ||||
private Graph graph; | private SwhBidirectionalGraph graph; | ||||
public void load_graph(String graphBasename) throws IOException { | public void load_graph(String graphBasename) throws IOException { | ||||
System.err.println("Loading graph " + graphBasename + " ..."); | System.err.println("Loading graph " + graphBasename + " ..."); | ||||
this.graph = Graph.loadMapped(graphBasename); | this.graph = SwhBidirectionalGraph.loadMapped(graphBasename); | ||||
System.err.println("Graph loaded."); | System.err.println("Graph loaded."); | ||||
} | } | ||||
public Graph get_graph() { | public SwhBidirectionalGraph get_graph() { | ||||
return graph.copy(); | return graph.copy(); | ||||
} | } | ||||
public String stats() { | public String stats() { | ||||
try { | try { | ||||
Stats stats = new Stats(graph.getPath()); | Stats stats = new Stats(graph.getPath()); | ||||
ObjectMapper objectMapper = new ObjectMapper(); | ObjectMapper objectMapper = new ObjectMapper(); | ||||
objectMapper.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE); | objectMapper.setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE); | ||||
Show All 37 Lines | public QueryHandler get_handler(String clientFIFO) { | ||||
return new QueryHandler(graph.copy(), clientFIFO); | return new QueryHandler(graph.copy(), clientFIFO); | ||||
} | } | ||||
private interface NodeCountVisitor { | private interface NodeCountVisitor { | ||||
void accept(long nodeId, Traversal.NodeIdConsumer consumer); | void accept(long nodeId, Traversal.NodeIdConsumer consumer); | ||||
} | } | ||||
public class QueryHandler { | public class QueryHandler { | ||||
Graph graph; | SwhBidirectionalGraph graph; | ||||
BufferedWriter out; | BufferedWriter out; | ||||
String clientFIFO; | String clientFIFO; | ||||
public QueryHandler(Graph graph, String clientFIFO) { | public QueryHandler(SwhBidirectionalGraph graph, String clientFIFO) { | ||||
this.graph = graph; | this.graph = graph; | ||||
this.clientFIFO = clientFIFO; | this.clientFIFO = clientFIFO; | ||||
this.out = null; | this.out = null; | ||||
} | } | ||||
public void writeNode(SWHID swhid) { | public void writeNode(SWHID swhid) { | ||||
try { | try { | ||||
out.write(swhid.toString() + "\n"); | out.write(swhid.toString() + "\n"); | ||||
▲ Show 20 Lines • Show All 109 Lines • Show Last 20 Lines |