|
@@ -628,12 +628,12 @@ UA_StatusCode UA_Server_run_mainloop(UA_Server *server, UA_Boolean *running) {
|
|
|
}
|
|
|
|
|
|
UA_StatusCode UA_Server_run_shutdown(UA_Server *server, UA_UInt16 nThreads){
|
|
|
-#ifdef UA_MULTITHREADING
|
|
|
UA_Job *stopJobs;
|
|
|
for(size_t i = 0; i < server->networkLayersSize; i++) {
|
|
|
- size_t stopJobsSize = server->networkLayers[i]->stop(server->networkLayers[i], &jobs);
|
|
|
+ size_t stopJobsSize = server->networkLayers[i]->stop(server->networkLayers[i], &stopJobs);
|
|
|
processJobs(server, stopJobs, stopJobsSize);
|
|
|
}
|
|
|
+#ifdef UA_MULTITHREADING
|
|
|
/* Wait for all worker threads to finish */
|
|
|
for(UA_UInt32 i=0;i<nThreads;i++) {
|
|
|
pthread_join(server->thr[i], UA_NULL);
|