<> <> <> <> <> <> <> DIRECTORY Basics USING [BITAND, LowHalf], BasicTime, <> IntervalTimer USING [NowInPulses, Pulses, WaitForExpirationTimeInPulses], <> Process USING [Detach, GetCurrent, MsecToTicks, Priority, priorityForeground, SetPriority, SetTimeout], PupDefs USING [GetFreePupBuffer, GetPupContentsBytes, PupBuffer, PupSocket, ReturnFreePupBuffer, SetPupContentsBytes, SetPupContentsWords], PupTypes USING [PupType], Rope USING [ROPE], SpyOps USING [Record, StackType], VoiceStream; VoiceStreamSocket: MONITOR LOCKS Lock IMPORTS Basics, BasicTime, IntervalTimer, Process, PupDefs, SpyOps, VoiceStream EXPORTS VoiceStream SHARES VoiceStream = BEGIN OPEN VoiceStream; socketPriority: Process.Priority _ Process.priorityForeground; <> MicrosecondsPerPulse: LONG CARDINAL = 32; PulsesPerMillisecond: LONG CARDINAL = 31; -- really 31.25 <> BluejayVoiceType: PupTypes.PupType = LOOPHOLE[250]; ProbeReplyType: PupTypes.PupType = LOOPHOLE[251]; LarkFirstVoiceType: PupTypes.PupType = LOOPHOLE[252]; RetransmitRequestType: PupTypes.PupType = LOOPHOLE[253]; LarkVoiceType: PupTypes.PupType = LOOPHOLE[254]; BluejayPacket: TYPE = LONG POINTER TO BluejayPacketObject; <> <> <> BluejayPacketObject: TYPE = MACHINE DEPENDENT RECORD [ blank1: [0..77B], ignore: BOOL, probeRequest: BOOL, blank2: [0..17B], encryptionKeyIndex: [0..17B], energy: CARDINAL, silenceMS: CARDINAL, blank3: CARDINAL ]; ProbeReply: TYPE = LONG POINTER TO ProbeReplyPacketObject; <> <> <> ProbeReplyPacketObject: TYPE = MACHINE DEPENDENT RECORD [ replyID: CARDINAL, maxPacketSize: CARDINAL, maxBuffers: CARDINAL, blank1: CARDINAL ]; <> <> <> LarkPacketObject: TYPE = MACHINE DEPENDENT RECORD [ blank1: [0..377B], blank2: [0..17B], encryptionKeyIndex: [0..17B], energy: CARDINAL, silenceMS: CARDINAL, -- preceding data blank3: CARDINAL ]; <> <> <> <> bytesPerPacket: INTEGER = 160; bytesPerMs: NAT = 8; debugSwitch: BOOL _ FALSE; maxLostTime: LONG CARDINAL _ 100000 / MicrosecondsPerPulse; now: LONG CARDINAL; timesLate: LONG CARDINAL _ 0; noPieceMS: NAT _ 200; SetSocket: PUBLIC ENTRY PROC [handle: Handle, socket: PupDefs.PupSocket] = { ENABLE UNWIND => NULL; IF handle.errorRope # NIL THEN ERROR Error[handle.errorCode, handle.errorRope]; <> IF handle.connection = NIL THEN handle.connection _ NEW[VoiceStream.ConnectionObject]; handle.connection.socket _ NIL; IF socket # NIL THEN { handle.connection.socket _ socket; handle.notified _ TRUE; Process.Detach[FORK receiveProc[handle, socket]]; Process.Detach[FORK sendProc[handle, socket]]; }; }; checkHandle: ENTRY PROC [handle: Handle, socket: PupDefs.PupSocket] RETURNS [Rope.ROPE] = { ENABLE UNWIND => NULL; <<>> <> IF handle.connection.socket # socket THEN RETURN ["Socket changed."]; IF handle.errorRope # NIL THEN RETURN [handle.errorRope]; RETURN [NIL]; }; forceToJukebox: ENTRY PROC [handle: Handle] = { <<>> <> ENABLE UNWIND => NULL; flushBuffer[handle]; WHILE (handle.firstServerBuffer # NIL) AND (handle.errorRope = NIL) AND (handle.piece # NIL) DO WAIT client ENDLOOP; }; receiveProc: PROC [handle: Handle, origSocket: PupDefs.PupSocket] = { <<>> <> ENABLE { Error => { <> CONTINUE; }; }; input: PupDefs.PupBuffer; expLarkTime: CARDINAL _ 0; -- Expected time for next data. larkTime: CARDINAL _ 0; -- Time of current packet. silenceMs: CARDINAL _ 0; dataBytes: CARDINAL; first: BOOL _ TRUE; -- first packet of recording reason: Rope.ROPE _ NIL; Process.SetPriority[socketPriority]; <> WHILE (reason _ checkHandle[handle, origSocket]) = NIL DO input _ handle.connection.socket.get[]; IF input = NIL THEN LOOP; <> larkTime _ input.pupID.a; SELECT input.pupType FROM <> = ProbeReplyType => { AdjustLocked[handle.connection, input]; handle.connection.packetSize _ input.pupWords[1]; handle.connection.bufferSpace _ input.pupWords[2] * (handle.connection.packetSize / bytesPerMs); }; <> = LarkVoiceType, = LarkFirstVoiceType => { silenceMs _ larkTime - expLarkTime; silenceMs _ MIN[silenceMs, 1000]; input.pupWords[2] _ MIN[260, input.pupWords[2]]; IF NOT first AND silenceMs NOT IN [0..250) THEN { <> silenceMs _ 0; }; <> IF first THEN silenceMs _ 0 ELSE silenceMs _ silenceMs + input.pupWords[2]; dataBytes _ PupDefs.GetPupContentsBytes[input] - 8; dataBytes _ Basics.BITAND[dataBytes, 0177770B]; [] _ Put[handle: handle, silentBytes: silenceMs * bytesPerMs, block: [@input.pupWords[4], 0, dataBytes]]; expLarkTime _ larkTime + input.pupWords[2] + (dataBytes/bytesPerMs); first _ FALSE; }; ENDCASE; PupDefs.ReturnFreePupBuffer[input]; ENDLOOP; <> }; AdjustLocked: ENTRY PROC [c: VoiceStream.Connection, b: PupDefs.PupBuffer] = { ENABLE UNWIND => NULL; rp: ProbeReply; deltaLark, deltaLocal: INT; rp _ LOOPHOLE[@b.pupBody]; IF rp^.replyID = c.probeSequenceNumber THEN { <<>> <> IF c.initialProbeFinished THEN { <> c.roundTripMS _ (Basics.LowHalf[(IntervalTimer.NowInPulses[] - c.probeLaunchTime) / PulsesPerMillisecond] + c.roundTripMS) / 2; deltaLocal _ c.probeLaunchTime - c.localEpoch; <> deltaLark _ LONG[b.pupID.a - c.larkEpoch] * PulsesPerMillisecond; <> c.drift _ c.drift + deltaLocal - deltaLark; SELECT TRUE FROM c.drift < -312 => { c.sendNext _ c.sendNext - 150; c.drift _ c.drift + 150; }; c.drift > 312 => { <> <> c.sendNext _ c.sendNext + 150; c.drift _ c.drift - 150; }; ENDCASE; <> < {>> <> <> <<};>> < 10000 => {>> <> <> <> <> <<};>> <> c.larkEpoch _ b.pupID.a; c.localEpoch _ c.probeLaunchTime; } ELSE { -- initial probe case <> c.roundTripMS _ Basics.LowHalf[(IntervalTimer.NowInPulses[] - c.probeLaunchTime) / PulsesPerMillisecond]; c.localEpoch _ c.probeLaunchTime; c.larkEpoch _ b.pupID.a; c.drift _ 0; c.initialProbeFinished _ TRUE; NOTIFY c.initialProbeDone; }; }; }; sendProc: PROC [handle: Handle, origSocket: PupDefs.PupSocket] = { <> ENABLE { Error => { <> CONTINUE; }; }; output: PupDefs.PupBuffer _ NIL; pp: BluejayPacket; c: VoiceStream.Connection _ handle.connection; silenceLength: NAT; voiceLength: NAT; reason: Rope.ROPE; silenceMS: NAT _ 0; voiceMS: NAT _ 0; <> lastPlayed: IntervalTimer.Pulses; noPieceThisTime: BOOL _ FALSE; wakeTime: IntervalTimer.Pulses; { Process.SetPriority[socketPriority]; c.initialProbeFinished _ FALSE; Process.SetTimeout[condition: @c.initialProbeDone, ticks: Process.MsecToTicks[100]]; <> EmptyProbe[handle: handle, origSocket: origSocket]; IF NOT c.initialProbeFinished THEN { <> handle.errorRope _ "Lark failed to respond"; handle.errorCode _ Timeout; GOTO Cleanup; }; <> <> c.timeToPlay _ c.larkEpoch + MIN[120, c.bufferSpace]; <> c.sendNext _ c.localEpoch; <> lastPlayed _ IntervalTimer.NowInPulses[] - (10000 / MicrosecondsPerPulse); <> WHILE (reason _ checkHandle[handle, origSocket]) = NIL DO IF output = NIL THEN { output _ PupDefs.GetFreePupBuffer[]; pp _ LOOPHOLE[@output.pupBody]; output.pupType _ BluejayVoiceType; output.pupID.b _ c.sequenceNumber; c.sequenceNumber _ c.sequenceNumber + 1; pp^ _ [ blank1: 0, ignore: FALSE, probeRequest: FALSE, blank2: 0, encryptionKeyIndex: 0, energy: 0, silenceMS: 0, blank3: 0 ]; }; output.pupID.a _ c.timeToPlay; <<>> <> [silence: silenceLength, bytesTransferred: voiceLength, keyIndex: pp.encryptionKeyIndex] _ VoiceStream.Get[handle: handle, maxSilentBytes: 500 * bytesPerMs, block: [@output.pupWords[4], 0, bytesPerPacket]]; voiceLength _ Basics.BITAND[voiceLength, 0177770B]; silenceMS _ silenceLength/bytesPerMs; voiceMS _ voiceLength/bytesPerMs; <> noPieceThisTime _ (silenceLength = 0) AND (voiceLength = 0); IF noPieceThisTime THEN silenceMS _ noPieceMS; c.packetMS _ silenceMS + voiceMS; pp.silenceMS _ silenceMS; PupDefs.SetPupContentsBytes[output, SIZE[BluejayPacketObject] * 2 + voiceLength]; <<>> <> < 0 THEN {>> <> <> < maxLostTime THEN {>> <> <> <<};>> <<};>> <> < 0 THEN {>> <> <> < maxLostTime THEN {>> <> <> <<};>> <<};>> now _ IntervalTimer.NowInPulses[]; IF LOOPHOLE[(LOOPHOLE[lastPlayed, LONG CARDINAL] + (5000 / MicrosecondsPerPulse)) - now, INT] > 0 THEN { IntervalTimer.WaitForExpirationTimeInPulses[lastPlayed + (5000 / MicrosecondsPerPulse)]; -- wait at least 5 mS now _ IntervalTimer.NowInPulses[]; IF (now - (lastPlayed + (5000 / MicrosecondsPerPulse))) > maxLostTime THEN { timesLate _ timesLate + 1; IF debugSwitch THEN SpyOps.Record[type: LAST[SpyOps.StackType]]; }; }; <> now _ IntervalTimer.NowInPulses[]; wakeTime _ c.sendNext; IF LOOPHOLE[wakeTime - now, INT] > 0 THEN { IntervalTimer.WaitForExpirationTimeInPulses[wakeTime]; now _ IntervalTimer.NowInPulses[]; IF now - wakeTime > maxLostTime THEN { timesLate _ timesLate + 1; IF debugSwitch THEN SpyOps.Record[type: LAST[SpyOps.StackType]]; }; }; PlayPacketLocked[c, pp, output]; IF (reason _ checkHandle[handle, origSocket]) # NIL THEN { PupDefs.ReturnFreePupBuffer[output]; output _ NIL; EXIT; }; c.socket.put[output]; output _ NIL; <> lastPlayed _ IntervalTimer.NowInPulses[]; ENDLOOP; GOTO Cleanup; EXITS Cleanup => { <> }; }; }; <> PlayPacketLocked: ENTRY PROC [c: VoiceStream.Connection, pp: BluejayPacket, b: PupDefs.PupBuffer] = { ENABLE UNWIND => NULL; IF (c.sendNext - c.probeLaunchTime) NOT IN [0..450000 / MicrosecondsPerPulse) THEN { pp^.probeRequest _ TRUE; <> c.probeLaunchTime _ IntervalTimer.NowInPulses[]; c.probeSequenceNumber _ b.pupID.b; }; c.timeToPlay _ c.timeToPlay + c.packetMS; <> c.sendNext _ c.sendNext + (LONG[c.packetMS] * PulsesPerMillisecond); }; EmptyProbe: PROC [handle: VoiceStream.Handle, origSocket: PupDefs.PupSocket] = { b: PupDefs.PupBuffer; pp: BluejayPacket; trySN: CARDINAL; c: VoiceStream.Connection _ handle.connection; WHILE checkHandle[handle, origSocket] = NIL DO b _ PupDefs.GetFreePupBuffer[]; pp _ LOOPHOLE[@b.pupBody]; trySN _ c.sequenceNumber; c.sequenceNumber _ c.sequenceNumber + 1; b.pupID.a _ 0; b.pupID.b _ trySN; b.pupType _ BluejayVoiceType; pp^ _ [ blank1: 0, ignore: TRUE, probeRequest: TRUE, blank2: 0, encryptionKeyIndex: 0, energy: 0, silenceMS: 0, blank3: 0 ]; PupDefs.SetPupContentsWords[b, SIZE[BluejayPacketObject]]; SendProbeLocked[c, b]; c.socket.put[b]; WaitLocked[c]; IF c.initialProbeFinished THEN EXIT; ENDLOOP; }; SendProbeLocked: ENTRY PROC [c: VoiceStream.Connection, b: PupDefs.PupBuffer] = { ENABLE UNWIND => NULL; <> c.probeLaunchTime _ IntervalTimer.NowInPulses[]; c.probeSequenceNumber _ b.pupID.b; }; WaitLocked: ENTRY PROC [c: VoiceStream.Connection] = { WAIT c.initialProbeDone; }; END. L. Stewart, June 5, 1983 4:30 pm, no notify on SetSocket L. Stewart, June 6, 1983 1:15 pm, LarkFirstVoiceType packet type L. Stewart, June 20, 1983 4:52 pm, Try using Pulses instead of Microseconds L. Stewart, July 9, 1983 4:48 pm, added noPieceMS in place of constant L. Stewart, May 14, 1985 6:29:20 pm PDT, Cedar 5, L <> <> <<>>