CSY/reowolf Changeset - 63f3efc9c886 · Centrum Wiskunde & Informatica (CWI)

Changeset - 63f3efc9c886

Parent rev.

Child rev.

[Not reviewed]

0 8 1

Christopher Esterhuyse - 5 years ago 2020-06-26 09:26:02
christopher.esterhuyse@gmail.com

more logging, tests and comments. re-implemented checking for consistency for natives (eagerly) and proto components (after run_to_blocker). deduplicated each connector's failure requests toward the sink

2 files changed:

examples/6_amy_log.txt

examples/6_atomic/amy.c

Changeset was too big and was cut off... Show full diff anyway

0 comments (0 inline, 0 general)

examples/6_amy_log.txt

➞

Show inline comments

@@ new file 100644 @@
 CID(3382080479): Created with connector_id 3382080479
 CID(3382080479): Added port pair (out->in) ptID(3382080479'0) -> ptID(3382080479'1)
 CID(3382080479): ~~~ CONNECT called timeout None
 CID(3382080479): Successfully connected 0 endpoints
 CID(3382080479): beginning neighborhood construction
 CID(3382080479): Edge case of no neighbors! No parent an no children!
 CID(3382080479): Successfully created neighborhood Neighborhood { parent: None, children: {} }
 CID(3382080479): Beginning session optimization
 CID(3382080479): Gathered all children's maps. ConnectorId set is... []
 CID(3382080479): Inserting my own info. Unoptimized subtree map is {3382080479: SessionInfo { serde_proto_description: SerdeProtocolDescription((A big honkin' protocol description)), port_info: PortInfo { polarities: {ptID(3382080479'1): Getter, ptID(3382080479'0): Putter}, peers: {ptID(3382080479'0): ptID(3382080479'1), ptID(3382080479'1): ptID(3382080479'0)}, routes: {ptID(3382080479'0): LocalComponent(Native), ptID(3382080479'1): LocalComponent(Native)} }, proto_components: {} }}
 CID(3382080479): I am the leader! I will optimize this session
 CID(3382080479): Session map optimize START
 CID(3382080479): Session map optimize END
 CID(3382080479): Optimized info map is {3382080479: SessionInfo { serde_proto_description: SerdeProtocolDescription((A big honkin' protocol description)), port_info: PortInfo { polarities: {ptID(3382080479'1): Getter, ptID(3382080479'0): Putter}, peers: {ptID(3382080479'0): ptID(3382080479'1), ptID(3382080479'1): ptID(3382080479'0)}, routes: {ptID(3382080479'0): LocalComponent(Native), ptID(3382080479'1): LocalComponent(Native)} }, proto_components: {} }}. Sending to children Iter([])
 CID(3382080479): All session info dumped!: {
     3382080479: SessionInfo {
         serde_proto_description: SerdeProtocolDescription(
             (A big honkin' protocol description),
         ),
         port_info: PortInfo {
             polarities: {
                 ptID(3382080479'1): Getter,
                 ptID(3382080479'0): Putter,
             },
             peers: {
                 ptID(3382080479'0): ptID(3382080479'1),
                 ptID(3382080479'1): ptID(3382080479'0),
             },
             routes: {
                 ptID(3382080479'0): LocalComponent(
                     Native,
                 ),
                 ptID(3382080479'1): LocalComponent(
                     Native,
                 ),
             },
         },
         proto_components: {},
     },
+}
 CID(3382080479): Session optimizations applied
 CID(3382080479): connect() finished. setup phase complete
 CID(3382080479): ~~~ SYNC called with timeout Some(5s); starting round 0
 CID(3382080479): Nonsync running 0 proto components...
 CID(3382080479): All 0 proto components are now done with Nonsync phase
 CID(3382080479): Solution storage initialized
 CID(3382080479): Translating 1 native batches into branches...
 CID(3382080479): Native branch index=0 contains internal inconsistency wrt. fvID(3382080479'1). Skipping
 CID(3382080479): Native starts with no branches! Failure!
 CID(3382080479): No parent. Deciding on failure
 CID(3382080479): Committing to decision Failure!
 CID(3382080479): Announcing decision CommMsg(CommMsg { round_index: 0, contents: Announce { decision: Failure } }) through child endpoints {}
 CID(3382080479): Connector dropping. Goodbye!

examples/6_atomic/amy.c

➞

Show inline comments

@@ @@ -7,7 +7,9 @@ int main(int argc, char** argv) { @@
 	char * pdl_ptr = buffer_pdl("eg_protocols.pdl");
 	size_t pdl_len = strlen(pdl_ptr);
 	Arc_ProtocolDescription * pd = protocol_description_parse(pdl_ptr, pdl_len);
 	Connector * c = connector_new(pd);
 	char logpath[] = "./6_amy_log.txt";
 	Connector * c = connector_new_logging(pd, logpath, sizeof(logpath)-1);
 	printf("Err %s\n", reowolf_error_peek(NULL));
 	PortId putter, getter;
 	connector_add_port_pair(c, &putter, &getter);
@@ @@ -21,6 +23,7 @@ int main(int argc, char** argv) { @@
 	int err = connector_sync(c, 5000);
 	printf("Error code %d with string `%s`\n", err, reowolf_error_peek(NULL));
 	/*
 	printf("Let's try again, doing both\n");
 	connector_put_bytes(c, putter, "hello", 5);
 	connector_get(c, getter);
@@ @@ -29,6 +32,7 @@ int main(int argc, char** argv) { @@
 	size_t msg_len;
 	const char * msg_ptr = connector_gotten_bytes(c, getter, &msg_len);
 	printf("Got msg `%.*s`\n", msg_len, msg_ptr);
 	*/
 	protocol_description_destroy(pd);
 	connector_destroy(c);

Changeset was too big and was cut off... Show full diff anyway

0 comments (0 inline, 0 general)