summaryrefslogtreecommitdiffstats
path: root/runtime/netstrm.h
diff options
context:
space:
mode:
authorRainer Gerhards <rgerhards@adiscon.com>2008-04-18 11:40:15 +0200
committerRainer Gerhards <rgerhards@adiscon.com>2008-04-18 11:40:15 +0200
commit1daf8d492f932739b6fcde732812116c7666b2bc (patch)
tree24dd3b699f1e4277919a64f4d9f513e1821b7b01 /runtime/netstrm.h
parentea4a3a3cd95faf9328def84e3e253d6c1a4375f7 (diff)
downloadrsyslog-1daf8d492f932739b6fcde732812116c7666b2bc.tar.gz
rsyslog-1daf8d492f932739b6fcde732812116c7666b2bc.tar.xz
rsyslog-1daf8d492f932739b6fcde732812116c7666b2bc.zip
converted netstrm into generic netstrm and the nsd_pctp driver
Diffstat (limited to 'runtime/netstrm.h')
-rw-r--r--runtime/netstrm.h14
1 files changed, 7 insertions, 7 deletions
diff --git a/runtime/netstrm.h b/runtime/netstrm.h
index 7f267a36..75b7c457 100644
--- a/runtime/netstrm.h
+++ b/runtime/netstrm.h
@@ -24,21 +24,21 @@
#ifndef INCLUDED_NETSTRM_H
#define INCLUDED_NETSTRM_H
+#include "nsd.h" /* we need our driver interface to be defined */
+
/* the netstrm object */
struct netstrm_s {
BEGINobjInstance; /* Data to implement generic object - MUST be the first data element! */
- uchar *pRemHostIP; /**< IP address of remote peer (currently used in server mode, only) */
- uchar *pRemHostName; /**< host name of remote peer (currently used in server mode, only) */
- int sock; /**< the socket we use for regular, single-socket, operations */
- int *socks; /**< the socket(s) we use for listeners, element 0 has nbr of socks */
- int iSessMax; /**< maximum number of sessions permitted */
+ nsd_if_t Drvr; /**< our stream driver */
+ nsd_t *pDrvrData; /**< the driver's data elements */
+ uchar *pDrvrName; /**< nsd driver name to use, or NULL if system default */
};
-/* interfaces */
+/* interface */
BEGINinterface(netstrm) /* name must also be changed in ENDinterface macro! */
rsRetVal (*Construct)(netstrm_t **ppThis);
- rsRetVal (*ConstructFinalize)(netstrm_t __attribute__((unused)) *pThis);
+ rsRetVal (*ConstructFinalize)(netstrm_t *pThis);
rsRetVal (*Destruct)(netstrm_t **ppThis);
rsRetVal (*AbortDestruct)(netstrm_t **ppThis);
rsRetVal (*LstnInit)(netstrm_t *pThis, unsigned char *pLstnPort);