created_port_info.peer_comp_id = reservation.id();

            },

            None => {

                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));

                }

            }

        }

    }

    // Store component in runtime storage and retrieve component fields in their

    // name memory location

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

        reservation, component_instance, 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);

    // Transfer messages and link instantiator to created component

    for pair in port_pairs.iter() {

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

        transfer_messages(inbox_main, inbox_backup, pair, instantiator_ctx, created_ctx, created_component.as_mut());

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

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

            // Set up channel between instantiator component port, and its peer,

            // which is owned by the new component

            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));

        }

    }

    // By definition we did not have any remote peers for the transferred ports,

    // so we can schedule the new component immediately

    sched_ctx.runtime.enqueue_work(created_key);

}

/// Puts the component in an execution state where the specified component will

/// end up being created. The component goes through state changes (driven by

/// incoming control messages) to make sure that all of the ports that are going

/// to be transferred are not in a blocked state. Once finished the component

/// returns to the `NonSync` mode.

pub(crate) fn default_start_create_component(

    exec_state: &mut CompExecState, sched_ctx: &SchedulerCtx, comp_ctx: &mut CompCtx,

            }

        }

    }

    // 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

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

        transfer_messages(inbox_main, inbox_backup, pair, instantiator_ctx, created_ctx, created_component.as_mut());

        // 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

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,

        });

    }

        auto to_send = {};

        auto shutdown = false;

        while (!shutdown) {

            auto keep_going = true;

            sync {

                while (keep_going) {

                    auto cmd = get(cmds);

                        to_send = data;

                        keep_going = false;

                        put(tx, to_send);

                        keep_going = false;

                        keep_going = false;

                        shutdown = true;

                    }

                }

            }

        }

    }

    comp fake_client(inet::TcpConnection conn) {

        sync {

            auto val = get(conn.rx);

            while (val[0] != 1 || val[1] != 3 || val[2] != 3 || val[3] != 7) {

                print(\"this is going very wrong\");

            }

        }

    }

    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());

}

        while (i < num_values) {

            sync {

                auto a = get(generator);

            }

            i += 1;

        }

    }

    comp constructor() {

        channel tx -> rx;

        auto num_values = 25;

        new random_u32(tx, 1, 100, num_values);

        new random_taker(rx, num_values);

    }

    ").expect("compilation");

    let rt = Runtime::new(1, LOG_LEVEL, pd).unwrap();

    create_component(&rt, "", "constructor", no_args());

}

#[test]

fn test_tcp_socket_http_request() {

    let _pd = ProtocolDescription::parse(b"

    import std.internet::*;

        print(\"*** TCPSocket: Sending request\");

        sync {

        }

        print(\"*** TCPSocket: Receiving response\");

        auto buffer = {};

        auto done_receiving = false;

        sync while (!done_receiving) {

            auto data = get(data_rx);

            buffer @= data;

            // Completely crap detection of end-of-document. But here we go, we

            // try to detect the trailing </html>. Proper way would be to parse

            // for 'content-length' or 'content-encoding'

            s32 index = 0;

            s32 partial_length = cast(length(data) - 7);

            while (index < partial_length) {

                // No string conversion yet, so check byte buffer one byte at

                // a time.

                auto c1 = data[index];

                if (c1 == cast('<')) {

                    auto c2 = data[index + 1];

                    auto c3 = data[index + 2];

                    auto c4 = data[index + 3];

                    auto c5 = data[index + 4];

                    auto c6 = data[index + 5];

                    auto c7 = data[index + 6];

                    if ( // i.e. if (data[index..] == '</html>'

                        c2 == cast('/') && c3 == cast('h') && c4 == cast('t') &&

                        c5 == cast('m') && c6 == cast('l') && c7 == cast('>')

                    ) {

                        print(\"*** TCPSocket: Detected </html>\");

                        done_receiving = true;

                    }

                }

                index += 1;

            }

        }

        print(\"*** TCPSocket: Requesting shutdown\");

        sync {

        }

    }

    comp main() {

        channel cmd_tx -> cmd_rx;

        channel data_tx -> data_rx;

        new tcp_client({142, 250, 179, 163}, 80, cmd_rx, data_tx); // port 80 of google

        new requester(cmd_tx, data_rx);

    }

    ").expect("compilation");

    // This test is disabled because it performs a HTTP request to google.

    // create_component(&rt, "", "main", no_args());

}

#[test]

fn test_sending_receiving_union() {

    let pd = ProtocolDescription::parse(b"

    union Cmd {

        Set(u8[]),

        Get,

        Shutdown,

    }

    comp database(in<Cmd> rx, out<u8[]> tx) {

        auto stored = {};

        auto done = false;

        while (!done) {

            sync {

                auto command = get(rx);

                if (let Cmd::Set(bytes) = command) {

                    print(\"database: storing value\");

                    stored = bytes;

                } else if (let Cmd::Get = command) {

                    print(\"database: returning value\");

                    put(tx, stored);

#module std.internet

union ClientCmd {

    Send(u8[]),

    Receive,

    Finish,

    Shutdown,

}

    #builtin

}

union ListenerCmd {

    Accept,

    Shutdown,

}

struct TcpConnection {

    in<u8[]> rx,

}

/* comp tcp_listener(u8[] ip, u16 port, in<ListenerCmd> cmds, out<TcpConnection> rx) {

    #builtin

} */