create a server in the negotiator thread... this thread should be renamed to MASTER...

git-svn-id: http://www.frescor.org/private/svn/frescor/fna/trunk@1094 35b4ef3e-fd22-0410-ab77-dab3279adceb

diff --git a/src_frescan/frescan_negotiator_thread.c b/src_frescan/frescan_negotiator_thread.c
index d3c719d9e799542cd34237f309b2c0fa2d7406cd..d0a02e81e080f6c69d672515921d9cc17afaff9a 100644 (file)
--- a/src_frescan/frescan_negotiator_thread.c
+++ b/src_frescan/frescan_negotiator_thread.c
@@ -20,6 +20,7 @@
 #include "frescan_debug.h"
 #include "frescan_data.h"
 #include "frescan_requests_queue.h"
+#include "frescan_servers.h"
 
 static void *frescan_neg_thread(void *arg);
 
@@ -76,6 +77,7 @@ static void *frescan_neg_thread(void *arg)
         frescan_robj_id_t    reply;
         frescan_contract_t   *contract;
         frescan_neg_return_info_t *neg_return_info;
+        frescan_server_params_t server_params;
 
         DEBUG(FRESCAN_NEG_THREAD_ENABLE_DEBUG, "negotiator thread starts\n");
 
@@ -99,8 +101,15 @@ static void *frescan_neg_thread(void *arg)
                                 err = frescan_request_get_return_info(request, (void *)&neg_return_info);
                                 assert(err == 0);
 
+                                // TODO: sched test + add contract to table
+                                // so far always accepted witht he min values
                                 neg_return_info->error = 0;
-                                neg_return_info->id = 78;
+                                server_params.values = contract->min_values;
+                                server_params.prio   = contract->prio;
+                                err = frescan_servers_create((frescan_network_t)(uint32_t)arg,
+                                                             &server_params,
+                                                             &neg_return_info->id);
+                                assert(err == 0);
 
                                 err = frescan_replyobject_signal(reply);
                                 assert(err == 0);