Pds/src/bmsg.msg.c

31 ** is identified by a unique identifier, the bport identifier, and
1107 ** process has a global receive queue and an associated bport with
1132 ** Sending a message to a bport in the same shared memory domain
1133 ** involves putting a message in the bport's send queue. Application
1684 ** a bport. The bport is created on receiving a bport_open message.
1992 ** Every process has a single base port (bport) to/from which messages
2005 ** the one with the highest bport identifier.
2040     struct port * next;         /* next bport 		   	        */
2041     struct port * prev;         /* previous bport 	   	        */
2096 bport_allocate(port,bport)
2098     bport_t * bport;
2112     * (pds_address_t *) ((char *) &bport->bmsg_queue_address + BMSG_ADDR_OFFSET);
2116     if (bport->bdomain_id == bdomain_self())
2121             (char *) bport->bnet_address,
2123     p->bport_number = bport->bport_number;
2124     p->bpid = bport->bpid;
2125     p->bport_id = bport->bport_id;
2126     p->bdomain_id = bport->bdomain_id;
2175     port_t * first;		/* first bport 	*/
2176     port_t * last;		/* last bport	*/
2986     bport_t bport;
3005 	        bport.bpid = port->bpid;
3006 	        bport.bport_id = port->bport_id;
3007 	        bport.bdomain_id = port->bdomain_id;
3008 	        bport.bmsg_queue_address = (bmem_address_t) send_queue;
3009 	        strcpy((char *) bport.bnet_address,
3011 	        bport.bport_number = port->bport_number;
3013 	        bproc_trigger(&bport);
3227     /* read {bport|bmem}{request|reply} */
3323 **		by storing the identifier of their associated bport
3638     bport_t bport;
3740         /* initialise bport */
3741         bport.bpid = bpid;
3742         bport.bport_id = port_id;
3743         bport.bdomain_id = domain_id;
3744         bport.bmsg_queue_address = msg_queue_address;
3745 	strncpy((char *) bport.bnet_address,
3748         bport.bport_number = bport_number;
3751         if ((ret = bport_allocate(&port,&bport)) != BMSG_OK) {
4657 bport_port(port_id,bport)
4659     bport_t * bport;
4666     if (!port_id || !bport) return(BMSG_INVAL);
4672     bport->bpid = port->bpid;
4673     bport->bport_id = port->bport_id;
4674     bport->bdomain_id = port->bdomain_id;
4677       ((char *) &bport->bmsg_queue_address + BMSG_ADDR_OFFSET) =
4681     strncpy((char *) bport->bnet_address,
4684     bport->bport_number = port->bport_number;
4695 bport_open(bport)
4696     bport_t * bport;
4710     if (!bport ||
4711 	!bport->bport_id ||
4712 	!bport->bdomain_id) return(BMSG_INVAL);
4715     if ((bret = bport_allocate(&port,bport)) != BMSG_OK)
4729     if (bport->bdomain_id != bdomain_self()) {
4731 	address = inet_addr(bport->bnet_address);
4738             rem_ctrl_sock_name.sin_port = htons(bport->bport_number);
6085     bport_t bport;
6122     /* copy identifiers into bport structure */
6123     bport.bport_id = port_id;
6124     bport.bdomain_id = domain->bdomain_id;
6126     /* store local process identifier in bport structure */
6127     bport.bpid = (bpid_t) getpid();
6203     /* copy receive queue address into bport structure */
6207 	         ((char *) &bport.bmsg_queue_address + BMSG_ADDR_OFFSET));
6256     /* get portno and copy it into bport structure */
6266     bport.bport_number = ntohs(ctrl_sock_name.sin_port);
6268     /* get internet address and copy it into bport structure */
6279     strncpy((char *) bport.bnet_address,
6282     bport.bnet_address[BNET_ADDRESSLEN_MAX] = '\0';
6285     if ((bret = bport_allocate(&port_local,&bport)) != BMSG_OK)