diff --git a/client.c b/client.c index 9fca925..17f1639 100644 --- a/client.c +++ b/client.c @@ -40,7 +40,7 @@ int client_connect(conn_handler handler, char *servip, int16_t port) { if(0 != ret) break; - if (0 >= write(connfd, buffer, sizeof(buffer))) { + if (0 >= write(connfd, buffer, strlen(buffer))) { printf("client_connect: cannot write to socket\n"); ret = -1; } diff --git a/issuer.c b/issuer.c index 42127af..dcb754d 100644 --- a/issuer.c +++ b/issuer.c @@ -95,6 +95,7 @@ int process_issuer(char *buffer) { } break; default: + issuer.state = READY; bzero(buffer, MAX_BUFSIZE); strncpy(buffer, "ERR\n", 4); break; @@ -107,6 +108,7 @@ int process_issuer(char *buffer) { } break; default: + issuer.state = READY; bzero(buffer, MAX_BUFSIZE); strncpy(buffer, "ERR\n", 4); break; @@ -135,6 +137,7 @@ int process_issuer(char *buffer) { printf("error()\n"); bzero(buffer, MAX_BUFSIZE); strncpy(buffer, "ERR\n", 4); + issuer.state = READY; ret = 0; } diff --git a/member.c b/member.c index 205bee3..84b0509 100644 --- a/member.c +++ b/member.c @@ -205,23 +205,23 @@ int member_verifymsg(char *buffer) { } //"PUBLISH" > "PUBLISH " -int member_publish(char *buffer) { - char *current; - int ret = 0; - uint8_t binbuf[MAX_BUFSIZE]; - bzero(buffer, MAX_BUFSIZE); +/* int member_publish(char *buffer) { */ +/* char *current; */ +/* int ret = 0; */ +/* uint8_t binbuf[MAX_BUFSIZE]; */ +/* bzero(buffer, MAX_BUFSIZE); */ - strncpy(buffer, "PUBLISH ", 8); +/* strncpy(buffer, "PUBLISH ", 8); */ - current = &buffer[8]; - bzero(binbuf, MAX_BUFSIZE); - ecdaa_member_public_key_FP256BN_serialize(binbuf, &member.mpk); - ret = ecdaa_encode(binbuf, current, ECDAA_MEMBER_PUBLIC_KEY_FP256BN_LENGTH); +/* current = &buffer[8]; */ +/* bzero(binbuf, MAX_BUFSIZE); */ +/* ecdaa_member_public_key_FP256BN_serialize(binbuf, &member.mpk); */ +/* ret = ecdaa_encode(binbuf, current, ECDAA_MEMBER_PUBLIC_KEY_FP256BN_LENGTH); */ - current[ret] = '\n'; +/* current[ret] = '\n'; */ - return 0; -} +/* return 0; */ +/* } */ //"JOINSTART " > "APPEND " int member_joinappend(char *buffer) {