aboutsummaryrefslogtreecommitdiff
path: root/src/core/socket.c
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/socket.c
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/socket.c')
-rw-r--r--src/core/socket.c5
1 files changed, 0 insertions, 5 deletions
diff --git a/src/core/socket.c b/src/core/socket.c
index dadc9073..0224a812 100644
--- a/src/core/socket.c
+++ b/src/core/socket.c
@@ -571,11 +571,6 @@ nni_sock_create(nni_sock **sp, const nni_proto *proto)
(void) nni_sock_setopt(
s, NNG_OPT_TCP_KEEPALIVE, &on, sizeof(on), NNI_TYPE_BOOL);
- if (s->s_sock_ops.sock_filter != NULL) {
- nni_msgq_set_filter(
- s->s_urq, s->s_sock_ops.sock_filter, s->s_data);
- }
-
*sp = s;
return (rv);
}