sofia windows compiler warnings

This commit is contained in:
Jeff Lenk 2013-04-02 17:25:10 -05:00
parent ed782ed15b
commit ff9571e1e9
3 changed files with 65 additions and 39 deletions

View File

@ -60,6 +60,12 @@
static char const __func__[] = "tport_type_ws"; static char const __func__[] = "tport_type_ws";
#endif #endif
#if HAVE_WIN32
#include <io.h>
#define access(_filename, _mode) _access(_filename, _mode)
#define R_OK (04)
#endif
/* ---------------------------------------------------------------------- */ /* ---------------------------------------------------------------------- */
/* WS */ /* WS */

View File

@ -120,22 +120,24 @@ static int cheezy_get_var(char *data, char *name, char *buf, size_t buflen)
if (p != (char *)1 && *p!='\0') { if (p != (char *)1 && *p!='\0') {
char *v, *e; char *v, *e = 0;
if ((v = strchr(p, ':'))) { v = strchr(p, ':');
if (v) {
v++; v++;
while(v && *v == ' ') { while(v && *v == ' ') {
v++; v++;
} }
if (v) { if (v) {
if (!(e = strchr(v, '\r'))) { e = strchr(v, '\r');
if (!e) {
e = strchr(v, '\n'); e = strchr(v, '\n');
} }
} }
if (v && e) { if (v && e) {
int cplen; int cplen;
int len = e - v; size_t len = e - v;
if (len > buflen - 1) { if (len > buflen - 1) {
cplen = buflen -1; cplen = buflen -1;
@ -159,6 +161,9 @@ static int b64encode(unsigned char *in, size_t ilen, unsigned char *out, size_t
size_t x=0; size_t x=0;
unsigned int b=0,l=0; unsigned int b=0,l=0;
if(olen) {
}
for(x=0;x<ilen;x++) { for(x=0;x<ilen;x++) {
b = (b<<8) + in[x]; b = (b<<8) + in[x];
l += 8; l += 8;
@ -218,8 +223,8 @@ int ws_handshake(wsh_t *wsh)
unsigned char output[SHA1_HASH_SIZE] = ""; unsigned char output[SHA1_HASH_SIZE] = "";
char b64[256] = ""; char b64[256] = "";
char respond[512] = ""; char respond[512] = "";
ssize_t bytes; issize_t bytes;
char *p, *e; char *p, *e = 0;
if (wsh->sock == ws_sock_invalid) { if (wsh->sock == ws_sock_invalid) {
return -3; return -3;
@ -240,7 +245,8 @@ int ws_handshake(wsh_t *wsh)
p = wsh->buffer + 4; p = wsh->buffer + 4;
if (!(e = strchr(p, ' '))) { e = strchr(p, ' ');
if (!e) {
goto err; goto err;
} }
@ -289,15 +295,19 @@ int ws_handshake(wsh_t *wsh)
} }
ssize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes) issize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes)
{ {
ssize_t r; issize_t r;
int x = 0; int x = 0;
if (wsh->ssl) { if (wsh->ssl) {
do { do {
r = SSL_read(wsh->ssl, data, bytes); r = SSL_read(wsh->ssl, data, bytes);
#ifndef _MSC_VER
if (x++) usleep(10000); if (x++) usleep(10000);
#else
if (x++) Sleep(10);
#endif
} while (r == -1 && SSL_get_error(wsh->ssl, r) == SSL_ERROR_WANT_READ && x < 100); } while (r == -1 && SSL_get_error(wsh->ssl, r) == SSL_ERROR_WANT_READ && x < 100);
return r; return r;
@ -305,7 +315,11 @@ ssize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes)
do { do {
r = recv(wsh->sock, data, bytes, 0); r = recv(wsh->sock, data, bytes, 0);
if (x++) usleep(10000); #ifndef _MSC_VER
if (x++) usleep(10000);
#else
if (x++) Sleep(10);
#endif
} while (r == -1 && (errno == EAGAIN || errno == EINTR) && x < 100); } while (r == -1 && (errno == EAGAIN || errno == EINTR) && x < 100);
//if (r<0) { //if (r<0) {
@ -315,7 +329,7 @@ ssize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes)
return r; return r;
} }
ssize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes) issize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes)
{ {
size_t r; size_t r;
@ -388,7 +402,7 @@ int ws_init(wsh_t *wsh, ws_socket_t sock, size_t buflen, SSL_CTX *ssl_ctx, int c
return 0; return 0;
} }
ssize_t ws_close(wsh_t *wsh, int16_t reason) issize_t ws_close(wsh_t *wsh, int16_t reason)
{ {
if (wsh->down) { if (wsh->down) {
@ -437,10 +451,10 @@ ssize_t ws_close(wsh_t *wsh, int16_t reason)
} }
ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data) issize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data)
{ {
ssize_t need = 2; issize_t need = 2;
char *maskp; char *maskp;
again: again:
@ -509,7 +523,7 @@ ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data)
u64 = (uint64_t *) wsh->payload; u64 = (uint64_t *) wsh->payload;
wsh->payload += 8; wsh->payload += 8;
wsh->plen = ntohl(*u64); wsh->plen = ntohl((u_long)*u64);
} else if (wsh->plen == 126) { } else if (wsh->plen == 126) {
uint16_t *u16; uint16_t *u16;
@ -534,7 +548,7 @@ ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data)
need = (wsh->plen - (wsh->datalen - need)); need = (wsh->plen - (wsh->datalen - need));
if ((need + wsh->datalen) > wsh->buflen) { if ((need + wsh->datalen) > (issize_t)wsh->buflen) {
/* too big - Ain't nobody got time fo' dat */ /* too big - Ain't nobody got time fo' dat */
*oc = WSOC_CLOSE; *oc = WSOC_CLOSE;
return ws_close(wsh, WS_DATA_TOO_BIG); return ws_close(wsh, WS_DATA_TOO_BIG);
@ -543,7 +557,7 @@ ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data)
wsh->rplen = wsh->plen - need; wsh->rplen = wsh->plen - need;
while(need) { while(need) {
ssize_t r = ws_raw_read(wsh, wsh->payload + wsh->rplen, need); issize_t r = ws_raw_read(wsh, wsh->payload + wsh->rplen, need);
if (r < 1) { if (r < 1) {
/* invalid read - protocol err .. */ /* invalid read - protocol err .. */
@ -557,7 +571,7 @@ ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data)
} }
if (mask && maskp) { if (mask && maskp) {
uint32_t i; issize_t i;
for (i = 0; i < wsh->datalen; i++) { for (i = 0; i < wsh->datalen; i++) {
wsh->payload[i] ^= maskp[i % 4]; wsh->payload[i] ^= maskp[i % 4];
@ -590,7 +604,7 @@ ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data)
} }
} }
ssize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes) issize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes)
{ {
if (bytes + wsh->wdatalen > wsh->buflen) { if (bytes + wsh->wdatalen > wsh->buflen) {
@ -611,9 +625,9 @@ ssize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes)
return bytes; return bytes;
} }
ssize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc) issize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc)
{ {
ssize_t r = 0; issize_t r = 0;
if (!wsh->wdatalen) { if (!wsh->wdatalen) {
return -1; return -1;
@ -627,7 +641,7 @@ ssize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc)
} }
ssize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes) issize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes)
{ {
uint8_t hdr[14] = { 0 }; uint8_t hdr[14] = { 0 };
size_t hlen = 2; size_t hlen = 2;
@ -638,10 +652,10 @@ ssize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes)
//printf("WRITE[%ld]-----------------------------:\n[%s]\n-----------------------------------\n", bytes, (char *) data); //printf("WRITE[%ld]-----------------------------:\n[%s]\n-----------------------------------\n", bytes, (char *) data);
hdr[0] = oc | 0x80; hdr[0] = (uint8_t)(oc | 0x80);
if (bytes < 126) { if (bytes < 126) {
hdr[1] = bytes; hdr[1] = (uint8_t)bytes;
} else if (bytes < 0x10000) { } else if (bytes < 0x10000) {
uint16_t *u16; uint16_t *u16;
@ -661,11 +675,11 @@ ssize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes)
*u64 = htonl(bytes); *u64 = htonl(bytes);
} }
if (ws_raw_write(wsh, (void *) &hdr[0], hlen) != hlen) { if (ws_raw_write(wsh, (void *) &hdr[0], hlen) != (issize_t)hlen) {
return -1; return -1;
} }
if (ws_raw_write(wsh, data, bytes) != bytes) { if (ws_raw_write(wsh, data, bytes) != (issize_t)bytes) {
return -2; return -2;
} }

View File

@ -8,19 +8,24 @@
#define B64BUFFLEN 1024 #define B64BUFFLEN 1024
#include <sys/types.h> #include <sys/types.h>
#ifndef _MSC_VER
#include <arpa/inet.h> #include <arpa/inet.h>
#include <sys/wait.h> #include <sys/wait.h>
#include <sys/socket.h>
#else
#pragma warning(disable:4996)
#endif
#include <string.h> #include <string.h>
#include <unistd.h> #include <unistd.h>
#include <string.h> #include <string.h>
#include <stdint.h> #include <stdint.h>
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#include <sys/socket.h>
#include <assert.h> #include <assert.h>
#include <errno.h> #include <errno.h>
//#include "sha1.h" //#include "sha1.h"
#include <openssl/ssl.h> #include <openssl/ssl.h>
#include <sofia-sip/su_types.h>
struct globals_s { struct globals_s {
@ -57,11 +62,11 @@ typedef struct wsh_s {
char *buffer; char *buffer;
char *wbuffer; char *wbuffer;
size_t buflen; size_t buflen;
ssize_t datalen; issize_t datalen;
ssize_t wdatalen; issize_t wdatalen;
char *payload; char *payload;
ssize_t plen; issize_t plen;
ssize_t rplen; issize_t rplen;
SSL *ssl; SSL *ssl;
int handshake; int handshake;
uint8_t down; uint8_t down;
@ -70,25 +75,26 @@ typedef struct wsh_s {
unsigned :0; unsigned :0;
} wsh_t; } wsh_t;
ssize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc); issize_t ws_send_buf(wsh_t *wsh, ws_opcode_t oc);
ssize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes); issize_t ws_feed_buf(wsh_t *wsh, void *data, size_t bytes);
ssize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes); issize_t ws_raw_read(wsh_t *wsh, void *data, size_t bytes);
ssize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes); issize_t ws_raw_write(wsh_t *wsh, void *data, size_t bytes);
ssize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data); issize_t ws_read_frame(wsh_t *wsh, ws_opcode_t *oc, uint8_t **data);
ssize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes); issize_t ws_write_frame(wsh_t *wsh, ws_opcode_t oc, void *data, size_t bytes);
int ws_init(wsh_t *wsh, ws_socket_t sock, size_t buflen, SSL_CTX *ssl_ctx, int close_sock); int ws_init(wsh_t *wsh, ws_socket_t sock, size_t buflen, SSL_CTX *ssl_ctx, int close_sock);
ssize_t ws_close(wsh_t *wsh, int16_t reason); issize_t ws_close(wsh_t *wsh, int16_t reason);
void init_ssl(void); void init_ssl(void);
void deinit_ssl(void); void deinit_ssl(void);
#ifndef _MSC_VER
static inline uint64_t get_unaligned_uint64(const void *p) static inline uint64_t get_unaligned_uint64(const void *p)
{ {
const struct { uint64_t d; } __attribute__((packed)) *pp = p; const struct { uint64_t d; } __attribute__((packed)) *pp = p;
return pp->d; return pp->d;
} }
#endif
#endif #endif