aboutsummaryrefslogtreecommitdiff
path: root/src/core/protocol.h
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2019-03-13 00:50:48 -0700
committerGarrett D'Amore <garrett@damore.org>2019-03-13 00:50:48 -0700
commitf723fa9655e1e7fadc1a15b94b66de674ab9fe17 (patch)
tree8788e128e723bbd936bee0b03287a49df789a116 /src/core/protocol.h
parentf65f819f7fb3bbe9e24bc73342b4f335f5034fe0 (diff)
downloadnng-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.h14
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;
};