~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to vio/violite.h

  • Committer: Brian Aker
  • Date: 2008-08-08 15:38:16 UTC
  • Revision ID: brian@tangent.org-20080808153816-858pru9i35hq1rgz
Merging up a bunch of assert() and cleanup of my_sock typedef

Show diffs side-by-side

added added

removed removed

Lines of Context:
38
38
#define VIO_BUFFERED_READ 2                     /* use buffered read */
39
39
#define VIO_READ_BUFFER_SIZE 16384              /* size of read buffer */
40
40
 
41
 
Vio*    vio_new(my_socket sd, enum enum_vio_type type, uint flags);
 
41
Vio*    vio_new(int sd, enum enum_vio_type type, uint flags);
42
42
 
43
43
void    vio_delete(Vio* vio);
44
44
int     vio_close(Vio* vio);
45
 
void    vio_reset(Vio* vio, enum enum_vio_type type, my_socket sd, uint32_t flags);
 
45
void    vio_reset(Vio* vio, enum enum_vio_type type, int sd, uint32_t flags);
46
46
size_t  vio_read(Vio *vio, uchar *      buf, size_t size);
47
47
size_t  vio_read_buff(Vio *vio, uchar * buf, size_t size);
48
48
size_t  vio_write(Vio *vio, const uchar * buf, size_t size);
63
63
/* Return last error number */
64
64
int     vio_errno(Vio*vio);
65
65
/* Get socket number */
66
 
my_socket vio_fd(Vio*vio);
 
66
int vio_fd(Vio*vio);
67
67
/* Remote peer's address and name in text form */
68
68
bool vio_peer_addr(Vio *vio, char *buf, uint16_t *port, size_t buflen);
69
 
bool    vio_poll_read(Vio *vio,uint timeout);
 
69
bool vio_poll_read(Vio *vio, int timeout);
70
70
bool vio_peek_read(Vio *vio, uint *bytes);
71
71
 
72
72
void vio_end(void);
107
107
/* This structure is for every connection on both sides */
108
108
struct st_vio
109
109
{
110
 
  my_socket             sd;             /* my_socket - real or imaginary */
 
110
  int           sd;             /* int - real or imaginary */
111
111
  int                   fcntl_mode;     /* Buffered fcntl(sd,F_GETFL) */
112
112
  struct sockaddr_storage       local;          /* Local internet address */
113
113
  struct sockaddr_storage       remote;         /* Remote internet address */
132
132
  bool (*should_retry)(Vio*);
133
133
  bool (*was_interrupted)(Vio*);
134
134
  int32_t     (*vioclose)(Vio*);
135
 
  void    (*timeout)(Vio*, uint32_t which, uint32_t timeout);
 
135
  void    (*timeout)(Vio*, bool is_sndtimeo, int32_t timeout);
136
136
  char                  *read_buffer;   /* buffer for vio_read_buff */
137
137
};
138
138
#endif /* vio_violite_h_ */