arzmq-sys 0.6.3

Low-level bindings to the zeromq library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128

/*********************************************************************
 *
 * AUTHORIZATION TO USE AND DISTRIBUTE
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that: 
 *
 * (1) source code distributions retain this paragraph in its entirety, 
 *  
 * (2) distributions including binary code include this paragraph in
 *     its entirety in the documentation or other materials provided 
 *     with the distribution, and 
 *
 * (3) all advertising materials mentioning features or use of this 
 *     software display the following acknowledgment:
 * 
 *      "This product includes software written and developed 
 *       by Brian Adamson, Joe Macker and Justin Dean of the 
 *       Naval Research Laboratory (NRL)." 
 *         
 *  The name of NRL, the name(s) of NRL  employee(s), or any entity
 *  of the United States Government may not be used to endorse or
 *  promote  products derived from this software, nor does the 
 *  inclusion of the NRL written and developed software  directly or
 *  indirectly suggest NRL or United States  Government endorsement
 *  of this product.
 * 
 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
 ********************************************************************/

// New router template for adding a protocol to CMU extensions of ns2

#ifndef __ProtoManetKernel_h__
#define __ProtoManetKernel_h__

#include <cmu-trace.h>
#include <priqueue.h>
#include <rtqueue.h>
#include <rttable.h>
#include <classifier/classifier-port.h>
//#include <packet.h>
#include <red.h>
#include "protoDebug.h"       // for DMSG()


#define CURRENT_TIME    Scheduler::instance().clock()
#define INVALID                -1                          // invalid return value

class ProtolibMK; // forward decleration

/**
 * @class BroadcastID
 *
 * @brief Broadcast ID Cache
*/
class BroadcastID {
  friend class ProtolibMK;
 public:
        BroadcastID(nsaddr_t i, u_int32_t b) { src = i; id = b;  }
 protected:
        LIST_ENTRY(BroadcastID) link;
        nsaddr_t        src;
        u_int32_t       id;
        double          expire;         // now + BCAST_ID_SAVE s
};

LIST_HEAD(bcache, BroadcastID);


/**
 * @class ProtolibMK
 * 
 * @brief  The Routing Agent
 */
class ProtolibMK: public Agent {

 public:
        ProtolibMK(nsaddr_t id); // constructor

        void		recv(Packet *p, Handler *);
	void            rt_failed(Packet *p);
	int             index;
	void            forward(Packet *p, nsaddr_t nexthop);// used to forward packets in entirety
	bool            bcastforward(Packet *p); // used to decied to forward broadcast packets back out interface. returns true if it does.

 protected:
	int idnumber;
	int numberofforwards, numberofrecv;
        int             command(int, const char *const *); 
        int             initialized() { return 1 && target_; } 
	NsObject*       ProtolibMKFind(Packet* p); //used to see if listener is attached to node code modified from Classifier::find
	Agent*          manetpointer;
								/*
         * Packet TX Routines
         */
	void            forward(char *copysh); // used for forwarding the sub header part of the packet 
	
        bcache          bihead;                 // Broadcast ID Cache

        /*
         * A mechanism for logging the contents of the routing
         * table.
         */
	 Trace           *logtarget;

        /*
         * A pointer to the network interface queue that sits
         * between the "classifier" and the "link layer".
         */
        PriQueue        *ifqueue;
	/* for passing packets up to agents */
	PortClassifier *dmux_;

};

#endif /* __ProtoManetKernel_h__ */