Ad van der Weiden / Mbed 2 deprecated myBlueUSB

Test version of BlueUSB stack. Includes SDP and RFCOMM. As Client it allows to connect to my fischertechnik TX Controller. As Server it echo\\\\\\\'s characters to Putty. PIN=1234

Dependencies:   mbed myUSBHost AvailableMemory

Dependents:   mbed_TANK_Kinect myBlueUSB_ros ftusbClass

Socket.cpp@0:81ed8b6e4a8b, 2011-04-04 (annotated)

Committer:
networker
Date:
Mon Apr 04 16:41:03 2011 +0000
Revision:
0:81ed8b6e4a8b
initial revision

Who changed what in which revision?

UserRevisionLine numberNew contents of line
networker 0:81ed8b6e4a8b 1 /*
networker 0:81ed8b6e4a8b 2 Copyright (c) 2010 Peter Barrett
networker 0:81ed8b6e4a8b 3
networker 0:81ed8b6e4a8b 4 Permission is hereby granted, free of charge, to any person obtaining a copy
networker 0:81ed8b6e4a8b 5 of this software and associated documentation files (the "Software"), to deal
networker 0:81ed8b6e4a8b 6 in the Software without restriction, including without limitation the rights
networker 0:81ed8b6e4a8b 7 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
networker 0:81ed8b6e4a8b 8 copies of the Software, and to permit persons to whom the Software is
networker 0:81ed8b6e4a8b 9 furnished to do so, subject to the following conditions:
networker 0:81ed8b6e4a8b 10
networker 0:81ed8b6e4a8b 11 The above copyright notice and this permission notice shall be included in
networker 0:81ed8b6e4a8b 12 all copies or substantial portions of the Software.
networker 0:81ed8b6e4a8b 13
networker 0:81ed8b6e4a8b 14 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
networker 0:81ed8b6e4a8b 15 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
networker 0:81ed8b6e4a8b 16 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
networker 0:81ed8b6e4a8b 17 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
networker 0:81ed8b6e4a8b 18 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
networker 0:81ed8b6e4a8b 19 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
networker 0:81ed8b6e4a8b 20 THE SOFTWARE.
networker 0:81ed8b6e4a8b 21 */
networker 0:81ed8b6e4a8b 22
networker 0:81ed8b6e4a8b 23 #include <stdio.h>
networker 0:81ed8b6e4a8b 24 #include <stdlib.h>
networker 0:81ed8b6e4a8b 25 #include <stdio.h>
networker 0:81ed8b6e4a8b 26 #include <string.h>
networker 0:81ed8b6e4a8b 27
networker 0:81ed8b6e4a8b 28 #include "Utils.h"
networker 0:81ed8b6e4a8b 29 #include "Socket.h"
networker 0:81ed8b6e4a8b 30
networker 0:81ed8b6e4a8b 31 #define MAX_SOCKET_HANDLERS 4
networker 0:81ed8b6e4a8b 32 #define MAX_SOCKETS 16
networker 0:81ed8b6e4a8b 33
networker 0:81ed8b6e4a8b 34 class SocketInternalPad
networker 0:81ed8b6e4a8b 35 {
networker 0:81ed8b6e4a8b 36 public:
networker 0:81ed8b6e4a8b 37 SocketInternal si;
networker 0:81ed8b6e4a8b 38 u8 pad[8];
networker 0:81ed8b6e4a8b 39 };
networker 0:81ed8b6e4a8b 40
networker 0:81ed8b6e4a8b 41 class SocketManager
networker 0:81ed8b6e4a8b 42 {
networker 0:81ed8b6e4a8b 43 SocketHandler* _handlers[MAX_SOCKET_HANDLERS];
networker 0:81ed8b6e4a8b 44 SocketInternalPad _sockets[MAX_SOCKETS];
networker 0:81ed8b6e4a8b 45
networker 0:81ed8b6e4a8b 46 public:
networker 0:81ed8b6e4a8b 47 SocketManager()
networker 0:81ed8b6e4a8b 48 {
networker 0:81ed8b6e4a8b 49 memset(_handlers,0,sizeof(_handlers));
networker 0:81ed8b6e4a8b 50 memset(_sockets,0,sizeof(_sockets));
networker 0:81ed8b6e4a8b 51 }
networker 0:81ed8b6e4a8b 52
networker 0:81ed8b6e4a8b 53 SocketHandler* GetHandler(int type)
networker 0:81ed8b6e4a8b 54 {
networker 0:81ed8b6e4a8b 55 if (type < 1 || type > MAX_SOCKET_HANDLERS)
networker 0:81ed8b6e4a8b 56 return 0;
networker 0:81ed8b6e4a8b 57 return _handlers[type - 1];
networker 0:81ed8b6e4a8b 58 }
networker 0:81ed8b6e4a8b 59
networker 0:81ed8b6e4a8b 60 SocketInternal* GetInternal(int s)
networker 0:81ed8b6e4a8b 61 {
networker 0:81ed8b6e4a8b 62 if (s < 1 || s > MAX_SOCKETS)
networker 0:81ed8b6e4a8b 63 return 0;
networker 0:81ed8b6e4a8b 64 return &_sockets[s - 1].si;
networker 0:81ed8b6e4a8b 65 }
networker 0:81ed8b6e4a8b 66
networker 0:81ed8b6e4a8b 67 int RegisterSocketHandler(int type, SocketHandler* handler)
networker 0:81ed8b6e4a8b 68 {
networker 0:81ed8b6e4a8b 69 if (type < 1 || type > MAX_SOCKET_HANDLERS)
networker 0:81ed8b6e4a8b 70 return ERR_SOCKET_TYPE_NOT_FOUND;
networker 0:81ed8b6e4a8b 71 _handlers[type - 1] = handler;
networker 0:81ed8b6e4a8b 72 return 0;
networker 0:81ed8b6e4a8b 73 }
networker 0:81ed8b6e4a8b 74
networker 0:81ed8b6e4a8b 75 int Open(int type, SocketAddrHdr* addr, SocketCallback callback, void* userData)
networker 0:81ed8b6e4a8b 76 {
networker 0:81ed8b6e4a8b 77 SocketHandler* h = GetHandler(type);
networker 0:81ed8b6e4a8b 78 if (!h)
networker 0:81ed8b6e4a8b 79 return ERR_SOCKET_TYPE_NOT_FOUND;
networker 0:81ed8b6e4a8b 80
networker 0:81ed8b6e4a8b 81 for (int i = 0; i < MAX_SOCKETS; i++)
networker 0:81ed8b6e4a8b 82 {
networker 0:81ed8b6e4a8b 83 SocketInternal* si = (SocketInternal*)(_sockets+i);
networker 0:81ed8b6e4a8b 84 if (si->ID == 0)
networker 0:81ed8b6e4a8b 85 {
networker 0:81ed8b6e4a8b 86 si->ID = i+1;
networker 0:81ed8b6e4a8b 87 si->Type = type;
networker 0:81ed8b6e4a8b 88 si->Callback = callback;
networker 0:81ed8b6e4a8b 89 si->userData = userData;
networker 0:81ed8b6e4a8b 90 printf("Opening socket %d for type %d, invoking 'Open' on %p (=%s)\n", si->ID, type, h, h->Name());
networker 0:81ed8b6e4a8b 91 return h->Open(si,addr);
networker 0:81ed8b6e4a8b 92 }
networker 0:81ed8b6e4a8b 93 }
networker 0:81ed8b6e4a8b 94 return ERR_SOCKET_NONE_LEFT;
networker 0:81ed8b6e4a8b 95 }
networker 0:81ed8b6e4a8b 96
networker 0:81ed8b6e4a8b 97 int Send(int socket, const u8* data, int len)
networker 0:81ed8b6e4a8b 98 {
networker 0:81ed8b6e4a8b 99 SocketInternal* si = GetInternal(socket);
networker 0:81ed8b6e4a8b 100 if (!si || si->ID != socket)
networker 0:81ed8b6e4a8b 101 return ERR_SOCKET_NOT_FOUND;
networker 0:81ed8b6e4a8b 102 // printf("sending %d bytes to socket %d (ID=%d)\n", len, socket, si->ID);
networker 0:81ed8b6e4a8b 103 return GetHandler(si->Type)->Send(si,data,len);
networker 0:81ed8b6e4a8b 104 }
networker 0:81ed8b6e4a8b 105
networker 0:81ed8b6e4a8b 106 int Close(int socket)
networker 0:81ed8b6e4a8b 107 {
networker 0:81ed8b6e4a8b 108 SocketInternal* si = GetInternal(socket);
networker 0:81ed8b6e4a8b 109 if (!si || si->ID != socket)
networker 0:81ed8b6e4a8b 110 return ERR_SOCKET_NOT_FOUND;
networker 0:81ed8b6e4a8b 111 si->SetState(SocketState_Closing);
networker 0:81ed8b6e4a8b 112 int retval = GetHandler(si->Type)->Close(si);
networker 0:81ed8b6e4a8b 113 //si->SetState(Socket_Closed);
networker 0:81ed8b6e4a8b 114 //si->ID = 0;
networker 0:81ed8b6e4a8b 115 return retval;
networker 0:81ed8b6e4a8b 116 }
networker 0:81ed8b6e4a8b 117 };
networker 0:81ed8b6e4a8b 118
networker 0:81ed8b6e4a8b 119 SocketManager gSocketManager;
networker 0:81ed8b6e4a8b 120
networker 0:81ed8b6e4a8b 121 int Socket_Open(int type, SocketAddrHdr* addr, SocketCallback callback, void* userData)
networker 0:81ed8b6e4a8b 122 {
networker 0:81ed8b6e4a8b 123 return gSocketManager.Open(type,addr,callback,userData);
networker 0:81ed8b6e4a8b 124 }
networker 0:81ed8b6e4a8b 125
networker 0:81ed8b6e4a8b 126 int Socket_Send(int socket, const u8* data, int len)
networker 0:81ed8b6e4a8b 127 {
networker 0:81ed8b6e4a8b 128 return gSocketManager.Send(socket,data,len);
networker 0:81ed8b6e4a8b 129 }
networker 0:81ed8b6e4a8b 130
networker 0:81ed8b6e4a8b 131 int Socket_Close(int socket)
networker 0:81ed8b6e4a8b 132 {
networker 0:81ed8b6e4a8b 133 return gSocketManager.Close(socket);
networker 0:81ed8b6e4a8b 134 }
networker 0:81ed8b6e4a8b 135
networker 0:81ed8b6e4a8b 136 int RegisterSocketHandler(int type, SocketHandler* handler)
networker 0:81ed8b6e4a8b 137 {
networker 0:81ed8b6e4a8b 138 return gSocketManager.RegisterSocketHandler(type,handler);
networker 0:81ed8b6e4a8b 139 }
networker 0:81ed8b6e4a8b 140
networker 0:81ed8b6e4a8b 141 SocketInternal* GetSocketInternal(int socket)
networker 0:81ed8b6e4a8b 142 {
networker 0:81ed8b6e4a8b 143 return gSocketManager.GetInternal(socket);
networker 0:81ed8b6e4a8b 144 }
networker 0:81ed8b6e4a8b 145