DXR is a code search and navigation tool aimed at making sense of large projects. It supports full-text and regex searches as well as structural queries.

Mercurial (2f19e7b646e0)

VCS Links

Line Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192
<!DOCTYPE HTML>
<html>
<head>
  <script type="application/javascript" src="mediaStreamPlayback.js"></script>
</head>
<body>
<pre id="test">
<script type="application/javascript">
  createHTML({ title: "PeerConnection feed to a graph with non default rate", bug: "1387454" });
  /**
   * Run a test to verify that when we use the streem with nonDefault rate to/from a PC
   * the connection fails. (PC is always on default rate).
   */

  let pc1;
  let pc2;

  let offerOptions = {
    offerToReceiveAudio: 1,
  };

  function getName(pc) {
    return (pc === pc1) ? 'pc1' : 'pc2';
  }

  function getOtherPc(pc) {
    return (pc === pc1) ? pc2 : pc1;
  }

  function onAddIceCandidateSuccess(pc) {
    ok(true, getName(pc) + ' addIceCandidate success');
  }

  function onAddIceCandidateError(pc, error) {
    ok(false, getName(pc) + ' failed to add ICE Candidate: ' + error.toString());
  }

  function onIceCandidate(pc, event, done) {
    if (!event.candidate) {
      ok(pc.iceGatheringState === 'complete', getName(pc) + " ICE gathering state has reached complete");
      done();
      return;
    }
    getOtherPc(pc).addIceCandidate(event.candidate)
    .then(() => {
        onAddIceCandidateSuccess(pc);
      },
      (err) => {
        onAddIceCandidateError(pc, err);
      });
    info(getName(pc) + ' ICE candidate: ' + event.candidate.candidate);
  }

  function onIceStateChange(pc, event) {
    if (pc) {
      info(getName(pc) + ' ICE state: ' + pc.iceConnectionState);
      info('ICE state change event: ', event);
    }
  }

  function onCreateOfferSuccess(desc) {
    info('Offer from pc1\n' + desc.sdp);
    info('pc1 setLocalDescription start');

    pc1.setLocalDescription(desc)
    .then(() => {
      onSetLocalSuccess(pc1);
    },
    onSetSessionDescriptionError);

    info('pc2 setRemoteDescription start');
    pc2.setRemoteDescription(desc).then(() => {
      onSetRemoteSuccess(pc2);
    },
    onSetSessionDescriptionError);

    info('pc2 createAnswer start');

    // Since the 'remote' side has no media stream we need
    // to pass in the right constraints in order for it to
    // accept the incoming offer of audio and video.
    pc2.createAnswer()
    .then(onCreateAnswerSuccess, onCreateSessionDescriptionError);
  }

  function onSetSessionDescriptionError(error) {
    ok(false, 'Failed to set session description: ' + error.toString());
  }

  function onSetLocalSuccess(pc) {
    ok(true, getName(pc) + ' setLocalDescription complete');
  }

  function onCreateSessionDescriptionError(error) {
    ok(false, 'Failed to create session description: ' + error.toString());
  }

  function onSetRemoteSuccess(pc) {
    ok(true, getName(pc) + ' setRemoteDescription complete');
  }

  function onCreateAnswerSuccess(desc) {
    info('Answer from pc2:\n' + desc.sdp);
    info('pc2 setLocalDescription start');
    pc2.setLocalDescription(desc).then(() => {
      onSetLocalSuccess(pc2);
    },
    onSetSessionDescriptionError);
    info('pc1 setRemoteDescription start');
    pc1.setRemoteDescription(desc).then(() => {
        onSetRemoteSuccess(pc1);
    },
    onSetSessionDescriptionError);
  }

  async function getRemoteStream(localStream) {
    info("got local stream")
    let audioTracks = localStream.getAudioTracks();

    let servers = null;

    pc1 = new RTCPeerConnection(servers);
    info('Created local peer connection object pc1');
    let iceComplete1 = new Promise( (resolve, reject) => {
	  pc1.onicecandidate = (e) => {
	    onIceCandidate(pc1, e, resolve);
	  };
    });

    pc2 = new RTCPeerConnection(servers);
    info('Created remote peer connection object pc2');
    let iceComplete2 = new Promise( (resolve, reject) => {
      pc2.onicecandidate = (e) => {
        onIceCandidate(pc2, e, resolve);
      };
    });

    pc1.oniceconnectionstatechange = (e) => {
      onIceStateChange(pc1, e);
    };
    pc2.oniceconnectionstatechange = (e) => {
      onIceStateChange(pc2, e);
    };

    let remoteStreamPromise = new Promise((resolve, reject) => {
      pc2.ontrack = (e) => {
        info('pc2 received remote stream ' + e.streams[0]);
        resolve(e.streams[0]);
      };
    });

    localStream.getTracks().forEach((track) => {
      pc1.addTrack(track, localStream);
    });
    info('Added local stream to pc1');

    info('pc1 createOffer start');
    pc1.createOffer(offerOptions)
    .then(onCreateOfferSuccess,onCreateSessionDescriptionError);

    let promise_arr = await Promise.all([remoteStreamPromise, iceComplete1, iceComplete2]);

    return promise_arr[0];
  }

  runTest( async () => {
    // Local stream operates at non default rate (32000)
    const nonDefaultRate = 32000;
    let nonDefault_ctx = new AudioContext({sampleRate: nonDefaultRate});
    oscillator = nonDefault_ctx.createOscillator();
    let dest = nonDefault_ctx.createMediaStreamDestination();
    oscillator.connect(dest);
    oscillator.start();

    // Wait for remote stream
    let remoteStream = await getRemoteStream(dest.stream)
    ok(true, 'Got remote stream ' + remoteStream);

    // remoteStream now comes from PC so operates at default
    // rates. Verify that by adding to a default context
    let ac = new AudioContext;
    let source_default_rate = ac.createMediaStreamSource(remoteStream);

    // Now try to add the remoteStream on a non default context
    mustThrowWith("Connect stream with graph of different sample rate", "NotSupportedError", () => {
      let source_non_default_rate = nonDefault_ctx.createMediaStreamSource(remoteStream);
    });
  })
</script>
</pre>
</body>
</html>