agorise/c-libp2p
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

logic fix

Browse source
This commit is contained in:
jmjatlanta 2017-08-09 11:12:16 -05:00
parent f84ec579f2
commit bff867ae4d
1 changed files with 14 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
secio/secio.c
View file

@ -44,13 +44,24 @@ int libp2p_secio_can_handle(const uint8_t* incoming, size_t incoming_size) {
return 0; return 0;
char* result = strstr((char*)incoming, "/ipfs/secio"); char* result = strstr((char*)incoming, "/ipfs/secio");
if (result != NULL && result == (char*)incoming) if (result != NULL && result == (char*)incoming)
return 0;
return 1; return 1;
return 0;
} }
/***
* Handle a secio message
* @param incoming the incoming bytes
* @param incoming_size the size of the incoming buffer
* @param session_context who is attempting to connect
* @param protocol_context a SecioContext that contains the needed information
* @returns <0 on error, 0 if okay
*/
int libp2p_secio_handle_message(const uint8_t* incoming, size_t incoming_size, struct SessionContext* session_context, void* protocol_context) { int libp2p_secio_handle_message(const uint8_t* incoming, size_t incoming_size, struct SessionContext* session_context, void* protocol_context) {
struct SecioContext* ctx = (struct SecioContext*)protocol_context; struct SecioContext* ctx = (struct SecioContext*)protocol_context;
return libp2p_secio_handshake(session_context, ctx->private_key, ctx->peer_store); int retVal = libp2p_secio_handshake(session_context, ctx->private_key, ctx->peer_store);
if (retVal)
return 0;
return -1;
} }
int libp2p_secio_shutdown(void* context) { int libp2p_secio_shutdown(void* context) {