").append(c.replace(bP,"")).find(g):c)),d&&i.each(d,[c,b,a])}});return this},serialize:function(){return f.param(this.serializeArray())},serializeArray:function(){return this.map(function(){return this.elements?f.makeArray(this.elements):this}).filter(function(){return this.name&&!this.disabled&&(this.checked||bQ.test(this.nodeName)||bK.test(this.type))}).map(function(a,b){var c=f(this).val();return c==null?null:f.isArray(c)?f.map(c,function(a,c){return{name:b.name,value:a.replace(bH,"\r\n")}}):{name:b.name,value:c.replace(bH,"\r\n")}}).get()}}),f.each("ajaxStart ajaxStop ajaxComplete ajaxError ajaxSuccess ajaxSend".split(" "),function(a,b){f.fn[b]=function(a){return this.bind(b,a)}}),f.each(["get","post"],function(a,c){f[c]=function(a,d,e,g){f.isFunction(d)&&(g=g||e,e=d,d=b);return f.ajax({type:c,url:a,data:d,success:e,dataType:g})}}),f.extend({getScript:function(a,c){return f.get(a,b,c,"script")},getJSON:function(a,b,c){return f.get(a,b,c,"json")},ajaxSetup:function(a,b){b?cb(a,f.ajaxSettings):(b=a,a=f.ajaxSettings),cb(a,b);return a},ajaxSettings:{url:bX,isLocal:bL.test(bY[1]),global:!0,type:"GET",contentType:"application/x-www-form-urlencoded",processData:!0,async:!0,accepts:{xml:"application/xml, text/xml",html:"text/html",text:"text/plain",json:"application/json, text/javascript","*":bZ},contents:{xml:/xml/,html:/html/,json:/json/},responseFields:{xml:"responseXML",text:"responseText"},converters:{"* text":a.String,"text html":!0,"text json":f.parseJSON,"text xml":f.parseXML},flatOptions:{context:!0,url:!0}},ajaxPrefilter:b_(bV),ajaxTransport:b_(bW),ajax:function(a,c){function w(a,c,l,m){if(s!==2){s=2,q&&clearTimeout(q),p=b,n=m||"",v.readyState=a>0?4:0;var o,r,u,w=c,x=l?cd(d,v,l):b,y,z;if(a>=200&&a<300||a===304){if(d.ifModified){if(y=v.getResponseHeader("Last-Modified"))f.lastModified[k]=y;if(z=v.getResponseHeader("Etag"))f.etag[k]=z}if(a===304)w="notmodified",o=!0;else try{r=ce(d,x),w="success",o=!0}catch(A){w="parsererror",u=A}}else{u=w;if(!w||a)w="error",a<0&&(a=0)}v.status=a,v.statusText=""+(c||w),o?h.resolveWith(e,[r,w,v]):h.rejectWith(e,[v,w,u]),v.statusCode(j),j=b,t&&g.trigger("ajax"+(o?"Success":"Error"),[v,d,o?r:u]),i.fireWith(e,[v,w]),t&&(g.trigger("ajaxComplete",[v,d]),--f.active||f.event.trigger("ajaxStop"))}}typeof a=="object"&&(c=a,a=b),c=c||{};var d=f.ajaxSetup({},c),e=d.context||d,g=e!==d&&(e.nodeType||e instanceof f)?f(e):f.event,h=f.Deferred(),i=f.Callbacks("once memory"),j=d.statusCode||{},k,l={},m={},n,o,p,q,r,s=0,t,u,v={readyState:0,setRequestHeader:function(a,b){if(!s){var c=a.toLowerCase();a=m[c]=m[c]||a,l[a]=b}return this},getAllResponseHeaders:function(){return s===2?n:null},getResponseHeader:function(a){var c;if(s===2){if(!o){o={};while(c=bJ.exec(n))o[c[1].toLowerCase()]=c[2]}c=o[a.toLowerCase()]}return c===b?null:c},overrideMimeType:function(a){s||(d.mimeType=a);return this},abort:function(a){a=a||"abort",p&&p.abort(a),w(0,a);return this}};h.promise(v),v.success=v.done,v.error=v.fail,v.complete=i.add,v.statusCode=function(a){if(a){var b;if(s<2)for(b in a)j[b]=[j[b],a[b]];else b=a[v.status],v.then(b,b)}return this},d.url=((a||d.url)+"").replace(bI,"").replace(bN,bY[1]+"//"),d.dataTypes=f.trim(d.dataType||"*").toLowerCase().split(bR),d.crossDomain==null&&(r=bT.exec(d.url.toLowerCase()),d.crossDomain=!(!r||r[1]==bY[1]&&r[2]==bY[2]&&(r[3]||(r[1]==="http:"?80:443))==(bY[3]||(bY[1]==="http:"?80:443)))),d.data&&d.processData&&typeof d.data!="string"&&(d.data=f.param(d.data,d.traditional)),ca(bV,d,c,v);if(s===2)return!1;t=d.global,d.type=d.type.toUpperCase(),d.hasContent=!bM.test(d.type),t&&f.active++===0&&f.event.trigger("ajaxStart");if(!d.hasContent){d.data&&(d.url+=(bO.test(d.url)?"&":"?")+d.data,delete d.data),k=d.url;if(d.cache===!1){var x=f.now(),y=d.url.replace(bS,"$1_="+x);d.url=y+(y===d.url?(bO.test(d.url)?"&":"?")+"_="+x:"")}}(d.data&&d.hasContent&&d.contentType!==!1||c.contentType)&&v.setRequestHeader("Content-Type",d.contentType),d.ifModified&&(k=k||d.url,f.lastModified[k]&&v.setRequestHeader("If-Modified-Since",f.lastModified[k]),f.etag[k]&&v.setRequestHeader("If-None-Match",f.etag[k])),v.setRequestHeader("Accept",d.dataTypes[0]&&d.accepts[d.dataTypes[0]]?d.accepts[d.dataTypes[0]]+(d.dataTypes[0]!=="*"?", "+bZ+"; q=0.01":""):d.accepts["*"]);for(u in d.headers)v.setRequestHeader(u,d.headers[u]);if(d.beforeSend&&(d.beforeSend.call(e,v,d)===!1||s===2)){v.abort();return!1}for(u in{success:1,error:1,complete:1})v[u](d[u]);p=ca(bW,d,c,v);if(!p)w(-1,"No Transport");else{v.readyState=1,t&&g.trigger("ajaxSend",[v,d]),d.async&&d.timeout>0&&(q=setTimeout(function(){v.abort("timeout")},d.timeout));try{s=1,p.send(l,w)}catch(z){s<2?w(-1,z):f.error(z)}}return v},param:function(a,c){var d=[],e=function(a,b){b=f.isFunction(b)?b():b,d[d.length]=encodeURIComponent(a)+"="+encodeURIComponent(b)};c===b&&(c=f.ajaxSettings.traditional);if(f.isArray(a)||a.jquery&&!f.isPlainObject(a))f.each(a,function(){e(this.name,this.value)});else for(var g in a)cc(g,a[g],c,e);return d.join("&").replace(bF,"+")}}),f.extend({active:0,lastModified:{},etag:{}});var cf=f.now(),cg=/(\=)\?(&|$)|\?\?/i;f.ajaxSetup({jsonp:"callback",jsonpCallback:function(){return f.expando+"_"+cf++}}),f.ajaxPrefilter("json jsonp",function(b,c,d){var e=b.contentType==="application/x-www-form-urlencoded"&&typeof b.data=="string";if(b.dataTypes[0]==="jsonp"||b.jsonp!==!1&&(cg.test(b.url)||e&&cg.test(b.data))){var g,h=b.jsonpCallback=f.isFunction(b.jsonpCallback)?b.jsonpCallback():b.jsonpCallback,i=a[h],j=b.url,k=b.data,l="$1"+h+"$2";b.jsonp!==!1&&(j=j.replace(cg,l),b.url===j&&(e&&(k=k.replace(cg,l)),b.data===k&&(j+=(/\?/.test(j)?"&":"?")+b.jsonp+"="+h))),b.url=j,b.data=k,a[h]=function(a){g=[a]},d.always(function(){a[h]=i,g&&f.isFunction(i)&&a[h](g[0])}),b.converters["script json"]=function(){g||f.error(h+" was not called");return g[0]},b.dataTypes[0]="json";return"script"}}),f.ajaxSetup({accepts:{script:"text/javascript, application/javascript, application/ecmascript, application/x-ecmascript"},contents:{script:/javascript|ecmascript/},converters:{"text script":function(a){f.globalEval(a);return a}}}),f.ajaxPrefilter("script",function(a){a.cache===b&&(a.cache=!1),a.crossDomain&&(a.type="GET",a.global=!1)}),f.ajaxTransport("script",function(a){if(a.crossDomain){var d,e=c.head||c.getElementsByTagName("head")[0]||c.documentElement;return{send:function(f,g){d=c.createElement("script"),d.async="async",a.scriptCharset&&(d.charset=a.scriptCharset),d.src=a.url,d.onload=d.onreadystatechange=function(a,c){if(c||!d.readyState||/loaded|complete/.test(d.readyState))d.onload=d.onreadystatechange=null,e&&d.parentNode&&e.removeChild(d),d=b,c||g(200,"success")},e.insertBefore(d,e.firstChild)},abort:function(){d&&d.onload(0,1)}}}});var ch=a.ActiveXObject?function(){for(var a in cj)cj[a](0,1)}:!1,ci=0,cj;f.ajaxSettings.xhr=a.ActiveXObject?function(){return!this.isLocal&&ck()||cl()}:ck,function(a){f.extend(f.support,{ajax:!!a,cors:!!a&&"withCredentials"in a})}(f.ajaxSettings.xhr()),f.support.ajax&&f.ajaxTransport(function(c){if(!c.crossDomain||f.support.cors){var d;return{send:function(e,g){var h=c.xhr(),i,j;c.username?h.open(c.type,c.url,c.async,c.username,c.password):h.open(c.type,c.url,c.async);if(c.xhrFields)for(j in c.xhrFields)h[j]=c.xhrFields[j];c.mimeType&&h.overrideMimeType&&h.overrideMimeType(c.mimeType),!c.crossDomain&&!e["X-Requested-With"]&&(e["X-Requested-With"]="XMLHttpRequest");try{for(j in e)h.setRequestHeader(j,e[j])}catch(k){}h.send(c.hasContent&&c.data||null),d=function(a,e){var j,k,l,m,n;try{if(d&&(e||h.readyState===4)){d=b,i&&(h.onreadystatechange=f.noop,ch&&delete cj[i]);if(e)h.readyState!==4&&h.abort();else{j=h.status,l=h.getAllResponseHeaders(),m={},n=h.responseXML,n&&n.documentElement&&(m.xml=n),m.text=h.responseText;try{k=h.statusText}catch(o){k=""}!j&&c.isLocal&&!c.crossDomain?j=m.text?200:404:j===1223&&(j=204)}}}catch(p){e||g(-1,p)}m&&g(j,k,m,l)},!c.async||h.readyState===4?d():(i=++ci,ch&&(cj||(cj={},f(a).unload(ch)),cj[i]=d),h.onreadystatechange=d)},abort:function(){d&&d(0,1)}}}});var cm={},cn,co,cp=/^(?:toggle|show|hide)$/,cq=/^([+\-]=)?([\d+.\-]+)([a-z%]*)$/i,cr,cs=[["height","marginTop","marginBottom","paddingTop","paddingBottom"],["width","marginLeft","marginRight","paddingLeft","paddingRight"],["opacity"]],ct;f.fn.extend({show:function(a,b,c){var d,e;if(a||a===0)return this.animate(cw("show",3),a,b,c);for(var g=0,h=this.length;g
=i.duration+this.startTime){this.now=this.end,this.pos=this.state=1,this.update(),i.animatedProperties[this.prop]=!0;for(b in i.animatedProperties)i.animatedProperties[b]!==!0&&(g=!1);if(g){i.overflow!=null&&!f.support.shrinkWrapBlocks&&f.each(["","X","Y"],function(a,b){h.style["overflow"+b]=i.overflow[a]}),i.hide&&f(h).hide();if(i.hide||i.show)for(b in i.animatedProperties)f.style(h,b,i.orig[b]),f.removeData(h,"fxshow"+b,!0),f.removeData(h,"toggle"+b,!0);d=i.complete,d&&(i.complete=!1,d.call(h))}return!1}i.duration==Infinity?this.now=e:(c=e-this.startTime,this.state=c/i.duration,this.pos=f.easing[i.animatedProperties[this.prop]](this.state,c,0,1,i.duration),this.now=this.start+(this.end-this.start)*this.pos),this.update();return!0}},f.extend(f.fx,{tick:function(){var a,b=f.timers,c=0;for(;c-1,k={},l={},m,n;j?(l=e.position(),m=l.top,n=l.left):(m=parseFloat(h)||0,n=parseFloat(i)||0),f.isFunction(b)&&(b=b.call(a,c,g)),b.top!=null&&(k.top=b.top-g.top+m),b.left!=null&&(k.left=b.left-g.left+n),"using"in b?b.using.call(a,k):e.css(k)}},f.fn.extend({position:function(){if(!this[0])return null;var a=this[0],b=this.offsetParent(),c=this.offset(),d=cz.test(b[0].nodeName)?{top:0,left:0}:b.offset();c.top-=parseFloat(f.css(a,"marginTop"))||0,c.left-=parseFloat(f.css(a,"marginLeft"))||0,d.top+=parseFloat(f.css(b[0],"borderTopWidth"))||0,d.left+=parseFloat(f.css(b[0],"borderLeftWidth"))||0;return{top:c.top-d.top,left:c.left-d.left}},offsetParent:function(){return this.map(function(){var a=this.offsetParent||c.body;while(a&&!cz.test(a.nodeName)&&f.css(a,"position")==="static")a=a.offsetParent;return a})}}),f.each(["Left","Top"],function(a,c){var d="scroll"+c;f.fn[d]=function(c){var e,g;if(c===b){e=this[0];if(!e)return null;g=cA(e);return g?"pageXOffset"in g?g[a?"pageYOffset":"pageXOffset"]:f.support.boxModel&&g.document.documentElement[d]||g.document.body[d]:e[d]}return this.each(function(){g=cA(this),g?g.scrollTo(a?f(g).scrollLeft():c,a?c:f(g).scrollTop()):this[d]=c})}}),f.each(["Height","Width"],function(a,c){var d=c.toLowerCase();f.fn["inner"+c]=function(){var a=this[0];return a?a.style?parseFloat(f.css(a,d,"padding")):this[d]():null},f.fn["outer"+c]=function(a){var b=this[0];return b?b.style?parseFloat(f.css(b,d,a?"margin":"border")):this[d]():null},f.fn[d]=function(a){var e=this[0];if(!e)return a==null?null:this;if(f.isFunction(a))return this.each(function(b){var c=f(this);c[d](a.call(this,b,c[d]()))});if(f.isWindow(e)){var g=e.document.documentElement["client"+c],h=e.document.body;return e.document.compatMode==="CSS1Compat"&&g||h&&h["client"+c]||g}if(e.nodeType===9)return Math.max(e.documentElement["client"+c],e.body["scroll"+c],e.documentElement["scroll"+c],e.body["offset"+c],e.documentElement["offset"+c]);if(a===b){var i=f.css(e,d),j=parseFloat(i);return f.isNumeric(j)?j:i}return this.css(d,typeof a=="string"?a:a+"px")}}),a.jQuery=a.$=f})(window);
\ No newline at end of file
diff --git a/bacnet-stack/demo/perl/Documentation/syntax.css b/bacnet-stack/demo/perl/Documentation/syntax.css
new file mode 100755
index 00000000..7b9c78c5
--- /dev/null
+++ b/bacnet-stack/demo/perl/Documentation/syntax.css
@@ -0,0 +1,75 @@
+pre{
+ font-family: "Courier New", Courier, monospace, sans-serif;
+ text-align: left;
+ line-height: 1.6em;
+ font-size: 11px;
+ padding: 0.1em 0.5em 0.3em 0.7em;
+ border: 2px solid #888;
+ margin: 1.7em 0 1.7em 0.3em;
+ overflow: auto;
+ width: 93%;
+ background: #EEEEEE;
+}
+h1 {
+ font-size: 20pt;
+ counter-increment: counter-h1;
+ counter-reset: counter-h2;
+}
+h2 {
+ font-size: 17pt;
+ counter-increment: counter-h2;
+ counter-reset: counter-h3;
+}
+h3 {
+ font-size: 14pt;
+ counter-increment: counter-h3;
+ counter-reset: counter-h4;
+}
+h1:before {
+ content: counter(counter-h1) ". ";
+}
+h2:before {
+ content: counter(counter-h1) "." counter(counter-h2) ". ";
+}
+h3:before {
+ content: counter(counter-h1) "." counter(counter-h2) "." counter(counter-h3) ". ";
+}
+ul {
+ list-style-type: circle;
+}
+.quotedString
+{
+ color: #0000FF;
+}
+.comment
+{
+ color: #999999;
+}
+.operator
+{
+ color: #00CCCC;
+}
+.builtinVariable
+{
+ color: #CCCC00;
+}
+.variableSpecifier
+{
+ color: #FF0000;
+}
+.keyword
+{
+ color: #AA0033;
+}
+.builtinFunction
+{
+ color: #AA00AA;
+}
+.identifier
+{
+ color: #009900;
+}
+.number
+{
+ color: #9999FF;
+}
diff --git a/bacnet-stack/demo/perl/Documentation/syntax.js b/bacnet-stack/demo/perl/Documentation/syntax.js
new file mode 100755
index 00000000..bce49d90
--- /dev/null
+++ b/bacnet-stack/demo/perl/Documentation/syntax.js
@@ -0,0 +1,137 @@
+var ie = document.all != null;
+var moz = !ie && document.getElementById != null && document.layers == null;
+function emulateHTMLModel()
+{
+// copied from http://www.webfx.nu/dhtml/ieemu/htmlmodel.html
+
+// This function is used to generate a html string for the text properties/methods
+// It replaces '\n' with " as well as fixes consecutive white spaces
+// It also repalaces some special characters
+function convertTextToHTML(s) {
+ s = s.replace(/\&/g, "&").replace(//g, ">").replace(/\n/g, "'s
+ * css is defined separately. See the array classes to find out the css class names.
+ */
+function HighlightCode(object)
+{
+ codeText = object.innerText; //HTML.replace(/<.*?>/g, "");
+ object.innerHTML = '';
+ var left;
+ var match;
+ var right;
+ while (codeText.length > 0)
+ {
+ var mode = -1 ;
+ var index = 999999999;
+ for (var i = 0; i < RE.length; i++)
+ {
+ if ((codeText.match(RE[i])) && (RegExp.leftContext.length < index))
+ {
+ left = RegExp.leftContext;
+ match = RegExp.lastMatch;
+ right = RegExp.rightContext;
+ index = RegExp.leftContext.length;
+ mode = i;
+ }
+ }
+ if (mode == -1)
+ {
+ object.appendChild(document.createTextNode(codeText)); //.replace(/\r\n/g, "\r")));
+ codeText = '';
+ }
+ else
+ {
+ // append the plain text to the block
+ object.appendChild(document.createTextNode(left)); //.replace(/\r\n/g, "\r")));
+
+ // create a new with the current code
+ var span = document.createElement("span");
+ span.setAttribute("className", classes[mode]); // ie
+ span.setAttribute("class", classes[mode]); //mozilla
+ span.appendChild(document.createTextNode(match));
+ object.appendChild(span);
+
+ codeText = right;
+ }
+ }
+}
+
+// little bit of JQuery to highlight code in all pre elements
+$(document).ready(function(){
+ $("pre").each(function(i){
+ HighlightCode(this);
+ });
+});
+
diff --git a/bacnet-stack/demo/perl/bacnet.pl b/bacnet-stack/demo/perl/bacnet.pl
new file mode 100644
index 00000000..75291a68
--- /dev/null
+++ b/bacnet-stack/demo/perl/bacnet.pl
@@ -0,0 +1,869 @@
+use warnings;
+use strict;
+use Getopt::Long;
+use Convert::Binary::C;
+use Hash::Util qw/lock_hash/;
+use English;
+use Scalar::Util qw/looks_like_number/;
+use File::Basename;
+use File::Spec;
+use Pod::Usage;
+use Carp;
+
+=head1 NAME
+
+bacnet.pl - Scriptable BACnet communications
+
+=head1 DESCRIPTION
+
+This is a tool for scriptable BACnet communication. Users can write their own
+scripts using standard Perl syntax and API defined in this tool to perform desired
+execution sequences. For details on this tool's API, see Documentation.html. For other
+Perl documentation, see http://perldoc.perl.org
+
+=begin html
+
+
+=head3 Inputs to ReadProperty
+
+=begin html
+
+ devideInstance - the instance number of the device we are readingobjectName - the enumeration for the object name we are readingobjectInstance - the instance number of the object we are readingpropertyName - the enumeration for the property name we are readingindex - Optional (default -1): the index number we are reading from. -1 if not applicable
+
+=end html
+
+=head3 Outputs from ReadProperty
+
+=begin html
+
+ result - the sting result (value or error) for ReadPropertyisFailure - zero means no failure, non-zero means failure
+
+=end html
+
+=head3 Example of ReadProperty
+
+The following example will read AV0.PresentValue from device 1234
+
+ my ($res, $failed) = ReadProperty(1234, 'OBJECT_ANALOG_VALUE', 0, 'PROP_PRESENT_VALUE');
+
+=cut
+
+sub ReadProperty {
+ my $deviceInstance = shift;
+ my $objectName = shift;
+ my $objectInstance = shift;
+ my $propertyName = shift;
+ my $index = shift;
+ my $isFailure = BindToDevice($deviceInstance);
+
+ # Loop for early exit
+ while(1)
+ {
+ last if $isFailure;
+
+ my ($objectPrintName, $objectValue) = LookupEnumValue('BACNET_OBJECT_TYPE', $objectName);
+ my ($propertyPrintName, $propertyValue) = LookupEnumValue('BACNET_PROPERTY_ID', $propertyName);
+
+ my $msg = "ReadProperty $objectPrintName" . '[' . $objectInstance . "].$propertyPrintName";
+ if (defined($index))
+ {
+ $msg .= ".$index";
+ } else {
+ $index = -1;
+ }
+ $msg .= " from Device" . '[' . $deviceInstance . "] ==> ";
+
+ LogAnswer('', 0);
+ if ( BacnetReadProperty($deviceInstance, $objectValue, $objectInstance, $propertyValue, $index) )
+ {
+ BacnetGetError($errorMsg);
+ $msg .= "Problem: $errorMsg";
+ $isFailure = 1;
+ }
+ else
+ {
+ $msg .= $answer;
+ $isFailure = 0;
+ }
+ Log($msg);
+ last;
+ }
+
+ return ($answer, $isFailure);
+}
+
+=head2 ReadPropertyMultiple
+
+This function implements the ReadPropertyMultiple service. There are no built in retry
+mechanisms. NOTE: all enumerations are defined in F
+
+=head3 Inputs to ReadPropertyMultiple
+
+=begin html
+
+ devideInstance - the instance number of the device we are readingr_answerList - reference to a list where to store the answerslist - a list of ReadAccessSpecifications
+ objectType - the enumeration for the object name to read fromobjectInstance - the instance number of the object we are readingpropertyName - the enumeration for the property name we are readingindex - the index number we are reading from. Use -1 if not applicable
+
+
+=end html
+
+=head3 Outputs from ReadPropertyMultiple
+
+=begin html
+
+ result - the 'QQQ' delimited concatenated sting result (value or error) for ReadPropertyMultiple. The parsed out result is returned in r_answerListisFailure - zero means no failure, non-zero means failure
+
+=end html
+
+=head3 Example of ReadPropertyMultiple
+
+The following example will read AV0.PresentValue and AV1.PresentValue from device 1234
+
+ my @RPM_request = ();
+ my @RPM_answer = ();
+ my $failed;
+ push @RPM_request, ['OBJECT_ANALOG_VALUE', 0, 'PROP_PRESENT_VALUE', -1];
+ push @RPM_request, ['OBJECT_ANALOG_VALUE', 1, 'PROP_PRESENT_VALUE', -1];
+ (undef, $failed) = ReadPropertyMultiple(1234, \@RPM_answer, @RPM_request);
+
+=cut
+
+sub ReadPropertyMultiple
+{
+ my $deviceInstanceNumber = shift;
+ my $r_answerList = shift;
+ my @list = @ARG;
+ my @modifiedList = ();
+ my $msg = '';
+ my $isFailure = BindToDevice($deviceInstanceNumber);
+
+ # loop for early exit
+ while(1)
+ {
+ last if $isFailure;
+
+ Log("ReadPropertyMultiple:");
+ $logIndent += 4;
+
+ foreach my $r_prop (@list)
+ {
+ my @tmpList = ();
+ push @tmpList, $$r_prop[$_] for (0 .. 3);
+ (undef, $tmpList[0]) = LookupEnumValue('BACNET_OBJECT_TYPE', $$r_prop[0]);
+ (undef, $tmpList[2]) = LookupEnumValue('BACNET_PROPERTY_ID', $$r_prop[2]);
+ push @modifiedList, \@tmpList;
+ }
+
+ LogAnswer('', 0);
+ @{$r_answerList} = ();
+ if (BacnetReadPropertyMultiple($deviceInstanceNumber, @modifiedList))
+ {
+ BacnetGetError($errorMsg);
+ Log("Problem: $errorMsg");
+ $isFailure = 1;
+ }
+ else
+ {
+ my $i = 0;
+ foreach (split('QQQ', $answer))
+ {
+ my ($objectPrintName, undef) = LookupEnumValue('BACNET_OBJECT_TYPE', $list[$i][0]);
+ my ($propertyPrintName, undef) = LookupEnumValue('BACNET_PROPERTY_ID', $list[$i][2]);
+ my $msg = $objectPrintName . '.[' . $list[$i][1] . '].' . $propertyPrintName;
+ if ($list[$i][3] != -1)
+ {
+ $msg .= '.[' . $list[$i][3] . ']';
+ }
+ $msg .= " ==> $_";
+ Log($msg);
+ push @{$r_answerList}, $_;
+ $i++;
+ }
+ $isFailure = 0;
+ }
+
+ $logIndent -= 4;
+ last;
+ }
+
+ return ($answer, $isFailure);
+}
+
+=head2 WriteProperty
+
+This function implements the WriteProperty service. There are no built in retry
+mechanisms. NOTE: all enumerations are defined in F
+
+=head3 Inputs to WriteProperty
+
+=begin html
+
+ devideInstance - the instance number of the device we are writingobjectName - the enumeration for the object name we are writingobjectInstance - the instance number of the object we are writingpropertyName - the enumeration for the property name we are writingtagName - the enumeration for the type of value we are writing. To specify context tags, prepend the tag name with "Cn:" where 'n' is the context number.value - the value we are writingpriority - Optional (default 0): the priority within Priority Array to write at. Use 1-16 when specify priority, 0 to not specify priority.index - Optional (default -1): the index within an array we are writing to. Use positive number to indicate index, -1 to not specify index.
+
+=end html
+
+=head3 Outputs from WriteProperty
+
+=begin html
+
+ result - the sting result (value or error) for WritePropertyisFailure - zero means no failure, non-zero means failure
+
+=end html
+
+=head3 Example of WriteProperty
+
+The following example will write 1.0 to AV0.PresentValue in device 1234
+
+ my ($res, $failed) = WriteProperty(1234, 'OBJECT_ANALOG_VALUE', 0, 'PROP_PRESENT_VALUE', 'BACNET_APPLICATION_TAG_REAL', 1.0);
+
+=cut
+
+sub WriteProperty {
+ my $deviceInstance = shift;
+ my $objectName = shift;
+ my $objectInstance = shift;
+ my $propertyName = shift;
+ my $tagName = shift;
+ my $value = shift;
+ my $priority = shift;
+ my $index = shift;
+ my $isFailure = BindToDevice($deviceInstance);
+
+ # loop for early exit
+ while(1)
+ {
+ last if $isFailure;
+
+ my ($objectPrintName, $objectValue) = LookupEnumValue('BACNET_OBJECT_TYPE', $objectName);
+ my ($propertyPrintName, $propertyValue) = LookupEnumValue('BACNET_PROPERTY_ID', $propertyName);
+
+ my $tagValue = '';
+ if ($tagName =~ /^(C\d+):(.*)$/)
+ {
+ $tagName = $2;
+ $tagValue = "$1 ";
+ }
+ my ($tagPrintName, $tagNewValue) = LookupEnumValue('BACNET_APPLICATION_TAG', $tagName);
+ $tagValue .= $tagNewValue;
+
+ my $msg = "WriteProperty $tagPrintName:$value to $objectPrintName" . '[' . $objectInstance . "].$propertyPrintName";
+ if (defined($index))
+ {
+ $msg .= '[' . $index . ']';
+ }
+ else
+ {
+ # an index of -1 means that we are not writing to an array
+ $index = -1;
+ }
+ if (defined($priority))
+ {
+ $msg .= '@' . $priority
+ }
+ else
+ {
+ # a priority of 0 means we are not writing to a priority array
+ $priority = 0;
+ }
+ $msg .= " in Device" . '[' . $deviceInstance . "] ==> ";
+
+ LogAnswer('', 0);
+ if ( BacnetWriteProperty($deviceInstance, $objectValue, $objectInstance, $propertyValue, $priority, $index, $tagValue, $value) )
+ {
+ BacnetGetError($errorMsg);
+ $msg .= "Problem: $errorMsg\n";
+ $isFailure = 1;
+ }
+ else
+ {
+ $msg .= $answer;
+ $isFailure = 0;
+ }
+ Log($msg);
+ last;
+ }
+
+ return ($answer, $isFailure);
+}
+
+=head2 TimeSync
+
+This function implements the TimeSync and UTCTimeSync services
+
+=head3 Inputs to TimeSync
+
+=begin html
+
+ deviceInstanceNumber - the instance number of the device we are readingyear - Year (i.e. 2011)month - Month (i.e. 11 for November)day - Day (i.e. 1 for first of month)hour - Hour (i.e. 23 for 11pm)minute - Minute (i.e. 0-59)second - Second (i,e. 0-59)utcOffset - Optional: if specified defines the UTC offset and forces UTCTimeSync
+
+=end html
+
+=head3 Outputs from TimeSync
+
+=begin html
+
+ isFailure - zero means no failure, non-zero means failure
+
+=end html
+
+=head3 Example of TimeSync
+
+ $isFailure = TimeSync($deviceInstance, $1, $2, $3, $4, $5, $6) unless $isFailure;
+
+=cut
+
+sub TimeSync
+{
+ my $deviceInstanceNumber = shift;
+ my $year = shift;
+ my $month = shift;
+ my $day = shift;
+ my $hour = shift;
+ my $minute = shift;
+ my $second = shift;
+ my $utcOffset = shift;
+ my $isUTC;
+
+ my $isFailure = BindToDevice($deviceInstanceNumber);
+
+ # loop for early exit
+ while(1)
+ {
+ last if $isFailure;
+
+ # be a pessimist. Assume things will fail
+ $isFailure = 1;
+
+ if (defined($utcOffset))
+ {
+ $isUTC = 1;
+ Log("UTC Time Sync not yet supported.");
+ last;
+ }
+ else
+ {
+ $utcOffset = 0;
+ $isUTC = 0;
+ }
+
+ if ($year < 1900 || $year > 2099)
+ {
+ Log("Year '$year' is invalid.");
+ last;
+ }
+
+ if ($month <= 0 || $month > 12)
+ {
+ Log("Month '$month' is invalid.");
+ last;
+ }
+
+ if ($day <= 0 || $day > 31)
+ {
+ Log("Day '$day' is invalid.");
+ last;
+ }
+
+ if ($hour < 0 || $hour > 23)
+ {
+ Log("Hour '$hour' is invalid.");
+ last;
+ }
+
+ if ($minute < 0 || $minute > 59)
+ {
+ Log("Minute '$minute' is invalid.");
+ last;
+ }
+
+ if ($second < 0 || $second > 59)
+ {
+ Log("Second '$second' is invalid.");
+ last;
+ }
+
+ Log("TimeSync: Device[$deviceInstanceNumber] $year/$month/$day $hour:$minute:$second");
+
+ $isFailure = BacnetTimeSync($deviceInstanceNumber, $year, $month, $day, $hour, $minute, $second, $isUTC, $utcOffset);
+ last;
+ }
+
+ return $isFailure;
+}
+
+=head2 Log
+
+This function prints out to the desired method of logging (STDOUT or file).
+NewLine characters are not required when making calls to this function. If any
+NewLine characters are specified, they will be stripped out. To print an empty
+line, pass in a space as the message. NOTE: This function will honor previous
+requests to silence the log (see SilcenseLog for details)
+
+=head3 Inputs to Log
+
+=begin html
+
+ msg - the message to output
+
+
+=end html
+
+=head3 Example of Log
+
+The following example will print out "hello world"
+
+ Log("Hello World");
+
+=cut
+
+###############################################################################
+# Global Variables affecting this function
+# logIsQuiet do not print anytihng if the log was qieted
+# logIndent how many spaces to put in front of every logged line
+###############################################################################
+sub Log {
+ my $msg = shift;
+
+ if (defined($msg) && !$logIsQuiet)
+ {
+ my @last = split('', substr($msg, -2));
+
+ # if there is nothing to print, then don't do it
+ return if (scalar(@last) == 0);
+
+ # if there are newline-like characters, get rid of them.
+ while ($msg =~/^(.*)[\r\n]+(.*)$/)
+ {
+ $msg = $1 . $2;
+ }
+
+ local $OUTPUT_RECORD_SEPARATOR = "\n";
+ print $logTo ' ' x $logIndent . $msg;
+ }
+}
+
+=head2 SilenceLog
+
+This function requests that all future log messages be either suppressed or
+enabled.
+
+=head3 Inputs to SilenceLog
+
+=begin html
+
+ logIsQuiet - zero means print to log, non-zero means supress log
+
+
+=end html
+
+=head3 Outputs from SilenceLog
+
+The previous value of whether or not the log was silenced before caling this
+function.
+
+=head3 Example of SilenceLog
+
+The following example will print out "hello", but not "world"
+
+ Log("Hello");
+ SilenceLog(1);
+ Log("World");
+
+=cut
+
+sub SilenceLog {
+ my $prevValue = $logIsQuiet;
+ $logIsQuiet = shift;
+ return $prevValue;
+}
+
+=head2 Retry
+
+This function will try to execute the requested command up to specified number
+of times, awaiting the requested answer, with a specified pause between
+retries. NOTE: the only functions which can be executed by this function are
+ones which return two parameres in the form of ($response, $isFailure)
+
+=head3 Inputs to Retry
+
+=begin html
+
+ r_func - The reference to the function which is to be retriedr_funcArgs - A reference to an array of arguments for the function to be executeddesiredOutput - The condition which will terminate the retrying. Can be either a number or a regexp to patch against the $response return of the functionmaxTries - The maximum number of retry attempts before calling it quitssleepSeconds - The number of seconds (could be fractional) to wait between retries
+
+=end html
+
+=head3 Outputs from Retry
+
+=begin html
+
+ $resp - The response from the last execution of requested functionisFailure - zero means no failure, non-zero means failure
+
+=end html
+
+=head3 Example of Retry
+
+The following example will execute the ReadProperty function to read a property
+from an object (see ReadProperty for details on those arguments) with up to
+$maxRetries retries (with $retryDelay delay between retries) or unitl the
+desired answer of 42 is received.
+
+ my ($resp, $isFailure) = Retry(
+ \&ReadProperty, [$deviceInstance, 'OBJECT_ANALOG_VALUE', 0, 'PROP_PRESENT_VALUE'],
+ 42, $maxRetries, $retryDelay
+ );
+ if ($isFailure)
+ {
+ die "Value was not 42. Last response was '$resp'";
+ }
+
+The following example will try to execute a WriteProperty (see that function for
+details on its arguments) until the write succeeds.
+
+ my ($resp, $isFailure) = Retry(
+ \&WriteProperty, [$deviceInstance, 'OBJECT_ANALOG_VALUE', 0, 'PROP_PRESENT_VALUE', 'BACNET_APPLICATION_TAG_REAL', 42.0],
+ "Acknowledged", $maxRetries, $retryDelay
+ );
+ if ($isFailure)
+ {
+ die "Could not write 42. Last response was '$resp'";
+ }
+
+=cut
+sub Retry {
+ my $r_func = shift;
+ my $r_funcArgs = shift;
+ my $desiredOutput = shift;
+ my $maxTries = shift;
+ my $sleepSeconds = shift;
+
+ my ($resp, $failed);
+
+ my $i;
+ for ($i=0; $i<$maxTries; $i++)
+ {
+ ($resp, $failed) = &{$r_func}(@{$r_funcArgs});
+ unless ($failed)
+ {
+ if (looks_like_number($desiredOutput))
+ {
+ last if (looks_like_number($resp) && ($resp == $desiredOutput));
+ }
+ else
+ {
+ last if ($resp =~ /$desiredOutput/);
+ }
+ }
+ select(undef, undef, undef, $sleepSeconds);
+ }
+
+ return ($resp, ($i == $maxTries));
+}
+
+
+##########################################
+# These are the supporting functions
+##########################################
+
+sub LookupEnumValue {
+ my $enumType = shift;
+ my $enumName = shift;
+ my $printName;
+
+ if (!exists($C_ENUMS{$enumType}{$enumName}))
+ {
+ print "Requested enumeration '$enumName' does not exist within '$enumType'.\n";
+ exit -1;
+ }
+
+ # lookup the value
+ my $value = $C_ENUMS{$enumType}{$enumName};
+
+ # reformat the OBJECT name style
+ my %reformat = (
+ 'BACNET_PROPERTY_ID' => 'PROP',
+ 'BACNET_OBJECT_TYPE' => 'OBJECT',
+ 'BACNET_APPLICATION_TAG' => 'BACNET_APPLICATION_TAG',
+ );
+
+ if (exists($reformat{$enumType}))
+ {
+ if ($enumName =~ /$reformat{$enumType}_(.*)/)
+ {
+ $printName = '';
+ $printName .= ucfirst lc $_ foreach (split('_', $1));
+ }
+ }
+
+ return ($printName, $value);
+}
+
+sub BindToDevice {
+ my $deviceInstance = shift;
+ my $isFailure = 0;
+
+ if ( BacnetBindToDevice($deviceInstance) )
+ {
+ BacnetGetError($errorMsg);
+ Log("Problem binding to deivce $deviceInstance: $errorMsg\n");
+ $isFailure = 1;
+ }
+
+ return $isFailure;
+}
+
+sub LogAnswer {
+ my $newAnswer = shift;
+ my $append = shift;
+
+ $answer = '' unless $append;
+ $answer .= $newAnswer;
+}
+
diff --git a/bacnet-stack/demo/perl/example_readprop.pl b/bacnet-stack/demo/perl/example_readprop.pl
new file mode 100644
index 00000000..dd36c430
--- /dev/null
+++ b/bacnet-stack/demo/perl/example_readprop.pl
@@ -0,0 +1,16 @@
+use warnings;
+use strict;
+
+if (scalar(@ARGV) == 1)
+{
+ my $device = $ARGV[0];
+ my ($resp, $failed) = ReadProperty($device, 'OBJECT_ANALOG_VALUE', 0, 'PROP_PRESENT_VALUE');
+
+ print "status was '$failed' and the response was '$resp'\n";
+}
+else
+{
+ print "Must specify device instance number as an argument to this script\n";
+}
+
+1;
diff --git a/bacnet-stack/demo/perl/perl_bindings.c b/bacnet-stack/demo/perl/perl_bindings.c
new file mode 100644
index 00000000..62b23a36
--- /dev/null
+++ b/bacnet-stack/demo/perl/perl_bindings.c
@@ -0,0 +1,1126 @@
+#include "bacdef.h"
+#include "handlers.h"
+#include "bacenum.h"
+#include "datalink.h"
+#include "device.h"
+#include
+#include "arf.h"
+
+// Free is redefined as a macro, but Perl does not like that.
+#undef free
+
+/* global variables used in this file */
+static uint32_t Target_Device_Object_Instance = 4194303;
+static unsigned Target_Max_APDU = 0;
+static bool Error_Detected = false;
+static BACNET_ADDRESS Target_Address;
+static uint8_t Request_Invoke_ID = 0;
+static bool isReadPropertyHandlerRegistered = false;
+static bool isReadPropertyMultipleHandlerRegistered = false;
+static bool isWritePropertyHandlerRegistered = false;
+static bool isAtomicWriteFileHandlerRegistered = false;
+static bool isAtomicReadFileHandlerRegistered = false;
+
+/****************************************/
+// Logging Support
+/****************************************/
+#define MAX_ERROR_STRING 128
+#define NO_ERROR "No Error"
+static char Last_Error[MAX_ERROR_STRING] = NO_ERROR;
+static void LogError(const char *msg)
+{
+ strcpy(Last_Error, msg);
+ Error_Detected = true;
+}
+void BacnetGetError(SV *errorMsg)
+{
+ sv_setpv(errorMsg, Last_Error);
+ strcpy(Last_Error, NO_ERROR);
+ Error_Detected = false;
+}
+static void __LogAnswer(const char *msg, unsigned append)
+{
+ dSP;
+ ENTER;
+ SAVETMPS;
+ PUSHMARK(SP);
+ XPUSHs(sv_2mortal(newSVpv(msg, 0)));
+ XPUSHs(sv_2mortal(newSViv(append)));
+ PUTBACK;
+ call_pv("LogAnswer", G_DISCARD);
+ FREETMPS;
+ LEAVE;
+}
+
+/****************************************/
+// TODO: This should really be fixed in the library
+
+/* used to load the app data struct with the proper data
+ converted from a command line argument */
+bool my_bacapp_parse_application_data(
+ BACNET_APPLICATION_TAG tag_number,
+ const char *argv,
+ BACNET_APPLICATION_DATA_VALUE * value)
+{
+ int hour, min, sec, hundredths;
+ int year, month, day, wday;
+ int object_type = 0;
+ uint32_t instance = 0;
+ bool status = false;
+ long long_value = 0;
+ unsigned long unsigned_long_value = 0;
+ double double_value = 0.0;
+ int count = 0;
+
+ if (value && (tag_number < MAX_BACNET_APPLICATION_TAG)) {
+ status = true;
+ value->tag = tag_number;
+ switch (tag_number) {
+ case BACNET_APPLICATION_TAG_BOOLEAN:
+ long_value = strtol(argv, NULL, 0);
+ if (long_value)
+ value->type.Boolean = true;
+ else
+ value->type.Boolean = false;
+ break;
+ case BACNET_APPLICATION_TAG_UNSIGNED_INT:
+ unsigned_long_value = strtoul(argv, NULL, 0);
+ value->type.Unsigned_Int = unsigned_long_value;
+ break;
+ case BACNET_APPLICATION_TAG_SIGNED_INT:
+ long_value = strtol(argv, NULL, 0);
+ value->type.Signed_Int = long_value;
+ break;
+ case BACNET_APPLICATION_TAG_REAL:
+ double_value = strtod(argv, NULL);
+ value->type.Real = (float) double_value;
+ break;
+#if defined (BACAPP_DOUBLE)
+ case BACNET_APPLICATION_TAG_DOUBLE:
+ double_value = strtod(argv, NULL);
+ value->type.Double = double_value;
+ break;
+#endif
+ case BACNET_APPLICATION_TAG_OCTET_STRING:
+ status =
+ octetstring_init(&value->type.Octet_String,
+ (uint8_t *) argv, strlen(argv));
+ break;
+ case BACNET_APPLICATION_TAG_CHARACTER_STRING:
+ status =
+ characterstring_init_ansi(&value->type.Character_String,
+ (char *) argv);
+ break;
+ case BACNET_APPLICATION_TAG_BIT_STRING:
+ /* FIXME: how to parse a bit string? */
+ status = false;
+ bitstring_init(&value->type.Bit_String);
+ break;
+ case BACNET_APPLICATION_TAG_ENUMERATED:
+ unsigned_long_value = strtoul(argv, NULL, 0);
+ value->type.Enumerated = unsigned_long_value;
+ break;
+ case BACNET_APPLICATION_TAG_DATE:
+ count =
+ sscanf(argv, "%d/%d/%d:%d", &year, &month, &day, &wday);
+ if (count == 3) {
+ datetime_set_date(&value->type.Date, (uint16_t) year,
+ (uint8_t) month, (uint8_t) day);
+ } else if (count == 4) {
+ value->type.Date.year = (uint16_t) year;
+ value->type.Date.month = (uint8_t) month;
+ value->type.Date.day = (uint8_t) day;
+ value->type.Date.wday = (uint8_t) wday;
+ } else {
+ status = false;
+ }
+ break;
+ case BACNET_APPLICATION_TAG_TIME:
+ count =
+ sscanf(argv, "%d:%d:%d.%d", &hour, &min, &sec,
+ &hundredths);
+ if (count == 4) {
+ value->type.Time.hour = (uint8_t) hour;
+ value->type.Time.min = (uint8_t) min;
+ value->type.Time.sec = (uint8_t) sec;
+ value->type.Time.hundredths = (uint8_t) hundredths;
+ } else if (count == 3) {
+ value->type.Time.hour = (uint8_t) hour;
+ value->type.Time.min = (uint8_t) min;
+ value->type.Time.sec = (uint8_t) sec;
+ value->type.Time.hundredths = 0;
+ } else if (count == 2) {
+ value->type.Time.hour = (uint8_t) hour;
+ value->type.Time.min = (uint8_t) min;
+ value->type.Time.sec = 0;
+ value->type.Time.hundredths = 0;
+ } else {
+ status = false;
+ }
+ break;
+ case BACNET_APPLICATION_TAG_OBJECT_ID:
+ count = sscanf(argv, "%d:%d", &object_type, &instance);
+ if (count == 2) {
+ value->type.Object_Id.type = (uint16_t) object_type;
+ value->type.Object_Id.instance = instance;
+ } else {
+ status = false;
+ }
+ break;
+ default:
+ break;
+ }
+ value->next = NULL;
+ }
+
+ return status;
+}
+
+// end of TODO
+/****************************************/
+
+/**************************************/
+// error handlers
+/*************************************/
+static void MyAbortHandler(
+ BACNET_ADDRESS * src,
+ uint8_t invoke_id,
+ uint8_t abort_reason,
+ bool server)
+{
+ (void) server;
+ if (address_match(&Target_Address, src) &&
+ (invoke_id == Request_Invoke_ID))
+ {
+ char msg[MAX_ERROR_STRING];
+ sprintf(msg, "BACnet Abort: %s", bactext_abort_reason_name((int) abort_reason));
+ LogError(msg);
+ }
+}
+
+static void MyRejectHandler(
+ BACNET_ADDRESS * src,
+ uint8_t invoke_id,
+ uint8_t reject_reason)
+{
+ if (address_match(&Target_Address, src) &&
+ (invoke_id == Request_Invoke_ID))
+ {
+ char msg[MAX_ERROR_STRING];
+ sprintf(msg, "BACnet Reject: %s", bactext_reject_reason_name((int) reject_reason));
+ LogError(msg);
+ }
+}
+
+static void My_Error_Handler(
+ BACNET_ADDRESS * src,
+ uint8_t invoke_id,
+ BACNET_ERROR_CLASS error_class,
+ BACNET_ERROR_CODE error_code)
+{
+ if (address_match(&Target_Address, src) &&
+ (invoke_id == Request_Invoke_ID))
+ {
+ char msg[MAX_ERROR_STRING];
+ sprintf(msg, "BACnet Error: %s: %s", bactext_error_class_name((int) error_class), bactext_error_code_name((int) error_code));
+ LogError(msg);
+ }
+}
+
+/**********************************/
+/* ACK handlers */
+/**********************************/
+
+/*****************************************/
+// Decode the ReadProperty Ack and pass to perl
+/****************************************/
+#define MAX_ACK_STRING 512
+void rp_ack_extract_data(BACNET_READ_PROPERTY_DATA * data)
+{
+ char ackString[MAX_ACK_STRING] = "";
+ char *pAckString = &ackString[0];
+ BACNET_OBJECT_PROPERTY_VALUE object_value; /* for bacapp printing */
+ BACNET_APPLICATION_DATA_VALUE value; /* for decode value data */
+ int len = 0;
+ uint8_t *application_data;
+ int application_data_len;
+ bool first_value = true;
+ bool print_brace = false;
+ size_t str_len;
+
+ if (data)
+ {
+ application_data = data->application_data;
+ application_data_len = data->application_data_len;
+ /* FIXME: what if application_data_len is bigger than 255? */
+ /* value? need to loop until all of the len is gone... */
+ for (;;) {
+ len =
+ bacapp_decode_application_data(application_data,
+ (uint8_t) application_data_len, &value);
+ if (first_value && (len < application_data_len))
+ {
+ first_value = false;
+ strncat(pAckString, "{", 1);
+ pAckString += 1;
+ print_brace = true;
+ }
+ object_value.object_type = data->object_type;
+ object_value.object_instance = data->object_instance;
+ object_value.object_property = data->object_property;
+ object_value.array_index = data->array_index;
+ object_value.value = &value;
+ bacapp_extract_value(&pAckString, ackString+MAX_ACK_STRING, &str_len, &object_value);
+ if (len > 0) {
+ if (len < application_data_len) {
+ application_data += len;
+ application_data_len -= len;
+ /* there's more! */
+ strncat(pAckString, ",", 1);
+ pAckString += 1;
+ } else {
+ break;
+ }
+ } else {
+ break;
+ }
+ }
+ if (print_brace)
+ {
+ strncat(pAckString, "}", 1);
+ pAckString += 1;
+ }
+
+ // Now let's call a Perl function to display the data
+ __LogAnswer(ackString, 0);
+ }
+}
+
+/*****************************************/
+// Decode the ReadPropertyMultiple Ack and pass to perl
+/****************************************/
+void rpm_ack_extract_data(BACNET_READ_ACCESS_DATA * rpm_data)
+{
+ BACNET_OBJECT_PROPERTY_VALUE object_value; /* for bacapp printing */
+ BACNET_PROPERTY_REFERENCE *listOfProperties;
+ BACNET_APPLICATION_DATA_VALUE *value;
+ bool array_value = false;
+ char ackString[MAX_ACK_STRING] = "";
+ char *pAckString = &ackString[0];
+ size_t str_len;
+
+ if (rpm_data) {
+ listOfProperties = rpm_data->listOfProperties;
+ while (listOfProperties) {
+ value = listOfProperties->value;
+ if (value) {
+ if (value->next) {
+ strncat(pAckString, "{", 1);
+ pAckString++;
+ array_value = true;
+ } else {
+ array_value = false;
+ }
+ object_value.object_type = rpm_data->object_type;
+ object_value.object_instance = rpm_data->object_instance;
+ while (value) {
+ object_value.object_property = listOfProperties->propertyIdentifier;
+ object_value.array_index = listOfProperties->propertyArrayIndex;
+ object_value.value = value;
+ bacapp_extract_value(&pAckString, ackString+MAX_ACK_STRING, &str_len, &object_value);
+ if (value->next) {
+ strncat(pAckString, ",", 1);
+ pAckString++;
+ } else {
+ if (array_value) {
+ strncat(pAckString, "}", 1);
+ pAckString++;
+ }
+ }
+ value = value->next;
+ }
+ } else {
+ /* AccessError */
+ sprintf(ackString, "BACnet Error: %s: %s",
+ bactext_error_class_name((int) listOfProperties->
+ error.error_class),
+ bactext_error_code_name((int) listOfProperties->
+ error.error_code));
+ LogError(ackString);
+ }
+ listOfProperties = listOfProperties->next;
+
+ // Add a separator between consecutive entries so that Perl can
+ // parse this out
+ strncat(pAckString, "QQQ", 3);
+ pAckString += 3;
+ }
+
+ // Now let's call a Perl function to display the data
+ __LogAnswer(ackString, 1);
+ }
+}
+
+static void AtomicReadFileAckHandler(
+ uint8_t * service_request,
+ uint16_t service_len,
+ BACNET_ADDRESS * src,
+ BACNET_CONFIRMED_SERVICE_ACK_DATA * service_data)
+{
+ int len = 0;
+ BACNET_ATOMIC_READ_FILE_DATA data;
+
+ if (address_match(&Target_Address, src) && (service_data->invoke_id == Request_Invoke_ID))
+ {
+ len = arf_ack_decode_service_request(service_request, service_len, &data);
+ if (len > 0)
+ {
+ /* validate the parameters before storing data */
+ if ((data.access == FILE_STREAM_ACCESS) && (service_data->invoke_id == Request_Invoke_ID))
+ {
+ char msg[32];
+ uint8_t *pFileData;
+ int i;
+
+ sprintf(msg, "EOF=%d,start=%d,", data.endOfFile, data.type.stream.fileStartPosition);
+ __LogAnswer(msg, 0);
+
+ pFileData = octetstring_value(&data.fileData);
+ for (i=0; iinvoke_id == Request_Invoke_ID)) {
+ len = rp_ack_decode_service_request(service_request, service_len, &data);
+ if (len > 0)
+ {
+ rp_ack_extract_data(&data);
+ }
+ }
+}
+
+/** Handler for a ReadPropertyMultiple ACK.
+ * @ingroup DSRPM
+ * For each read property, print out the ACK'd data,
+ * and free the request data items from linked property list.
+ *
+ * @param service_request [in] The contents of the service request.
+ * @param service_len [in] The length of the service_request.
+ * @param src [in] BACNET_ADDRESS of the source of the message
+ * @param service_data [in] The BACNET_CONFIRMED_SERVICE_DATA information
+ * decoded from the APDU header of this message.
+ */
+static void My_Read_Property_Multiple_Ack_Handler(
+ uint8_t * service_request,
+ uint16_t service_len,
+ BACNET_ADDRESS * src,
+ BACNET_CONFIRMED_SERVICE_ACK_DATA * service_data)
+{
+ int len = 0;
+ BACNET_READ_ACCESS_DATA *rpm_data;
+ BACNET_READ_ACCESS_DATA *old_rpm_data;
+ BACNET_PROPERTY_REFERENCE *rpm_property;
+ BACNET_PROPERTY_REFERENCE *old_rpm_property;
+ BACNET_APPLICATION_DATA_VALUE *value;
+ BACNET_APPLICATION_DATA_VALUE *old_value;
+
+ if (address_match(&Target_Address, src) &&
+ (service_data->invoke_id == Request_Invoke_ID)) {
+ rpm_data = calloc(1, sizeof(BACNET_READ_ACCESS_DATA));
+ if (rpm_data) {
+ len =
+ rpm_ack_decode_service_request(service_request, service_len,
+ rpm_data);
+ }
+ if (len > 0) {
+ while (rpm_data) {
+ rpm_ack_extract_data(rpm_data);
+ rpm_property = rpm_data->listOfProperties;
+ while (rpm_property) {
+ value = rpm_property->value;
+ while (value) {
+ old_value = value;
+ value = value->next;
+ free(old_value);
+ }
+ old_rpm_property = rpm_property;
+ rpm_property = rpm_property->next;
+ free(old_rpm_property);
+ }
+ old_rpm_data = rpm_data;
+ rpm_data = rpm_data->next;
+ free(old_rpm_data);
+ }
+ } else {
+ LogError("RPM Ack Malformed! Freeing memory...");
+ while (rpm_data) {
+ rpm_property = rpm_data->listOfProperties;
+ while (rpm_property) {
+ value = rpm_property->value;
+ while (value) {
+ old_value = value;
+ value = value->next;
+ free(old_value);
+ }
+ old_rpm_property = rpm_property;
+ rpm_property = rpm_property->next;
+ free(old_rpm_property);
+ }
+ old_rpm_data = rpm_data;
+ rpm_data = rpm_data->next;
+ free(old_rpm_data);
+ }
+ }
+ }
+}
+
+void My_Write_Property_SimpleAck_Handler(
+ BACNET_ADDRESS * src,
+ uint8_t invoke_id)
+{
+ if (address_match(&Target_Address, src) &&
+ (invoke_id == Request_Invoke_ID))
+ {
+ __LogAnswer("WriteProperty Acknowledged!", 0);
+ }
+}
+
+
+static void Init_Service_Handlers()
+{
+ Device_Init(NULL);
+
+ /* we need to handle who-is to support dynamic device binding to us */
+ apdu_set_unconfirmed_handler(SERVICE_UNCONFIRMED_WHO_IS, handler_who_is);
+
+ /* handle i-am to support binding to other devices */
+ apdu_set_unconfirmed_handler(SERVICE_UNCONFIRMED_I_AM, handler_i_am_bind);
+
+ /* set the handler for all the services we don't implement
+ It is required to send the proper reject message... */
+ apdu_set_unrecognized_service_handler_handler (handler_unrecognized_service);
+
+ /* we must implement read property - it's required! */
+ apdu_set_confirmed_handler(SERVICE_CONFIRMED_READ_PROPERTY, handler_read_property);
+
+ /* handle generic errors coming back */
+ apdu_set_abort_handler(MyAbortHandler);
+ apdu_set_reject_handler(MyRejectHandler);
+}
+
+typedef enum
+{
+ waitAnswer,
+ waitBind,
+} waitAction;
+
+static void Wait_For_Answer_Or_Timeout(unsigned timeout_ms, waitAction action)
+{
+ // Wait for timeout, failure, or success
+ time_t last_seconds = time(NULL);
+ time_t timeout_seconds = (apdu_timeout() / 1000) * apdu_retries();
+ time_t elapsed_seconds = 0;
+ uint16_t pdu_len = 0;
+ BACNET_ADDRESS src = {0}; /* address where message came from */
+ uint8_t Rx_Buf[MAX_MPDU] = { 0 };
+
+ while (true)
+ {
+ time_t current_seconds = time(NULL);
+
+ // If error was detected then bail out
+ if (Error_Detected)
+ {
+ LogError("Some other error occurred");
+ break;
+ }
+
+ if (elapsed_seconds > timeout_seconds)
+ {
+ LogError("APDU Timeout");
+ break;
+ }
+
+ /* Process PDU if one comes in */
+ pdu_len = datalink_receive(&src, &Rx_Buf[0], MAX_MPDU, timeout_ms);
+ if (pdu_len)
+ {
+ npdu_handler(&src, &Rx_Buf[0], pdu_len);
+ }
+
+ /* at least one second has passed */
+ if (current_seconds != last_seconds)
+ {
+ tsm_timer_milliseconds(((current_seconds - last_seconds) * 1000));
+ }
+
+ if (action == waitAnswer)
+ {
+ // Response was received. Exit.
+ if (tsm_invoke_id_free(Request_Invoke_ID))
+ {
+ break;
+ }
+ else if (tsm_invoke_id_failed(Request_Invoke_ID))
+ {
+ LogError("TSM Timeout!");
+ tsm_free_invoke_id(Request_Invoke_ID);
+ break;
+ }
+ }
+ else if (action == waitBind)
+ {
+ if (address_bind_request(Target_Device_Object_Instance, &Target_Max_APDU, &Target_Address))
+ {
+ break;
+ }
+ }
+ else
+ {
+ LogError("Invalid waitAction requested");
+ break;
+ }
+
+ // Keep track of time
+ elapsed_seconds += (current_seconds - last_seconds);
+ last_seconds = current_seconds;
+ }
+}
+
+/****************************************************/
+/* Interface API */
+/****************************************************/
+
+/****************************************************/
+// This is the most fundamental setup needed to start communication
+/****************************************************/
+void BacnetPrepareComm()
+{
+ /* setup my info */
+ Device_Set_Object_Instance_Number(BACNET_MAX_INSTANCE);
+ address_init();
+ Init_Service_Handlers();
+ dlenv_init();
+}
+
+/****************************************************/
+// Try to bind to a device. If successful, return zero. If failure, return
+// non-zero and log the error details
+/****************************************************/
+int BacnetBindToDevice(int deviceInstanceNumber)
+{
+ int isFailure = 0;
+
+ // Store the requested device instance number in the global variable for
+ // reference in other communication routines
+ Target_Device_Object_Instance = deviceInstanceNumber;
+
+ /* try to bind with the device */
+ if (! address_bind_request(deviceInstanceNumber, &Target_Max_APDU, &Target_Address))
+ {
+ Send_WhoIs(Target_Device_Object_Instance, Target_Device_Object_Instance);
+
+ // Wait for timeout, failure, or success
+ Wait_For_Answer_Or_Timeout(100, waitBind);
+ }
+
+ // Clean up after ourselves
+ isFailure = Error_Detected;
+ Error_Detected = false;
+ return isFailure;
+}
+
+/****************************************************/
+// This is the interface to ReadProperty
+/****************************************************/
+int BacnetReadProperty(int deviceInstanceNumber, int objectType, int objectInstanceNumber, int objectProperty, int objectIndex)
+{
+ if (!isReadPropertyHandlerRegistered)
+ {
+ /* handle the data coming back from confirmed requests */
+ apdu_set_confirmed_ack_handler(SERVICE_CONFIRMED_READ_PROPERTY, My_Read_Property_Ack_Handler);
+
+ /* handle any errors coming back */
+ apdu_set_error_handler(SERVICE_CONFIRMED_READ_PROPERTY, My_Error_Handler);
+
+ // indicate that handlers are now registered
+ isReadPropertyHandlerRegistered = true;
+ }
+
+ // Send the message out
+ Request_Invoke_ID = Send_Read_Property_Request(deviceInstanceNumber, objectType, objectInstanceNumber, objectProperty, objectIndex);
+ Wait_For_Answer_Or_Timeout(100, waitAnswer);
+
+ int isFailure = Error_Detected;
+ Error_Detected = 0;
+ return isFailure;
+}
+
+/************************************************/
+// This is the interface to ReadPropertyMultiple
+/************************************************/
+int BacnetReadPropertyMultiple(int deviceInstanceNumber, ... )
+{
+ // Get the variable argument list from the stack
+ Inline_Stack_Vars;
+ int rpmIndex = 1;
+ BACNET_READ_ACCESS_DATA *rpm_object = calloc(1, sizeof(BACNET_READ_ACCESS_DATA));
+ BACNET_READ_ACCESS_DATA *Read_Access_Data = rpm_object;
+ BACNET_PROPERTY_REFERENCE *rpm_property;
+ uint8_t buffer[MAX_PDU] = { 0 };
+
+ while (rpmIndex < Inline_Stack_Items)
+ {
+ SV *pSV = Inline_Stack_Item(rpmIndex++);
+
+ // Make sure the argument is an Array Reference
+ if (SvTYPE(SvRV(pSV)) != SVt_PVAV)
+ {
+ LogError("Argument is not an Array reference");
+ break;
+ }
+
+ // Make sure we can access the memory
+ if (rpm_object)
+ {
+ rpm_object->listOfProperties = NULL;
+ }
+ else
+ {
+ LogError("Memory Allocation Issue");
+ break;
+ }
+
+ AV *pAV = (AV *)SvRV(pSV);
+ SV **ppSV;
+
+ // The 0th argument is the object type
+ ppSV = av_fetch(pAV, 0, 0);
+ if (ppSV)
+ {
+ rpm_object->object_type = SvIV(*ppSV);
+ }
+ else
+ {
+ LogError("Problem parsing the Array of arguments");
+ break;
+ }
+
+ // The 1st argument is the object instance
+ ppSV = av_fetch(pAV, 1, 0);
+ if (ppSV)
+ {
+ rpm_object->object_instance = SvIV(*ppSV);
+ }
+ else
+ {
+ LogError("Problem parsing the Array of arguments");
+ break;
+ }
+
+ // The 2nd argument is the property type
+ ppSV = av_fetch(pAV, 2, 0);
+ if (ppSV)
+ {
+ rpm_property = calloc(1, sizeof(BACNET_PROPERTY_REFERENCE));
+ rpm_object->listOfProperties = rpm_property;
+ if (rpm_property)
+ {
+ rpm_property->propertyIdentifier = SvIV(*ppSV);
+ }
+ else
+ {
+ LogError("Memory allocation error");
+ break;
+ }
+ }
+ else
+ {
+ LogError("Problem parsing the Array of arguments");
+ break;
+ }
+
+ // The 3rd argument is the property index
+ ppSV = av_fetch(pAV, 3, 0);
+ if (ppSV)
+ {
+ rpm_property->propertyArrayIndex = SvIV(*ppSV);
+ }
+ else
+ {
+ LogError("Problem parsing the Array of arguments");
+ break;
+ }
+
+ // Advance to the next RPM index
+ if (rpmIndex < Inline_Stack_Items)
+ {
+ rpm_object->next = calloc(1, sizeof(BACNET_READ_ACCESS_DATA));
+ rpm_object = rpm_object->next;
+ }
+ else
+ {
+ rpm_object->next = NULL;
+ }
+ }
+
+ if (!isReadPropertyMultipleHandlerRegistered)
+ {
+ /* handle the data coming back from confirmed requests */
+ apdu_set_confirmed_ack_handler(SERVICE_CONFIRMED_READ_PROP_MULTIPLE,
+ My_Read_Property_Multiple_Ack_Handler);
+
+ /* handle any errors coming back */
+ apdu_set_error_handler(SERVICE_CONFIRMED_READ_PROP_MULTIPLE, My_Error_Handler);
+
+ // indicate that handlers are now registered
+ isReadPropertyMultipleHandlerRegistered = true;
+ }
+
+ // Send the message out
+ if (!Error_Detected)
+ {
+ Request_Invoke_ID = Send_Read_Property_Multiple_Request(
+ &buffer[0], sizeof(buffer),
+ deviceInstanceNumber, Read_Access_Data);
+ Wait_For_Answer_Or_Timeout(100, waitAnswer);
+ }
+
+ // Clean up allocated memory
+ BACNET_READ_ACCESS_DATA *old_rpm_object;
+ BACNET_PROPERTY_REFERENCE *old_rpm_property;
+
+ rpm_object = Read_Access_Data;
+ old_rpm_object = rpm_object;
+ while (rpm_object)
+ {
+ rpm_property = rpm_object->listOfProperties;
+ while (rpm_property)
+ {
+ old_rpm_property = rpm_property;
+ rpm_property = rpm_property->next;
+ free(old_rpm_property);
+ }
+ old_rpm_object = rpm_object;
+ rpm_object = rpm_object->next;
+ free(old_rpm_object);
+ }
+
+ // Process the return value
+ int isFailure = Error_Detected;
+ Error_Detected = 0;
+ return isFailure;
+}
+
+/****************************************************/
+// This is the interface to WriteProperty
+/****************************************************/
+int BacnetWriteProperty(int deviceInstanceNumber,
+ int objectType,
+ int objectInstanceNumber,
+ int objectProperty,
+ int objectPriority,
+ int objectIndex,
+ const char *tag,
+ const char *value)
+{
+ char msg[MAX_ERROR_STRING];
+ int isFailure = 1;
+
+ if (!isWritePropertyHandlerRegistered)
+ {
+ /* handle the ack coming back */
+ apdu_set_confirmed_simple_ack_handler(SERVICE_CONFIRMED_WRITE_PROPERTY, My_Write_Property_SimpleAck_Handler);
+
+ /* handle any errors coming back */
+ apdu_set_error_handler(SERVICE_CONFIRMED_WRITE_PROPERTY, My_Error_Handler);
+
+ // indicate that handlers are now registered
+ isWritePropertyHandlerRegistered = true;
+ }
+
+ if (objectIndex == -1)
+ {
+ objectIndex = BACNET_ARRAY_ALL;
+ }
+
+ // Loop for eary exit;
+ do
+ {
+ // Handle the tag/value pair
+ uint8_t context_tag = 0;
+ BACNET_APPLICATION_TAG property_tag;
+ BACNET_APPLICATION_DATA_VALUE propertyValue;
+
+ if (toupper(tag[0]) == 'C')
+ {
+ context_tag = strtol(&tag[1], NULL, 0);
+ propertyValue.context_tag = context_tag;
+ propertyValue.context_specific = true;
+ }
+ else
+ {
+ propertyValue.context_specific = false;
+ }
+ property_tag = strtol(tag, NULL, 0);
+
+ if (property_tag >= MAX_BACNET_APPLICATION_TAG)
+ {
+ sprintf(msg, "Error: tag=%u - it must be less than %u", property_tag, MAX_BACNET_APPLICATION_TAG);
+ LogError(msg);
+ break;
+ }
+ if (!my_bacapp_parse_application_data(property_tag, value, &propertyValue))
+ {
+ sprintf(msg, "Error: unable to parse the tag value");
+ LogError(msg);
+ break;
+ }
+ propertyValue.next = NULL;
+
+ // Send out the message
+ Request_Invoke_ID = Send_Write_Property_Request(
+ deviceInstanceNumber,
+ objectType, objectInstanceNumber,
+ objectProperty, &propertyValue, objectPriority, objectIndex);
+ Wait_For_Answer_Or_Timeout(100, waitAnswer);
+
+ // If we get here, then there were no explicit failures. However, there
+ // could have been implicit failures. Let's look at those also.
+ isFailure = Error_Detected;
+ } while(false);
+
+ // Clean up after ourselves.
+ Error_Detected = false;
+ return isFailure;
+}
+
+
+int BacnetAtomicWriteFile (int deviceInstanceNumber,
+ int fileInstanceNumber,
+ int blockStartAddr,
+ int blockNumBytes,
+ char *nibbleBuffer)
+{
+ BACNET_OCTET_STRING fileData;
+ int i, nibble;
+ uint8_t byteValue;
+ unsigned char nibbleValue;
+
+ if (!isAtomicWriteFileHandlerRegistered)
+ {
+ /* handle any errors coming back */
+ apdu_set_error_handler(SERVICE_CONFIRMED_ATOMIC_WRITE_FILE, My_Error_Handler);
+
+ // indicate that handlers are now registered
+ isAtomicWriteFileHandlerRegistered = true;
+ }
+
+ for (i=0; i= '0') && (nibbleValue <= '9') )
+ {
+ byteValue += (nibbleValue-'0') << (4*(1-nibble));
+ }
+ else if ( (nibbleValue >= 'A') && (nibbleValue <= 'F') )
+ {
+ byteValue += (nibbleValue-'A'+10) << (4*(1-nibble));
+ }
+ else
+ {
+ LogError("Bad data in buffer.");
+ }
+ }
+ fileData.value[i] = byteValue;
+ }
+ octetstring_truncate(&fileData, blockNumBytes);
+
+ // Send out the message and wait for answer
+ if (!Error_Detected)
+ {
+ Request_Invoke_ID = Send_Atomic_Write_File_Stream(
+ deviceInstanceNumber,
+ fileInstanceNumber,
+ blockStartAddr,
+ &fileData);
+ Wait_For_Answer_Or_Timeout(100, waitAnswer);
+ }
+
+ int isFailure = Error_Detected;
+ Error_Detected = 0;
+ return isFailure;
+}
+
+int BacnetGetMaxApdu()
+{
+ unsigned requestedOctetCount = 0;
+ uint16_t my_max_apdu = 0;
+
+ /* calculate the smaller of our APDU size or theirs
+ and remove the overhead of the APDU (varies depending on size).
+ note: we could fail if there is a bottle neck (router)
+ and smaller MPDU in betweeen. */
+ if (Target_Max_APDU < MAX_APDU) {
+ my_max_apdu = Target_Max_APDU;
+ } else {
+ my_max_apdu = MAX_APDU;
+ }
+ /* Typical sizes are 50, 128, 206, 480, 1024, and 1476 octets */
+ if (my_max_apdu <= 50) {
+ requestedOctetCount = my_max_apdu - 19;
+ } else if (my_max_apdu <= 480) {
+ requestedOctetCount = my_max_apdu - 32;
+ } else if (my_max_apdu <= 1476) {
+ requestedOctetCount = my_max_apdu - 64;
+ } else {
+ requestedOctetCount = my_max_apdu / 2;
+ }
+
+ return requestedOctetCount;
+}
+
+int BacnetTimeSync(int deviceInstanceNumber,
+ int year,
+ int month,
+ int day,
+ int hour,
+ int minute,
+ int second,
+ int isUTC,
+ int UTCOffset)
+
+{
+ BACNET_DATE bdate;
+ BACNET_TIME btime;
+ struct tm my_time;
+ time_t aTime;
+ struct tm *newTime;
+
+ my_time.tm_sec = second;
+ my_time.tm_min = minute;
+ my_time.tm_hour = hour;
+ my_time.tm_mday = day;
+ my_time.tm_mon = month-1;
+ my_time.tm_year = year-1900;
+ my_time.tm_wday = 0; // does not matter
+ my_time.tm_yday = 0; // does not matter
+ my_time.tm_isdst = 0; // does not matter
+
+ aTime = mktime(&my_time);
+ newTime = localtime(&aTime);
+
+ bdate.year = newTime->tm_year;
+ bdate.month = newTime->tm_mon+1;
+ bdate.day = newTime->tm_mday;
+ bdate.wday = newTime->tm_wday ? newTime->tm_wday : 7;
+ btime.hour = newTime->tm_hour;
+ btime.min = newTime->tm_min;
+ btime.sec = newTime->tm_sec;
+ btime.hundredths = 0;
+
+ int len = 0;
+ int pdu_len = 0;
+ int bytes_sent = 0;
+ BACNET_NPDU_DATA npdu_data;
+ BACNET_ADDRESS my_address;
+ uint8_t Handler_Transmit_Buffer[MAX_PDU] = { 0 };
+
+ // Loop for eary exit
+ do
+ {
+ if (!dcc_communication_enabled())
+ {
+ LogError("DCC communicaiton is not enabled");
+ break;
+ }
+
+ /* encode the NPDU portion of the packet */
+ npdu_encode_npdu_data(&npdu_data, false, MESSAGE_PRIORITY_NORMAL);
+ datalink_get_my_address(&my_address);
+ pdu_len = npdu_encode_pdu(&Handler_Transmit_Buffer[0], &Target_Address, &my_address, &npdu_data);
+
+ /* encode the APDU portion of the packet */
+ len = timesync_encode_apdu(&Handler_Transmit_Buffer[pdu_len], &bdate, &btime);
+ pdu_len += len;
+
+ /* send it out the datalink */
+ bytes_sent = datalink_send_pdu(&Target_Address, &npdu_data, &Handler_Transmit_Buffer[0], pdu_len);
+ if (bytes_sent <= 0)
+ {
+ char errorMsg[64];
+ sprintf(errorMsg, "Failed to Send Time-Synchronization Request (%s)!", strerror(errno));
+ LogError(errorMsg);
+ break;
+ }
+
+ Wait_For_Answer_Or_Timeout(100, waitAnswer);
+ } while (false);
+
+ int isFailure = Error_Detected;
+ Error_Detected = 0;
+ return isFailure;
+}
+
+/****************************************************/
+// This is the interface to AtomicReadFile
+/****************************************************/
+int BacnetAtomicReadFile(int deviceInstanceNumber, int fileInstanceNumber, int startOffset, int numBytes)
+{
+ if (!isAtomicReadFileHandlerRegistered)
+ {
+ /* handle the data coming back from confirmed requests */
+ apdu_set_confirmed_ack_handler(SERVICE_CONFIRMED_ATOMIC_READ_FILE, AtomicReadFileAckHandler);
+
+ /* handle any errors coming back */
+ apdu_set_error_handler(SERVICE_CONFIRMED_ATOMIC_READ_FILE, My_Error_Handler);
+
+ // indicate that handlers are now registered
+ isAtomicReadFileHandlerRegistered = true;
+ }
+
+ // Send the message out
+ Request_Invoke_ID = Send_Atomic_Read_File_Stream(deviceInstanceNumber, fileInstanceNumber, startOffset, numBytes);
+ Wait_For_Answer_Or_Timeout(100, waitAnswer);
+
+ int isFailure = Error_Detected;
+ Error_Detected = 0;
+ return isFailure;
+}
+
diff --git a/bacnet-stack/demo/perl/readme.txt b/bacnet-stack/demo/perl/readme.txt
new file mode 100644
index 00000000..bb33b8a4
--- /dev/null
+++ b/bacnet-stack/demo/perl/readme.txt
@@ -0,0 +1,14 @@
+The BACnet Scriptable (using Perl) Tool.
+
+* Running this tool assumes that the library has been already built. Currently,
+ the tool assumes only win32 port, but should be easily modifiable for any
+ port build. The library has to be built with BBMD_DEFINE=-DBBMD_ENABLED\=1
+* This tool has to be run from a path without any spaces. The presence of the
+ .Inline directory is required.
+* Run the tool without any arguments to see usage instructions
+* To run the example ReapProperty script (which reads Analog Value 0 Present
+ Value) for Device at instance 1234 run the following command
+
+ perl bacnet.pl --script example_readprop.pl -- 1234
+
+