00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00038
00039 #include "APIRegistration.h"
00040 #include "bundling/Bundle.h"
00041 #include "bundling/BundleDaemon.h"
00042 #include "bundling/BundleList.h"
00043
00044 namespace dtn {
00045
00046 APIRegistration::APIRegistration(const oasys::Builder& builder)
00047 : Registration(builder)
00048 {
00049 bundle_list_ = new BlockingBundleList(logpath_);
00050 }
00051
00052 APIRegistration::APIRegistration(u_int32_t regid,
00053 const EndpointIDPattern& endpoint,
00054 failure_action_t action,
00055 u_int32_t expiration,
00056 const std::string& script)
00057 : Registration(regid, endpoint, action, expiration, script)
00058 {
00059 bundle_list_ = new BlockingBundleList(logpath_);
00060 }
00061
00062 APIRegistration::~APIRegistration()
00063 {
00064 delete bundle_list_;
00065 }
00066
00067 void
00068 APIRegistration::deliver_bundle(Bundle* bundle)
00069 {
00070 if (!active() && (failure_action_ == DROP)) {
00071 log_info("deliver_bundle: "
00072 "dropping bundle id %d for passive registration %d (%s)",
00073 bundle->bundleid_, regid_, endpoint_.c_str());
00074
00075
00076 BundleDaemon::post(new BundleDeliveredEvent(bundle, this));
00077 return;
00078 }
00079
00080 if (!active() && (failure_action_ == EXEC)) {
00081
00082
00083 log_info("deliver_bundle: "
00084 "running script '%s' for registration %d (%s)",
00085 script_.c_str(), regid_, endpoint_.c_str());
00086
00087 system(script_.c_str());
00088
00089 }
00090
00091 log_info("deliver_bundle: queuing bundle id %d for %s delivery to %s",
00092 bundle->bundleid_,
00093 active() ? "active" : "deferred",
00094 endpoint_.c_str());
00095
00096 if (BundleDaemon::instance()->params_.test_permuted_delivery_) {
00097 bundle_list_->insert_random(bundle);
00098 } else {
00099 bundle_list_->push_back(bundle);
00100 }
00101 }
00102
00103
00104 }