HeartBeatMessage hbm=HeartBeatMessage.newBuilder().setMemRate(((Double)jobContext.getData("mem")).floatValue())
.addAllDebugRunnings(context.getDebugRunnings().keySet())
.addAllManualRunnings(context.getManualRunnings().keySet())
.addAllRunnings(context.getRunnings().keySet())
.setTimestamp(new Date().getTime()).build();
Request req=Request.newBuilder().setRid(AtomicIncrease.getAndIncrement()).setOperate(Operate.HeartBeat).setBody(hbm.toByteString()).build();
SocketMessage sm=SocketMessage.newBuilder().setKind(Kind.REQUEST).setBody(req.toByteString()).build();
return context.getServerChannel().write(sm);
}
}