diff options
| author | Even Rouault <even.rouault@spatialys.com> | 2017-05-09 15:44:46 +0200 |
|---|---|---|
| committer | Even Rouault <even.rouault@spatialys.com> | 2017-05-09 20:46:20 +0200 |
| commit | 563bd8499e63db976ca8358216138647593354bc (patch) | |
| tree | 003599ed2b0cffd932d2122c3f72c142070efafd /src/lib/openjpip/imgsock_manager.c | |
| parent | d4e54e9f35d532062533f1d369c159810b01d224 (diff) | |
Reformat whole codebase with astyle.options (#128)
Diffstat (limited to 'src/lib/openjpip/imgsock_manager.c')
| -rw-r--r-- | src/lib/openjpip/imgsock_manager.c | 292 |
1 files changed, 154 insertions, 138 deletions
diff --git a/src/lib/openjpip/imgsock_manager.c b/src/lib/openjpip/imgsock_manager.c index 4337e608..35eb5489 100644 --- a/src/lib/openjpip/imgsock_manager.c +++ b/src/lib/openjpip/imgsock_manager.c @@ -36,174 +36,190 @@ #define strncasecmp _strnicmp #endif -msgtype_t identify_clientmsg( SOCKET connected_socket) +msgtype_t identify_clientmsg(SOCKET connected_socket) { - OPJ_SIZE_T receive_size; - char buf[BUF_LEN]; - static const char *magicid[] = { "JPIP-stream", "PNM request", "XML request", - "TID request", "CID request", "CID destroy", "SIZ request", "JP2 save", - "QUIT"}; - int i; - - receive_size = receive_line( connected_socket, buf); - - if( receive_size == 0){ - fprintf( stderr, "Error to receive the header of client message\n"); - return MSGERROR; - } + OPJ_SIZE_T receive_size; + char buf[BUF_LEN]; + static const char *magicid[] = { "JPIP-stream", "PNM request", "XML request", + "TID request", "CID request", "CID destroy", "SIZ request", "JP2 save", + "QUIT" + }; + int i; + + receive_size = receive_line(connected_socket, buf); + + if (receive_size == 0) { + fprintf(stderr, "Error to receive the header of client message\n"); + return MSGERROR; + } - for( i=0; i<NUM_OF_MSGTYPES; i++){ - if( strncasecmp( magicid[i], buf, strlen(magicid[i])) == 0){ - fprintf( stderr, "%s\n", magicid[i]); - return i; + for (i = 0; i < NUM_OF_MSGTYPES; i++) { + if (strncasecmp(magicid[i], buf, strlen(magicid[i])) == 0) { + fprintf(stderr, "%s\n", magicid[i]); + return i; + } } - } - - fprintf( stderr, "Cannot identify client message type %s\n", buf); - return MSGERROR; + + fprintf(stderr, "Cannot identify client message type %s\n", buf); + return MSGERROR; } -Byte_t * receive_JPIPstream( SOCKET connected_socket, char **target, char **tid, char **cid, OPJ_SIZE_T *streamlen) +Byte_t * receive_JPIPstream(SOCKET connected_socket, char **target, char **tid, + char **cid, OPJ_SIZE_T *streamlen) { - char buf[BUF_LEN]; - const char versionstring[] = "version 1.2"; - int idatalen; - OPJ_SIZE_T linelen, datalen; - Byte_t *jpipstream; - - *target = *cid = *tid = NULL; - - if((linelen = receive_line( connected_socket, buf)) == 0) - return NULL; - if( strncmp( versionstring, buf, strlen(versionstring))!=0){ - fprintf( stderr, "Wrong format\n"); - return NULL; - } - - if((linelen = receive_line( connected_socket, buf)) == 0) - return NULL; - - if( strstr( buf, "jp2")){ - /* register cid option*/ - *target = strdup( buf); - - if((linelen = receive_line( connected_socket, buf)) == 0) - return NULL; - if( strcmp( buf, "0") != 0) - *tid = strdup( buf); - - if((linelen = receive_line( connected_socket, buf)) == 0) - return NULL; - if( strcmp( buf, "0") != 0) - *cid = strdup( buf); - - if((linelen = receive_line( connected_socket, buf)) == 0) - return NULL; - } - - idatalen = atoi( buf); - if( idatalen < 0 ) - { - fprintf( stderr, "Receive Data: %d Bytes\n", idatalen); - return NULL; + char buf[BUF_LEN]; + const char versionstring[] = "version 1.2"; + int idatalen; + OPJ_SIZE_T linelen, datalen; + Byte_t *jpipstream; + + *target = *cid = *tid = NULL; + + if ((linelen = receive_line(connected_socket, buf)) == 0) { + return NULL; + } + if (strncmp(versionstring, buf, strlen(versionstring)) != 0) { + fprintf(stderr, "Wrong format\n"); + return NULL; + } + + if ((linelen = receive_line(connected_socket, buf)) == 0) { + return NULL; + } + + if (strstr(buf, "jp2")) { + /* register cid option*/ + *target = strdup(buf); + + if ((linelen = receive_line(connected_socket, buf)) == 0) { + return NULL; + } + if (strcmp(buf, "0") != 0) { + *tid = strdup(buf); + } + + if ((linelen = receive_line(connected_socket, buf)) == 0) { + return NULL; + } + if (strcmp(buf, "0") != 0) { + *cid = strdup(buf); + } + + if ((linelen = receive_line(connected_socket, buf)) == 0) { + return NULL; + } + } + + idatalen = atoi(buf); + if (idatalen < 0) { + fprintf(stderr, "Receive Data: %d Bytes\n", idatalen); + return NULL; + } + datalen = (OPJ_SIZE_T)idatalen; + fprintf(stdout, "Receive Data: %lu Bytes\n", datalen); + + jpipstream = receive_stream(connected_socket, datalen); + + /* check EOR*/ + if (jpipstream[datalen - 3] == 0x00 && (jpipstream[datalen - 2] == 0x01 || + jpipstream[datalen - 2] == 0x02)) { + *streamlen = datalen - 3; + } else { + *streamlen = datalen; } - datalen = (OPJ_SIZE_T)idatalen; - fprintf( stdout, "Receive Data: %lu Bytes\n", datalen); - - jpipstream = receive_stream( connected_socket, datalen); - - /* check EOR*/ - if( jpipstream[datalen-3] == 0x00 && ( jpipstream[datalen-2] == 0x01 || jpipstream[datalen-2] == 0x02)) - *streamlen = datalen -3; - else - *streamlen = datalen; - - return jpipstream; + + return jpipstream; } -void send_XMLstream( SOCKET connected_socket, Byte_t *xmlstream, OPJ_SIZE_T length) +void send_XMLstream(SOCKET connected_socket, Byte_t *xmlstream, + OPJ_SIZE_T length) { - Byte_t header[5]; - - header[0] = 'X'; - header[1] = 'M'; - header[2] = 'L'; - header[3] = (Byte_t)((length >> 8) & 0xff); - header[4] = (Byte_t)(length & 0xff); - - send_stream( connected_socket, header, 5); - send_stream( connected_socket, xmlstream, length); + Byte_t header[5]; + + header[0] = 'X'; + header[1] = 'M'; + header[2] = 'L'; + header[3] = (Byte_t)((length >> 8) & 0xff); + header[4] = (Byte_t)(length & 0xff); + + send_stream(connected_socket, header, 5); + send_stream(connected_socket, xmlstream, length); } -void send_IDstream( SOCKET connected_socket, const char *id, OPJ_SIZE_T idlen, const char *label); +void send_IDstream(SOCKET connected_socket, const char *id, OPJ_SIZE_T idlen, + const char *label); -void send_CIDstream( SOCKET connected_socket, const char *cid, OPJ_SIZE_T cidlen) +void send_CIDstream(SOCKET connected_socket, const char *cid, OPJ_SIZE_T cidlen) { - send_IDstream( connected_socket, cid, cidlen, "CID"); + send_IDstream(connected_socket, cid, cidlen, "CID"); } -void send_TIDstream( SOCKET connected_socket, const char *tid, OPJ_SIZE_T tidlen) +void send_TIDstream(SOCKET connected_socket, const char *tid, OPJ_SIZE_T tidlen) { - send_IDstream( connected_socket, tid, tidlen, "TID"); + send_IDstream(connected_socket, tid, tidlen, "TID"); } -void send_IDstream( SOCKET connected_socket, const char *id, OPJ_SIZE_T idlen, const char *label) +void send_IDstream(SOCKET connected_socket, const char *id, OPJ_SIZE_T idlen, + const char *label) { - char header[4]; + char header[4]; - header[0] = label[0]; - header[1] = label[1]; - header[2] = label[2]; - header[3] = (char)(idlen & 0xff); + header[0] = label[0]; + header[1] = label[1]; + header[2] = label[2]; + header[3] = (char)(idlen & 0xff); - send_stream( connected_socket, header, 4); - send_stream( connected_socket, id, idlen); + send_stream(connected_socket, header, 4); + send_stream(connected_socket, id, idlen); } -void send_PNMstream( SOCKET connected_socket, Byte_t *pnmstream, unsigned int width, unsigned int height, unsigned int numofcomp, Byte_t maxval) -{ - OPJ_SIZE_T pnmlen = 0; - Byte_t header[7]; - - pnmlen = width*height*numofcomp; - - header[0] = 'P'; - header[1] = numofcomp==3 ? 6:5; - header[2] = (width >> 8) & 0xff; - header[3] = width & 0xff; - header[4] = (height >> 8) & 0xff; - header[5] = height & 0xff; - header[6] = maxval; - - send_stream( connected_socket, header, 7); - send_stream( connected_socket, pnmstream, pnmlen); +void send_PNMstream(SOCKET connected_socket, Byte_t *pnmstream, + unsigned int width, unsigned int height, unsigned int numofcomp, Byte_t maxval) +{ + OPJ_SIZE_T pnmlen = 0; + Byte_t header[7]; + + pnmlen = width * height * numofcomp; + + header[0] = 'P'; + header[1] = numofcomp == 3 ? 6 : 5; + header[2] = (width >> 8) & 0xff; + header[3] = width & 0xff; + header[4] = (height >> 8) & 0xff; + header[5] = height & 0xff; + header[6] = maxval; + + send_stream(connected_socket, header, 7); + send_stream(connected_socket, pnmstream, pnmlen); } -void send_SIZstream( SOCKET connected_socket, unsigned int width, unsigned int height) +void send_SIZstream(SOCKET connected_socket, unsigned int width, + unsigned int height) { - Byte_t response[9]; - - response[0] = 'S'; - response[1] = 'I'; - response[2] = 'Z'; - response[3] = (width >> 16) & 0xff; - response[4] = (width >> 8) & 0xff; - response[5] = width & 0xff; - response[6] = (height >> 16) & 0xff; - response[7] = (height >> 8) & 0xff; - response[8] = height & 0xff; - - send_stream( connected_socket, response, 9); + Byte_t response[9]; + + response[0] = 'S'; + response[1] = 'I'; + response[2] = 'Z'; + response[3] = (width >> 16) & 0xff; + response[4] = (width >> 8) & 0xff; + response[5] = width & 0xff; + response[6] = (height >> 16) & 0xff; + response[7] = (height >> 8) & 0xff; + response[8] = height & 0xff; + + send_stream(connected_socket, response, 9); } -void response_signal( SOCKET connected_socket, OPJ_BOOL succeed) +void response_signal(SOCKET connected_socket, OPJ_BOOL succeed) { - Byte_t code; + Byte_t code; - if( succeed) - code = 1; - else - code = 0; + if (succeed) { + code = 1; + } else { + code = 0; + } - send_stream( connected_socket, &code, 1); + send_stream(connected_socket, &code, 1); } |
