mirror of
https://github.com/php/php-src.git
synced 2026-03-31 04:32:19 +02:00
86 lines
2.0 KiB
C
86 lines
2.0 KiB
C
/*
|
|
+----------------------------------------------------------------------+
|
|
| PHP Version 5 |
|
|
+----------------------------------------------------------------------+
|
|
| Copyright (c) 1997-2014 The PHP Group |
|
|
+----------------------------------------------------------------------+
|
|
| This source file is subject to version 3.01 of the PHP license, |
|
|
| that is bundled with this package in the file LICENSE, and is |
|
|
| available through the world-wide-web at the following url: |
|
|
| http://www.php.net/license/3_01.txt |
|
|
| If you did not receive a copy of the PHP license and are unable to |
|
|
| obtain it through the world-wide-web, please send a note to |
|
|
| license@php.net so we can mail you a copy immediately. |
|
|
+----------------------------------------------------------------------+
|
|
| Authors: Anatol Belski <ab@php.net> |
|
|
+----------------------------------------------------------------------+
|
|
*/
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif
|
|
|
|
#include "phpdbg_io.h"
|
|
|
|
PHPDBG_API int
|
|
phpdbg_consume_bytes(int sock, char *ptr, int len, int tmo)
|
|
{/*{{{*/
|
|
int got_now, i = len, j;
|
|
char *p = ptr;
|
|
#ifndef PHP_WIN32
|
|
struct pollfd pfd;
|
|
|
|
pfd.fd = sock;
|
|
pfd.events = POLLIN;
|
|
|
|
j = poll(&pfd, 1, tmo);
|
|
|
|
if (j == 0) {
|
|
#else
|
|
struct fd_set readfds;
|
|
struct timeval ttmo;
|
|
|
|
FD_ZERO(&readfds);
|
|
FD_SET(sock, &readfds);
|
|
|
|
ttmo.tv_sec = 0;
|
|
ttmo.tv_usec = tmo*1000;
|
|
|
|
j = select(0, &readfds, NULL, NULL, &ttmo);
|
|
|
|
if (j <= 0) {
|
|
#endif
|
|
return -1;
|
|
}
|
|
|
|
while(i > 0) {
|
|
got_now = recv(sock, p, i, 0);
|
|
if (got_now == -1) {
|
|
return -1;
|
|
}
|
|
i -= got_now;
|
|
p += got_now;
|
|
}
|
|
|
|
return len;
|
|
}/*}}}*/
|
|
|
|
PHPDBG_API int
|
|
phpdbg_send_bytes(int sock, char *ptr, int len)
|
|
{/*{{{*/
|
|
int sent, i = len;
|
|
char *p = ptr;
|
|
|
|
while(i > 0) {
|
|
sent = send(sock, p, i, 0);
|
|
if (sent == -1) {
|
|
return -1;
|
|
}
|
|
i -= sent;
|
|
p += sent;
|
|
}
|
|
|
|
return len;
|
|
}/*}}}*/
|
|
|