devs/libstrophe-gh
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Replace usage of EBADFD (not in POSIX)

Browse Source
This commit is contained in:
Omar Polo
2024-02-05 10:29:17 +01:00
committed by Steffen Jaeckel
parent d6d71e97f8
commit 9410530507
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/compression.c
View File

@@ -63,7 +63,7 @@ static int _conn_decompress(struct xmpp_compression *comp,
break; break;
default: default:
strophe_error(comp->conn->ctx, "zlib", "inflate error %d", ret); strophe_error(comp->conn->ctx, "zlib", "inflate error %d", ret);
comp->conn->error = EBADFD; comp->conn->error = ret;
conn_disconnect(comp->conn); conn_disconnect(comp->conn);
break; break;
} }
@@ -129,7 +129,7 @@ _compression_write(xmpp_conn_t *conn, const void *buff, size_t len, int flush)
} }
if (ret != Z_OK) { if (ret != Z_OK) {
strophe_error(conn->ctx, "zlib", "deflate error %d", ret); strophe_error(conn->ctx, "zlib", "deflate error %d", ret);
conn->error = EBADFD; conn->error = ret;
conn_disconnect(conn); conn_disconnect(conn);
return ret; return ret;
} }
@@ -227,22 +227,22 @@ int compression_init(xmpp_conn_t *conn)
comp->compression.stream.next_out = comp->compression.buffer; comp->compression.stream.next_out = comp->compression.buffer;
comp->compression.stream.avail_out = STROPHE_COMPRESSION_BUFFER_SIZE; comp->compression.stream.avail_out = STROPHE_COMPRESSION_BUFFER_SIZE;
int err = deflateInit(&comp->compression.stream, Z_DEFAULT_COMPRESSION); int ret = deflateInit(&comp->compression.stream, Z_DEFAULT_COMPRESSION);
if (err != Z_OK) { if (ret != Z_OK) {
strophe_free_and_null(conn->ctx, comp->compression.buffer); strophe_free_and_null(conn->ctx, comp->compression.buffer);
conn->error = EBADFD; conn->error = ret;
conn_disconnect(conn); conn_disconnect(conn);
return err; return ret;
} }
_init_zlib_compression(conn->ctx, &comp->decompression); _init_zlib_compression(conn->ctx, &comp->decompression);
err = inflateInit(&comp->decompression.stream); ret = inflateInit(&comp->decompression.stream);
if (err != Z_OK) { if (ret != Z_OK) {
strophe_free_and_null(conn->ctx, comp->decompression.buffer); strophe_free_and_null(conn->ctx, comp->decompression.buffer);
conn->error = EBADFD; conn->error = ret;
conn_disconnect(conn); conn_disconnect(conn);
return err; return ret;
} }
return 0; return 0;
} }