@@ -2314,22 +2314,6 @@ PHP_METHOD(Redis, discard)
2314
2314
redis_send_discard (INTERNAL_FUNCTION_PARAM_PASSTHRU ,redis_sock );
2315
2315
}
2316
2316
2317
- PHP_REDIS_API int
2318
- redis_sock_read_multibulk_pipeline_reply (INTERNAL_FUNCTION_PARAMETERS ,
2319
- RedisSock * redis_sock )
2320
- {
2321
- array_init (return_value );
2322
-
2323
- redis_sock_read_multibulk_multi_reply_loop (INTERNAL_FUNCTION_PARAM_PASSTHRU ,
2324
- redis_sock ,return_value ,0 );
2325
-
2326
- /* free allocated function/request memory */
2327
- free_reply_callbacks (redis_sock );
2328
-
2329
- return 0 ;
2330
-
2331
- }
2332
-
2333
2317
/* redis_sock_read_multibulk_multi_reply */
2334
2318
PHP_REDIS_API int redis_sock_read_multibulk_multi_reply (INTERNAL_FUNCTION_PARAMETERS ,
2335
2319
RedisSock * redis_sock )
@@ -2378,8 +2362,7 @@ PHP_METHOD(Redis, exec)
2378
2362
2379
2363
IF_MULTI () {
2380
2364
cmd_len = redis_cmd_format_static (& cmd ,"EXEC" ,"" );
2381
-
2382
- SOCKET_WRITE_COMMAND (redis_sock ,cmd ,cmd_len )
2365
+ SOCKET_WRITE_COMMAND (redis_sock ,cmd ,cmd_len )
2383
2366
efree (cmd );
2384
2367
2385
2368
if (redis_sock_read_multibulk_multi_reply (
@@ -2414,11 +2397,12 @@ PHP_METHOD(Redis, exec)
2414
2397
offset += ri -> request_size ;
2415
2398
}
2416
2399
request [total ]= '\0' ;
2417
- if (redis_sock_write (redis_sock ,request ,total TSRMLS_CC )< 0 ||
2418
- redis_sock_read_multibulk_pipeline_reply (
2419
- INTERNAL_FUNCTION_PARAM_PASSTHRU ,redis_sock )< 0
2420
- ) {
2400
+ if (redis_sock_write (redis_sock ,request ,total TSRMLS_CC )< 0 ) {
2421
2401
ZVAL_FALSE (return_value );
2402
+ }else {
2403
+ array_init (return_value );
2404
+ redis_sock_read_multibulk_multi_reply_loop (
2405
+ INTERNAL_FUNCTION_PARAM_PASSTHRU ,redis_sock ,return_value ,0 );
2422
2406
}
2423
2407
efree (request );
2424
2408
}else {