再接続できない場合がある

[dazy1030]

• RTMPに関する表現が間違っていたら申し訳ありません
• 回避策があればぜひ教えていただきたいです

Describe the bug

• ~requireNetworkFramework を true にしてRTMPNWSocket を利用している~
• RTMPのステータスが NetConnection.Connect.Closed になった後に再接続を行うと、NetConnection.Connect.Success まではいけるが publish(_:) のメソッドを呼んでも NetStream.Publish.Start にならない場合がある

To Reproduce

• 100％発生するわけではないが、高頻度で発生する

1. ~requireNetworkFramework を trueに~
2. 接続ができる環境で、RTMPConnection の connect(_:) を呼びRTMP接続を行う
3. NetConnection.Connect.Success な状態になったらRTMPStreamの publish(_:) を呼びストリームを流し始める
4. 機内モードで接続を遮断する
5. NetConnection.Connect.Closed の状態になったら、RTMPConnection の connect(_:) を呼びRTMP接続を試みる
6. （RTMPSocketと差分があり、接続できない状態で connect(_:) を呼ぶと接続できるまで繰り返す）
7. 機内モードを解除する
8. NetConnection.Connect.Success の状態になったらRTMPStreamの publish(_:) を呼ぶ
9. 待っても NetStream.Publish.Start の状態にならず、ストリームも流れていない

Expected behavior

• NetConnection.Connect.Success の後に publish(_:) を呼ぶことでストリームを再度流すことができる

Smartphone:

• iPhone8
• OS: iOS14.3
• v1.1.3

Additional context Logboard で収集した役に立ちそうなログを記載します

• 一部アドレスなどは置き換えています
• +++ から始まる行は、addEventListener で受信したRTMPStatusです

  +++ status code NetConnection.Connect.Closed
  2021-19-04 21:33:45.322 [Debug] [com.haishinkit.HaishinKit] [RTMPConnection.swift:472] didSetReadyState(_:) > uninitialized
  2021-04-19 21:33:45.323050+0900 UploaderExtension[35121:2313124] [connection] nw_connection_copy_connected_local_endpoint [C26] Connection has no local endpoint
  2021-04-19 21:33:45.331851+0900 UploaderExtension[35121:2313124] [] nw_path_evaluator_create_flow_inner NECP_CLIENT_ACTION_ADD_FLOW UUIDっぽいなにか [65: No route to host]
  2021-04-19 21:33:45.332686+0900 UploaderExtension[35121:2313124] [connection] nw_endpoint_flow_setup_channel [C34 IPアドレス in_progress channel-flow (satisfied (Path is satisfied), interface: en0, ipv4, dns)] failed to request add nexus flow
  2021-04-19 21:33:47.765713+0900 UploaderExtension[35121:2313134] [connection] nw_connection_get_connected_socket [C35] Client called nw_connection_get_connected_socket on unconnected nw_connection
  2021-04-19 21:33:47.765834+0900 UploaderExtension[35121:2313134] TCP Conn 0x2830bd600 Failed : error 0:50 [50]
  2021-04-19 21:33:49.784399+0900 UploaderExtension[35121:2313132] [connection] nw_connection_get_connected_socket [C36] Client called nw_connection_get_connected_socket on unconnected nw_connection
  2021-04-19 21:33:49.784557+0900 UploaderExtension[35121:2313132] TCP Conn 0x2830acbb0 Failed : error 0:50 [50]
  2021-04-19 21:33:51.808683+0900 UploaderExtension[35121:2313124] [connection] nw_connection_get_connected_socket [C37] Client called nw_connection_get_connected_socket on unconnected nw_connection
  2021-04-19 21:33:51.808808+0900 UploaderExtension[35121:2313124] TCP Conn 0x2830acbb0 Failed : error 0:50 [50]
  2021-19-04 21:33:52.397 [Debug] [com.haishinkit.HaishinKit] [RTMPConnection.swift:472] didSetReadyState(_:) > versionSent
  2021-19-04 21:33:52.407 [Debug] [com.haishinkit.HaishinKit] [RTMPConnection.swift:472] didSetReadyState(_:) > ackSent
  2021-19-04 21:33:52.413 [Debug] [com.haishinkit.HaishinKit] [RTMPConnection.swift:472] didSetReadyState(_:) > handshakeDone
  2021-19-04 21:33:52.414 [Trace] [com.haishinkit.HaishinKit] [RTMPNWSocket.swift:102] doOutput(chunk:locked:) > RTMPChunk{size: 0,type: zero,streamId: 3,message: Optional(RTMPCommandMessage{type: amf0Command,length: 267,streamId: 0,timestamp: 0,payload: 255 bytes,objectEncoding: amf0,commandName: connect,transactionId: 1,commandObject: Optional(["videoCodecs": Optional(128), "swfUrl": nil, "fpad": Optional(false), "videoFunction": Optional(1), "tcUrl": Optional("RTMPのアドレス"), "pageUrl": nil, "app": Optional("hls"), "flashVer": Optional("FMLE/3.0 (compatible; FMSc/1.0)"), "capabilities": Optional(239), "audioCodecs": Optional(1024), "objectEncoding": Optional(0)]),arguments: [],serializer: AMF0Serializer{data: 0 bytes,position: 0,reference: HaishinKit.AMFReference}}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.422 [Trace] [com.haishinkit.HaishinKit] [RTMPConnection.swift:531] listen(_:) > RTMPChunk{size: 128,type: zero,streamId: 2,message: Optional(RTMPWindowAcknowledgementSizeMessage{type: windowAck,length: 4,streamId: 0,timestamp: 0,payload: 4 bytes,size: 5000000}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.423 [Trace] [com.haishinkit.HaishinKit] [RTMPNWSocket.swift:102] doOutput(chunk:locked:) > RTMPChunk{size: 0,type: zero,streamId: 2,message: Optional(RTMPWindowAcknowledgementSizeMessage{type: windowAck,length: 16,streamId: 0,timestamp: 0,payload: 4 bytes,size: 5000000}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.429 [Trace] [com.haishinkit.HaishinKit] [RTMPConnection.swift:531] listen(_:) > RTMPChunk{size: 128,type: zero,streamId: 2,message: Optional(RTMPSetPeerBandwidthMessage{type: bandwidth,length: 5,streamId: 0,timestamp: 0,payload: 5 bytes,size: 5000000,limit: dynamic}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.429 [Trace] [com.haishinkit.HaishinKit] [RTMPConnection.swift:531] listen(_:) > RTMPChunk{size: 128,type: zero,streamId: 2,message: Optional(RTMPSetChunkSizeMessage{type: chunkSize,length: 4,streamId: 0,timestamp: 0,payload: 4 bytes,size: 4096}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.430 [Trace] [com.haishinkit.HaishinKit] [RTMPConnection.swift:531] listen(_:) > RTMPChunk{size: 4096,type: zero,streamId: 3,message: Optional(RTMPCommandMessage{type: amf0Command,length: 190,streamId: 0,timestamp: 0,payload: 190 bytes,objectEncoding: amf0,commandName: _result,transactionId: 1,commandObject: Optional(["fmsVer": Optional("FMS/3,0,1,123"), "capabilities": Optional(31.0)]),arguments: [Optional(["objectEncoding": Optional(0.0), "level": Optional("status"), "code": Optional("NetConnection.Connect.Success"), "description": Optional("Connection succeeded.")])],serializer: AMF0Serializer{data: 0 bytes,position: 0,reference: HaishinKit.AMFReference}}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.431 [Trace] [com.haishinkit.HaishinKit] [RTMPNWSocket.swift:102] doOutput(chunk:locked:) > RTMPChunk{size: 0,type: zero,streamId: 2,message: Optional(RTMPSetChunkSizeMessage{type: chunkSize,length: 16,streamId: 0,timestamp: 0,payload: 4 bytes,size: 8192}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.431 [Trace] [com.haishinkit.HaishinKit] [RTMPNWSocket.swift:102] doOutput(chunk:locked:) > RTMPChunk{size: 0,type: zero,streamId: 3,message: Optional(RTMPCommandMessage{type: amf0Command,length: 37,streamId: 0,timestamp: 0,payload: 25 bytes,objectEncoding: amf0,commandName: createStream,transactionId: 2,commandObject: nil,arguments: [],serializer: AMF0Serializer{data: 0 bytes,position: 0,reference: HaishinKit.AMFReference}}),fragmented: false,_data: 12 bytes}
  +++ status code NetConnection.Connect.Success
  2021-19-04 21:33:52.478 [Trace] [com.haishinkit.HaishinKit] [RTMPConnection.swift:531] listen(_:) > RTMPChunk{size: 4096,type: zero,streamId: 3,message: Optional(RTMPCommandMessage{type: amf0Command,length: 29,streamId: 0,timestamp: 0,payload: 29 bytes,objectEncoding: amf0,commandName: _result,transactionId: 2,commandObject: Optional([:]),arguments: [Optional(1.0)],serializer: AMF0Serializer{data: 0 bytes,position: 0,reference: HaishinKit.AMFReference}}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.480 [Trace] [com.haishinkit.HaishinKit] [RTMPNWSocket.swift:102] doOutput(chunk:locked:) > RTMPChunk{size: 0,type: zero,streamId: 3,message: Optional(RTMPCommandMessage{type: amf0Command,length: 102,streamId: 0,timestamp: 0,payload: 90 bytes,objectEncoding: amf0,commandName: FCPublish,transactionId: 3,commandObject: nil,arguments: [Optional("ストリームキー")],serializer: AMF0Serializer{data: 0 bytes,position: 0,reference: HaishinKit.AMFReference}}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.481 [Trace] [com.haishinkit.HaishinKit] [RTMPNWSocket.swift:102] doOutput(chunk:locked:) > RTMPChunk{size: 0,type: zero,streamId: 4,message: Optional(RTMPCommandMessage{type: amf0Command,length: 107,streamId: 1,timestamp: 0,payload: 95 bytes,objectEncoding: amf0,commandName: publish,transactionId: 0,commandObject: nil,arguments: [Optional("ストリームキー"), Optional("live")],serializer: AMF0Serializer{data: 0 bytes,position: 0,reference: HaishinKit.AMFReference}}),fragmented: false,_data: 12 bytes}
  2021-19-04 21:33:52.534 [Trace] [com.haishinkit.HaishinKit] [RTMPConnection.swift:531] listen(_:) > RTMPChunk{size: 4096,type: zero,streamId: 5,message: Optional(RTMPCommandMessage{type: amf0Command,length: 108,streamId: 1,timestamp: 0,payload: 108 bytes,objectEncoding: amf0,commandName: onStatus,transactionId: 0,commandObject: Optional([:]),arguments: [Optional(["description": Optional("Already publishing"), "level": Optional("error"), "code": Optional("NetStream.Publish.BadName")])],serializer: AMF0Serializer{data: 0 bytes,position: 0,reference: HaishinKit.AMFReference}}),fragmented: false,_data: 12 bytes}

[shogo4405]

機内モードで接続を遮断する

1〜3 のときはスムーズにいって。機内モードで接続を遮断するとうまくいかないという理解で良いでしょうか？ WiFi -> 4G -> WiFi のテストとiOS12/13のときのテストで終わっていました。

開発者も意図はしていないのでただのバグになり。解決方法は現在のところはなさそうです。

[dazy1030]

遅くの時間にありがとうございます

1〜3 のときはスムーズにいって。機内モードで接続を遮断するとうまくいかないという理解で良いでしょうか？

そうですね。記載させていただいた問題をもっと利用者目線に言うと、配信中になんらかの原因で接続が切れてそこから復帰しづらい、といった感じです。確かに初回で失敗した試しはないですね。

[dazy1030]

どうやらRTMPNWSocketの問題ではなかったようなので、タイトルと内容に一部変更を加えました。 RTMPの仕様をまだちゃんと把握できていませんが、おそらく切断前のストリームが削除されていない状態で同じ名前でストリームを作成しようとしているのが原因な気がします。

[dazy1030]

徐々にRTMPの仕様を理解してきて、不具合でないことがわかりました。

処理が漏れていて気がついていなかったのですが、8. の NetConnection.Connect.Success の後に NetStream.Publish.BadName を受信していました。 これは同じ名前のストリームで公開しようとした時に起こるエラーのようで、前のストリームがサーバー目線でまだ生きているという判定の時に起こるエラーでした。前のストリームはタイムアウトで死んだとみなされるため、BadName を受信した場合は成功するまで Publish を繰り返せば良いというのが正しい再接続の方法のようでした。

理解不足のままissue化してしまい失礼しました。解決したためcloseさせていただきます。