|
Esta sección te permite ver todos los posts escritos por este usuario. Ten en cuenta que sólo puedes ver los posts escritos en zonas a las que tienes acceso en este momento.
Mensajes - captaindanieo
26
« en: Jueves 6 de Diciembre de 2007, 11:17 »
Eternal Idol, pues a mi no me realiza esas acciones al ejecutarlo. He probado a cambiar la cadena como tu dices, pero no funciona. Ni la cadena numérica ni una cadena de letras se reciben. En la ventana del Servidor solo se muestra lo siguiente: Conexion Recibida Sigo aqui en modo servidor Esperando nuevos datos Voy a leer Sigo aqui en modo servidor Sigo aqui en modo servidor Sigo aqui en modo servidor Sigo aqui en modo servidor Sigo aqui en modo servidor .... El servidor no recibe nada, y debería de hacerlo, ¿no? Muchas gracias por las molestias. ¿Podría ser del compilador? No lo creo, ¿no? Uso el dev c++. Ya es que no se que puede estar pasando. Estoy revisando las líneas de código una por una, lo que debe de ejecutarse, y en principio debería ir. No se
27
« en: Miércoles 5 de Diciembre de 2007, 21:39 »
El socket es creado en la capa L2CAP que creamos cuando elegimos la opción cliente o servidor. Cuando elegimos Servidor, hacemos un socketserver en el puerto 3000, y estamos ahi a la escucha, y además creamos un thread paralelo a la escucha siempre de lo que pueda venir por el socket. Cuando elegimos Cliente se define un SocketClient por ese mismo puerto 3000, y se permanece a la escucha permanente en otro thread por si llegan datos por el puerto 3000. Cuando el canal de la capa correspondiente a servidor realiza la llamada a Sendbytes y envía por el socket, el Cliente está a la escucha de llegada de datos por ese puerto 3000, y por tanto debería recibir la cadena enviada. La recepción de los datos por el socket se realiza en bucleLectura, a la cual se le pasa un puntero y siempre llama a thisL2cap->leerSocket(), que es donde se realiza el ReceiveBytes(). El único socket que tengo definido es 's', en L2CAP. Ya que a los canales, les paso en el constructor un puntero a ese mismo socket s, y la variable sockCanal es simplemente una copia de dicho puntero. Debería de funcionar, ¿no?
28
« en: Martes 4 de Diciembre de 2007, 23:18 »
Para el funcionamiento de los sockets tengo incluidas en el proyecto las bibliotecas de libwsock32.a y winsock2.h. Son las únicas bibliotecas u objetos añadidos en las opciones de proyecto. Todo lo demás está en el código.
29
« en: Lunes 3 de Diciembre de 2007, 22:28 »
pc. es el nombre de mi computadora. En ese campo debe ir el nombre del host, de quien abre la conexión. La línea que debería provocar la escritura es, justo en el Constructor del canal L2capchannel, la que dice: pt2Func (_ME,"080001000205040001004000"); O sea, justo cuando creamos el canal para meterlo en el vector de canales, justo cuando lo creamos, en el costructor estamos mandando datos (esto lo hice así para probar cuanto antes el tema de los sockets). Esa línea no es la escritura en sí, sino que provoca que se llame al Wrapper definido en L2cap (y efectivamente se le llama correctamente, ya que se muestra por pantalla un mensaje de que se está en el Wrapper). void L2cap::Wrapper_a_escribeEnSocket (void* pt2Object, std::string cadena) { cout<<"Welcome to WRAPPER"<<endl; L2cap* mySelf = (L2cap*) pt2Object; mySelf->escribeEnSocket(cadena); //mySelf->sendRaw(); // Esto debería de funcionar, pero tampoco }
En escribeEnSocket es donde se realiza la escritura en sí, y se le pasa la cadena a escribir. En ella se realiza un SendBytes, que es lo que envía por el socket. Muchas gracias.
30
« en: Lunes 3 de Diciembre de 2007, 16:43 »
No logro dar con el por qué
31
« en: Domingo 2 de Diciembre de 2007, 15:28 »
Muchas gracias EternalIdol.
Sigo intentando encontrar el por qué no funciona. Estaré atento a tu respuesta cuando puedas. Muchísimas gracias.
32
« en: Domingo 2 de Diciembre de 2007, 14:12 »
-----------------------------| l2capChannel.cpp |-------------------- #include <stdlib.h> #include <iostream> #include <time.h> #include <sstream> #include <string> #include <L2capChannel.h> using namespace std; L2capChannel::L2capChannel (int CID, int PSM, Socket* a) // Constructor { _estado = CLOSED; _localCID = CID; _PSM = PSM; sockCanal = a; std::string cad = "080001000305040001004000"; sockCanal->SendBytes(cad); // No escribe, no se por que } L2capChannel::L2capChannel (int CID, int PSM,void* a, void(*pt2Func)(void*, std::string)) { _estado = CLOSED; _localCID = CID; _PSM = PSM; _ME = a; cout<<"Se supone que enviamos!"<<endl; pt2Func (_ME,"080001000205040001004000"); // Llama al Wrapper y éste deberia escribir, pero no lo hace // _ME->sendRaw(); // deberia poder mandar asi tambien, pero no } L2capChannel::~L2capChannel () // Constructor { } void L2capChannel::imprimeArray (Tpdu_L2CAP datain, unsigned int longitud) { unsigned int i; printf(" \n\n El array de datos es el siguiente: \n \n"); for (i=0; i<(longitud); i++) { printf("%X ",*(datain+i)); } printf(" \n \n"); } void L2capChannel::escribeL2CAPcon_req_TX () { L2CAPcon_req_TX.Code = L2CAP_CONREQ; L2CAPcon_req_TX.ID = _identifier; L2CAPcon_req_TX.Length = 4; L2CAPcon_req_TX.PSM = _PSM; L2CAPcon_req_TX.SCID = _localCID; } void L2capChannel::escribeL2CAPcon_res_TX (int result) { L2CAPcon_res_TX.Code = L2CAP_CONRES; L2CAPcon_res_TX.ID = L2CAPcon_req_RX.ID; L2CAPcon_res_TX.Length = 6; L2CAPcon_res_TX.DCID = _localCID; L2CAPcon_res_TX.SCID = _remoteCID; L2CAPcon_res_TX.Result = result; L2CAPcon_res_TX.Status = 0x0000; } void L2capChannel::leerL2CAPcon_req(Tpdu_L2CAP datain, unsigned int &n) { L2CAPcon_req_RX.Code = *(datain + n); L2CAPcon_req_RX.ID = *(datain + n+1); L2CAPcon_req_RX.Length = *(datain + n+2) + (*(datain+n+3))*256; L2CAPcon_req_RX.PSM = *(datain + n+4) + (*(datain+n+5))*256; L2CAPcon_req_RX.SCID = *(datain + n+6) + (*(datain+n+7))*256; int _remoteCID = L2CAPcon_req_RX.SCID; n += (L2CAPcon_req_RX.Length + 4); cout<<"vamos por aqui"<<endl; if (_estado==CLOSED) { unsigned int result=0; //successfull if (result==0) { escribeL2CAPcon_res_TX (result); _estado=WAIT_CONFIG; } else if (result==1) //pending { escribeL2CAPcon_res_TX (result); _estado=WAIT_CONNECT; } else //No puede { escribeL2CAPcon_res_TX (result); } sendComando(L2CAP_CONRES); } } // leerL2CAPcon_req int L2capChannel::leerL2CAPcon_res(Tpdu_L2CAP datain, unsigned int &n) { unsigned int _receivedIdentifier = *(datain + n+1); switch (_estado) { case WAIT_CONNECT_RSP: { if (L2CAPcon_req_RX.ID !=_receivedIdentifier) { cout<<"Identificador no se corresponde con el esperado."<<endl; return 2; } L2CAPcon_res_RX.Code = *(datain + n); // Code = 03 L2CAPcon_res_RX.ID = *(datain + n+1); L2CAPcon_res_RX.Length = *(datain + n+2) + (*(datain+n+3))*256; L2CAPcon_res_RX.DCID = *(datain + n+4) + (*(datain+n+5))*256; L2CAPcon_res_RX.SCID = *(datain + n+6) + (*(datain+n+7))*256; L2CAPcon_res_RX.Result = *(datain + n+8) + (*(datain+n+9))*256; L2CAPcon_res_RX.Status = *(datain + n+10) + (*(datain+n+11))*256; n += (L2CAPcon_res_RX.Length + 4); switch (L2CAPcon_res_RX.Result) { case 0: //Success { _estado = WAIT_CONFIG; _remoteCID = L2CAPcon_res_RX.DCID; break; } case 1: //pending { break; } case 2: //Refused { _estado = CLOSED; cout<<"PSM not supported."<<endl; return -1; break; } case 3: //Refused { _estado = CLOSED; cout<<"Security block."<<endl; return -1; break; } case 4: //Refused { _estado = CLOSED; cout<<"No resources available."<<endl; return -1; break; } default: { } } return 0; break; } default : { return 1; } } } void L2capChannel::imprimeComando (unsigned int codigo) { unsigned int i; switch (codigo) { case L2CAP_CONREQ : { printf("\n \n*****Connection Request******* \n"); printf("El campo Code es de valor %X \n",L2CAPcon_req_RX.Code); printf("El campo ID es de valor %X \n",L2CAPcon_req_RX.ID); printf("El campo Length es de valor %X \n",L2CAPcon_req_RX.Length); printf("El campo PSM es de valor %X \n",L2CAPcon_req_RX.PSM); printf("El campo SCID es de valor %X \n \n",L2CAPcon_req_RX.SCID); break; } case L2CAP_CONRES : { printf("\n \n*****Connection Response******* \n"); printf("El campo Code es de valor %X \n",L2CAPcon_res_RX.Code); printf("El campo ID es de valor %X \n",L2CAPcon_res_RX.ID); printf("El campo Length es de valor %X \n",L2CAPcon_res_RX.Length); printf("El campo DCID es de valor %X \n",L2CAPcon_res_RX.DCID); printf("El campo SCID es de valor %X \n",L2CAPcon_res_RX.SCID); printf("El campo Result es de valor %X \n",L2CAPcon_res_RX.Result); printf("El campo Status es de valor %X \n \n",L2CAPcon_res_RX.Status); break; } } } int L2capChannel::entradaComandos (Tpdu_L2CAP pdu, unsigned int longitud) { int res; unsigned int n, tipocomando; // Comprobamos que realmente se ha recibido una trama de control if (!(*(pdu+2)==0x01)&(*(pdu+3)==0x00)) { cout<<"Esperado trama-C. Entrada no valida."<<endl; return 1; } cout<<"Efectivamente era una trama de control. Ya estamos en el CANAL."<<endl; n = 4; _receivedIdentifier = *(pdu+5); // de momento, sin considerar varios comandos en 1 trama-C tipocomando = *(pdu+n); switch (tipocomando) { case L2CAP_CONREQ: { leerL2CAPcon_req(pdu,n); break; } case L2CAP_CONRES: { res = leerL2CAPcon_res(pdu,n); break; } default : { cout <<"Comando no valido."<<endl; return 2; break; } } situacion (); return 0; } void L2capChannel::situacion () // Saca por pantalla el estado en el que nos encontramos { switch (_estado) { case CLOSED : { printf("\t \t Estado = CLOSED \n \n"); break; } case WAIT_CONNECT : { printf("\t \t Estado = WAIT_CONNECT \n \n"); break; } case WAIT_CONNECT_RSP : { printf("\t \t Estado = WAIT_CONNECT_RSP \n \n"); break; } case OPEN : { printf("\t \t Estado = OPEN \n \n"); break; } case WAIT_DISCONNECT : { printf("\t \t Estado = WAIT_DISCONNECT \n \n"); break; } case WAIT_CONFIG : { printf("\t \t Estado = WAIT_CONFIG \n \n"); break; } case WAIT_SEND_CONFIG : { printf("\t \t Estado = WAIT_SEND_CONFIG \n \n"); break; } case WAIT_CONFIG_REQ_RSP : { printf("\t \t Estado = WAIT_CONFIG_REQ_RSP \n \n"); break; } case WAIT_CONFIG_RSP : { printf("\t \t Estado = WAIT_CONFIG_RSP \n \n"); break; } case WAIT_CONFIG_REQ : { printf("\t \t Estado = WAIT_CONFIG_REQ \n \n"); break; } default : { } } } string L2capChannel::arrayToString(Tpdu_L2CAP a) { unsigned int longitud,num,cal; longitud = *(a) + (*(a+1))*256; string result = ""; for (int i=0; i<longitud; i++) { num = a[i]; if (Esnumero(char((num/16)+'0'))) { result = result + char((num/16)+'0'); } else { result = result + char((num/16)+'A'-10); } cal=(num-(num/16)*16); if (Esnumero(char( cal+'0'))) { result = result + char(cal+'0'); } else { result = result + char(cal+'A'-10); } } return result; } bool L2capChannel::Esnumero (char valor) { bool test; switch (valor) { case '1': case '2': case '3': case '4': case '5': case '6': case '7': case '8': case '9': case '0': { test = true; break; } default : { test = false; break; } } return test; } void L2capChannel::sendComando (unsigned int tipocomando) { string cad; Tpdu_L2CAP dataout ={0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00}; printf("\n Se va a enviar a continuacion una PDU de contenido: \n"); switch (tipocomando) { case L2CAP_CONREQ : //0x02 { vuelcaL2CAPcon_req(dataout); imprimeArray (dataout,L2CAPcon_req_TX.Length + 8); break; } case L2CAP_CONRES : //0x03 { vuelcaL2CAPcon_res(dataout); imprimeArray (dataout,L2CAPcon_res_TX.Length + 8); break; } default : { printf("Error. Campo Codigo incorrecto en SendComando \n"); } } cad = arrayToString(dataout); cout<<"Se va a enviar por el socket una PDU de contenido: "<<cad<<endl; // sockCanal->SendBytes(cad); // Canal manda mensaje por socket, si pasasemos el puntero a socket en el constructor // pt2Func (_ME,cad); // Llama al Wrapper y éste deberia escribir, pero no lo hace } //SendComando // ********FUNCIONES DE VOLCADO DE DATOS DESDE LAS VARIABLES REGISTRO******** // ******************** AL ARRAY DE SALIDA (PDU)**************************** void L2capChannel::vuelcaL2CAPcon_req(Tpdu_L2CAP &dataout) { unsigned int longitud,ind,res,coc; longitud = L2CAPcon_req_TX.Length; coc = longitud + 4; for (ind=0;(ind<2);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } *(dataout+ind) = 0x1; // trama de control ind++; *(dataout+ind) = 0x0; ind++;; *(dataout+ind) = L2CAPcon_req_TX.Code; ind++; *(dataout+ind)= L2CAPcon_req_TX.ID; ind++; coc = L2CAPcon_req_TX.Length; for (ind=6;(ind<8);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } coc = L2CAPcon_req_TX.PSM; for (ind=8;(ind<10);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } coc = L2CAPcon_req_TX.SCID; for (ind=10;(ind<12);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } } void L2capChannel::vuelcaL2CAPcon_res(Tpdu_L2CAP &dataout) { unsigned int longitud,ind,res,coc; longitud = L2CAPcon_res_TX.Length; coc = longitud + 4; for (ind=0;(ind<2);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } *(dataout+ind) = 0x1; // trama de control ind++; *(dataout+ind) = 0x0; ind++;; *(dataout+ind) = L2CAPcon_res_TX.Code; ind++; *(dataout+ind)= L2CAPcon_res_TX.ID; ind++; coc = L2CAPcon_res_TX.Length; for (ind=6;(ind<8);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } coc = L2CAPcon_res_TX.DCID; for (ind=8;(ind<10);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } coc = L2CAPcon_res_TX.SCID; for (ind=10;(ind<12);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } coc = L2CAPcon_res_TX.Result; for (ind=12;(ind<14);ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } coc = L2CAPcon_res_TX.Status; for (ind=14;(ind<(longitud+8));ind++) { res = coc % 256; *(dataout+ind) = res; coc = coc / 256; } } int L2capChannel::connectChannel() { cout<<endl<<endl<<"Creando CANAL"<<endl<<endl; if (_estado == CLOSED) { srand(time(NULL)); _identifier=rand(); escribeL2CAPcon_req_TX (); sendComando (L2CAP_CONREQ); _estado = WAIT_CONNECT_RSP; return 0; } else { cout<<"Apertura canal no valida. Estado no CLOSED."<<endl; return 1; } }
33
« en: Domingo 2 de Diciembre de 2007, 14:08 »
Buenos dias. Últimamente todo son problemas en el trabajo que estoy programando, y no acabo de salir de uno cuando me encuentro en otro todavía mas grande. Antes de nada darle las gracias a Eternal Idol, por todas las respuestas y ayudas en los posts que he ido posteando estos dias atrás, y que sin duda me han ayudado a seguir adelante. Muchísimas gracias. Mi programa, se distribuye en varias partes. El objetivo es implementar una capa de protocolo, y para ello, he hecho uso de las clases. Mi clase L2cap, es la clase de mi capa que quiero implementar. Y dentro de ella, se hace uso de otra clase, que es la clase L2capChannel. Cuando dos instancias de L2cap establecen una comunicación entre ellas, crean un canal L2capChannel, y establecen una comunicación por socket. Para los sockets he usado una clase que ya había implementada. Con lo cual hago uso de ella para dicha comunicación. Los sockets los tengo en la clase L2cap, y cuando envío o recibo datos desde L2cap funciona sin problema aparente. (Es decir, si desde L2cap hago una llamada a sendRaw por ejemplo, se transmite el mensaje creado en sendRaw por el socket y llega a la otra entidad de mi programa). La cosa es que yo necesito también que el L2capChannel, en algún momento determinado, como por ejemplo cuando reciba un mensaje de datos que sea una ConnectionRequest, deba enviar él otro mensaje que sea una ConnectionResponse. Y por tanto, para dicho envío, ha de hacer uso de los sockets. Por lo tanto, el canal debería de poder también enviar por el socket. Primeramente pensé en pasarle en el constructor de L2capChannel, un puntero al socket. De manera que pudiese escribir din problemas. Sin embargo no funciona. Y no se por qué, porque revisé todo y debería de haber funcionado. Otra alternativa que pensé fue en hacerlo mediante callbacks, que es la que actualmente tengo implementada (el constructor de L2capChannel en el caso de pasarle el puntero a socket lo tengo entre comentarios, y ahora solo uso el de callback). Sin embargo el resultado es el mismo. Y ya no se que mas puedo hacer. He intentado hacerlo de todas las maneras posibles, pero llevo semanas atascado en dicha comunicación y no hay manera. La ejecución del programa ha de hacerse de la siguiente manera: Primero ejecuto, y elijo la opción 1, que es el modo Servidor. De esa manera habrá alguien escuchando en el puerto. Seguidamente, ejecuto el programa de nuevo, dejando el otro abierto, y ésta vez, elegimos la opción 2, que es el modo cliente. Ésto provocará que a la hora de crear mi nueva capa L2cap lo haga de forma diferente (como cliente). Y después de crear mi capa, llama a la primitiva de L2cap OpenChannelReq. Tanto en el caso del Servidor como del Cliente, he colocado un bucle infinito para que no finalice la ejecución del programa, y en dicho bucle saca un mensaje por pantalla. OpenChannel se encarga de abrir un nuevo canal para una comunicación. Para ello busca un CID (identificador de canal) libre, y crea un nuevo L2capChannel, introduciéndolo en el vector de canales, y construyendo dicho canal mandándole mediante callback la funcion que usará el canal para enviar datos por el socket (ya que el socket está en L2cap y no en L2capChannel). Seguidamente actualiza también el vector tabla, que es simplemente un registro de los canales que han sido creados en mi capa L2cap. Y finalmente, se hace una llamada a ese canal creado en el vector, a su procedimiento connectChannel(). [connect channel, provocaría la elaboración de una Connection Request, la almacenaria en variables globales, pasaría dichas variables a un array de salida, crearia una string con el contenido a mandar, y la tendría que mandar por el socket]Sin embargo, en lugar de toda esta secuencia de acciones, para testear la comunicación por el socket, en el mismo constructor del canal L2capChannel, he puesto que se llame al Wrapper a la función que escribe en el socket en L2cap. He puesto que escriba una cadena de caracteres, que resulta que es una ConnectionRequest. La llamada al Wrapper se realiza perfectamente, ya que se muestra por pantalla que se ha entrado en dicha función. Pero por el socket no se escribe nada. El Servidor debería de recibir la cadena por el socket, y no la recibe. El cliente muestra que se ha creado un canal, muestra el contenido de la tabla, y dice que ha enviado por el socket una cadena, pero al Servidor no le llega. Se que quizás sea muy extenso el código, he intentado reducirlo al máximo dejando solo lo indispensable para ver el problema de la comunicación por socket. Muchísimas gracias por todo. Pongo el código a continuación de cada uno de los archivos, comenzando por la clase Socket, seguida de los archivos de mi programa. Muchas gracias. -----------------------------| socket.h |-------------------- #ifndef SOCKET_H #define SOCKET_H #include <C:\Dev-Cpp\include\WinSock2.h> #include <string> enum TypeSocket {BlockingSocket, NonBlockingSocket}; class Socket { public: virtual ~Socket(); Socket(const Socket&); Socket& operator=(Socket&); std::string ReceiveLine(); std::string ReceiveBytes(); void Close(); // The parameter of SendLine is not a const reference // because SendLine modifes the std::string passed. void SendLine (std::string); // The parameter of SendBytes is a const reference // because SendBytes does not modify the std::string passed // (in contrast to SendLine). void SendBytes(const std::string&); protected: friend class SocketServer; friend class SocketSelect; Socket(SOCKET s); Socket(); SOCKET s_; int* refCounter_; private: static void Start(); static void End(); static int nofSockets_; }; class SocketClient : public Socket { public: SocketClient(const std::string& host, int port); }; class SocketServer : public Socket { public: SocketServer(int port, int connections, TypeSocket type=BlockingSocket); Socket* Accept(); }; // http: //msdn.microsoft .com/library/default.asp?url=/library/en-us/winsock/wsapiref_2tiq.asp class SocketSelect { public: SocketSelect(Socket const * const s1, Socket const * const s2=NULL, TypeSocket type=BlockingSocket); bool Readable(Socket const * const s); private: fd_set fds_; }; #endif
-----------------------------| socket.cpp |-------------------- #include <SOCKET.h> #include <iostream> using namespace std; int Socket::nofSockets_= 0; void Socket::Start() { if (!nofSockets_) { WSADATA info; if (WSAStartup(MAKEWORD(2,0), &info)) { throw "Could not start WSA"; } } ++nofSockets_; } void Socket::End() { WSACleanup(); } Socket::Socket() : s_(0) { Start(); // UDP: use SOCK_DGRAM instead of SOCK_STREAM s_ = socket(AF_INET,SOCK_STREAM,0); if (s_ == INVALID_SOCKET) { throw "INVALID_SOCKET"; } refCounter_ = new int(1); } Socket::Socket(SOCKET s) : s_(s) { Start(); refCounter_ = new int(1); }; Socket::~Socket() { if (! --(*refCounter_)) { Close(); delete refCounter_; } --nofSockets_; if (!nofSockets_) End(); } Socket::Socket(const Socket& o) { refCounter_=o.refCounter_; (*refCounter_)++; s_ =o.s_; nofSockets_++; } Socket& Socket::operator=(Socket& o) { (*o.refCounter_)++; refCounter_=o.refCounter_; s_ =o.s_; nofSockets_++; return *this; } void Socket::Close() { closesocket(s_); } std::string Socket::ReceiveBytes() { std::string ret; char buf[1024]; while (1) { u_long arg = 0; if (ioctlsocket(s_, FIONREAD, &arg) != 0) { break; } if (arg == 0) { break; } if (arg > 1024) { arg = 1024; } int rv = recv (s_, buf, arg, 0); if (rv <= 0) { break; } std::string t; t.assign (buf, rv); ret += t; } return ret; } std::string Socket::ReceiveLine() { std::string ret; while (1) { char r; switch(recv(s_, &r, 1, 0)) { case 0: // not connected anymore; // ... but last line sent // might not end in \n, // so return ret anyway. return ret; case -1: return ""; // if (errno == EAGAIN) { // return ret; // } else { // // not connected anymore // return ""; // } } ret += r; if (r == '\n') return ret; } } void Socket::SendLine(std::string s) { s += '\n'; send(s_,s.c_str(),s.length(),0); } void Socket::SendBytes(const std::string& s) { send(s_,s.c_str(),s.length(),0); } SocketServer::SocketServer(int port, int connections, TypeSocket type) { sockaddr_in sa; memset(&sa, 0, sizeof(sa)); sa.sin_family = PF_INET; sa.sin_port = htons(port); s_ = socket(AF_INET, SOCK_STREAM, 0); if (s_ == INVALID_SOCKET) { throw "INVALID_SOCKET"; } if(type==NonBlockingSocket) { u_long arg = 1; ioctlsocket(s_, FIONBIO, &arg); } /* bind the socket to the internet address */ if (bind(s_, (sockaddr *)&sa, sizeof(sockaddr_in)) == SOCKET_ERROR) { closesocket(s_); throw "INVALID_SOCKET"; } listen(s_, connections); } Socket* SocketServer::Accept() { SOCKET new_sock = accept(s_, 0, 0); if (new_sock == INVALID_SOCKET) { int rc = WSAGetLastError(); if(rc==WSAEWOULDBLOCK) { return 0; // non-blocking call, no request pending } else { throw "Invalid Socket"; } } Socket* r = new Socket(new_sock); return r; } SocketClient::SocketClient(const std::string& host, int port) : Socket() { std::string error; hostent *he; if ((he = gethostbyname(host.c_str())) == 0) { error = strerror(errno); throw error; } sockaddr_in addr; addr.sin_family = AF_INET; addr.sin_port = htons(port); addr.sin_addr = *((in_addr *)he->h_addr); memset(&(addr.sin_zero), 0, 8); if (::connect(s_, (sockaddr *) &addr, sizeof(sockaddr))) { error = strerror(WSAGetLastError()); throw error; } } SocketSelect::SocketSelect(Socket const * const s1, Socket const * const s2, TypeSocket type) { FD_ZERO(&fds_); FD_SET(const_cast<Socket*>(s1)->s_,&fds_); if(s2) { FD_SET(const_cast<Socket*>(s2)->s_,&fds_); } TIMEVAL tval; tval.tv_sec = 0; tval.tv_usec = 1; TIMEVAL *ptval; if(type==NonBlockingSocket) { ptval = &tval; } else { ptval = 0; } if (select (0, &fds_, (fd_set*) 0, (fd_set*) 0, ptval) == SOCKET_ERROR) throw "Error in select"; } bool SocketSelect::Readable(Socket const* const s) { if (FD_ISSET(s->s_,&fds_)) return true; return false; }
-----------------------------| tipos.h |-------------------- // DEFINICION DE TIPOS typedef unsigned int Tpdu_L2CAP [1200]; // Dato de entrada, PDU L2CAP typedef struct { unsigned int Code; unsigned int ID; int Length; int PSM; int SCID; } TL2CAP_con_req; // Connection Request packet typedef struct { unsigned int Code; unsigned int ID; int Length; int DCID; int SCID; int Result; int Status; } TL2CAP_con_res; // Connection Response packet
-----------------------------| constantes.h |-------------------- // Codigos de los comandos de señalizacion #define L2CAP_CONREQ 0x02 #define L2CAP_CONRES 0x03 // Estados definidos en la máquina de estados #define CLOSED 0x00 #define WAIT_CONNECT 0x01 #define WAIT_CONNECT_RSP 0x02 #define CONFIG 0x03 // Consta de un numero de sub estados #define OPEN 0x04 #define WAIT_DISCONNECT 0x05 // Sub estados dentro del estado CONFIG #define WAIT_CONFIG 0x06 #define WAIT_SEND_CONFIG 0x07 #define WAIT_CONFIG_REQ_RSP 0x08 #define WAIT_CONFIG_RSP 0x09 #define WAIT_CONFIG_REQ 0x10 // Eventos #define OPENCHANNEL_REQ 0x01 #define OPENCHANNEL_RSP 0x02 #define CONNECTREQ 0x03 #define CONNECTRSP 0x04
-----------------------------| principal.cpp |-------------------- #include <cstdlib> #include <iostream> #include <L2cap.h> #include <windows.h> using namespace std; int main() { int msg,opcion; std::string cadena; msg = 0; do { system("cls"); opcion = 0; cout <<endl<<" *-----------------------------------------*"; cout <<endl<<" | B L U E T O O T H |"; cout <<endl<<" *-----------------------------------------*"; cout <<endl<<" | M E N U L 2 C A P v 2.1. |"; cout <<endl<<" *-----------------------------------------*"; cout <<endl<<" | |"; cout <<endl<<" | 1.- Modo Servidor................. (1) |"; cout <<endl<<" | 2.- Modo Cliente manda PDU........ (2) |"; cout <<endl<<" | 3.- Salir......................... (3) |"; cout <<endl<<" | |"; cout <<endl<<" *-----------------------------------------*"<<endl<<endl<<endl; cout <<endl<<" > Elija una Opcion.......... "; scanf("%d",&opcion); }while (opcion < 1 || opcion > 3); //Lee Menu y llama funciones switch(opcion) { case 1: { system("cls"); L2cap micapa(1); while (1) { cout<<"Sigo aqui en modo Servidor..."<<endl; Sleep(4000); } break; } case 2: { system("cls"); L2cap micapa(2); micapa.Openchannel_req (); //micapa.sendRaw(); // Si utilizo sendRaw desde aquí, SI funciona la comunicación //por Socket de client a Serv, pero no de Serv a cliente (el canal no escribe por socket) while (1) { cout<<"Sigo aqui en modo Cliente..."<<endl; Sleep(4000); } system("pause"); break; } case 3: { system("cls"); L2cap micapa(3); micapa.Salir(); cout <<endl<<" > FIN DEL PROGRAMA.........."<<endl<<endl; break; } } return 0; }
-----------------------------| l2cap.h |-------------------- //#include <Socket.h> #include <L2capChannel.h> #include <vector> #include <string> #include <sstream> #include <iostream> #include <cstdlib> #include <stdio.h> #include <stdlib.h> using namespace std; // DEFINICION DE TIPOS typedef struct { unsigned int CID; unsigned int PSM; int funcptr; } Ttabla; typedef L2capChannel *Tpcanal; class L2cap { public: L2cap (int mode); // Constructor. ~L2cap (); // Destructor. void Salir (); void Send_Data(std::string cadena); // Modo Cliente void Server(int argc, char* argv[]); // Modo Servidor void leerSocketClient(); void leerSocketServer(); void leerSocket(); void sendRaw(); bool escuchando(); void escribeEnSocket(std::string cadena); static void Wrapper_a_escribeEnSocket (void* pt2Object, std::string cadena); int Openchannel_req (); private: // VARIABLES GLOBALES Socket *s; bool _escuchando; vector<Ttabla> tabla; vector<L2capChannel*> canales; // FUNCIONES void string_to_bytearray (std::string str, unsigned int* &array, int& size); unsigned int Leertipotrama (Tpdu_L2CAP datain); static unsigned __stdcall bucleLectura(void* a); void Analiza_contenido(std::string r); int BuscaTabla(int cid); void ImprimeTabla(); int AsignaCID(void); };
-----------------------------| l2cap.cpp |-------------------- #include <L2cap.h> #include <Socket.h> #include <vector> #include <process.h> #include <string> #include <sstream> #include <iostream> #include <cstdlib> #include <stdio.h> using namespace std; bool L2cap::escuchando() { return _escuchando; } unsigned __stdcall L2cap::bucleLectura(void* a) { L2cap *thisL2cap = (L2cap*)a; while (thisL2cap->escuchando()) { cout<<endl<<"Esperando Nuevos datos..."<<endl; thisL2cap->leerSocket(); } return 0; } L2cap::L2cap (int mode) // Constructor { _escuchando = true; if (mode==1) // Modo Servidor { SocketServer in(3000,5); Socket* sa=in.Accept(); s = sa; cout<<"Conexion Recibida"<<endl; unsigned ret; _beginthreadex(0,0,bucleLectura,(void*)this,0,&ret); } else if (mode==2) // Modo Cliente { SocketClient sb("pc.", 3000); s = &sb; *(s) = sb; //Con esto hemos anclado el contenido del puntero y ya no se borra al salir del Constructor unsigned ret; _beginthreadex(0,0,bucleLectura,(void*)this,0,&ret); } } //Ctor L2cap::~L2cap () // Destructor { } void L2cap::string_to_bytearray(std::string str, unsigned int* &array, int& size) { int length = str.length(); // nos aseguramos de que la cadena entrante tiene un número de elementos par if(length%2 == 1) { str = "0" + str; length++; } // Reservamos memoria para el array de salida array = new unsigned int[length/2]; size = length/2; std::stringstream sstr(str); for(int i=0; i < size; i++) { char ch1, ch2; sstr >> ch1 >> ch2; unsigned int dig1, dig2; if(isdigit(ch1)) dig1 = ch1 - '0'; else if(ch1>='A' && ch1<='F') dig1 = ch1 - 'A' + 10; else if(ch1>='a' && ch1<='f') dig1 = ch1 - 'a' + 10; if(isdigit(ch2)) dig2 = ch2 - '0'; else if(ch2>='A' && ch2<='F') dig2 = ch2 - 'A' + 10; else if(ch2>='a' && ch2<='f') dig2 = ch2 - 'a' + 10; array[i] = dig1*16 + dig2; } } unsigned int L2cap::Leertipotrama(Tpdu_L2CAP datain) { unsigned int tipo; if ((*(datain+2)==0x01)&(*(datain+3)==0x00)) { tipo = 'C'; // Trama de control. c-frame } else if ((*(datain+2)==0x02)&(*(datain+3)==0x00)) { tipo = 'G'; // Trama G. Canal no orientado a conexión } else if ((*(datain+2)>=0x40)) { tipo = 'B'; // Trama-B } else { tipo = 'N'; // Tipo no válido } return tipo; } void L2cap::Salir () // Funcion que manda por socket la cadena salir que hace que salga del bucle infinito Server { int i; SocketClient s("pc.", 3000); //No hace falta crear el socket de nuevo std::string c1 = "exit"; s.SendBytes(c1); } int L2cap::BuscaTabla(int cid) { int bus=-1; for (int i=0; i<tabla.size();i++) { if (tabla[i].CID==cid) { bus=i; } } return bus; //Si no ha encontrado registrado en la tabla el CID buscado, devuelve -1, //En caso de q lo encuentre, devuelve la posicion en la que se encuentra el //canal con dicho CID } void L2cap::ImprimeTabla() { printf("\n\n----TABLA DE REGISTRO DE CANALES L2CAP----\n"); for (int i=0; i<tabla.size();i++) { printf("tabla [%d].CID = %X \n",i,tabla[i].CID); printf("tabla [%d].PSM = %X \n\n",i,tabla[i].PSM); } } int L2cap::AsignaCID() //Busca, para una trama de datos (B), que CID hay libre para asignarle //a la comunicación actual { int nuevoCID=0x40; while (BuscaTabla(nuevoCID)>=0) { printf("Ya esta registrado el CID de valor %X \n",nuevoCID); nuevoCID++; } printf("Registrado con exito el CID de valor %X \n",nuevoCID); return nuevoCID; //Devuelve el 1ero que no esta en la tabla } void L2cap::Analiza_contenido(std::string r) { unsigned int longitud, tipo; unsigned int* datain = NULL; int size,CID,bus,num; size = r.length(); if (size>0) { if (r =="exit") { _escuchando = false; cout<<"Escuchando se ha puesto a false"<<endl; } else { cout <<"Recibida una string de longitud "<<r.length()<<endl<<"y contenido: "<<r<<endl<<endl; string_to_bytearray(r,datain,size); longitud = size-4; // se trata del campo length, mientras q size es toda. tipo = Leertipotrama (datain); switch (tipo) { case 'C' : // Se trata de una trama-C { printf("Es una trama C \n \n"); // Primero vemos de que comando se trata int code = *(datain+4); if (code==L2CAP_CONREQ) { //Creamos un canal nuevo, actualizamos tabla,... int receivedPSM = *(datain+8) + (*(datain+9))*256; CID = AsignaCID(); //Asignamos nuevo CID cout<<"Recibida Connection Request"<<endl; canales.push_back(new L2capChannel(CID,receivedPSM,s)); //puntero a socket Ttabla elementoTabla; elementoTabla.CID = CID; elementoTabla.PSM = receivedPSM; tabla.push_back(elementoTabla); ImprimeTabla(); } else //Se trata de una: ConnectionRsp, ConfigReq, //ConfigRsp*, DiscReq { CID = *(datain+8) + (*(datain+9))*256; } bus=BuscaTabla(CID); if (bus >=0) { num=canales[bus]->entradaComandos(datain,longitud); } break; } case 'G' : // Se trata de una trama-G { printf("Es una trama G \n \n"); break; } case 'B' : //Se trata de una trama-B { printf("Es una trama B \n \n"); break; } case 'N': { printf("Trama no valida. \n \n"); break; } default : { printf("Algo esta pasando... \n \n"); } } } } } void L2cap::leerSocket() { cout<<"Voy a leer"<<endl; std::string r = ""; while (r.length()==0) { r = s->ReceiveBytes(); } Analiza_contenido(r); cout<<"Ya he leido"<<endl; } void L2cap::sendRaw() { std::string cadena="080001000205040001004000"; //Connection Request escribeEnSocket(cadena); cout<<"He enviado una cadena"<<endl; } int L2cap::Openchannel_req () { int res = 0; int PSM = 2; int CID,bus,num; CID = AsignaCID(); // Metemos en el vector de canales un nuevo elemento Canal que creamos con su constructor // canales.push_back(new L2capChannel(CID,PSM,s)); // Puntero a socket canales.push_back(new L2capChannel(CID,PSM,(void*)this,&Wrapper_a_escribeEnSocket)); // Callback // Metemos tambien los datos del canal que hemos creado para registrarlo en la tabla Ttabla elementoTabla; elementoTabla.CID = CID; elementoTabla.PSM = PSM; tabla.push_back(elementoTabla); ImprimeTabla(); bus=BuscaTabla(CID); if (bus >=0) { num=canales[bus]->connectChannel(); // Llamamos a connectChannel dentro de L2capChannel } return res; } void L2cap::escribeEnSocket(std::string cadena) { cout<<"Cadenita a mandar: "<<cadena<<endl; s->SendBytes(cadena); } void L2cap::Wrapper_a_escribeEnSocket (void* pt2Object, std::string cadena) { cout<<"Welcome to WRAPPER"<<endl; L2cap* mySelf = (L2cap*) pt2Object; mySelf->escribeEnSocket(cadena); //mySelf->sendRaw(); // Esto debería de funcionar, pero tampoco }
-----------------------------| l2capChannel.h |-------------------- #include <iostream> #include <string> #include <tipos.h> #include <constantes.h> #include <Socket.h> using namespace std; class L2capChannel { public: L2capChannel (int CID, int PSM,Socket* a); // Constructor. Se encarga de la correcta inicializacion L2capChannel (int CID, int PSM,void* a, void(*pt2Func)(void*, std::string)); ~L2capChannel (); unsigned int Obtener_estado(); int entradaComandos (Tpdu_L2CAP pdu, unsigned int longitud); int connectChannel(); private: // VARIABLES GLOBALES unsigned int _estado; // Indica el estado en el que nos encontramos unsigned int _leidos; unsigned int _MTU_negociada; unsigned int _MTU_sig; // de señalizacion unsigned int _identifier, _receivedIdentifier; int _localCID, _remoteCID, _PSM; void* _ME; Socket* sockCanal; //Variables de cada tipo de comando TL2CAP_con_req L2CAPcon_req_TX, L2CAPcon_req_RX; TL2CAP_con_res L2CAPcon_res_TX, L2CAPcon_res_RX; // FUNCIONES void sendComando (unsigned int tipocomando); void imprimeArray (Tpdu_L2CAP datain, unsigned int longitud); // funciones de lectura de cada tipo de trama-C void leerL2CAPcon_req(Tpdu_L2CAP pdu, unsigned int &n); int leerL2CAPcon_res(Tpdu_L2CAP pdu, unsigned int &n); void imprimeComando (unsigned int codigo); void escribeL2CAPcon_req_TX (void); void escribeL2CAPcon_res_TX (int result); void situacion (); void vuelcaL2CAPcon_req(Tpdu_L2CAP &dataout); void vuelcaL2CAPcon_res(Tpdu_L2CAP &dataout); string arrayToString(Tpdu_L2CAP a); bool Esnumero (char valor); };
34
« en: Domingo 2 de Diciembre de 2007, 11:45 »
Muchisimas gracias de nuevo EternalIdol.
35
« en: Viernes 30 de Noviembre de 2007, 20:47 »
Saludos de nuevo. Iba a abrir un nuevo hilo, pero al tratarse de nuevo de procedimientos con la std vector y estar trabajando dentro de una clase creo que sería mejor postearlo aquí. Bien. Yo dentro de mi clase, utilizo 2 elementos de tipo vector. Uno de ellos almacena punteros a elementos de otra clase, y el otro almacena simplemente un registro, en cada posición, y digamos que los dos están relacionados, y el segundo vector es como un 'registro' de lo que tengo almacenado en el primer vector (sus identificadores y demas..) Bueno, el problema me ha surgido cuando he intentado eliminar un elemento del vector. (el elemento ha de ser eliminaod de ambos, y en ambos tengo el problema). Creo que el problema aparece debido a que estoy utilizando la std vector dentro de una Clase. La eliminación de un elemento, en un vector, se realizaría de la siguiente forma: int posicion=5; //por ejemplo vector<int>::iterator itRemove = arNumbers.begin() + posicion; arNumbers.erase(itRemove);
El mensaje de error obtenido tras intentar realizar el procedimiento erase, es el siguiente: conversion from '__gnu_cxx::__normal_iterator<L2capChannel**, std::vector<L2capChannel*, std allocator<L2capChannel*> > >' to non-scalar type '__gnu_cxx::__normal_iterator<int*, std::vector<int,std::allocator<int> > >' requested no matching function for call to 'std::vector<L2capChannel*,std::allocator<L2capChannel*> > ::erase(__gnu_cxx::__normal_iterator<int*,std::vector<int,std::allocator<int> > >&)' candidates are: typename std::vector<_Tp, _Alloc>::iterator std::vector<_Tp, _Alloc>::erase(__gnu_cxx::__normal_iterator<typename _Alloc::pointer, std::vector<_Tp, _Alloc> >) [with _Tp = L2capChannel*, _Alloc = std::allocator<L2capChannel*>] note C:\Dev-Cpp\include\c++\3.4.2\bits\vector.tcc:108 typename std::vector<_Tp, _Alloc>::iterator std::vector<_Tp, _Alloc>::erase(__gnu_cxx::__normal_iterator<typename _Alloc::pointer, std::vector<_Tp, _Alloc> >, __gnu_cxx::__normal_iterator<typename _Alloc::pointer, std::vector<_Tp, _Alloc> >) [with _Tp = L2capChannel*, _Alloc = std::allocator<L2capChannel*>]
¿Que puedo hacer?
36
« en: Jueves 22 de Noviembre de 2007, 14:43 »
Muchísimas gracias de nuevo Eternal Idol, por tu respuesta. Un saludo.
37
« en: Jueves 22 de Noviembre de 2007, 09:34 »
Quería utilizar la stl vector, en lugar de un array, para ir almacenando valores conforme voy necesitando, y no tener que usar un array reservando un número de posiciones y eso. Los vectores, con sus instrucciones push_back, size(), ... son bastante cómodos en ese aspecto. Si lo que realizo es un vector de una variable normal, por decirlo de alguna manera, como un int, un registro con sus campos, ... no hay problema. vector <int> mivector; mivector.push_back(3); //Almacena el valor 3 en el vector tamaño = mivector.size(); //devuelve el tamaño que tiene actualmente
Cuando quiera acceder a un elemento en concreto de los que tiene almacenado el vector, puedo acceder a ellos mediante: elemento=mivector[indice];
Pero el problema me surge cuando lo que quiero almacenar en el vector no es una variable de ese tipo, sino que quiero almacenar punteros a una clase que tengo creada. Mi programa va a ir creando nuevos elementos de dicha clase conforme lo va necesitando, y yo en mi vector quiero almacenar punteros a cada uno de los elementos de tipo clase que haya creado. Ahora mi variable vector será: vector <*Tclase> mivector2; *Tclase elementonuevo; // tendre que ir almacenando punteros a Tclase mivector2.push_back(elementonuevo);
y para trabajar con los métodos de mi clase, de uno de los elementos que tengo en el vector, tendré que hacer: mivector2[indice]->metododemiclase(parametro1, parametro2);
¿Es correcto el planteamiento? Es que no termino de tenerlo claro si las definiciones y los accesos a los metodos de la clase se realizarían de esa manera. Muchisimas gracias de antemano!
38
« en: Jueves 8 de Noviembre de 2007, 16:19 »
Un millón de gracias Eternal Idol. Ya compila. Yo creo que todo va bien. Si el acceso a los elementos es como me has confirmado, entonces está perfecto  . Llevaba atascado varias semanas en ese punto, y nadie había podido ayudarme. Muchísimas gracias de nuevo!
39
« en: Jueves 8 de Noviembre de 2007, 15:51 »
Estoy usando devc++.
Sin embargo creo que había cometido algún error y se me había olvidado algún static en el código.
Parece que ahora funciona.
Para acceder a las variables y métodos de mi clase, lo único que tengo ue hacer es hacerlo mediante:
if (thisL2cap->escuchando);
por ejemplo, ¿no?
Y para acceder a los métodos de la clase socket, tendré que usar la variable socket creada en L2cap, por lo que el acceso deberá ser:
std::string r = thisL2cap->s->ReceiveBytes();
por ejemplo.
¿Está bien así?
40
« en: Jueves 8 de Noviembre de 2007, 14:54 »
Muchas gracias Eternal Idol. He realizado las modificaciones correspondientes, pero obtengo un error en _beginthreadex. In member function 'void L2cap:: Server(int,char**)'
argument of type 'unsigned int (L2cap:: )(void*) does not match 'unsigned int (*)(void*)'
Build error (L2cap.o) Error 1
41
« en: Jueves 8 de Noviembre de 2007, 00:31 »
Si pongo Answer como estátito cobtengo el error siguiente: invalid use of member L2cap::escuchando in static member function
He intentado aislar mi código, de manera que se pueda probar a compilar el código aquí escrito. Ya que si pongo solo partes del código no podemos probar a compilar quizás y no damos con la solución quizás. El código completo de la clase l2cap, tanto el h como el cpp es el siguiente: l2cap.h #include <Socket.h> #include <string> #include <sstream> #include <iostream> #include <cstdlib> #include <stdio.h> #include <stdlib.h> class L2cap { public: L2cap (); void Conecta(); // Modo Cliente void Server(int argc, char* argv[]); // Modo Servidor private: // VARIABLES GLOBALES bool escuchando; // FUNCIONES static unsigned __stdcall L2cap::Answer(void* a); };
L2cap.cpp #include <L2cap.h> #include <Socket.h> #include <process.h> #include <string> #include <sstream> #include <iostream> #include <cstdlib> #include <stdio.h> using namespace std; L2cap::L2cap () // Constructor { escuchando = true; } unsigned __stdcall L2cap::Answer(void* a) { Socket* s = (Socket*) a; int size; while (1) // escuchando { std::string r = s->ReceiveBytes(); size = r.length(); if (size>0) { if (escuchando); // <- aqui obtengo el error. no la ve } } delete s; return 0; } void L2cap::Server(int argc, char* argv[]) // Modo Servidor { SocketServer in(3000,5); while (escuchando) { Socket* s=in.Accept(); unsigned ret; _beginthreadex(0,0,Answer,(void*) s,0,&ret); } } void L2cap::Conecta() { std::string cadena; try { SocketClient s("pc.", 3000); //Ya esta abierto, no tengo que hacerlo de nuevo.?? cadena = "1600010002050400010040000A06020001000607040043004000"; s.SendBytes(cadena); } catch (const char* s) { cerr << s << endl; } catch (std::string s) { cerr << s << endl; } catch (...) { cerr << "unhandled exception\n"; } }
programa principal: principal.cpp #include <cstdlib> #include <iostream> #include <L2cap.h> using namespace std; int main() { int opcion; L2cap micapa; cout <<endl<<" *-----------------------------------------*"; cout <<endl<<" | 1.- Modo Servidor................. (1) |"; cout <<endl<<" | 2.- Modo Cliente manda msg........ (2) |"; cout <<endl<<" *-----------------------------------------*"<<endl<<endl; cout <<endl<<" > Elija una Opcion.......... "; scanf("%d",&opcion); //Lee Menu y llama funciones switch(opcion) { case 1: { micapa.Server(1,0); break; } case 2: { micapa.Conecta(); break; } } return 0; }
Y bueno, los archivos de la clase socket, son: el socket.cpp #include <SOCKET.h> #include <iostream> using namespace std; int Socket::nofSockets_= 0; void Socket::Start() { if (!nofSockets_) { WSADATA info; if (WSAStartup(MAKEWORD(2,0), &info)) { throw "Could not start WSA"; } } ++nofSockets_; } void Socket::End() { WSACleanup(); } Socket::Socket() : s_(0) { Start(); // UDP: use SOCK_DGRAM instead of SOCK_STREAM s_ = socket(AF_INET,SOCK_STREAM,0); if (s_ == INVALID_SOCKET) { throw "INVALID_SOCKET"; } refCounter_ = new int(1); } Socket::Socket(SOCKET s) : s_(s) { Start(); refCounter_ = new int(1); }; Socket::~Socket() { if (! --(*refCounter_)) { Close(); delete refCounter_; } --nofSockets_; if (!nofSockets_) End(); } Socket::Socket(const Socket& o) { refCounter_=o.refCounter_; (*refCounter_)++; s_ =o.s_; nofSockets_++; } Socket& Socket::operator=(Socket& o) { (*o.refCounter_)++; refCounter_=o.refCounter_; s_ =o.s_; nofSockets_++; return *this; } void Socket::Close() { closesocket(s_); } std::string Socket::ReceiveBytes() { std::string ret; char buf[1024]; while (1) { u_long arg = 0; if (ioctlsocket(s_, FIONREAD, &arg) != 0) { break; } if (arg == 0) { break; } if (arg > 1024) { arg = 1024; } int rv = recv (s_, buf, arg, 0); if (rv <= 0) { break; } std::string t; t.assign (buf, rv); ret += t; } return ret; } std::string Socket::ReceiveLine() { std::string ret; while (1) { char r; switch(recv(s_, &r, 1, 0)) { case 0: // not connected anymore; // ... but last line sent // might not end in \n, // so return ret anyway. return ret; case -1: return ""; // if (errno == EAGAIN) { // return ret; // } else { // // not connected anymore // return ""; // } } ret += r; if (r == '\n') return ret; } } void Socket::SendLine(std::string s) { s += '\n'; send(s_,s.c_str(),s.length(),0); } void Socket::SendBytes(const std::string& s) { send(s_,s.c_str(),s.length(),0); } SocketServer::SocketServer(int port, int connections, TypeSocket type) { sockaddr_in sa; memset(&sa, 0, sizeof(sa)); sa.sin_family = PF_INET; sa.sin_port = htons(port); s_ = socket(AF_INET, SOCK_STREAM, 0); if (s_ == INVALID_SOCKET) { throw "INVALID_SOCKET"; } if(type==NonBlockingSocket) { u_long arg = 1; ioctlsocket(s_, FIONBIO, &arg); } /* bind the socket to the internet address */ if (bind(s_, (sockaddr *)&sa, sizeof(sockaddr_in)) == SOCKET_ERROR) { closesocket(s_); throw "INVALID_SOCKET"; } listen(s_, connections); } Socket* SocketServer::Accept() { SOCKET new_sock = accept(s_, 0, 0); if (new_sock == INVALID_SOCKET) { int rc = WSAGetLastError(); if(rc==WSAEWOULDBLOCK) { return 0; // non-blocking call, no request pending } else { throw "Invalid Socket"; } } Socket* r = new Socket(new_sock); return r; } SocketClient::SocketClient(const std::string& host, int port) : Socket() { std::string error; hostent *he; if ((he = gethostbyname(host.c_str())) == 0) { error = strerror(errno); throw error; } sockaddr_in addr; addr.sin_family = AF_INET; addr.sin_port = htons(port); addr.sin_addr = *((in_addr *)he->h_addr); memset(&(addr.sin_zero), 0, 8); if (::connect(s_, (sockaddr *) &addr, sizeof(sockaddr))) { error = strerror(WSAGetLastError()); throw error; } } SocketSelect::SocketSelect(Socket const * const s1, Socket const * const s2, TypeSocket type) { FD_ZERO(&fds_); FD_SET(const_cast<Socket*>(s1)->s_,&fds_); if(s2) { FD_SET(const_cast<Socket*>(s2)->s_,&fds_); } TIMEVAL tval; tval.tv_sec = 0; tval.tv_usec = 1; TIMEVAL *ptval; if(type==NonBlockingSocket) { ptval = &tval; } else { ptval = 0; } if (select (0, &fds_, (fd_set*) 0, (fd_set*) 0, ptval) == SOCKET_ERROR) throw "Error in select"; } bool SocketSelect::Readable(Socket const* const s) { if (FD_ISSET(s->s_,&fds_)) return true; return false; }
y el socket.h #ifndef SOCKET_H #define SOCKET_H #include <WinSock2.h> #include <string> enum TypeSocket {BlockingSocket, NonBlockingSocket}; class Socket { public: virtual ~Socket(); Socket(const Socket&); Socket& operator=(Socket&); std::string ReceiveLine(); std::string ReceiveBytes(); void Close(); // The parameter of SendLine is not a const reference // because SendLine modifes the std::string passed. void SendLine (std::string); // The parameter of SendBytes is a const reference // because SendBytes does not modify the std::string passed // (in contrast to SendLine). void SendBytes(const std::string&); protected: friend class SocketServer; friend class SocketSelect; Socket(SOCKET s); Socket(); SOCKET s_; int* refCounter_; private: static void Start(); static void End(); static int nofSockets_; }; class SocketClient : public Socket { public: SocketClient(const std::string& host, int port); }; class SocketServer : public Socket { public: SocketServer(int port, int connections, TypeSocket type=BlockingSocket); Socket* Accept(); }; class SocketSelect { public: SocketSelect(Socket const * const s1, Socket const * const s2=NULL, TypeSocket type=BlockingSocket); bool Readable(Socket const * const s); private: fd_set fds_; }; #endif
Con eso ya se puede compilar el programa creando un proyecto con esos archivos, y el error obtenido es el que no es un uso válido en un miembro estático. A ver si pudiesemos encontrar la solución, muchisimas gracias. pd: La clase socket, fue realizada por René Nyffenegger.
42
« en: Miércoles 7 de Noviembre de 2007, 21:38 »
Muchas gracias de nuevo. La comunicación por sockets la requiero porque me es necesario para simular el comportamiento entre dos instancias de mi programa, que se estén ejecutando, ya sea en la misma máquina o en máquinas distintas. No he entendido muy bien la solución de crearme otro miembro en la clase l2cap, ¿a que se refiere? De todas formas muchas gracias por tus respuestas Eternal Idol.
43
« en: Miércoles 7 de Noviembre de 2007, 08:48 »
¿Que significa declarar esa función como static Eternal Idol? Es que soy totalmente novato en la programación y me pierdo.  El código que yo tengo en mi programa, y que da problemas, es el de abajo del primer post. Las declaraciones las tengo tal y como están ahí, pero obtengo el error de tipos ese que he resaltado en negrita. ¿Puede ser que beginthreadex no pueda usarse dentro de una clase? Si le quito el que esté dentro de mi clase, es decir, si la función Answer no la defino como L2cap::Answer, y en los parámetros elimino también el L2cap:: (en beginthreadex, para Answer), el código funciona. Pero si no incluyese referencia a ningún objeto de mi clase L2cap. En cuanto hago referencia a una variable por ejemplo, obtengo el error de que no está definida. Es que creo que no me había explicado bien del todo. Un saludo y muchísimas gracias de nuevo.
44
« en: Martes 6 de Noviembre de 2007, 15:27 »
Hola.
Si, efectivamente. Dentro de mi clase, uso la clase socket para establecer una conexion con otra clase igual que la mia.
La declaración de beginthreadex que tengo puesta en mi código es esa misma, y obtengo el error siguiente:
In member function 'void L2cap::Server (int,char**)' argument of type 'unsigned int (L2cap:: )(void*) does not match 'unsigned int (*)(void*)') Buil error (L2cap.o) Error 1.
Parece que al estar dentro de mi clase L2cap, obtiene un error de parámetros o algo. Ahi es donde tengo el problema.
45
« en: Martes 6 de Noviembre de 2007, 08:05 »
Hola. Es mi primer mensaje en el foro. Aprovecho para saludar y daros a todos las gracias por vuestra ayuda. Soy un programador mas o menos novato, y no tengo mucha o ninguna idea de muchas, cosas, y bueno. Vereis. Para la implementación del programa que estoy haciendo, he tenido que usar comunicación por sockets, para que se comuniquen dos entidades de mi programa. Y para ello he usado una clase socket implementada, que contaba con ejemplos de servidor y de cliente. El problema está en que estoy usando dicha clase socket, en una clase mia que me he creado. El código de la clase socket, para un servidor, tal y como estaba definido por el autor de la clase es el siguiente (no es el que yo tengo en mi programa, que lo he puesto mas abajo): unsigned __stdcall Answer(void* a) { Socket* s = (Socket*) a; while (1) { std::string r = s->ReceiveLine(); if (r.empty()) break; s->SendLine(r); } delete s; return 0; } int main(int argc, char* argv[]) { SocketServer in(2000,5); while (1) { Socket* s=in.Accept(); unsigned ret; _beginthreadex(0,0,Answer,(void*) s,0,&ret); } return 0; }
En mi programa, mi problema está en que yo estoy haciendo uso de dicha clase socket, y de actuar como servidor, dentro de una clase que me he creado. Y el problema que tengo es que, tras recibir datos por el socket, yo quiero comprobar si son un tipo de datos u otros, y uso variables globales pertenecientes a mi clase. Para trabajar en mi clase tendre que declarar la función main como Nombremiclase::Server(int arg...). Y para ver las variables globales desde la stdcall, supongo que tendré que ponerla en mi clase también... No se, llevo varios dias intentandolo y estoy hundido, no hay manera. A ver si alguien supiese. Os dejo el codigo que tengo implementado en mi clase, y el error que obtengo, que es : In member function 'void L2cap::Server (int,char**)' argument of type 'unsigned int (L2cap:: )(void*) does not match 'unsigned int (*)(void*)') Buil error (L2cap.o) Error 1. unsigned __stdcall L2cap::Answer(void* a) { L2capChannel canal; Socket* s = (Socket*) a; unsigned int longitud, leidos, tipo, pos, NumBytes,opt; unsigned int* datain = NULL; int size; while (1) // escuchando { std::string r = s->ReceiveBytes(); size = r.length(); L2cap::string_to_bytearray(r,datain,size); Write(datain,size); longitud = size-4; // se trata del campo length, mientras q size es toda tipo = Leertipotrama (datain); if (r =="exit") { // escuchando = false; // cout<<"Escuchando se ha puesto a false"<<endl; } else if ((r.length())>0) { cout <<"Recibida una string de longitud "<<r.length()<<endl<<"y contenido: "<<r<<endl<<endl; canal.EntradaDatos(r); } // s->SendBytes(r); } delete s; return 0; } void L2cap::Server(int argc, char* argv[]) // Modo Servidor { SocketServer in(3000,5); while (escuchando) { Socket* s=in.Accept(); unsigned ret; _beginthreadex(0,0,L2cap::Answer,(void*) s,0,&ret); } }
Ojalá podais ayudarme, muchísimas gracias de antemano. Un saludo.
|
|
|