(peer: any)
| 56 | |
| 57 | // 初始化发送端 |
| 58 | function initSend(peer: any) { |
| 59 | if (peer.isInited) { |
| 60 | return |
| 61 | } |
| 62 | let code = genDigitCode(4) |
| 63 | let retryCount = 2048 |
| 64 | while (waitConnectPool.has(code)) { |
| 65 | if (retryCount-- <= 0) { |
| 66 | peer.send(JSON.stringify({ type: 'err', data: -1, msg: 'Init code fail' })) |
| 67 | throw new Error('Init code fail') |
| 68 | } |
| 69 | // 碰撞时重新生成取件码 |
| 70 | code = genDigitCode(4) |
| 71 | } |
| 72 | waitConnectPool.set(code, peer) |
| 73 | peer.isInited = true |
| 74 | initPool.delete(peer.id) |
| 75 | // 初始化发送端成功，返回连接码 |
| 76 | peer.send(JSON.stringify({ type: 'code', code: code })) |
| 77 | heartbeat(peer) |
| 78 | } |
| 79 | |
| 80 | // 初始化接收端 |
| 81 | function initReceive(peer: any, code: string) { |
no test coverage detected