if ((nr= ::recv(ptr->fd,
ptr->read_ptr + ptr->read_data_length,
MEMCACHED_MAX_BUFFER - ptr->read_data_length,
- MSG_DONTWAIT|MSG_NOSIGNAL)) <= 0)
+ MSG_NOSIGNAL)) <= 0)
{
if (nr == 0)
{
int flags;
if (with_flush)
{
- flags= MSG_NOSIGNAL|MSG_DONTWAIT;
+ flags= MSG_NOSIGNAL;
}
else
{
- flags= MSG_NOSIGNAL|MSG_DONTWAIT|MSG_MORE;
+ flags= MSG_NOSIGNAL|MSG_MORE;
}
ssize_t sent_length= ::send(ptr->fd, local_write_ptr, write_length, flags);
ssize_t data_read;
do
{
- data_read= ::recv(ptr->fd, ptr->read_buffer, MEMCACHED_MAX_BUFFER, MSG_DONTWAIT|MSG_NOSIGNAL);
+ data_read= ::recv(ptr->fd, ptr->read_buffer, MEMCACHED_MAX_BUFFER, MSG_NOSIGNAL);
if (data_read == SOCKET_ERROR)
{
switch (get_socket_errno())
char buffer[MEMCACHED_MAX_BUFFER];
do
{
- data_read= ::recv(ptr->fd, ptr->read_buffer, sizeof(buffer), MSG_DONTWAIT|MSG_NOSIGNAL);
+ data_read= ::recv(ptr->fd, ptr->read_buffer, sizeof(buffer), MSG_NOSIGNAL);
if (data_read == SOCKET_ERROR)
{
switch (get_socket_errno())