src/server/worker/api_server.go
func (a *APIServer) GetChunk(request *GetChunkRequest, server Worker_GetChunkServer) error {
	filter := hashtree.NewFilter(a.numShards, request.Shard)
	if request.Stats {
		return a.chunkStatsCache.Get(request.Id, grpcutil.NewStreamingBytesWriter(server), filter)
	}
	return a.chunkCache.Get(request.Id, grpcutil.NewStreamingBytesWriter(server), filter)
}
func (a *APIServer) GetChunk(request *GetChunkRequest, server Worker_GetChunkServer) error {
	filter := hashtree.NewFilter(a.numShards, request.Shard)
	if request.Stats {
		return a.chunkStatsCache.Get(request.Id, grpcutil.NewStreamingBytesWriter(server), filter)
	}
	return a.chunkCache.Get(request.Id, grpcutil.NewStreamingBytesWriter(server), filter)
}
func ( a * APIServer ) GetChunk ( request * GetChunkRequest , server Worker_GetChunkServer ) error { filter := hashtree . NewFilter ( a . numShards , request . Shard ) if request . Stats { return a . chunkStatsCache . Get ( request . Id , grpcutil . NewStreamingBytesWriter ( server ) , filter ) } return a . chunkCache . Get ( request . Id , grpcutil . NewStreamingBytesWriter ( server ) , filter ) }
// GetChunk returns the merged datum hashtrees of a particular chunk (if available)
GetChunk returns the merged datum hashtrees of a particular chunk ( if available )