Changeset 5257
- Timestamp:
- 02/12/08 07:59:23 (1 year ago)
- Files:
-
- libwired/trunk/libwired/p7/wi-p7-socket.c (modified) (5 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
libwired/trunk/libwired/p7/wi-p7-socket.c
r5253 r5257 954 954 } 955 955 956 p7_spec = wi_p7_spec_init_with_string(wi_p7_spec_alloc(), string); 956 p7_spec = wi_p7_spec_init_with_string(wi_p7_spec_alloc(), string, 957 wi_p7_spec_opposite_originator(wi_p7_spec_originator(p7_socket->spec))); 957 958 958 959 if(!p7_spec) … … 1254 1255 input += input_processed; 1255 1256 input_size -= input_processed; 1257 1258 if(compression == _WI_P7_SOCKET_DECOMPRESS && input_size == 0) 1259 break; 1256 1260 } 1257 1261 … … 1266 1270 static int _wi_p7_socket_xflate_buffer(z_stream *stream, _wi_p7_socket_compression_t compression, const void *input, uint32_t input_size, uint32_t *input_processed, void *output, uint32_t *output_size) { 1267 1271 int err; 1268 1272 1269 1273 stream->next_in = (Bytef *) input; 1270 1274 stream->avail_in = input_size; … … 1274 1278 stream->avail_out = *output_size; 1275 1279 stream->total_out = 0; 1276 1280 1277 1281 if(compression == _WI_P7_SOCKET_COMPRESS) 1278 1282 err = deflate(stream, Z_SYNC_FLUSH); … … 1280 1284 err = inflate(stream, Z_SYNC_FLUSH); 1281 1285 1282 *input_processed = stream->total_in; 1283 *output_size = stream->total_out; 1286 if(err == Z_OK) { 1287 *input_processed = stream->total_in; 1288 *output_size = stream->total_out; 1289 } 1284 1290 1285 1291 return err;
