sim/SimRegistration.cc
changeset 0 2b3e5ec03512
equal deleted inserted replaced
-1:000000000000 0:2b3e5ec03512
       
     1 /*
       
     2  *    Copyright 2004-2006 Intel Corporation
       
     3  * 
       
     4  *    Licensed under the Apache License, Version 2.0 (the "License");
       
     5  *    you may not use this file except in compliance with the License.
       
     6  *    You may obtain a copy of the License at
       
     7  * 
       
     8  *        http://www.apache.org/licenses/LICENSE-2.0
       
     9  * 
       
    10  *    Unless required by applicable law or agreed to in writing, software
       
    11  *    distributed under the License is distributed on an "AS IS" BASIS,
       
    12  *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
       
    13  *    See the License for the specific language governing permissions and
       
    14  *    limitations under the License.
       
    15  */
       
    16 
       
    17 #ifdef HAVE_CONFIG_H
       
    18 #  include <dtn-config.h>
       
    19 #endif
       
    20 
       
    21 #include <oasys/io/FileIOClient.h>
       
    22 #include <oasys/util/StringBuffer.h>
       
    23 
       
    24 #include "Simulator.h"
       
    25 #include "SimLog.h"
       
    26 #include "SimRegistration.h"
       
    27 #include "Topology.h"
       
    28 #include "bundling/Bundle.h"
       
    29 #include "bundling/BundleDaemon.h"
       
    30 #include "bundling/BundleEvent.h"
       
    31 #include "storage/GlobalStore.h"
       
    32 
       
    33 using namespace dtn;
       
    34 
       
    35 namespace dtnsim {
       
    36 
       
    37 SimRegistration::SimRegistration(Node* node, const EndpointID& endpoint)
       
    38     : Registration(GlobalStore::instance()->next_regid(),
       
    39                    endpoint, DEFER, 0, 0), node_(node)
       
    40 {
       
    41     logpathf("/reg/%s/%d", node->name(), regid_);
       
    42 
       
    43     log_debug("new sim registration");
       
    44 }
       
    45 
       
    46 void
       
    47 SimRegistration::deliver_bundle(Bundle* bundle)
       
    48 {
       
    49     size_t payload_len = bundle->payload().length();
       
    50 
       
    51     log_info("N[%s]: RCV id:%d %s -> %s size:%zu",
       
    52              node_->name(), bundle->bundleid(),
       
    53              bundle->source().c_str(), bundle->dest().c_str(),
       
    54              payload_len);
       
    55 
       
    56     BundleDaemon::post(new BundleDeliveredEvent(bundle, this));
       
    57 }
       
    58 
       
    59 } // namespace dtnsim