diff options
| author | Garrett D'Amore <garrett@damore.org> | 2019-03-13 00:50:48 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2019-03-13 00:50:48 -0700 |
| commit | f723fa9655e1e7fadc1a15b94b66de674ab9fe17 (patch) | |
| tree | 8788e128e723bbd936bee0b03287a49df789a116 /src/core/protocol.h | |
| parent | f65f819f7fb3bbe9e24bc73342b4f335f5034fe0 (diff) | |
| download | nng-f723fa9655e1e7fadc1a15b94b66de674ab9fe17.tar.gz nng-f723fa9655e1e7fadc1a15b94b66de674ab9fe17.tar.bz2 nng-f723fa9655e1e7fadc1a15b94b66de674ab9fe17.zip | |
fixes #815 Eliminate socket filters on message queues
This also eliminates the enforcement of NNG_OPT_RECVMAXSZ for inproc,
which never really made much sense. This helps inproc go faster.
While here, also clean up the entry point for protocols to support
a drain option, since we don't use that anywhere.
Diffstat (limited to 'src/core/protocol.h')
| -rw-r--r-- | src/core/protocol.h | 14 |
1 files changed, 1 insertions, 13 deletions
diff --git a/src/core/protocol.h b/src/core/protocol.h index f164ee45..005e34fd 100644 --- a/src/core/protocol.h +++ b/src/core/protocol.h @@ -1,5 +1,5 @@ // -// Copyright 2018 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2019 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // // This software is supplied under the terms of the MIT License, a @@ -105,18 +105,6 @@ struct nni_proto_sock_ops { // Receive a message. void (*sock_recv)(void *, nni_aio *); - // Message filter. This may be NULL, but if it isn't, then - // messages coming into the system are routed here just before being - // delivered to the application. To drop the message, the protocol - // should return NULL, otherwise the message (possibly modified). - nni_msg *(*sock_filter)(void *, nni_msg *); - - // Socket draining is intended to permit protocols to "drain" - // before exiting. For protocols where draining makes no - // sense, this may be NULL. (Example: REQ and SURVEYOR should - // not drain, because they cannot receive a reply!) - void (*sock_drain)(void *, nni_aio *); - // Options. Must not be NULL. Final entry should have NULL name. nni_option *sock_options; }; |
