Revision 2c811df1 src/urt_node.c

View differences:

src/urt_node.c
73 73 
  node->thread = thread;
74 74 
  node->setupcallback = setupcallback;
75 75 
  node->setupparams = setupparams;
76 
  node->loopcallback = loopcallback;
76 77 
  node->loopparams = loopparams;
77 
  node->shutdowncallback = loopcallback;
78 
  node->shutdownparams = loopparams;
78 
  node->shutdowncallback = shutdowncallback;
79 
  node->shutdownparams = shutdownparams;
79 80 
  node->stage = 0;
80 
  // add later: urteventlistenerinit
81 
  urtEventListenerInit(node->listener);
81 82 
  #if (URT_CFG_PUBSUB_PROFILING || URT_CFG_RPC_PROFILING)
82 83 
    node->loops = 0;
83 84 
  #endif /* URT_CFG_PUBSUB_PROFILING || URT_CFG_RPC_PROFILING */
84 
    // add later: lock core,..
85 
  urt_core_t temp; //TODO: Correct?
86 
  urtMutexLock(&temp._lock);
87 
    node->next = temp._nodes;
88 
    temp._nodes = node;
89 
  urtMutexUnlock(&temp._lock);
85 90 
  return;
86 91 
}

Also available in: Unified diff