Subversion Repositories planix.SVN

enum {

	NbNameLen = 16,	

	NbnsTimeoutBroadcast = 1000,

	NbnsRetryBroadcast = 3,

	NbnsPort = 137,

	NbDgramMaxLen = 576,

};

typedef struct NbnsHdr {

	uchar name_trn_id[2];

	uchar ctrl[2];

	uchar qdcount[2];

	uchar ancount[2];

	uchar nscount[2];

	uchar arcount[2];

} NbnsHdr;

enum {

	NbnsResponse = 1 << 15

};

enum {

	NbnsOpShift = 11,

	NbnsOpMask = 0xf,

	NbnsOpQuery = 0,

	NbnsOpRegistration = 5,

	NbnsOpRelease = 6,

	NbnsOpWack = 7,

	NbnsOpRefresh = 8

};

enum {

	NbnsFlagBroadcast = (1 << 4),

	NbnsFlagRecursionAvailable = (1 << 7),

	NbnsFlagRecursionDesired = (1 << 8),

	NbnsFlagTruncation = (1 << 9),

	NbnsFlagAuthoritativeAnswer = (1 << 10),

};

enum {

	NbnsRcodeShift = 0,

	NbnsRcodeMask = 0xf,

};

enum {

	NbnsQuestionTypeNb = 0x0020,

	NbnsQuestionTypeNbStat = 0x0021,

	NbnsQuestionClassIn = 0x0001,

};

enum {

	NbnsResourceTypeA = 0x0001,

	NbnsResourceTypeNs = 0x0002,

	NbnsResourceTypeNull = 0x000a,

	NbnsResourceTypeNb = 0x0020,

	NbnsResourceTypeNbStat = 0x0021,

	NbnsResourceClassIn = 0x0001,

};

typedef struct NbnsMessageQuestion NbnsMessageQuestion;

typedef struct NbnsMessageResource NbnsMessageResource;

typedef uchar NbName[NbNameLen];

int nbnamedecode(uchar *base, uchar *p, uchar *ep, NbName name);

int nbnameencode(uchar *p, uchar *ep, NbName name);

int nbnameequal(NbName name1, NbName name2);

void nbnamecpy(NbName n1, NbName n2);

void nbmknamefromstring(NbName nbname, char *string);

void nbmknamefromstringandtype(NbName nbname, char *string, uchar type);

void nbmkstringfromname(char *buf, int buflen, NbName name);

#pragma varargck type "B" uchar *

int nbnamefmt(Fmt *);

struct NbnsMessageQuestion {

	NbName name;

	ushort type;

	ushort class;

	NbnsMessageQuestion *next;

};

NbnsMessageQuestion *nbnsmessagequestionnew(NbName name, ushort type, ushort class);

struct NbnsMessageResource {

	NbName name;

	ushort type;

	ushort class;

	ulong ttl;

	ushort rdlength;

	uchar *rdata;

	NbnsMessageResource *next;

};

NbnsMessageResource *nbnsmessageresourcenew(NbName name, ushort type, ushort class, ulong ttl, int rdcount, uchar *rdata);

typedef struct NbnsMessage {

	ushort id;

	int response;

	int opcode;

	int broadcast;

	int recursionavailable;

	int recursiondesired;

	int truncation;

	int authoritativeanswer;

	int rcode;

	NbnsMessageQuestion *q;

	NbnsMessageResource *an;

	NbnsMessageResource *ns;

	NbnsMessageResource *ar;

} NbnsMessage;

NbnsMessage *nbnsmessagenew(void);

void nbnsmessageaddquestion(NbnsMessage *s, NbnsMessageQuestion *q);

void nbnsmessageaddresource(NbnsMessageResource **rp, NbnsMessageResource *r);

NbnsMessage *nbnsconvM2S(uchar *ap, int nap);

void nbnsmessagefree(NbnsMessage **sp);

void nbnsdumpmessage(NbnsMessage *s);

int nbnsconvS2M(NbnsMessage *s, uchar *ap, int nap);

NbnsMessage *nbnsmessagenamequeryrequestnew(ushort id, int broadcast, NbName name);

NbnsMessage *nbnsmessagenameregistrationrequestnew(ushort id, int broadcast, NbName name, ulong ttl, uchar *ipaddr);

typedef struct NbnsTransaction NbnsTransaction;

struct NbnsTransaction {

	ushort id;

	Channel *c;

	NbnsTransaction *next;

};

ushort nbnsnextid(void);

int nbnsfindname(uchar *serveripaddr, NbName name, uchar *ipaddr, ulong *ttlp);

int nbnsaddname(uchar *serveripaddr, NbName name, ulong ttl, uchar *ipaddr);

NbnsTransaction *nbnstransactionnew(NbnsMessage *request, uchar *ipaddr);

void nbnstransactionfree(NbnsTransaction **tp);

typedef struct NbnsAlarm NbnsAlarm;

struct NbnsAlarm {

	Channel *c;

	vlong expirems;

	NbnsAlarm *next;

};

void nbnsalarmset(NbnsAlarm *a, ulong millisec);

void nbnsalarmcancel(NbnsAlarm *a);

void nbnsalarmfree(NbnsAlarm **ap);

NbnsAlarm *nbnsalarmnew(void);

void nbnsalarmend(void);

typedef struct NbSession NbSession;

typedef int NBSSWRITEFN(NbSession *s, void *buf, long n);

struct NbSession {

	int fd;

	void *magic;

	NbName from;

	NbName to;

};

int nbsslisten(NbName to, NbName from, int (*accept)(void *magic, NbSession *s, NBSSWRITEFN **write), void *magic);

NbSession *nbssconnect(NbName to, NbName from);

void nbssfree(NbSession *s);

typedef struct NbScatterGather NbScatterGather;

struct NbScatterGather {

	void *p;

	long l;

};

int nbssgatherwrite(NbSession *s, NbScatterGather *a);

long nbssscatterread(NbSession *, NbScatterGather *a);

int nbsswrite(NbSession *s, void *buf, long n);

long nbssread(NbSession *s, void *buf, long n);

void *nbemalloc(ulong);

int nbnameresolve(NbName name, uchar *ipaddr);

void nbdumpdata(void *data, long datalen);

typedef struct NbDgram {

	uchar type;

	uchar flags;

	ushort id;

	uchar srcip[IPaddrlen];

	ushort srcport;

	union {

		struct {

			ushort length;

			ushort offset;

			NbName srcname;

			NbName dstname;

			uchar *data;

		} datagram;

		struct {

			uchar code;

		} error;

		struct {

			NbName dstname;

		} query;

	};

} NbDgram;

enum {

	NbDgramDirectUnique = 0x10,

	NbDgramDirectGroup,

	NbDgramBroadcast,

	NbDgramError,

	NbDgramQueryRequest,

	NbDgramPositiveQueryResponse,

	NbDgramNegativeQueryResponse,

	NbDgramMore = 1,

	NbDgramFirst = 2,

	NbDgramPort = 138,

	NbDgramErrorDestinationNameNotPresent = 0x82,

	NbDgramMaxPacket = 576,

};

typedef struct NbDgramSendParameters {

	NbName to;

	uchar type;

} NbDgramSendParameters;

int nbdgramconvM2S(NbDgram *s, uchar *p, uchar *ep);

int nbdgramconvS2M(uchar *p, uchar *ep, NbDgram *s);

void nbdgramdump(NbDgram *s);

int nbdgramsendto(uchar *ipaddr, ushort port, NbDgram *s);

int nbdgramsend(NbDgramSendParameters *p, unsigned char *data, long datalen);

char *nbdgramlisten(NbName to, int (*deliver)(void *magic, NbDgram *s), void *magic);

int nbnametablefind(NbName name, int add);

int nbnameisany(NbName name);

int nbremotenametablefind(NbName name, uchar *ipaddr);

int nbremotenametableadd(NbName name, uchar *ipaddr, ulong ttl);

typedef struct NbGlobals {

	uchar myipaddr[IPaddrlen];

	uchar bcastaddr[IPaddrlen];

	NbName myname;

} NbGlobals;

extern NbGlobals nbglobals;

extern NbName nbnameany;

int nbinit(void);

char *nbudpannounce(ushort port, int *fdp);

extern int nbudphdrsize;