51 lines
1.0 KiB
C
51 lines
1.0 KiB
C
|
#ifndef BUFIO_H
|
|||
|
|
#define BUFIO_H
|
|||
|
|
|
|||
|
|
#include <sys/types.h>
|
|||
|
|
#include "def.h"
|
|||
|
|
|
|||
|
|
#ifdef WINDOWS
|
|||
|
|
#include <Winsock2.h>
|
|||
|
|
#endif
|
|||
|
|
|
|||
|
|
class BufIo
|
|||
|
|
{
|
|||
|
|
private:
|
|||
|
|
char *b;
|
|||
|
|
size_t p;
|
|||
|
|
size_t n;
|
|||
|
|
|
|||
|
|
int f_socket_remote_closed;
|
|||
|
|
|
|||
|
|
ssize_t _realloc_buffer();
|
|||
|
|
ssize_t _SEND(SOCKET socket,char *buf,size_t len);
|
|||
|
|
ssize_t _RECV(SOCKET socket,char *buf,size_t len);
|
|||
|
|
|
|||
|
|
public:
|
|||
|
|
BufIo();
|
|||
|
|
~BufIo() { if(b){ delete []b; b = (char*) 0;} }
|
|||
|
|
|
|||
|
|
|
|||
|
|
void Reset(){ p = 0; f_socket_remote_closed = 0;}
|
|||
|
|
|
|||
|
|
void Close(){
|
|||
|
|
if( b ){ delete []b; b = (char*) 0; }
|
|||
|
|
p = n = 0;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
size_t Count() const { return p; } //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֽ<EFBFBD><D6BD><EFBFBD>
|
|||
|
|
size_t LeftSize() const { return (n - p); }
|
|||
|
|
|
|||
|
|
ssize_t PickUp(size_t len); //<2F>Ƴ<EFBFBD><C6B3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ǰlen<65><6E><EFBFBD>ֽ<EFBFBD>
|
|||
|
|
|
|||
|
|
ssize_t FeedIn(SOCKET sk); //<2F><>sk<73><6B><EFBFBD><EFBFBD><EFBFBD>ݵ<EFBFBD><DDB5><EFBFBD><EFBFBD><EFBFBD>ֱ<EFBFBD><D6B1><EFBFBD><EFBFBD>ʱ<EFBFBD><CAB1><EFBFBD><EFBFBD><EFBFBD>ݿɶ<DDBF><C9B6><EFBFBD><F2BBBAB3><EFBFBD><EFBFBD><EFBFBD>
|
|||
|
|
ssize_t FlushOut(SOCKET sk); //<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>д<EFBFBD><D0B4>socket
|
|||
|
|
ssize_t Put(SOCKET sk,char *buf,size_t len); //<2F><>buf<75><66><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ӵ<EFBFBD><D3B5><EFBFBD><EFBFBD><EFBFBD>
|
|||
|
|
ssize_t PutFlush(SOCKET sk,char *buf,size_t len);
|
|||
|
|
|
|||
|
|
char *BasePointer(){ return b; }
|
|||
|
|
char *CurrentPointer() { return ( b + p); }
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
#endif
|