head	1.6;
access;
symbols;
locks; strict;
comment	@ * @;


1.6
date	2001.08.23.12.43.26;	author simons;	state Exp;
branches;
next	1.5;

1.5
date	2001.08.23.12.42.49;	author simons;	state Exp;
branches;
next	1.4;

1.4
date	2001.08.23.12.41.12;	author simons;	state Exp;
branches;
next	1.3;

1.3
date	2001.08.23.12.39.26;	author simons;	state Exp;
branches;
next	1.2;

1.2
date	2001.08.23.12.34.40;	author simons;	state Exp;
branches;
next	1.1;

1.1
date	2001.08.23.12.24.47;	author simons;	state Exp;
branches;
next	;


desc
@@


1.6
log
@Remove unnecessary whitespace.
@
text
@#ifndef __LIBAMP_H__
#define __LIBAMP_H__

#include <sys/types.h>
#include <sys/uio.h>
#include <unistd.h>
#include <stdio.h>
#include <sys/socket.h>

typedef struct
    {
    int (*listen)(int fd, int backlog);
    int (*accept)(int fd, struct sockaddr* addr, socklen_t* addrlen);
    int (*bind)(int fd, const struct sockaddr* addr, socklen_t addrlen);
    int (*connect)(int fd, const struct sockaddr* name, socklen_t namelen);
    ssize_t (*read)(int fd, void* buf, size_t nbytes);
    ssize_t (*readv)(int fd, const struct iovec* iov, int iovcnt);
    ssize_t (*write)(int fd, const void* buf, size_t nbytes);
    ssize_t (*writev)(int fd, const struct iovec* iov, int iovcnt);
    ssize_t (*send)(int s, const void* msg, size_t len, int flags);
    ssize_t (*sendto)(int s, const void* msg, size_t len, int flags,
		      const struct sockaddr* to, socklen_t tolen);
    ssize_t (*recv)(int s, void* buf, size_t len, int flags);
    ssize_t (*recvfrom)(int s, void* buf, size_t len, int flags, struct sockaddr* from,
			socklen_t* fromlen);
    }
amp_engine_t;

typedef struct
    {
    int fd;
    amp_engine_t engine;
    }
amp_peer_t;

amp_peer_t* amp_create_message_port(const char* peer, amp_engine_t* engine);
int amp_destroy_message_port(amp_peer_t* peer);

amp_peer_t* amp_create_peer(const char* peer, const char* engine);
int amp_destroy_peer(amp_peer_t* peer);

int amp_peer2fd(amp_peer_t* peer);
amp_peer_t* amp_fd2peer(int fd);

int amp_send(amp_peer_t* peer, const void* msg, size_t msg_len);
int amp_receive(amp_peer_t* peer, const void** msg, size_t* msg_len);

#endif /* !defined(__LIBAMP_H__) */
@


1.5
log
@amp_create_xxx() now expects an amp_engine_t* as parameter.
@
text
@d12 3
a14 3
    int (*listen) (int fd, int backlog);
    int (*accept) (int fd, struct sockaddr* addr, socklen_t* addrlen);
    int (*bind) (int fd, const struct sockaddr* addr, socklen_t addrlen);
d16 4
a19 4
    ssize_t (*read) (int fd, void* buf, size_t nbytes);
    ssize_t (*readv) (int fd, const struct iovec* iov, int iovcnt);
    ssize_t (*write) (int fd, const void* buf, size_t nbytes);
    ssize_t (*writev) (int fd, const struct iovec* iov, int iovcnt);
@


1.4
log
@Added prototypes of routines mapping between amp_peer_t and fd.
@
text
@d36 1
a36 1
amp_peer_t* amp_create_message_port(const char* engine, const char* peer);
d39 1
a39 1
amp_peer_t* amp_create_peer(const char* engine, const char* peer);
@


1.3
log
@Added connect() to amp_engine_t.
@
text
@d42 3
@


1.2
log
@Added more routines to amp_engine_t.
@
text
@d13 5
a17 4
    int (*accept) (int fd, struct sockaddr *addr, socklen_t *addrlen);
    int (*bind) (int fd, const struct sockaddr *addr, socklen_t addrlen);
    ssize_t (*read) (int fd, void *buf, size_t nbytes);
    ssize_t (*readv) (int fd, const struct iovec *iov, int iovcnt);
d20 6
a25 6
    ssize_t (*send)(int s, const void *msg, size_t len, int flags);
    ssize_t (*sendto)(int s, const void *msg, size_t len, int flags,
		      const struct sockaddr *to, socklen_t tolen);
    ssize_t (*recv)(int s, void *buf, size_t len, int flags);
    ssize_t (*recvfrom)(int s, void *buf, size_t len, int flags, struct sockaddr *from,
			socklen_t *fromlen);
d35 3
@


1.1
log
@Added a skeleton project for the amp library.
@
text
@d12 13
a24 7
    int (*listen)(int s, int backlog);
    int (*accept)(int s, struct sockaddr *addr, socklen_t *addrlen);
    int (*bind)(int s, const struct sockaddr *addr, socklen_t addrlen);
    ssize_t (*read)(int d, void *buf, size_t nbytes);
    ssize_t (*readv)(int d, const struct iovec *iov, int iovcnt);
    ssize_t (*write)(int d, const void* buf, size_t nbytes);
    ssize_t (*writev)(int d, const struct iovec* iov, int iovcnt);
d30 1
a30 1
    int          fd;
d37 3
@