← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to vio/viosocket.c

  • Committer: Monty
  • Date: 2008-10-02 14:34:07 UTC
  • Revision ID: mordred@scylla.inaugust.com-20081002143407-id6de0nl3trrna4j
Fixed some max/min misses.

Show diffs side-by-side

added added

removed removed

Lines of Context:
vio/viosocket.c
22
22
 
23
23
#include "vio_priv.h"
24
24
#include <sys/socket.h>
25
 
#include <drizzled/util/test.h>
26
25
 
27
26
int vio_errno(Vio *vio __attribute__((unused)))
28
27
{
29
 
  return errno;
 
28
  return socket_errno;          /* On Win32 this mapped to WSAGetLastError() */
30
29
}
31
30
 
32
31
 
33
 
size_t vio_read(Vio * vio, unsigned char* buf, size_t size)
 
32
size_t vio_read(Vio * vio, uchar* buf, size_t size)
34
33
{
35
34
  size_t r;
36
35
 
47
46
  reduce number of syscalls.
48
47
*/
49
48
 
50
 
size_t vio_read_buff(Vio *vio, unsigned char* buf, size_t size)
 
49
size_t vio_read_buff(Vio *vio, uchar* buf, size_t size)
51
50
{
52
51
  size_t rc;
53
52
#define VIO_UNBUFFERED_READ_MIN_SIZE 2048
65
64
  }
66
65
  else if (size < VIO_UNBUFFERED_READ_MIN_SIZE)
67
66
  {
68
 
    rc= vio_read(vio, (unsigned char*) vio->read_buffer, VIO_READ_BUFFER_SIZE);
 
67
    rc= vio_read(vio, (uchar*) vio->read_buffer, VIO_READ_BUFFER_SIZE);
69
68
    if (rc != 0 && rc != (size_t) -1)
70
69
    {
71
70
      if (rc > size)
85
84
}
86
85
 
87
86
 
88
 
size_t vio_write(Vio * vio, const unsigned char* buf, size_t size)
 
87
size_t vio_write(Vio * vio, const uchar* buf, size_t size)
89
88
{
90
89
  size_t r;
91
90
 
168
167
bool
169
168
vio_should_retry(Vio * vio __attribute__((unused)))
170
169
{
171
 
  int en = errno;
172
 
  return (en == EAGAIN || en == EINTR ||
173
 
          en == EWOULDBLOCK);
 
170
  int en = socket_errno;
 
171
  return (en == SOCKET_EAGAIN || en == SOCKET_EINTR ||
 
172
          en == SOCKET_EWOULDBLOCK);
174
173
}
175
174
 
176
175
 
177
176
bool
178
177
vio_was_interrupted(Vio *vio __attribute__((unused)))
179
178
{
180
 
  int en= errno;
181
 
  return (en == EAGAIN || en == EINTR ||
182
 
          en == EWOULDBLOCK || en == ETIMEDOUT);
 
179
  int en= socket_errno;
 
180
  return (en == SOCKET_EAGAIN || en == SOCKET_EINTR ||
 
181
          en == SOCKET_EWOULDBLOCK || en == SOCKET_ETIMEDOUT);
183
182
}
184
183
 
185
184