|
@@ -309,7 +309,11 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
|
|
);
|
|
);
|
|
const walkingRes = await this.moveService.move(path, request);
|
|
const walkingRes = await this.moveService.move(path, request);
|
|
|
|
|
|
- // console.log('walkingRes-front', walkingRes);
|
|
|
|
|
|
+ console.log(
|
|
|
|
+ 'walkingRes-length',
|
|
|
|
+ Array.from(walkingRes).flat().length,
|
|
|
|
+ );
|
|
|
|
+
|
|
if (walkingRes && !this.onMoving.value) {
|
|
if (walkingRes && !this.onMoving.value) {
|
|
// console.log('walkingRes-front', walkingRes);
|
|
// console.log('walkingRes-front', walkingRes);
|
|
// shift出前第一个镜头数据
|
|
// shift出前第一个镜头数据
|
|
@@ -585,8 +589,9 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
|
|
this.requestIFrameQueueSub = this.requestIFrameQueue.subscribe(
|
|
this.requestIFrameQueueSub = this.requestIFrameQueue.subscribe(
|
|
(frameData: StreamFrameType) => {
|
|
(frameData: StreamFrameType) => {
|
|
const nextFrame = this.frameCnt.getValue() + 1;
|
|
const nextFrame = this.frameCnt.getValue() + 1;
|
|
- this.logger.warn('lostIframe', nextFrame);
|
|
|
|
|
|
+ this.logger.warn('lostIframe', nextFrame, frameData);
|
|
frameData.frame = nextFrame;
|
|
frameData.frame = nextFrame;
|
|
|
|
+ console.log('frameData', frameData);
|
|
this.streamService.pushFrameToSteam(frameData);
|
|
this.streamService.pushFrameToSteam(frameData);
|
|
this.frameCnt.next(nextFrame);
|
|
this.frameCnt.next(nextFrame);
|
|
this.resumeStream();
|
|
this.resumeStream();
|
|
@@ -666,7 +671,6 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
|
|
try {
|
|
try {
|
|
console.log('frame', frame);
|
|
console.log('frame', frame);
|
|
if (frame === 1) {
|
|
if (frame === 1) {
|
|
- debugger;
|
|
|
|
const redisData = await this.rotateService.echo(this.user_id, true);
|
|
const redisData = await this.rotateService.echo(this.user_id, true);
|
|
this.onSteaming = true;
|
|
this.onSteaming = true;
|
|
this.holdSteam();
|
|
this.holdSteam();
|