Jeff Thompson | 7850d78 | 2013-07-14 17:59:14 -0700 | [diff] [blame] | 1 | /* |
| 2 | * File: TcpTransport.h |
| 3 | * Author: jefft0 |
| 4 | * |
| 5 | * Created on July 14, 2013, 4:15 PM |
| 6 | */ |
| 7 | |
| 8 | #ifndef NDN_TCPTRANSPORT_H |
Jeff Thompson | 2d27e2f | 2013-08-09 12:55:00 -0700 | [diff] [blame] | 9 | #define NDN_TCPTRANSPORT_H |
Jeff Thompson | 7850d78 | 2013-07-14 17:59:14 -0700 | [diff] [blame] | 10 | |
Jeff Thompson | 5341219 | 2013-08-06 13:35:50 -0700 | [diff] [blame] | 11 | #include "socket-transport.h" |
Jeff Thompson | 0d567da | 2013-07-14 22:10:21 -0700 | [diff] [blame] | 12 | |
Jeff Thompson | 2d27e2f | 2013-08-09 12:55:00 -0700 | [diff] [blame] | 13 | #ifdef __cplusplus |
Jeff Thompson | 7850d78 | 2013-07-14 17:59:14 -0700 | [diff] [blame] | 14 | extern "C" { |
| 15 | #endif |
| 16 | |
| 17 | struct ndn_TcpTransport { |
Jeff Thompson | 0aa754a | 2013-07-17 17:42:28 -0700 | [diff] [blame] | 18 | struct ndn_SocketTransport base; |
Jeff Thompson | 7850d78 | 2013-07-14 17:59:14 -0700 | [diff] [blame] | 19 | }; |
| 20 | |
Jeff Thompson | 432c8be | 2013-08-09 16:16:08 -0700 | [diff] [blame] | 21 | /** |
| 22 | * Initialize the ndn_TcpTransport struct with default values for no connection yet. |
| 23 | * @param self A pointer to the ndn_TcpTransport struct. |
| 24 | */ |
Jeff Thompson | 0d567da | 2013-07-14 22:10:21 -0700 | [diff] [blame] | 25 | static inline void ndn_TcpTransport_init(struct ndn_TcpTransport *self) |
Jeff Thompson | 7850d78 | 2013-07-14 17:59:14 -0700 | [diff] [blame] | 26 | { |
Jeff Thompson | 0aa754a | 2013-07-17 17:42:28 -0700 | [diff] [blame] | 27 | ndn_SocketTransport_init(&self->base); |
Jeff Thompson | 7850d78 | 2013-07-14 17:59:14 -0700 | [diff] [blame] | 28 | } |
| 29 | |
Jeff Thompson | 432c8be | 2013-08-09 16:16:08 -0700 | [diff] [blame] | 30 | /** |
| 31 | * Connect with TCP to the host:port. |
| 32 | * @param self A pointer to the ndn_TcpTransport struct. |
| 33 | * @param host The host to connect to. |
| 34 | * @param port The port to connect to. |
| 35 | * @return 0 for success, else an error code. |
| 36 | */ |
Jeff Thompson | 0aa754a | 2013-07-17 17:42:28 -0700 | [diff] [blame] | 37 | static inline ndn_Error ndn_TcpTransport_connect(struct ndn_TcpTransport *self, char *host, unsigned short port) |
| 38 | { |
| 39 | return ndn_SocketTransport_connect(&self->base, SOCKET_TCP, host, port); |
| 40 | } |
Jeff Thompson | 0d567da | 2013-07-14 22:10:21 -0700 | [diff] [blame] | 41 | |
Jeff Thompson | 432c8be | 2013-08-09 16:16:08 -0700 | [diff] [blame] | 42 | /** |
| 43 | * Send data to the socket. |
| 44 | * @param self A pointer to the ndn_TcpTransport struct. |
| 45 | * @param data A pointer to the buffer of data to send. |
| 46 | * @param dataLength The number of bytes in data. |
| 47 | * @return 0 for success, else an error code. |
| 48 | */ |
Jeff Thompson | 0aa754a | 2013-07-17 17:42:28 -0700 | [diff] [blame] | 49 | static inline ndn_Error ndn_TcpTransport_send(struct ndn_TcpTransport *self, unsigned char *data, unsigned int dataLength) |
| 50 | { |
| 51 | return ndn_SocketTransport_send(&self->base, data, dataLength); |
| 52 | } |
Jeff Thompson | 0d567da | 2013-07-14 22:10:21 -0700 | [diff] [blame] | 53 | |
Jeff Thompson | 432c8be | 2013-08-09 16:16:08 -0700 | [diff] [blame] | 54 | /** |
| 55 | * Check if there is data ready on the socket to be received with ndn_TcpTransport_receive. |
| 56 | * @param self A pointer to the ndn_TcpTransport struct. |
| 57 | * @param receiveIsReady This will be set to 1 if data is ready, 0 if not. |
| 58 | * @return 0 for success, else an error code. |
| 59 | */ |
| 60 | static inline ndn_Error ndn_TcpTransport_receiveIsReady(struct ndn_TcpTransport *self, int *receiveIsReady) |
| 61 | { |
| 62 | return ndn_SocketTransport_receiveIsReady(&self->base, receiveIsReady); |
| 63 | } |
| 64 | |
| 65 | /** |
| 66 | * Receive data from the socket. NOTE: This is a blocking call. You should first call ndn_SocketTransport_receiveIsReady |
| 67 | * to make sure there is data ready to receive. |
| 68 | * @param self A pointer to the ndn_TcpTransport struct. |
| 69 | * @param buffer A pointer to the buffer to receive the data. |
| 70 | * @param bufferLength The maximum length of buffer. |
| 71 | * @param nBytes Return the number of bytes received into buffer. |
| 72 | * @return 0 for success, else an error code. |
| 73 | */ |
Jeff Thompson | 0aa754a | 2013-07-17 17:42:28 -0700 | [diff] [blame] | 74 | static inline ndn_Error ndn_TcpTransport_receive |
| 75 | (struct ndn_TcpTransport *self, unsigned char *buffer, unsigned int bufferLength, unsigned int *nBytes) |
| 76 | { |
| 77 | return ndn_SocketTransport_receive(&self->base, buffer, bufferLength, nBytes); |
| 78 | } |
Jeff Thompson | 0d567da | 2013-07-14 22:10:21 -0700 | [diff] [blame] | 79 | |
Jeff Thompson | 432c8be | 2013-08-09 16:16:08 -0700 | [diff] [blame] | 80 | /** |
| 81 | * Close the socket. |
| 82 | * @param self A pointer to the ndn_TcpTransport struct. |
| 83 | * @return 0 for success, else an error code. |
| 84 | */ |
Jeff Thompson | 5796388 | 2013-08-05 16:01:25 -0700 | [diff] [blame] | 85 | static inline ndn_Error ndn_TcpTransport_close(struct ndn_TcpTransport *self) |
| 86 | { |
| 87 | return ndn_SocketTransport_close(&self->base); |
| 88 | } |
| 89 | |
Jeff Thompson | 2d27e2f | 2013-08-09 12:55:00 -0700 | [diff] [blame] | 90 | #ifdef __cplusplus |
Jeff Thompson | 7850d78 | 2013-07-14 17:59:14 -0700 | [diff] [blame] | 91 | } |
| 92 | #endif |
| 93 | |
| 94 | #endif |