35 LaserdiscPlayer::Command::Command(
36 CommandController& commandController_,
37 StateChangeDistributor& stateChangeDistributor_,
39 : RecordedCommand(commandController_, stateChangeDistributor_,
40 scheduler_,
"laserdiscplayer")
44 void LaserdiscPlayer::Command::execute(
48 if (tokens.
size() == 1) {
52 laserdiscPlayer.getImageName().getResolved());
53 }
else if (tokens[1] ==
"eject") {
54 checkNumArgs(tokens, 2, Prefix{2},
nullptr);
55 result =
"Ejecting laserdisc.";
56 laserdiscPlayer.eject(time);
57 }
else if (tokens[1] ==
"insert") {
58 checkNumArgs(tokens, 3,
"filename");
60 result =
"Changing laserdisc.";
61 laserdiscPlayer.setImageName(
string(tokens[2].getString()), time);
62 }
catch (MSXException& e) {
63 throw CommandException(std::move(e).getMessage());
70 string LaserdiscPlayer::Command::help(
const vector<string>& tokens)
const
72 if (tokens.size() >= 2) {
73 if (tokens[1] ==
"insert") {
74 return "Inserts the specified laserdisc image into "
75 "the laserdisc player.";
76 }
else if (tokens[1] ==
"eject") {
77 return "Eject the laserdisc.";
80 return "laserdiscplayer insert <filename> "
81 ": insert a (different) laserdisc image\n"
82 "laserdiscplayer eject "
83 ": eject the laserdisc\n";
86 void LaserdiscPlayer::Command::tabCompletion(vector<string>& tokens)
const
88 if (tokens.size() == 2) {
89 using namespace std::literals;
90 static constexpr std::array extra = {
"eject"sv,
"insert"sv};
91 completeString(tokens, extra);
92 }
else if (tokens.size() == 3 && tokens[1] ==
"insert") {
104 xml.addChild(
"sound").addChild(
"volume",
"30000");
112 , syncAck (hwConf.getMotherBoard().getScheduler())
113 , syncOdd (hwConf.getMotherBoard().getScheduler())
114 , syncEven(hwConf.getMotherBoard().getScheduler())
115 , motherBoard(hwConf.getMotherBoard())
116 , ldControl(ldControl_)
117 , laserdiscCommand(motherBoard.getCommandController(),
118 motherBoard.getStateChangeDistributor(),
119 motherBoard.getScheduler())
120 , sampleClock(EmuTime::zero())
121 , start(EmuTime::zero())
124 , remoteState(REMOTE_IDLE)
125 , remoteLastEdge(EmuTime::zero())
126 , remoteLastBit(false)
127 , remoteProtocol(IR_NONE)
130 , playerState(PLAYER_STOPPED)
132 motherBoard.getCommandController(),
"autorunlaserdisc",
133 "automatically try to run Laserdisc", true)
135 motherBoard.getReactor().getGlobalSettings().getThrottleManager())
145 scheduleDisplayStart(getCurrentTime());
159 void LaserdiscPlayer::scheduleDisplayStart(EmuTime::param time)
164 syncOdd .setSyncPoint(frameClock + 1);
165 syncEven.setSyncPoint(frameClock + 2);
181 if (remoteLastBit == bit)
return;
186 remoteLastEdge = time;
189 switch (remoteState) {
192 remoteBits = remoteBitNr = 0;
197 if (5800 <= usec && usec < 11200) {
204 if (3400 <= usec && usec < 6200) {
211 if (usec >= 380 && usec < 1070) {
218 if (1260 <= usec && usec < 4720) {
220 remoteBits |= 1 << remoteBitNr;
221 }
else if (usec < 300 || usec >= 1065) {
230 if (++remoteBitNr == 32) {
231 byte custom = ( remoteBits >> 0) & 0xff;
232 byte customCompl = (~remoteBits >> 8) & 0xff;
233 byte code = ( remoteBits >> 16) & 0xff;
234 byte codeCompl = (~remoteBits >> 24) & 0xff;
235 if (custom == customCompl &&
238 submitRemote(
IR_NEC, code);
249 void LaserdiscPlayer::submitRemote(RemoteProtocol protocol,
unsigned code)
253 if (protocol != remoteProtocol || code != remoteCode ||
254 (protocol ==
IR_NEC && (code ==
one_of(0x42u, 0x17u)))) {
255 remoteProtocol = protocol;
257 remoteVblanksBack = 0;
258 remoteExecuteDelayed =
true;
261 remoteVblanksBack = 0;
262 remoteExecuteDelayed =
false;
268 return renderer->getRawFrame();
271 void LaserdiscPlayer::setAck(EmuTime::param time,
int wait)
274 syncAck.removeSyncPoint();
279 void LaserdiscPlayer::remoteButtonNEC(
unsigned code, EmuTime::param time)
284 case 0x47: f =
"C+";
break;
285 case 0x46: f =
"C-";
break;
286 case 0x43: f =
"D+";
break;
287 case 0x4b: f =
"L+";
break;
288 case 0x49: f =
"L-";
break;
289 case 0x4a: f =
"L@";
break;
290 case 0x58: f =
"M+";
break;
291 case 0x55: f =
"M-";
break;
292 case 0x17: f =
"P+";
break;
293 case 0x16: f =
"P@";
break;
294 case 0x18: f =
"P/";
break;
295 case 0x54: f =
"S+";
break;
296 case 0x50: f =
"S-";
break;
297 case 0x45: f =
"X+";
break;
298 case 0x41: f =
'F';
break;
299 case 0x40: f =
'C';
break;
300 case 0x42: f =
"END";
break;
301 case 0x00: f =
'0';
break;
302 case 0x01: f =
'1';
break;
303 case 0x02: f =
'2';
break;
304 case 0x03: f =
'3';
break;
305 case 0x04: f =
'4';
break;
306 case 0x05: f =
'5';
break;
307 case 0x06: f =
'6';
break;
308 case 0x07: f =
'7';
break;
309 case 0x08: f =
'8';
break;
310 case 0x09: f =
'9';
break;
311 case 0x5f: f =
"WAIT FRAME";
break;
319 std::cerr <<
"LaserdiscPlayer::remote " << f <<
'\n';
321 std::cerr <<
"LaserdiscPlayer::remote unknown " << std::hex << code <<
'\n';
330 if (code ==
one_of(0x49u, 0x4au, 0x4bu)) {
350 "ejecting laserdisc");
362 bool nonseekack =
true;
368 stillOnWaitFrame =
false;
378 nonseekack = video->getChapter(0) != 0;
390 seekNum = seekNum * 10 + code;
396 seekFrame(seekNum % 100000, time);
401 seekChapter(seekNum % 100, time);
406 waitFrame = seekNum % 100000;
407 if (waitFrame >= 101 && waitFrame < 200) {
408 auto frame = video->getChapter(
409 int(waitFrame - 100));
410 if (frame) waitFrame = frame;
419 if (seekState !=
SEEK_NONE && seekNum != 0) {
445 stillOnWaitFrame =
true;
456 "The Laserdisc player received a command to "
457 "play backwards (M-). This is currently not "
466 if (playingSpeed >= SPEED_STEP1) {
472 if (playingSpeed <= SPEED_X2) {
479 "The Laserdisc player received an unknown "
480 "command 0x", hex_string<2>(code));
493 void LaserdiscPlayer::execSyncAck(EmuTime::param time)
505 void LaserdiscPlayer::execSyncFrame(EmuTime::param time,
bool odd)
509 if (!odd || (video && video->getFrameRate() == 60)) {
511 (currentFrame > video->getFrames())) {
515 if (
auto* rawFrame = renderer->getRawFrame()) {
516 renderer->frameStart(time);
518 if (isVideoOutputAvailable(time)) {
519 auto frame = currentFrame;
520 if (video->getFrameRate() == 60) {
525 video->getFrameNo(*rawFrame, frame);
531 renderer->drawBlank(0, 128, 196);
533 renderer->frameEnd();
537 loadingIndicator.
update(seeking || sampleReads > 500);
541 scheduleDisplayStart(time);
547 if (remoteProtocol ==
IR_NEC) {
548 if (remoteExecuteDelayed) {
549 remoteButtonNEC(remoteCode, time);
552 if (++remoteVblanksBack > 6) {
556 remoteExecuteDelayed =
false;
559 void LaserdiscPlayer::setFrameStep()
561 switch (playingSpeed) {
588 void LaserdiscPlayer::nextFrame(EmuTime::param time)
590 if (waitFrame && waitFrame == currentFrame) {
595 if (stillOnWaitFrame) {
596 playingFromSample = getCurrentSample(time);
598 stillOnWaitFrame =
false;
607 switch (playingSpeed) {
625 && video->stopFrame(currentFrame)) {
627 playingFromSample = getCurrentSample(time);
632 void LaserdiscPlayer::setImageName(
string newImage, EmuTime::param time)
636 video = std::make_unique<OggReader>(oggImage, motherBoard.
getMSXCliComm());
638 unsigned inputRate = video->getSampleRate();
639 sampleClock.
setFreq(inputRate);
646 int LaserdiscPlayer::signalEvent(
const std::shared_ptr<const Event>& event) noexcept
654 void LaserdiscPlayer::autoRun()
662 string var =
"::auto_run_ld_counter";
664 "if ![info exists ", var,
"] { set ", var,
" 0 }\n"
666 "after time 2 \"if $", var,
"==\\$", var,
" { "
667 "type_via_keyboard 1CALLLD\\\\r }\"");
670 }
catch (CommandException& e) {
672 "Error executing loading instruction for AutoRun: ",
673 e.getMessage(),
"\n Please report a bug.");
677 void LaserdiscPlayer::generateChannels(
float** buffers,
unsigned num)
680 if (playerState !=
PLAYER_PLAYING || seeking || (muteLeft && muteRight)) {
681 buffers[0] =
nullptr;
686 size_t currentSample;
690 EmuDuration duration = sampleClock.
getTime() - start;
691 unsigned len = duration.getTicksAt(video->getSampleRate());
693 buffers[0] =
nullptr;
697 for (; pos < len; ++pos) {
698 buffers[0][pos * 2 + 0] = 0.0f;
699 buffers[0][pos * 2 + 1] = 0.0f;
702 currentSample = playingFromSample;
704 currentSample = getCurrentSample(start);
707 unsigned drift = video->getSampleRate() / 30;
709 if (currentSample > (lastPlayedSample + drift) ||
710 (currentSample + drift) < lastPlayedSample) {
712 lastPlayedSample = currentSample;
715 int left = stereoMode ==
RIGHT ? 1 : 0;
716 int right = stereoMode ==
LEFT ? 0 : 1;
719 const AudioFragment* audio = video->getAudio(lastPlayedSample);
723 buffers[0] =
nullptr;
726 for (; pos < num; ++pos) {
727 buffers[0][pos * 2 + 0] = 0.0f;
728 buffers[0][pos * 2 + 1] = 0.0f;
732 auto offset = unsigned(lastPlayedSample - audio->position);
733 unsigned len =
std::min(audio->length - offset, num - pos);
736 for (
unsigned i = 0; i < len; ++i, ++pos) {
737 buffers[0][pos * 2 + 0] = muteLeft ? 0.0f :
738 audio->pcm[left][offset + i];
739 buffers[0][pos * 2 + 1] = muteRight ? 0.0f :
740 audio->pcm[right][offset + i];
743 lastPlayedSample += len;
748 float LaserdiscPlayer::getAmplificationFactorImpl()
const
753 bool LaserdiscPlayer::updateBuffer(
unsigned length,
float* buffer,
768 void LaserdiscPlayer::play(EmuTime::param time)
780 lastPlayedSample = 0;
781 playingFromSample = 0;
790 playingSpeed = SPEED_1IN4;
798 playingFromSample = (currentFrame - 1ll) * 1001ll *
799 video->getSampleRate() / 30000ll;
811 size_t LaserdiscPlayer::getCurrentSample(EmuTime::param time)
813 switch(playerState) {
816 return playingFromSample;
818 return playingFromSample + sampleClock.
getTicksTill(time);
822 void LaserdiscPlayer::pause(EmuTime::param time)
828 playingFromSample = getCurrentSample(time);
830 playingFromSample = (currentFrame - 1ll) * 1001ll *
831 video->getSampleRate() / 30000ll;
840 void LaserdiscPlayer::stop(EmuTime::param time)
848 void LaserdiscPlayer::eject(EmuTime::param time)
857 void LaserdiscPlayer::stepFrame(
bool forwards)
859 bool needseek =
false;
865 if (currentFrame < video->getFrames()) {
869 if (currentFrame > 1) {
877 int64_t samplePos = (currentFrame - 1ll) * 1001ll *
878 video->getSampleRate() / 30000ll;
879 playingFromSample = samplePos;
882 if (video->getFrameRate() == 60)
883 video->seek(currentFrame * 2, samplePos);
885 video->seek(currentFrame, samplePos);
889 void LaserdiscPlayer::seekFrame(
size_t toFrame, EmuTime::param time)
894 if (toFrame <= 0) toFrame = 1;
895 if (toFrame > video->getFrames()) toFrame = video->getFrames();
904 auto dist = std::abs(int64_t(toFrame) - int64_t(currentFrame));
905 int seektime = (dist < 1000)
907 : (1800 + dist / 12);
909 int64_t samplePos = (toFrame - 1ll) * 1001ll *
910 video->getSampleRate() / 30000ll;
912 if (video->getFrameRate() == 60) {
913 video->seek(toFrame * 2, samplePos);
915 video->seek(toFrame, samplePos);
918 playingFromSample = samplePos;
919 currentFrame = toFrame;
925 setAck(time, seektime);
929 void LaserdiscPlayer::seekChapter(
int chapter, EmuTime::param time)
932 auto frameNo = video->getChapter(chapter);
933 if (!frameNo)
return;
934 seekFrame(frameNo, time);
945 auto sample = getCurrentSample(time);
948 int channel = stereoMode ==
LEFT ? 0 : 1;
949 return int(audio->pcm[channel][sample - audio->position]
956 bool LaserdiscPlayer::isVideoOutputAvailable(EmuTime::param time)
960 bool videoOut = [&] {
961 switch (playerState) {
975 void LaserdiscPlayer::preVideoSystemChange() noexcept
980 void LaserdiscPlayer::postVideoSystemChange() noexcept
985 void LaserdiscPlayer::createRenderer()
991 static constexpr std::initializer_list<enum_string<LaserdiscPlayer::RemoteState>> RemoteStateInfo = {
1000 static constexpr std::initializer_list<enum_string<LaserdiscPlayer::PlayerState>> PlayerStateInfo = {
1009 static constexpr std::initializer_list<enum_string<LaserdiscPlayer::SeekState>> SeekStateInfo = {
1017 static constexpr std::initializer_list<enum_string<LaserdiscPlayer::StereoMode>> StereoModeInfo = {
1024 static constexpr std::initializer_list<enum_string<LaserdiscPlayer::RemoteProtocol>> RemoteProtocolInfo = {
1034 template<
typename Archive>
1038 ar.serialize(
"RemoteState", remoteState);
1040 ar.serialize(
"RemoteBitNr", remoteBitNr,
1041 "RemoteBits", remoteBits);
1042 if (ar.versionBelow(version, 3)) {
1043 assert(Archive::IS_LOADER);
1047 ar.serialize(
"RemoteLastBit", remoteLastBit,
1048 "RemoteLastEdge", remoteLastEdge,
1049 "RemoteProtocol", remoteProtocol);
1050 if (remoteProtocol !=
IR_NONE) {
1051 ar.serialize(
"RemoteCode", remoteCode);
1052 if (ar.versionBelow(version, 3)) {
1053 assert(Archive::IS_LOADER);
1056 ar.serialize(
"RemoteExecuteDelayed", remoteExecuteDelayed,
1057 "RemoteVblanksBack", remoteVblanksBack);
1061 ar.serialize(
"OggImage", oggImage);
1062 if constexpr (Archive::IS_LOADER) {
1064 if (!oggImage.
empty()) {
1065 setImageName(oggImage.
getResolved(), getCurrentTime());
1070 ar.serialize(
"PlayerState", playerState);
1074 ar.serialize(
"SeekState", seekState);
1076 ar.serialize(
"SeekNum", seekNum);
1078 ar.serialize(
"seeking", seeking);
1081 ar.serialize(
"WaitFrame", waitFrame);
1084 if (ar.versionAtLeast(version, 2)) {
1085 ar.serialize(
"StillOnWaitFrame", stillOnWaitFrame);
1088 ar.serialize(
"ACK", ack,
1089 "PlayingSpeed", playingSpeed);
1092 ar.serialize(
"CurrentFrame", currentFrame);
1094 ar.serialize(
"FrameStep", frameStep);
1098 ar.serialize(
"StereoMode", stereoMode,
1099 "FromSample", playingFromSample,
1100 "SampleClock", sampleClock);
1102 if constexpr (Archive::IS_LOADER) {
1104 if (video->getSampleRate() != sampleClock.
getFreq()) {
1105 uint64_t pos = playingFromSample;
1107 pos *= video->getSampleRate();
1110 playingFromSample = pos;
1111 sampleClock.
setFreq(video->getSampleRate());
1114 auto sample = getCurrentSample(getCurrentTime());
1115 if (video->getFrameRate() == 60)
1116 video->seek(currentFrame * 2, sample);
1118 video->seek(currentFrame, sample);
1119 lastPlayedSample = sample;
1123 if (ar.versionAtLeast(version, 4)) {
1124 ar.serialize(
"syncEven", syncEven,
1126 "syncAck", syncAck);
1131 if constexpr (Archive::IS_LOADER) {
1132 (void)isVideoOutputAvailable(getCurrentTime());
bool getBoolean() const noexcept
virtual void setLaserdiscPlayer(LaserdiscPlayer *laserdisc)=0
Set the Laserdisc Player; when the motor control is off, sound is read from the laserdisc.
void printWarning(std::string_view message)
Represents a clock with a fixed frequency.
virtual TclObject executeCommand(zstring_view command, CliConnection *connection=nullptr)=0
Execute the given command.
void detach(VideoSystemChangeListener &listener)
void attach(VideoSystemChangeListener &listener)
bool before(EmuTime::param e) const
Checks whether this clock's last tick is or is not before the given time stamp.
unsigned getTicksTill(EmuTime::param e) const
Calculate the number of ticks for this clock until the given time.
unsigned getFreq() const
Returns the frequency (in Hz) at which this clock ticks.
void advance(EmuTime::param e)
Advance this clock in time until the last tick which is not past the given time.
void setFreq(unsigned freq)
Change the frequency at which this clock ticks.
EmuTime::param getTime() const
Gets the time at which the last clock tick occurred.
static constexpr EmuDuration msec(unsigned x)
constexpr unsigned getTicksAt(unsigned freq) const
void unregisterEventListener(EventType type, EventListener &listener)
Unregisters a previously registered event listener.
void registerEventListener(EventType type, EventListener &listener, Priority priority=OTHER)
Registers a given object to receive certain events.
bool empty() const
Convenience method to test for empty filename.
const std::string & getResolved() const &
void setMuting(bool left, bool right, EmuTime::param time)
int16_t readSample(EmuTime::param time)
void extControl(bool bit, EmuTime::param time)
MSXMotherBoard & getMotherBoard()
const RawFrame * getRawFrame() const
void serialize(Archive &ar, unsigned version)
void update(bool newState)
Called by the device to indicate its loading state may have changed.
ReverseManager & getReverseManager()
CliComm & getMSXCliComm()
CommandController & getCommandController()
CassettePortInterface & getCassettePort()
void videoIn(bool enabled)
A video frame as output by the VDP scanline conversion unit, before any postprocessing filters are ap...
Contains the main loop of openMSX.
EventDistributor & getEventDistributor()
bool updateBuffer(unsigned length, float *buffer, EmuTime::param time) override
Generate sample data.
bool isReplaying() const override
static void restoreOld(Archive &ar, std::vector< Schedulable * > schedulables)
void updateStream(EmuTime::param time)
unsigned getInputRate() const
void setInputRate(unsigned sampleRate)
void unregisterSound()
Unregisters this sound device with the Mixer.
void registerSound(const DeviceConfig &config)
Registers this sound device with the Mixer.
constexpr index_type size() const noexcept
constexpr unsigned reverseNBits(unsigned x, unsigned bits)
Reverse the lower N bits of a given value.
constexpr uint8_t reverseByte(uint8_t a)
Reverse the bits in a byte.
constexpr vecN< N, T > min(const vecN< N, T > &x, const vecN< N, T > &y)
T length(const vecN< N, T > &x)
string getName(KeyCode keyCode)
Translate key code to key name.
unique_ptr< LDRenderer > createLDRenderer(LaserdiscPlayer &ld, Display &display)
Create the Laserdisc Renderer.
This file implemented 3 utility functions:
constexpr unsigned DUMMY_INPUT_RATE
SERIALIZE_ENUM(CassettePlayer::State, stateInfo)
FileContext userFileContext(string_view savePath)
#define OUTER(type, member)
#define INSTANTIATE_SERIALIZE_METHODS(CLASS)
TemporaryString tmpStrCat(Ts &&... ts)
std::string strCat(Ts &&...ts)