#![allow( clippy::type_complexity, clippy::too_many_arguments, clippy::large_enum_variant )] use mpstthree::binary::struct_trait::{end::End, recv::Recv, send::Send}; use mpstthree::generate; use mpstthree::role::broadcast::RoleBroadcast; use mpstthree::role::end::RoleEnd; use std::error::Error; static LOOPS: i64 = 100; // Create new roles generate!( "rec_and_cancel", MeshedChannels, A, B, C, D, E, F, G, H, I, J, K, L, M, N, O, P, Q, R, S, T ); // Types // Send/Recv type RS = Recv<(), Send<(), End>>; type SR = Send<(), Recv<(), End>>; // Roles type R2A = RoleA>; type R2B = RoleB>; type R2C = RoleC>; type R2D = RoleD>; type R2E = RoleE>; type R2F = RoleF>; type R2G = RoleG>; type R2H = RoleH>; type R2I = RoleI>; type R2J = RoleJ>; type R2K = RoleK>; type R2L = RoleL>; type R2M = RoleM>; type R2N = RoleN>; type R2O = RoleO>; type R2P = RoleP>; type R2Q = RoleQ>; type R2R = RoleR>; type R2S = RoleS>; type R2T = RoleT>; // A enum Branching0fromTtoA { More( MeshedChannels< RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursAtoT>>, R2T< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameA, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameA, >, ), } type RecursAtoT = Recv; // B enum Branching0fromTtoB { More( MeshedChannels< SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursBtoT>>, R2T< R2A< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameB, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameB, >, ), } type RecursBtoT = Recv; // C enum Branching0fromTtoC { More( MeshedChannels< SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursCtoT>>, R2T< R2A< R2B< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameC, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameC, >, ), } type RecursCtoT = Recv; // D enum Branching0fromTtoD { More( MeshedChannels< SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursDtoT>>, R2T< R2A< R2B< R2C< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameD, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameD, >, ), } type RecursDtoT = Recv; // E enum Branching0fromTtoE { More( MeshedChannels< SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursEtoT>>, R2T< R2A< R2B< R2C< R2D< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameE, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameE, >, ), } type RecursEtoT = Recv; // F enum Branching0fromTtoF { More( MeshedChannels< SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursFtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameF, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameF, >, ), } type RecursFtoT = Recv; // G enum Branching0fromTtoG { More( MeshedChannels< SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursGtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameG, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameG, >, ), } type RecursGtoT = Recv; // H enum Branching0fromTtoH { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursHtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameH, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameH, >, ), } type RecursHtoT = Recv; // I enum Branching0fromTtoI { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursItoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameI, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameI, >, ), } type RecursItoT = Recv; // J enum Branching0fromTtoJ { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursJtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameJ, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameJ, >, ), } type RecursJtoT = Recv; // K enum Branching0fromTtoK { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursKtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameK, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameK, >, ), } type RecursKtoT = Recv; // L enum Branching0fromTtoL { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursLtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2M< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameL, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameL, >, ), } type RecursLtoT = Recv; // M enum Branching0fromTtoM { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursMtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2N< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameM, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameM, >, ), } type RecursMtoT = Recv; // N enum Branching0fromTtoN { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, RS, Recv<(), Send<(), RecursNtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2O< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameN, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameN, >, ), } type RecursNtoT = Recv; // O enum Branching0fromTtoO { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, RS, Recv<(), Send<(), RecursOtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2P< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameO, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameO, >, ), } type RecursOtoT = Recv; // P enum Branching0fromTtoP { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, RS, Recv<(), Send<(), RecursPtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2Q< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameP, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameP, >, ), } type RecursPtoT = Recv; // Q enum Branching0fromTtoQ { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, RS, Recv<(), Send<(), RecursQtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2R< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameQ, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameQ, >, ), } type RecursQtoT = Recv; // R enum Branching0fromTtoR { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, RS, Recv<(), Send<(), RecursRtoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2S< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameR, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameR, >, ), } type RecursRtoT = Recv; // S enum Branching0fromTtoS { More( MeshedChannels< SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, SR, Recv<(), Send<(), RecursStoT>>, R2T< R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N< R2O< R2P< R2Q< R2R< RoleT< RoleEnd, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, >, NameS, >, ), Done( MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RoleEnd, NameS, >, ), } type RecursStoT = Recv; // T type Choose0fromTtoA = Send; type Choose0fromTtoB = Send; type Choose0fromTtoC = Send; type Choose0fromTtoD = Send; type Choose0fromTtoE = Send; type Choose0fromTtoF = Send; type Choose0fromTtoG = Send; type Choose0fromTtoH = Send; type Choose0fromTtoI = Send; type Choose0fromTtoJ = Send; type Choose0fromTtoK = Send; type Choose0fromTtoL = Send; type Choose0fromTtoM = Send; type Choose0fromTtoN = Send; type Choose0fromTtoO = Send; type Choose0fromTtoP = Send; type Choose0fromTtoQ = Send; type Choose0fromTtoR = Send; type Choose0fromTtoS = Send; type EndpointMoreT = MeshedChannels< Send<(), Recv<(), Choose0fromTtoA>>, Send<(), Recv<(), Choose0fromTtoB>>, Send<(), Recv<(), Choose0fromTtoC>>, Send<(), Recv<(), Choose0fromTtoD>>, Send<(), Recv<(), Choose0fromTtoE>>, Send<(), Recv<(), Choose0fromTtoF>>, Send<(), Recv<(), Choose0fromTtoG>>, Send<(), Recv<(), Choose0fromTtoH>>, Send<(), Recv<(), Choose0fromTtoI>>, Send<(), Recv<(), Choose0fromTtoJ>>, Send<(), Recv<(), Choose0fromTtoK>>, Send<(), Recv<(), Choose0fromTtoL>>, Send<(), Recv<(), Choose0fromTtoM>>, Send<(), Recv<(), Choose0fromTtoN>>, Send<(), Recv<(), Choose0fromTtoO>>, Send<(), Recv<(), Choose0fromTtoP>>, Send<(), Recv<(), Choose0fromTtoQ>>, Send<(), Recv<(), Choose0fromTtoR>>, Send<(), Recv<(), Choose0fromTtoS>>, R2A< R2B< R2C< R2D< R2E< R2F< R2G< R2H< R2I< R2J< R2K< R2L< R2M< R2N>>>>>, >, >, >, >, >, >, >, >, >, >, >, >, >, NameT, >; // Creating the MP sessions type EndpointA = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursAtoT, RoleT, NameA, >; type EndpointB = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursBtoT, RoleT, NameB, >; type EndpointC = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursCtoT, RoleT, NameC, >; type EndpointD = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursDtoT, RoleT, NameD, >; type EndpointE = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursEtoT, RoleT, NameE, >; type EndpointF = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursFtoT, RoleT, NameF, >; type EndpointG = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursGtoT, RoleT, NameG, >; type EndpointH = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursHtoT, RoleT, NameH, >; type EndpointI = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursItoT, RoleT, NameI, >; type EndpointJ = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursJtoT, RoleT, NameJ, >; type EndpointK = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursKtoT, RoleT, NameK, >; type EndpointL = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursLtoT, RoleT, NameL, >; type EndpointM = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursMtoT, RoleT, NameM, >; type EndpointN = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursNtoT, RoleT, NameN, >; type EndpointO = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursOtoT, RoleT, NameO, >; type EndpointP = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursPtoT, RoleT, NameP, >; type EndpointQ = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursQtoT, RoleT, NameQ, >; type EndpointR = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursRtoT, RoleT, NameR, >; type EndpointS = MeshedChannels< End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, End, RecursStoT, RoleT, NameS, >; type EndpointT = MeshedChannels< Choose0fromTtoA, Choose0fromTtoB, Choose0fromTtoC, Choose0fromTtoD, Choose0fromTtoE, Choose0fromTtoF, Choose0fromTtoG, Choose0fromTtoH, Choose0fromTtoI, Choose0fromTtoJ, Choose0fromTtoK, Choose0fromTtoL, Choose0fromTtoM, Choose0fromTtoN, Choose0fromTtoO, Choose0fromTtoP, Choose0fromTtoQ, Choose0fromTtoR, Choose0fromTtoS, RoleBroadcast, NameT, >; fn endpoint_a(s: EndpointA) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoA::Done(s) => { s.close() }, Branching0fromTtoA::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_a(s) }, }) } #[inline] fn endpoint_b(s: EndpointB) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoB::Done(s) => { s.close() }, Branching0fromTtoB::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_b(s) }, }) } #[inline] fn endpoint_c(s: EndpointC) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoC::Done(s) => { s.close() }, Branching0fromTtoC::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_c(s) }, }) } #[inline] fn endpoint_d(s: EndpointD) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoD::Done(s) => { s.close() }, Branching0fromTtoD::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_d(s) }, }) } #[inline] fn endpoint_e(s: EndpointE) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoE::Done(s) => { s.close() }, Branching0fromTtoE::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_e(s) }, }) } #[inline] fn endpoint_f(s: EndpointF) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoF::Done(s) => { s.close() }, Branching0fromTtoF::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_f(s) }, }) } #[inline] fn endpoint_g(s: EndpointG) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoG::Done(s) => { s.close() }, Branching0fromTtoG::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_g(s) }, }) } #[inline] fn endpoint_h(s: EndpointH) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoH::Done(s) => { s.close() }, Branching0fromTtoH::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_h(s) }, }) } #[inline] fn endpoint_i(s: EndpointI) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoI::Done(s) => { s.close() }, Branching0fromTtoI::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_i(s) }, }) } #[inline] fn endpoint_j(s: EndpointJ) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoJ::Done(s) => { s.close() }, Branching0fromTtoJ::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_j(s) }, }) } #[inline] fn endpoint_k(s: EndpointK) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoK::Done(s) => { s.close() }, Branching0fromTtoK::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_k(s) }, }) } #[inline] fn endpoint_l(s: EndpointL) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoL::Done(s) => { s.close() }, Branching0fromTtoL::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_l(s) }, }) } #[inline] fn endpoint_m(s: EndpointM) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoM::Done(s) => { s.close() }, Branching0fromTtoM::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_m(s) }, }) } #[inline] fn endpoint_n(s: EndpointN) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoN::Done(s) => { s.close() }, Branching0fromTtoN::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_n(s) }, }) } #[inline] fn endpoint_o(s: EndpointO) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoO::Done(s) => { s.close() }, Branching0fromTtoO::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_o(s) }, }) } #[inline] fn endpoint_p(s: EndpointP) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoP::Done(s) => { s.close() }, Branching0fromTtoP::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_p(s) }, }) } #[inline] fn endpoint_q(s: EndpointQ) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoQ::Done(s) => { s.close() }, Branching0fromTtoQ::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_q(s) }, }) } #[inline] fn endpoint_r(s: EndpointR) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoR::Done(s) => { s.close() }, Branching0fromTtoR::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let (_, s) = s.recv()?; let s = s.send(())?; endpoint_r(s) }, }) } #[inline] fn endpoint_s(s: EndpointS) -> Result<(), Box> { offer_mpst!(s, { Branching0fromTtoS::Done(s) => { s.close() }, Branching0fromTtoS::More(s) => { let (_, s) = s.recv()?; let s = s.send(())?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; endpoint_s(s) }, }) } #[inline] fn endpoint_t(s: EndpointT) -> Result<(), Box> { let mut temp_s = s; for _ in 1..LOOPS { temp_s = recurs_t(temp_s)?; } let s = choose_mpst_t_to_all!( temp_s, Branching0fromTtoA::Done, Branching0fromTtoB::Done, Branching0fromTtoC::Done, Branching0fromTtoD::Done, Branching0fromTtoE::Done, Branching0fromTtoF::Done, Branching0fromTtoG::Done, Branching0fromTtoH::Done, Branching0fromTtoI::Done, Branching0fromTtoJ::Done, Branching0fromTtoK::Done, Branching0fromTtoL::Done, Branching0fromTtoM::Done, Branching0fromTtoN::Done, Branching0fromTtoO::Done, Branching0fromTtoP::Done, Branching0fromTtoQ::Done, Branching0fromTtoR::Done, Branching0fromTtoS::Done ); s.close() } fn recurs_t(s: EndpointT) -> Result> { let s: EndpointMoreT = choose_mpst_t_to_all!( s, Branching0fromTtoA::More, Branching0fromTtoB::More, Branching0fromTtoC::More, Branching0fromTtoD::More, Branching0fromTtoE::More, Branching0fromTtoF::More, Branching0fromTtoG::More, Branching0fromTtoH::More, Branching0fromTtoI::More, Branching0fromTtoJ::More, Branching0fromTtoK::More, Branching0fromTtoL::More, Branching0fromTtoM::More, Branching0fromTtoN::More, Branching0fromTtoO::More, Branching0fromTtoP::More, Branching0fromTtoQ::More, Branching0fromTtoR::More, Branching0fromTtoS::More ); let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; let s = s.send(())?; let (_, s) = s.recv()?; Ok(s) } fn main() { let ( thread_a, thread_b, thread_c, thread_d, thread_e, thread_f, thread_g, thread_h, thread_i, thread_j, thread_k, thread_l, thread_m, thread_n, thread_o, thread_p, thread_q, thread_r, thread_s, thread_t, ) = fork_mpst( endpoint_a, endpoint_b, endpoint_c, endpoint_d, endpoint_e, endpoint_f, endpoint_g, endpoint_h, endpoint_i, endpoint_j, endpoint_k, endpoint_l, endpoint_m, endpoint_n, endpoint_o, endpoint_p, endpoint_q, endpoint_r, endpoint_s, endpoint_t, ); thread_a.join().unwrap(); thread_b.join().unwrap(); thread_c.join().unwrap(); thread_d.join().unwrap(); thread_e.join().unwrap(); thread_f.join().unwrap(); thread_g.join().unwrap(); thread_h.join().unwrap(); thread_i.join().unwrap(); thread_j.join().unwrap(); thread_k.join().unwrap(); thread_l.join().unwrap(); thread_m.join().unwrap(); thread_n.join().unwrap(); thread_o.join().unwrap(); thread_p.join().unwrap(); thread_q.join().unwrap(); thread_r.join().unwrap(); thread_s.join().unwrap(); thread_t.join().unwrap(); }