|
|
@@ -374,7 +374,7 @@ int init_persistent_io (StreamPeerIO *pio, PacketPassInterface *user_recv_if)
|
|
|
FlowErrorDomain_Init(&pio->ioerrdomain, (FlowErrorDomain_handler)error_handler, pio);
|
|
|
|
|
|
// init sending objects
|
|
|
- PacketCopier_Init(&pio->output_user_copier, pio->payload_mtu);
|
|
|
+ PacketCopier_Init(&pio->output_user_copier, pio->payload_mtu, BReactor_PendingGroup(pio->reactor));
|
|
|
PacketProtoEncoder_Init(&pio->output_user_ppe, PacketCopier_GetOutput(&pio->output_user_copier));
|
|
|
PacketPassConnector_Init(&pio->output_connector, PACKETPROTO_ENCLEN(pio->payload_mtu), BReactor_PendingGroup(pio->reactor));
|
|
|
if (!SinglePacketBuffer_Init(&pio->output_user_spb, PacketProtoEncoder_GetOutput(&pio->output_user_ppe), PacketPassConnector_GetInput(&pio->output_connector), BReactor_PendingGroup(pio->reactor))) {
|
ambrop7