{
struct MessageQueue *head;
- GNUNET_break (NULL == socket->read_handle);
- GNUNET_break (NULL == socket->write_handle);
+ if (NULL != socket->read_handle)
+ {
+ LOG (GNUNET_ERROR_TYPE_WARNING,
+ "Closing STREAM socket when a read handle is pending\n");
+ }
+ if (NULL != socket->write_handle)
+ {
+ LOG (GNUNET_ERROR_TYPE_WARNING,
+ "Closing STREAM socket when a write handle is pending\n");
+ }
if (socket->read_task_id != GNUNET_SCHEDULER_NO_TASK)
{
case PEER1_WRITE:
GNUNET_assert (0);
case PEER1_WRITE_SHUTDOWN:
+ GNUNET_assert (cls == &peer1);
+ GNUNET_assert (SHUT_WR == operation);
peer1.test_ok = GNUNET_YES;
/* Peer2 should read with error */
peer2.bytes_read = 0;