instantiator_port.kind, instantiator_port.state

        );

        let created_port = created_ctx.get_port(created_port_handle);

        let created_port_id = created_port.self_id;

        // Modify port ID in the arguments to the new component and store them

        // for later access

        let is_open = instantiator_port.state.is_open();

        port_pairs.push(PortPair{

            instantiator_id: instantiator_port_id,

            instantiator_handle: instantiator_port_handle,

            created_id: created_port_id,

            created_handle: created_port_handle,

            is_open,

        });

        for location in port_location.iter().copied() {

            let value = arguments.get_value_mut(location);

            match value {

                Value::Input(id) => *id = port_id_to_eval(created_port_id),

                Value::Output(id) => *id = port_id_to_eval(created_port_id),

                _ => unreachable!(),

            }

        }

    }

    // For each of the ports in the newly created component we set the peer to

    // the correct value. We will not yet change the peer on the instantiator's

    // ports (as we haven't yet stored the new component in the runtime's

    // component storage)

    let mut created_component_has_remote_peers = false;

    for pair in port_pairs.iter() {

        let instantiator_port_info = instantiator_ctx.get_port(pair.instantiator_handle);

        let created_port_info = created_ctx.get_port_mut(pair.created_handle);

        if created_port_info.peer_comp_id == instantiator_ctx.id {

            // The peer of the created component's port seems to be the

            // instantiator.

            let created_port_peer_index = port_pairs.iter()

                .position(|v| v.instantiator_id == instantiator_port_info.peer_port_id);

            match created_port_peer_index {

                Some(created_port_peer_index) => {

                    // However, the peer port is also moved to the new

                    // component, so the complete channel is owned by the new

                    // component.

                    let peer_pair = &port_pairs[created_port_peer_index];

                    created_port_info.peer_port_id = peer_pair.created_id;

                    created_port_info.peer_comp_id = reservation.id();

                },

                None => {

                    // Peer port remains with instantiator. However, we cannot

                    // set the peer on the instantiator yet, because the new

                    // component has not yet been stored in the runtime's

                    // component storage. So we do this later

                    created_port_info.peer_comp_id = instantiator_ctx.id;

                    if pair.is_open {

                        created_ctx.change_port_peer(sched_ctx, pair.created_handle, Some(instantiator_ctx.id));

                    }

                }

            }

        } else {

            // Peer is a different component

            if pair.is_open {

                // And the port is still open, so we need to notify the peer

                let peer_handle = instantiator_ctx.get_peer_handle(created_port_info.peer_comp_id);

                let peer_info = instantiator_ctx.get_peer(peer_handle);

                created_ctx.change_port_peer(sched_ctx, pair.created_handle, Some(peer_info.id));

                created_component_has_remote_peers = true;

            }

        }

    }

    // Now we store the new component into the runtime's component storage using

    // the reservation.

    let component = create_component(

        &sched_ctx.runtime.protocol, procedure_id, procedure_type_id,

        arguments, port_pairs.len()

    );

    let (created_key, created_runtime_component) = sched_ctx.runtime.finish_create_component(

        reservation, component, created_ctx, false

    );

    let created_ctx = &mut created_runtime_component.ctx;

    let created_component = &mut created_runtime_component.component;

    created_component.on_creation(created_key.downgrade(), sched_ctx);

    // We now pass along the messages that the instantiator component still has

    // that belong to the new component. At the same time we'll take care of

    // setting the correct peer of the instantiator component

    for pair in port_pairs.iter() {

        // Transferring the messages and removing the port from the

        // instantiator component

        let instantiator_port_index = instantiator_ctx.get_port_index(pair.instantiator_handle);

        instantiator_ctx.change_port_peer(sched_ctx, pair.instantiator_handle, None);

        instantiator_ctx.remove_port(pair.instantiator_handle);

            message.data_header.target_port = pair.created_id;

            created_component.adopt_message(created_ctx, message);

        }

        let mut message_index = 0;

        while message_index < inbox_backup.len() {

            let message = &inbox_backup[message_index];

            if message.data_header.target_port == pair.instantiator_id {

                // Transfer the message

                let mut message = inbox_backup.remove(message_index);

                message.data_header.target_port = pair.created_id;

                created_component.adopt_message(created_ctx, message);

            } else {

                // Message does not belong to the port pair that we're

                // transferring to the new component.

                message_index += 1;

            }

        }

        // Here we take care of the case where the instantiator previously owned

        // both ends of the channel, but has transferred one port to the new

        // component (hence creating a channel between the instantiator

        // component and the new component).

        let created_port_info = created_ctx.get_port(pair.created_handle);

        if pair.is_open && created_port_info.peer_comp_id == instantiator_ctx.id {

            // Note: the port we're receiving here belongs to the instantiator

            // and is NOT in the "port_pairs" array.

            let instantiator_port_handle = instantiator_ctx.get_port_handle(created_port_info.peer_port_id);

            let instantiator_port_info = instantiator_ctx.get_port_mut(instantiator_port_handle);

            instantiator_port_info.peer_port_id = created_port_info.self_id;

            instantiator_ctx.change_port_peer(sched_ctx, instantiator_port_handle, Some(created_ctx.id));

        }

    }

    // Finally: if we did move ports around whose peers are different

    // components, then we'll initiate the appropriate protocol to notify them.

    if created_component_has_remote_peers {

        let schedule_entry_id = control.add_schedule_entry(created_ctx.id);

        for pair in &port_pairs {

            let port_info = created_ctx.get_port(pair.created_handle);

            if pair.is_open && port_info.peer_comp_id != instantiator_ctx.id && port_info.peer_comp_id != created_ctx.id {

                // Peer component is not the instantiator, and it is not the

                // new component itself

                let message = control.add_reroute_entry(

                    instantiator_ctx.id, port_info.peer_port_id, port_info.peer_comp_id,

                    pair.instantiator_id, pair.created_id, created_ctx.id,

                    schedule_entry_id

                );

                let peer_handle = created_ctx.get_peer_handle(port_info.peer_comp_id);

                let peer_info = created_ctx.get_peer(peer_handle);

                peer_info.handle.send_message_logged(sched_ctx, message, true);

            }

        }

    } else {

        // We can schedule the component immediately, we do not have to wait

        // for any peers: there are none.

        sched_ctx.runtime.enqueue_work(created_key);

    }

    exec_state.mode = CompMode::NonSync;

    exec_state.mode_component = (ProcedureDefinitionId::new_invalid(), TypeId::new_invalid());

}

pub(crate) fn ports_not_blocked(comp_ctx: &CompCtx, ports: &EncounteredPorts) -> bool {

    for (_port_locations, port_id) in ports {

        let port_handle = comp_ctx.get_port_handle(*port_id);

        let port_info = comp_ctx.get_port(port_handle);

        if port_info.state.is_blocked_due_to_port_change() {

            return false;

        }

    }

    return true;

}

/// Performs the default action of printing the provided error, and then putting

/// the component in the state where it will shut down. Only to be used for

/// builtin components: their error message construction is simpler (and more

/// common) as they don't have any source code.

pub(crate) fn default_handle_error_for_builtin(

    exec_state: &mut CompExecState, sched_ctx: &SchedulerCtx,

    location_and_message: (PortInstruction, String)

) {

    let (_location, message) = location_and_message;

    sched_ctx.error(&message);

    let exit_reason = if exec_state.mode.is_in_sync_block() {

        ExitReason::ErrorInSync

    } else {

        ExitReason::ErrorNonSync

    };

    exec_state.set_as_start_exit(exit_reason);

}

use super::*;

// silly test to make sure that the PDL will never be an issue when doing TCP

// stuff with the actual components

#[test]

fn test_stdlib_file() {

    compile_and_create_component("

    import std.internet as inet;

    comp fake_listener_once(out<inet::TcpConnection> tx) {

        channel cmd_tx -> cmd_rx;

        channel data_tx -> data_rx;

        new fake_socket(cmd_rx, data_tx);

        sync put(tx, inet::TcpConnection{

            tx: cmd_tx,

            rx: data_rx,

        });

    }

    comp fake_socket(in<inet::Cmd> cmds, out<u8[]> tx) {

        auto to_send = {};

        auto shutdown = false;

        while (!shutdown) {

            auto keep_going = true;

            sync {

                while (keep_going) {

                    auto cmd = get(cmds);

                    if (let inet::Cmd::Send(data) = cmd) {

                        to_send = data;

                    } else if (let inet::Cmd::Receive = cmd) {

                        put(tx, to_send);

                    } else if (let inet::Cmd::Finish = cmd) {

                        keep_going = false;

                    } else if (let inet::Cmd::Shutdown = cmd) {

                        keep_going = false;

                        shutdown = true;

                    }

                }

            }

        }

    }

    comp fake_client(inet::TcpConnection conn) {

        sync put(conn.tx, inet::Cmd::Send({1, 3, 3, 7}));

        sync {

            put(conn.tx, inet::Cmd::Receive);

            auto val = get(conn.rx);

            put(conn.tx, inet::Cmd::Finish);

        }

        sync put(conn.tx, inet::Cmd::Shutdown);

    }

    comp constructor() {

        channel conn_tx -> conn_rx;

        new fake_listener_once(conn_tx);

        // Same crap as before:

        channel cmd_tx -> unused_cmd_rx;

        channel unused_data_tx -> data_rx;

        auto connection = inet::TcpConnection{ tx: cmd_tx, rx: data_rx };

        sync {

            connection = get(conn_rx);

        }

        new fake_client(connection);

    }

    ", "constructor", no_args());

}