| 51,14 → 51,11 |
|---|
| void FSF_start_service_task(SOFT_TASK_MODEL *model) { |
| |
| // create the service task |
| cprintf("Create Service Task\n"); |
| // create the communication channel for negotiation and renegotiation |
| |
| channel[1] = port_create("CHANW",sizeof(struct mess),1,STREAM,WRITE); |
| cprintf("(ch %d)", channel[1]); |
| |
| channel[0] = port_create("CHANR",sizeof(struct mess),1,STREAM,READ); |
| cprintf("(ch %d)", channel[0]); |
| |
| server_task = task_create("stask",service_task,model,NULL); |
| if (server_task == -1) { |
| 283,9 → 280,9 |
|---|
| message.type=NEGOTIATE_CONTRACT; |
| memmove(&message.contract,contract, sizeof(fsf_contract_parameters_t)); |
| |
| cprintf("(ps %d)",port_send(channel[1],&message,BLOCK)); |
| port_send(channel[1],&message,BLOCK); |
| |
| cprintf("(pr %d)\n",port_receive(channel[0], &message, BLOCK)); |
| port_receive(channel[0], &message, BLOCK); |
| |
| if (message.server==-1) |
| return FSF_ERR_CONTRACT_REJECTED; |