summaryrefslogtreecommitdiff
path: root/src/mongo/util/net/message_port.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/util/net/message_port.cpp')
-rw-r--r--src/mongo/util/net/message_port.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/util/net/message_port.cpp b/src/mongo/util/net/message_port.cpp
index d0dc3cef28e..9a5a3ab1462 100644
--- a/src/mongo/util/net/message_port.cpp
+++ b/src/mongo/util/net/message_port.cpp
@@ -64,7 +64,7 @@ namespace mongo {
}
void append( Message& m ) {
- assert( m.header()->len <= 1300 );
+ verify( m.header()->len <= 1300 );
if ( len() + m.header()->len > 1300 )
flush();
@@ -180,10 +180,10 @@ again:
}
int z = (len+1023)&0xfffffc00;
- assert(z>=len);
+ verify(z>=len);
MsgData *md = (MsgData *) malloc(z);
ScopeGuard guard = MakeGuard(free, md);
- assert(md);
+ verify(md);
md->len = len;
char *p = (char *) &md->id;
@@ -234,7 +234,7 @@ again:
<< " response len: " << (unsigned)response.header()->len << '\n'
<< " response op: " << response.operation() << '\n'
<< " remote: " << psock->remoteString() << endl;
- assert(false);
+ verify(false);
response.reset();
}
mmm( log() << "*call() end" << endl; )
@@ -246,7 +246,7 @@ again:
}
void MessagingPort::say(Message& toSend, int responseTo) {
- assert( !toSend.empty() );
+ verify( !toSend.empty() );
mmm( log() << "* say() thr:" << GetCurrentThreadId() << endl; )
toSend.header()->id = nextMessageId();
toSend.header()->responseTo = responseTo;