checkpoint raster in minion -- need to pass back and merge box
This commit is contained in:
parent
3fb23a818b
commit
e77e46a096
2 changed files with 21 additions and 8 deletions
|
|
@ -429,7 +429,7 @@ class Topo {
|
||||||
minions.queue({
|
minions.queue({
|
||||||
cmd: "topo_slice",
|
cmd: "topo_slice",
|
||||||
id: widget.id,
|
id: widget.id,
|
||||||
resolution,
|
params,
|
||||||
slice
|
slice
|
||||||
}, data => {
|
}, data => {
|
||||||
resolve(data);
|
resolve(data);
|
||||||
|
|
@ -592,19 +592,33 @@ moto.broker.subscribe("minion.started", msg => {
|
||||||
const { funcs, cache, reply, log } = msg;
|
const { funcs, cache, reply, log } = msg;
|
||||||
|
|
||||||
funcs.topo_slice = (data, seq) => {
|
funcs.topo_slice = (data, seq) => {
|
||||||
const vertices = cache[data.id];
|
const { id, slice, params } = data;
|
||||||
const res = new kiri.topo_slicer(data.slice.index)
|
const { resolution } = params;
|
||||||
.setFromArray(vertices, data.slice)
|
const vertices = cache[id];
|
||||||
.slice(data.resolution)
|
const res = new kiri.topo_slicer(slice.index)
|
||||||
|
.setFromArray(vertices, slice)
|
||||||
|
.slice(resolution)
|
||||||
.map(rec => {
|
.map(rec => {
|
||||||
const ret = [ rec.z, rec.index ];
|
const { z, index, lines } = rec;
|
||||||
for (let line of rec.lines) {
|
|
||||||
|
const ret = [ z, index ];
|
||||||
|
for (let line of lines) {
|
||||||
const { p1, p2 } = line;
|
const { p1, p2 } = line;
|
||||||
if (!p1.swapped) { p1.swapXZ(); p1.swapped = true }
|
if (!p1.swapped) { p1.swapXZ(); p1.swapped = true }
|
||||||
if (!p2.swapped) { p2.swapXZ(); p2.swapped = true }
|
if (!p2.swapped) { p2.swapXZ(); p2.swapped = true }
|
||||||
ret.push(p1.x, p1.y, p1.z);
|
ret.push(p1.x, p1.y, p1.z);
|
||||||
ret.push(p2.x, p2.y, p2.z);
|
ret.push(p2.x, p2.y, p2.z);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// const box = new THREE.Box2();
|
||||||
|
// const points = raster_slice({
|
||||||
|
// ...params,
|
||||||
|
// box,
|
||||||
|
// lines,
|
||||||
|
// gridx: index
|
||||||
|
// });
|
||||||
|
// console.log({ box, points });
|
||||||
|
|
||||||
return ret;
|
return ret;
|
||||||
});
|
});
|
||||||
reply({ seq, res });
|
reply({ seq, res });
|
||||||
|
|
|
||||||
|
|
@ -250,7 +250,6 @@ console.log(`kiri | init work | ${gapp.version || "rogue"}`);
|
||||||
|
|
||||||
// code is running in the worker / server context
|
// code is running in the worker / server context
|
||||||
const dispatch =
|
const dispatch =
|
||||||
self.worker =
|
|
||||||
kiri.server =
|
kiri.server =
|
||||||
kiri.worker = {
|
kiri.worker = {
|
||||||
pool_start(data, send) {
|
pool_start(data, send) {
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue