diff options
| author | Garrett D'Amore <garrett@damore.org> | 2024-12-11 07:46:27 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2024-12-11 07:49:53 -0800 |
| commit | 90308d8a3651d163c08d4fae3cfda90c5292e812 (patch) | |
| tree | 96688854eba01681b58a411fcd2ae6e4d8bf4d77 /src/sp | |
| parent | 7155676c0861b9f85e7a89a66dc1479085b8539b (diff) | |
| download | nng-90308d8a3651d163c08d4fae3cfda90c5292e812.tar.gz nng-90308d8a3651d163c08d4fae3cfda90c5292e812.tar.bz2 nng-90308d8a3651d163c08d4fae3cfda90c5292e812.zip | |
transports: all transports implement stop functions
Add test cases ensuring that the transports implement all
required functionality (entry points are not null).
Diffstat (limited to 'src/sp')
| -rw-r--r-- | src/sp/transport.c | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/src/sp/transport.c b/src/sp/transport.c index 919a0f37..178cc748 100644 --- a/src/sp/transport.c +++ b/src/sp/transport.c @@ -21,6 +21,37 @@ static nni_rwlock sp_tran_lk = NNI_RWLOCK_INITIALIZER; void nni_sp_tran_register(nni_sp_tran *tran) { +#ifndef NDEBUG + NNI_ASSERT(tran->tran_pipe->p_init != NULL); + NNI_ASSERT(tran->tran_pipe->p_fini != NULL); + NNI_ASSERT(tran->tran_pipe->p_stop != NULL); + NNI_ASSERT(tran->tran_pipe->p_close != NULL); + NNI_ASSERT(tran->tran_pipe->p_send != NULL); + NNI_ASSERT(tran->tran_pipe->p_recv != NULL); + NNI_ASSERT(tran->tran_pipe->p_peer != NULL); + + if (tran->tran_dialer != NULL) { + NNI_ASSERT(tran->tran_dialer->d_init != NULL); + NNI_ASSERT(tran->tran_dialer->d_fini != NULL); + NNI_ASSERT(tran->tran_dialer->d_close != NULL); + NNI_ASSERT(tran->tran_dialer->d_stop != NULL); + NNI_ASSERT(tran->tran_dialer->d_connect != NULL); + NNI_ASSERT(tran->tran_dialer->d_getopt != NULL); + NNI_ASSERT(tran->tran_dialer->d_setopt != NULL); + } + + if (tran->tran_listener != NULL) { + NNI_ASSERT(tran->tran_listener->l_init != NULL); + NNI_ASSERT(tran->tran_listener->l_fini != NULL); + NNI_ASSERT(tran->tran_listener->l_bind != NULL); + NNI_ASSERT(tran->tran_listener->l_accept != NULL); + NNI_ASSERT(tran->tran_listener->l_close != NULL); + NNI_ASSERT(tran->tran_listener->l_stop != NULL); + NNI_ASSERT(tran->tran_listener->l_getopt != NULL); + NNI_ASSERT(tran->tran_listener->l_setopt != NULL); + } +#endif + nni_rwlock_wrlock(&sp_tran_lk); if (!nni_list_node_active(&tran->tran_link)) { tran->tran_init(); |