Files
@ 28df9835906f
Branch filter:
Location: CSY/reowolf/examples/bench_21/main.c - annotation
28df9835906f
2.6 KiB
text/x-csrc
Reimplement namespaced identifier to support polymorphic args
This is somewhat of a temporary hack, as a namespaced identifier should
not really refer to types or polymorphic arguments. But we need a
tokenizer and a prepass to properly distinguish identifiers from types.
So it works, but error messages may be cryptic.
This is somewhat of a temporary hack, as a namespaced identifier should
not really refer to types or polymorphic arguments. But we need a
tokenizer and a prepass to properly distinguish identifiers from types.
So it works, but error messages may be cryptic.
ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b ef80a75d0e6b | #include <time.h>
#include "../../reowolf.h"
#include "../utility.c"
int main(int argc, char** argv) {
// one of two processes: {leader, follower}
// where a set of `par_msgs` messages are sent leader->follower after
// looping follower->leader->follower `msg_loops` times.
int i, j, cid, msg_loops, par_msgs;
char is_leader;
is_leader = argv[1][0];
msg_loops = atoi(argv[2]);
par_msgs = atoi(argv[3]);
// argv[4..8] encodes peer IP
printf("is_leader %c, msg_loops %d, par_msgs %d\n", is_leader, msg_loops, par_msgs);
cid = is_leader=='y'; // cid := { leader:1, follower:0 }
unsigned char pdl[] = "";
Arc_ProtocolDescription * pd = protocol_description_parse(pdl, sizeof(pdl)-1);
Connector * c = connector_new_with_id(pd, cid);
PortId native_ports[par_msgs];
FfiSocketAddr peer_addr = {
{
atoi(argv[4]),
atoi(argv[5]),
atoi(argv[6]),
atoi(argv[7])
}, 0/*dummy value*/};
int port = 7000;
// for each parallel message
for(i=0; i<par_msgs; i++) {
if(is_leader == 'y') {
peer_addr.port = port++;
connector_add_net_port(
c, &native_ports[i], peer_addr, Polarity_Putter, EndpointPolarity_Active);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
}
for(j=0; j<msg_loops; j++) {
PortId loop_getter, loop_putter;
// create {putter, getter} port pair
connector_add_net_port(
c, &loop_getter,
(FfiSocketAddr) {{0,0,0,0}, port++},
Polarity_Getter, EndpointPolarity_Passive);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
peer_addr.port = port++;
connector_add_net_port(
c, &loop_putter, peer_addr, Polarity_Putter, EndpointPolarity_Active);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
connector_add_component(c, "forward", 7,
(PortId[]){loop_getter, loop_putter}, 2);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
}
if(is_leader != 'y') {
connector_add_net_port(
c, &native_ports[i],
(FfiSocketAddr) {{0,0,0,0}, port++},
Polarity_Getter, EndpointPolarity_Passive);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
}
}
printf("Added all ports!\n");
connector_connect(c, -1);
printf("Error str `%s`\n", reowolf_error_peek(NULL));
printf("Connect OK!\n");
clock_t begin = clock();
char msg[] = "Hello, world!";
for(i=0; i<250; i++) {
if(is_leader == 'y') {
for(j=0; j<par_msgs; j++) {
connector_put_bytes(c, native_ports[j], msg, sizeof(msg)-1);
}
} else {
for(j=0; j<par_msgs; j++) {
connector_get(c, native_ports[j]);
}
}
connector_sync(c, -1);
}
clock_t end = clock();
double time_spent = (double)(end - begin) / CLOCKS_PER_SEC;
printf("Time taken: %f\n", time_spent);
return 0;
}
|