proxmox-mirrors/libgit2
1
0
Fork 0
mirror of https://git.proxmox.com/git/libgit2 synced 2025-08-06 04:49:46 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add gitno_buffer as a recv wrapper

Browse Source 
Signed-off-by: Carlos Martín Nieto <carlos@cmartin.tk>
This commit is contained in:
Carlos Martín Nieto 2011-06-24 16:25:26 +02:00
parent ce90a407c7
commit ea7a5452f4
2 changed files with 59 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
src/netops.c
View File

@ -38,6 +38,53 @@
#include "common.h"
#include "netops.h"
void gitno_buffer_setup(gitno_buffer *buf, void*data, unsigned int len, int fd)
{
memset(buf, 0x0, sizeof(gitno_buffer));
memset(data, 0x0, len);
buf->data = data;
buf->len = len - 1;
buf->offset = 0;
buf->fd = fd;
}
int gitno_recv(gitno_buffer *buf)
{
int ret;
ret = recv(buf->fd, buf->data + buf->offset, buf->len - buf->offset, 0);
if (ret < 0)
return git__throw(GIT_EOSERR, "Failed to receive data");
if (ret == 0) /* Orderly shutdown, so exit */
return GIT_SUCCESS;
buf->offset += ret;
return ret;
}
/* Consume up to ptr and move the rest of the buffer to the beginning */
void gitno_consume(gitno_buffer *buf, void *ptr)
{
int left;
assert(ptr - buf->data <= (int) buf->len);
left = buf->len - (ptr - buf->data);
memmove(buf->data, ptr, left);
memset(ptr, 0x0, left);
buf->offset = left;
}
/* Consume const bytes and move the rest of the buffer to the beginning */
void gitno_consume_n(gitno_buffer *buf, unsigned int cons)
{
memmove(buf->data, buf->data + cons, buf->len - buf->offset);
memset(buf->data + cons, 0x0, buf->len - buf->offset);
buf->offset -= cons;
}
int gitno_connect(const char *host, const char *port)
{
struct addrinfo *info, *p;

12
src/netops.h
View File

@ -4,6 +4,18 @@
#ifndef INCLUDE_netops_h__
#define INCLUDE_netops_h__
typedef struct gitno_buffer {
void *data;
unsigned int len;
unsigned int offset;
int fd;
} gitno_buffer;
void gitno_buffer_setup(gitno_buffer *buf, void *data, unsigned int len, int fd);
int gitno_recv(gitno_buffer *buf);
void gitno_consume(gitno_buffer *buf, void *ptr);
void gitno_consume_n(gitno_buffer *buf, unsigned int cons);
int gitno_connect(const char *host, const char *port);
int gitno_send(int s, const char *msg, int len, int flags);