Method recvMsg

SRC/actor/channel/TCP_SocketSSL.cpp:547–593

void Recv(Message &): Method to receive a message, also sets other_Addr.addr_in to that of sender

// void Recv(Message &):
// 	Method to receive a message, also sets other_Addr.addr_in to that of sender
int 
TCP_SocketSSL::recvMsg(int dbTag, int commitTag,
    Message &msg, ChannelAddress *theAddress)
{	
    // first check address is the only address a TCP_socket can send to
    SocketAddress *theSocketAddress = 0;
    if (theAddress != 0) {
        if (theAddress->getType() == SOCKET_TYPE) 
            theSocketAddress = (SocketAddress *)theAddress;
        else {
            opserr << "TCP_SocketSSL::recvMsg() - a TCP_SocketSSL ";
            opserr << "can only communicate with a TCP_SocketSSL";
            opserr << " address given is not of type SocketAddress\n"; 
            return -1;	    
        }		    
        if (memcmp((char *) &other_Addr.addr_in, (char *) &theSocketAddress->address.addr_in, 
            theSocketAddress->addrLength) != 0) {

                opserr << "TCP_SocketSSL::recvMsg() - a TCP_SocketSSL ";
                opserr << "can only communicate with one other TCP_SocketSSL\n"; 
                return -1;
        }
    }

    // if o.k. get a pointer to the data in the message and 
    // place the incoming data there
    int nleft, nread;
    char *gMsg;
    gMsg = msg.data;
    nleft = msg.length;

    while (nleft > 0) {
        nread = SSL_read(ssl, gMsg, nleft);
        if (nread < 0) {
            opserr << "TCP_SocketSSL::recvMsg() - could not read data\n";
            SSL_shutdown(ssl);
            SSL_free(ssl);
            SSL_CTX_free(ctx);
            cleanup_sockets();
            return -2;
        }
        nleft -= nread;
        gMsg  += nread;
    }

    return 0;
}


// void Recv(Message &):