Brandon Fictorie / Mbed 2 deprecated BF_Websocket

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   mbed

NetServices/api/TCPSocket.cpp@0:8cdad1c73e8e, 2012-03-25 (annotated)

Committer:
bfictorie
Date:
Sun Mar 25 17:26:30 2012 +0000
Revision:
0:8cdad1c73e8e

        

        
Who changed what in which revision?

        

            
                
UserRevisionLine numberNew contents of line

            
            


bfictorie

0:8cdad1c73e8e


     1







bfictorie

0:8cdad1c73e8e


     2

/*





bfictorie

0:8cdad1c73e8e


     3

Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)





bfictorie

0:8cdad1c73e8e


     4

 





bfictorie

0:8cdad1c73e8e


     5

Permission is hereby granted, free of charge, to any person obtaining a copy





bfictorie

0:8cdad1c73e8e


     6

of this software and associated documentation files (the "Software"), to deal





bfictorie

0:8cdad1c73e8e


     7

in the Software without restriction, including without limitation the rights





bfictorie

0:8cdad1c73e8e


     8

to use, copy, modify, merge, publish, distribute, sublicense, and/or sell





bfictorie

0:8cdad1c73e8e


     9

copies of the Software, and to permit persons to whom the Software is





bfictorie

0:8cdad1c73e8e


    10

furnished to do so, subject to the following conditions:





bfictorie

0:8cdad1c73e8e


    11

 





bfictorie

0:8cdad1c73e8e


    12

The above copyright notice and this permission notice shall be included in





bfictorie

0:8cdad1c73e8e


    13

all copies or substantial portions of the Software.





bfictorie

0:8cdad1c73e8e


    14

 





bfictorie

0:8cdad1c73e8e


    15

THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR





bfictorie

0:8cdad1c73e8e


    16

IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,





bfictorie

0:8cdad1c73e8e


    17

FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE





bfictorie

0:8cdad1c73e8e


    18

AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER





bfictorie

0:8cdad1c73e8e


    19

LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,





bfictorie

0:8cdad1c73e8e


    20

OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN





bfictorie

0:8cdad1c73e8e


    21

THE SOFTWARE.





bfictorie

0:8cdad1c73e8e


    22

*/





bfictorie

0:8cdad1c73e8e


    23







bfictorie

0:8cdad1c73e8e


    24

#include "TCPSocket.h"





bfictorie

0:8cdad1c73e8e


    25

#include "if/net/nettcpsocket.h"





bfictorie

0:8cdad1c73e8e


    26







bfictorie

0:8cdad1c73e8e


    27

TCPSocket::TCPSocket() : m_pNetTcpSocket(NULL), m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL)





bfictorie

0:8cdad1c73e8e


    28

{





bfictorie

0:8cdad1c73e8e


    29







bfictorie

0:8cdad1c73e8e


    30

}





bfictorie

0:8cdad1c73e8e


    31







bfictorie

0:8cdad1c73e8e


    32

TCPSocket::TCPSocket(NetTcpSocket* pNetTcpSocket) : m_pNetTcpSocket(pNetTcpSocket), m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL)





bfictorie

0:8cdad1c73e8e


    33

{





bfictorie

0:8cdad1c73e8e


    34

  m_pNetTcpSocket->setOnEvent(this, &TCPSocket::onNetTcpSocketEvent);





bfictorie

0:8cdad1c73e8e


    35

}





bfictorie

0:8cdad1c73e8e


    36







bfictorie

0:8cdad1c73e8e


    37

TCPSocket::~TCPSocket() //close()





bfictorie

0:8cdad1c73e8e


    38

{





bfictorie

0:8cdad1c73e8e


    39

  close();





bfictorie

0:8cdad1c73e8e


    40

}





bfictorie

0:8cdad1c73e8e


    41

  





bfictorie

0:8cdad1c73e8e


    42

TCPSocketErr TCPSocket::bind(const Host& me)





bfictorie

0:8cdad1c73e8e


    43

{





bfictorie

0:8cdad1c73e8e


    44

  TCPSocketErr tcpSocketErr = checkInst();





bfictorie

0:8cdad1c73e8e


    45

  if(tcpSocketErr)





bfictorie

0:8cdad1c73e8e


    46

    return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


    47

  return (TCPSocketErr) m_pNetTcpSocket->bind(me); 





bfictorie

0:8cdad1c73e8e


    48

}





bfictorie

0:8cdad1c73e8e


    49







bfictorie

0:8cdad1c73e8e


    50

TCPSocketErr TCPSocket::listen()





bfictorie

0:8cdad1c73e8e


    51

{





bfictorie

0:8cdad1c73e8e


    52

  TCPSocketErr tcpSocketErr = checkInst();





bfictorie

0:8cdad1c73e8e


    53

  if(tcpSocketErr)





bfictorie

0:8cdad1c73e8e


    54

    return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


    55

  return (TCPSocketErr) m_pNetTcpSocket->listen(); 





bfictorie

0:8cdad1c73e8e


    56

}





bfictorie

0:8cdad1c73e8e


    57







bfictorie

0:8cdad1c73e8e


    58

TCPSocketErr TCPSocket::connect(const Host& host)





bfictorie

0:8cdad1c73e8e


    59

{





bfictorie

0:8cdad1c73e8e


    60

  TCPSocketErr tcpSocketErr = checkInst();





bfictorie

0:8cdad1c73e8e


    61

  if(tcpSocketErr)





bfictorie

0:8cdad1c73e8e


    62

    return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


    63

  return (TCPSocketErr) m_pNetTcpSocket->connect(host); 





bfictorie

0:8cdad1c73e8e


    64

}





bfictorie

0:8cdad1c73e8e


    65







bfictorie

0:8cdad1c73e8e


    66

TCPSocketErr TCPSocket::accept(Host* pClient, TCPSocket** ppNewTCPSocket)





bfictorie

0:8cdad1c73e8e


    67

{





bfictorie

0:8cdad1c73e8e


    68

  TCPSocketErr tcpSocketErr = checkInst();





bfictorie

0:8cdad1c73e8e


    69

  if(tcpSocketErr)





bfictorie

0:8cdad1c73e8e


    70

    return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


    71

  NetTcpSocket* pNewNetTcpSocket;





bfictorie

0:8cdad1c73e8e


    72

  tcpSocketErr = (TCPSocketErr) m_pNetTcpSocket->accept(pClient, &pNewNetTcpSocket);





bfictorie

0:8cdad1c73e8e


    73

  if(pNewNetTcpSocket)





bfictorie

0:8cdad1c73e8e


    74

    *ppNewTCPSocket = new TCPSocket(pNewNetTcpSocket);





bfictorie

0:8cdad1c73e8e


    75

  return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


    76

}





bfictorie

0:8cdad1c73e8e


    77

  





bfictorie

0:8cdad1c73e8e


    78

int /*if < 0 : TCPSocketErr*/ TCPSocket::send(const char* buf, int len)





bfictorie

0:8cdad1c73e8e


    79

{





bfictorie

0:8cdad1c73e8e


    80

  TCPSocketErr tcpSocketErr = checkInst();





bfictorie

0:8cdad1c73e8e


    81

  if(tcpSocketErr)





bfictorie

0:8cdad1c73e8e


    82

    return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


    83

  return m_pNetTcpSocket->send(buf, len);  





bfictorie

0:8cdad1c73e8e


    84

}





bfictorie

0:8cdad1c73e8e


    85







bfictorie

0:8cdad1c73e8e


    86

int /*if < 0 : TCPSocketErr*/ TCPSocket::recv(char* buf, int len)





bfictorie

0:8cdad1c73e8e


    87

{





bfictorie

0:8cdad1c73e8e


    88

  TCPSocketErr tcpSocketErr = checkInst();





bfictorie

0:8cdad1c73e8e


    89

  if(tcpSocketErr)





bfictorie

0:8cdad1c73e8e


    90

    return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


    91

  return m_pNetTcpSocket->recv(buf, len);





bfictorie

0:8cdad1c73e8e


    92

}





bfictorie

0:8cdad1c73e8e


    93







bfictorie

0:8cdad1c73e8e


    94

TCPSocketErr TCPSocket::close()





bfictorie

0:8cdad1c73e8e


    95

{





bfictorie

0:8cdad1c73e8e


    96

  if(!m_pNetTcpSocket)





bfictorie

0:8cdad1c73e8e


    97

    return TCPSOCKET_SETUP;





bfictorie

0:8cdad1c73e8e


    98

  m_pNetTcpSocket->resetOnEvent();





bfictorie

0:8cdad1c73e8e


    99

  TCPSocketErr tcpSocketErr = (TCPSocketErr) m_pNetTcpSocket->close(); //Close (can already be closed)





bfictorie

0:8cdad1c73e8e


   100

  Net::releaseTcpSocket(m_pNetTcpSocket); //And release it so it can be freed when properly removed





bfictorie

0:8cdad1c73e8e


   101

  m_pNetTcpSocket = NULL;





bfictorie

0:8cdad1c73e8e


   102

  return tcpSocketErr;





bfictorie

0:8cdad1c73e8e


   103

}





bfictorie

0:8cdad1c73e8e


   104







bfictorie

0:8cdad1c73e8e


   105

//Callbacks





bfictorie

0:8cdad1c73e8e


   106

void TCPSocket::setOnEvent( void (*pMethod)(TCPSocketEvent) )





bfictorie

0:8cdad1c73e8e


   107

{





bfictorie

0:8cdad1c73e8e


   108

  m_pCb = pMethod;





bfictorie

0:8cdad1c73e8e


   109

}





bfictorie

0:8cdad1c73e8e


   110







bfictorie

0:8cdad1c73e8e


   111

#if 0 //For info only





bfictorie

0:8cdad1c73e8e


   112

template<class T> 





bfictorie

0:8cdad1c73e8e


   113

void TCPSocket::setOnEvent( T* pItem, void (T::*pMethod)(TCPSocketEvent) )





bfictorie

0:8cdad1c73e8e


   114

{





bfictorie

0:8cdad1c73e8e


   115

  m_pCbItem = (CDummy*) pItem;





bfictorie

0:8cdad1c73e8e


   116

  m_pCbMeth = (void (CDummy::*)(TCPSocketEvent)) pMethod;





bfictorie

0:8cdad1c73e8e


   117

}





bfictorie

0:8cdad1c73e8e


   118

#endif





bfictorie

0:8cdad1c73e8e


   119

  





bfictorie

0:8cdad1c73e8e


   120

void TCPSocket::resetOnEvent() //Disable callback





bfictorie

0:8cdad1c73e8e


   121

{





bfictorie

0:8cdad1c73e8e


   122

  m_pCb = NULL;





bfictorie

0:8cdad1c73e8e


   123

  m_pCbItem = NULL;





bfictorie

0:8cdad1c73e8e


   124

  m_pCbMeth = NULL;





bfictorie

0:8cdad1c73e8e


   125

}





bfictorie

0:8cdad1c73e8e


   126







bfictorie

0:8cdad1c73e8e


   127

void TCPSocket::onNetTcpSocketEvent(NetTcpSocketEvent e)





bfictorie

0:8cdad1c73e8e


   128

{





bfictorie

0:8cdad1c73e8e


   129

  if(m_pCbItem && m_pCbMeth)





bfictorie

0:8cdad1c73e8e


   130

    (m_pCbItem->*m_pCbMeth)((TCPSocketEvent) e);





bfictorie

0:8cdad1c73e8e


   131

  else if(m_pCb)





bfictorie

0:8cdad1c73e8e


   132

    m_pCb((TCPSocketEvent) e);





bfictorie

0:8cdad1c73e8e


   133

}





bfictorie

0:8cdad1c73e8e


   134







bfictorie

0:8cdad1c73e8e


   135

TCPSocketErr TCPSocket::checkInst()





bfictorie

0:8cdad1c73e8e


   136

{





bfictorie

0:8cdad1c73e8e


   137

  if(!m_pNetTcpSocket)





bfictorie

0:8cdad1c73e8e


   138

  {





bfictorie

0:8cdad1c73e8e


   139

    m_pNetTcpSocket = Net::tcpSocket();





bfictorie

0:8cdad1c73e8e


   140

    if(!m_pNetTcpSocket)





bfictorie

0:8cdad1c73e8e


   141

    {





bfictorie

0:8cdad1c73e8e


   142

      return TCPSOCKET_IF; //Interface did not return a socket (usually because a default interface does not exist)





bfictorie

0:8cdad1c73e8e


   143

    }





bfictorie

0:8cdad1c73e8e


   144

    m_pNetTcpSocket->setOnEvent(this, &TCPSocket::onNetTcpSocketEvent);





bfictorie

0:8cdad1c73e8e


   145

  }





bfictorie

0:8cdad1c73e8e


   146

  return TCPSOCKET_OK;





bfictorie

0:8cdad1c73e8e


   147

}