// // Copyright 2017 Garrett D'Amore // // This software is supplied under the terms of the MIT License, a // copy of which should be located in the distribution where this // file was obtained (LICENSE.txt). A copy of the license may also be // found online at https://opensource.org/licenses/MIT. // #include #include "core/nng_impl.h" // Protocol related stuff - generically. // The list of protocols is hardwired. This is reasonably unlikely to // change, as adding new protocols is not something intended to be done // outside of the core. extern nni_proto nni_bus_proto; extern nni_proto nni_pair_proto; extern nni_proto nni_rep_proto; extern nni_proto nni_req_proto; extern nni_proto nni_pub_proto; extern nni_proto nni_sub_proto; extern nni_proto nni_push_proto; extern nni_proto nni_pull_proto; extern nni_proto nni_surveyor_proto; extern nni_proto nni_respondent_proto; static nni_proto *protocols[] = { &nni_bus_proto, &nni_pair_proto, &nni_rep_proto, &nni_req_proto, &nni_pub_proto, &nni_sub_proto, &nni_push_proto, &nni_pull_proto, &nni_surveyor_proto, &nni_respondent_proto, NULL }; nni_proto * nni_proto_find(uint16_t num) { int i; nni_proto *p; for (i = 0; (p = protocols[i]) != NULL; i++) { if (p->proto_self == num) { break; } } return (p); } const char * nni_proto_name(uint16_t num) { nni_proto *p; if ((p = nni_proto_find(num)) == NULL) { return (NULL); } return (p->proto_name); } uint16_t nni_proto_number(const char *name) { nni_proto *p; int i; for (i = 0; (p = protocols[i]) != NULL; i++) { if (strcmp(p->proto_name, name) == 0) { return (p->proto_self); } } return (NNG_PROTO_NONE); } uint16_t nni_proto_peer(uint16_t num) { nni_proto *p; if ((p = nni_proto_find(num)) == NULL) { return (NNG_PROTO_NONE); } return (p->proto_peer); }