send.c

short * sendrequest_1_svc(param *para, struct svc_req *req){
    char* req_addr = inet_ntoa(req->rq_xprt->xp_raddr.sin_addr);
    l_sub* ptr = sub_list;

    while(ptr != NULL){
        if(strcmp(ptr.ip,req_addr)){
            if(check_session(ptr,para)!=1){
                response = INVALID_SESSION;
                return &response;
            }
            break;
        }
        ptr = ptr->next;
    }


    switch(para->arg.topic_or_message){
        case 0://topic
            return set_channel_1_svc(&para->arg.argument_u.t,req);
            break; 
        case 1://message
            return publish_1_svc(&para->arg.argument_u.m, req);
            break;
        default: break;
    }
}