serv_p4.cpp

MPICH是MPI的重要研究,提供了一系列的接口函数,为并行计算的实现提供了编程环境.

#ident	"@(#)poll.h	1.19	94/08/31 SMI"	

# 15 "/usr/include/sys/poll.h" 






typedef struct pollfd {
	int fd;				
	short events;			
	short revents;			
} pollfd_t;






















# 96 "/usr/include/sys/poll.h" 
# 125 "/usr/include/sys/poll.h" 


# 129 "/usr/include/sys/poll.h" 


# 133 "/usr/include/sys/poll.h" 



# 18 "/usr/include/sys/stream.h" 2
# 1 "/usr/include/sys/strmdep.h" 1










#ident	"@(#)strmdep.h	1.8	92/07/14 SMI"	

# 15 "/usr/include/sys/strmdep.h" 

























# 42 "/usr/include/sys/strmdep.h" 



# 19 "/usr/include/sys/stream.h" 2
# 1 "/usr/include/sys/cred.h" 1






























# 96 "/usr/include/sys/cred.h" 

# 20 "/usr/include/sys/stream.h" 2
# 1 "/usr/include/sys/t_lock.h" 1










# 49 "/usr/include/sys/t_lock.h" 
# 97 "/usr/include/sys/t_lock.h" 

# 21 "/usr/include/sys/stream.h" 2

# 24 "/usr/include/sys/stream.h" 


































typedef struct	queue {
	struct	qinit	*q_qinfo;	
	struct	msgb	*q_first;	
	struct	msgb	*q_last;	
	struct	queue	*q_next;	
	struct	queue	*q_link;	
	void		*q_ptr;		
	ulong		q_count;	
	ulong		q_flag;		
	long		q_minpsz;	
					
	long		q_maxpsz;	
					
	ulong		q_hiwat;	
	ulong		q_lowat;	
	struct qband	*q_bandp;	
	kmutex_t	q_lock;		
	struct stdata 	*q_stream;	
	struct	syncq	*q_syncq;	
	unsigned char	q_nband;	
	kcondvar_t	q_wait;		
	kcondvar_t	q_sync;		
	struct	queue	*q_nfsrv;	
	struct	queue	*q_nbsrv;	
	ushort		q_draining;	
	short		q_struiot;	
} queue_t;





















					











typedef struct qband {
	struct qband	*qb_next;	
	ulong		qb_count;	
	struct msgb	*qb_first;	
	struct msgb	*qb_last;	
	ulong		qb_hiwat;	
	ulong		qb_lowat;	
	ulong		qb_flag;	
} qband_t;
















typedef enum qfields {
	QHIWAT	= 0,		
	QLOWAT	= 1,		
	QMAXPSZ	= 2,		
	QMINPSZ	= 3,		
	QCOUNT	= 4,		
	QFIRST	= 5,		
	QLAST	= 6,		
	QFLAG	= 7,		
	QSTRUIOT = 8,		
	QBAD	= 9
} qfields_t;




struct module_info {
	ushort	mi_idnum;		
	char 	*mi_idname;		
	long	mi_minpsz;		
	long	mi_maxpsz;		
	ulong	mi_hiwat;		
	ulong 	mi_lowat;		
};




struct	qinit {
	int	(*qi_putp)();		
	int	(*qi_srvp)();		
	int	(*qi_qopen)();		
	int	(*qi_qclose)();		
	int	(*qi_qadmin)();		
	struct module_info *qi_minfo;	
	struct module_stat *qi_mstat;	
	int	(*qi_rwp)();		
	int	(*qi_infop)();		
	int	qi_struiot;		
};













struct streamtab {
	struct qinit *st_rdinit;
	struct qinit *st_wrinit;
	struct qinit *st_muxrinit;
	struct qinit *st_muxwinit;
};





struct linkblk {
	queue_t *l_qtop;	
				
	queue_t *l_qbot;	
	int	l_index;	
};




typedef struct free_rtn {
	void (*free_func)();
	char *free_arg;
	struct	free_rtn	*free_next;
	int free_flags;
} frtn_t;














typedef struct datab {
	struct free_rtn	*db_frtnp;
	unsigned char	*db_base;
	unsigned char	*db_lim;
	unsigned char	db_ref;
	unsigned char	db_type;
	unsigned char	db_refmin;
	unsigned char	db_struioflag;
	void		*db_cache;	
	unsigned char	*db_struiobase;
	unsigned char	*db_struiolim;
	unsigned char	*db_struioptr;
	union {
		unsigned char data[8];
		


	} db_struioun;
} dblk_t;




typedef struct	msgb {
	struct	msgb	*b_next;
	struct  msgb	*b_prev;
	struct	msgb	*b_cont;
	unsigned char	*b_rptr;
	unsigned char	*b_wptr;
	struct datab 	*b_datap;
	unsigned char	b_band;
	unsigned short	b_flag;
	queue_t		*b_queue;	
} mblk_t;














					

























# 313 "/usr/include/sys/stream.h" 



































struct iocblk {
	int 	ioc_cmd;		
	cred_t	*ioc_cr;		
	uint	ioc_id;			
	uint	ioc_count;		
	int	ioc_error;		
	int	ioc_rval;		
	long	ioc_filler[4];		
};








struct copyreq {
	int	cq_cmd;			
	cred_t	*cq_cr;			
	uint	cq_id;			
	caddr_t	cq_addr;		
	uint	cq_size;		
	int	cq_flag;		
	mblk_t *cq_private;		
	long	cq_filler[4];		
};







					

					
					





struct copyresp {
	int	cp_cmd;			
	cred_t	*cp_cr;			
	uint	cp_id;			
	caddr_t	cp_rval;		
					
	uint	cp_pad1;
	int	cp_pad2;
	mblk_t *cp_private;		
	long	cp_filler[4];
};









struct stroptions {
	ulong	so_flags;		
	short	so_readopt;		
	ushort	so_wroff;		
	long	so_minpsz;		
	long	so_maxpsz;		
	ulong	so_hiwat;		
	ulong	so_lowat;		
	unsigned char so_band;		
	ushort	so_erropt;		
};






























struct str_evmsg {
	long		 sv_event;	
	vnode_t		*sv_vp;		
	long		 sv_eid;	
	long		 sv_evpri;	
	long		 sv_flags;	
	uid_t		 sv_uid;	
	pid_t		 sv_pid;	
	hostid_t	 sv_hostid;	
	long		 sv_pad[4];	
};










typedef struct struiod {
	mblk_t		*d_mp;		
	uio_t		d_uio;		
	iovec_t d_iov[16];	
} struiod_t;




typedef struct infod {
	unsigned char	d_cmd;		
	unsigned char	d_res;		
	int		d_bytes;	
	int		d_count;	
	uio_t		*d_uiop;	
} infod_t;















# 506 "/usr/include/sys/stream.h" 












































































# 584 "/usr/include/sys/stream.h" 































# 684 "/usr/include/sys/stream.h" 





extern int nstrpush;			

# 693 "/usr/include/sys/stream.h" 



# 29 "/usr/include/netinet/in.h" 2
# 1 "/usr/include/sys/byteorder.h" 1







# 43 "/usr/include/sys/byteorder.h" 
# 62 "/usr/include/sys/byteorder.h" 

# 30 "/usr/include/netinet/in.h" 2




















































































struct in_addr {
	union {
		struct { u_char s_b1, s_b2, s_b3, s_b4; } S_un_b;
		struct { u_short s_w1, s_w2; } S_un_w;
		u_long S_addr;
	} S_un;






};




















































struct sockaddr_in {
	short	sin_family;
	u_short	sin_port;
	struct	in_addr sin_addr;
	char	sin_zero[8];
};
























struct ip_mreq {
	struct in_addr	imr_multiaddr;	
	struct in_addr	imr_interface;	
};





# 228 "/usr/include/netinet/in.h" 


# 232 "/usr/include/netinet/in.h" 



# 15 "/usr/include/rpc/auth_kerb.h" 2

# 19 "/usr/include/rpc/auth_kerb.h" 



# 24 "/usr/include/rpc/auth_kerb.h" 





enum authkerb_namekind {
	AKN_FULLNAME,
	AKN_NICKNAME
};



struct authkerb_fullname {
	KTEXT_ST ticket;
	u_long window;		
};




struct authkerb_clnt_cred {
	
	unsigned char k_flags;	
	char    pname[40]; 
	char    pinst[40];	
	char    prealm[40]; 
	unsigned long checksum;	
	des_cblock session;	
	int	life;		
	unsigned long time_sec;	
	unsigned long address;	
	
	
	unsigned long expiry;	
	u_long nickname;	
	u_long window;		
};

typedef struct authkerb_clnt_cred authkerb_clnt_cred;




struct authkerb_cred {
	enum authkerb_namekind akc_namekind;
	struct authkerb_fullname akc_fullname;
	u_long akc_nickname;
};




struct authkerb_verf {
	union {
		struct timeval akv_ctime;	
		des_block akv_xtime;		
	} akv_time_u;
	u_long akv_int_u;
};


























# 123 "/usr/include/rpc/auth_kerb.h" 


# 127 "/usr/include/rpc/auth_kerb.h" 



# 39 "/usr/include/rpc/rpc.h" 2

# 1 "/usr/include/rpc/svc.h" 1












#ident	"@(#)svc.h	1.35	95/01/13 SMI"

# 1 "/usr/include/rpc/rpc_com.h" 1










# 82 "/usr/include/rpc/rpc_com.h" 

# 16 "/usr/include/rpc/svc.h" 2
# 1 "/usr/include/rpc/rpc_msg.h" 1




# 217 "/usr/include/rpc/rpc_msg.h" 

# 17 "/usr/include/rpc/svc.h" 2
# 1 "/usr/include/sys/tihdr.h" 1










#ident	"@(#)tihdr.h	1.8	92/07/14 SMI"	

# 15 "/usr/include/sys/tihdr.h" 





















































































































struct T_conn_req {
	long	PRIM_type;	
	long	DEST_length;	
	long	DEST_offset;	
	long	OPT_length;	
	long	OPT_offset;	
};



struct T_conn_res {
	long    PRIM_type;	
	queue_t *QUEUE_ptr;	
	long    OPT_length;	
	long	OPT_offset;	
	long    SEQ_number;	
};



struct T_discon_req {
	long    PRIM_type;	
	long    SEQ_number;	
};



struct T_data_req {
	long	PRIM_type;	
	long	MORE_flag;	
};



struct T_exdata_req {
	long	PRIM_type;	
	long	MORE_flag;	
};



struct T_info_req {
	long	PRIM_type;	
};



struct T_bind_req {
	long	PRIM_type;		
	long	ADDR_length;		
	long	ADDR_offset;		
	unsigned long CONIND_number;	
};



struct T_unbind_req {
	long	PRIM_type;	
};



struct T_unitdata_req {
	long	PRIM_type;	
	long	DEST_length;	
	long	DEST_offset;	
	long	OPT_length;	
	long	OPT_offset;	
};



struct T_optmgmt_req {
	long	PRIM_type;	
	long	OPT_length;	
	long	OPT_offset;	
	long    MGMT_flags;	
};



struct T_ordrel_req {
	long	PRIM_type;	
};



struct T_conn_ind {
	long	PRIM_type;	
	long	SRC_length;	
	long	SRC_offset;	
	long	OPT_length;	
	long    OPT_offset;	
	long    SEQ_number;	
};



struct T_conn_con {
	long	PRIM_type;	
	long	RES_length;	
	long	RES_offset;	
	long	OPT_length;	
	long    OPT_offset;	
};



struct T_discon_ind {
	long	PRIM_type;	
	long	DISCON_reason;	
	long    SEQ_number;	
};



struct T_data_ind {
	long 	PRIM_type;	
	long	MORE_flag;	
};



struct T_exdata_ind {
	long	PRIM_type;	
	long	MORE_flag;	
};



struct T_info_ack {
	long	PRIM_type;	
	long	TSDU_size;	
	long	ETSDU_size;	
	long	CDATA_size;	
	long	DDATA_size;	
	long	ADDR_size;	
	long	OPT_size;	
	long    TIDU_size;	
	long    SERV_type;	
	long    CURRENT_state;  
	long    PROVIDER_flag;  
};



struct T_bind_ack {
	long		PRIM_type;	
	long		ADDR_length;	
	long		ADDR_offset;	
	unsigned long	CONIND_number;	
};



struct T_error_ack {
	long 	PRIM_type;	
	long	ERROR_prim;	
	long	TLI_error;	
	long	UNIX_error;	
};



struct T_ok_ack {
	long 	PRIM_type;	
	long	CORRECT_prim;	
};



struct T_unitdata_ind {
	long	PRIM_type;	
	long	SRC_length;	
	long	SRC_offset;	
	long	OPT_length;	
	long	OPT_offset;	
};



struct T_uderror_ind {
	long	PRIM_type;	
	long	DEST_length;	
	long	DEST_offset;	
	long	OPT_length;	
	long	OPT_offset;	
	long	ERROR_type;	
};



struct T_optmgmt_ack {
	long	PRIM_type;	
	long	OPT_length;	
	long	OPT_offset;	
	long    MGMT_flags;	
};



struct T_ordrel_ind {
	long	PRIM_type;	
};




union T_primitives {
	long			type;		
	struct T_conn_req	conn_req;	
	struct T_conn_res	conn_res;	
	struct T_discon_req	discon_req;	
	struct T_data_req	data_req;	
	struct T_exdata_req	exdata_req;	
	struct T_info_req	info_req;	
	struct T_bind_req	bind_req;	
	struct T_unbind_req	unbind_req;	
	struct T_unitdata_req	unitdata_req;	
	struct T_optmgmt_req	optmgmt_req;	
	struct T_ordrel_req	ordrel_req;	
	struct T_conn_ind	conn_ind;	
	struct T_conn_con	conn_con;	
	struct T_discon_ind	discon_ind;	
	struct T_data_ind	data_ind;	
	struct T_exdata_ind	exdata_ind;	
	struct T_info_ack	info_ack;	
	struct T_bind_ack	bind_ack;	
	struct T_error_ack	error_ack;	
	struct T_ok_ack		ok_ack;		
	struct T_unitdata_ind	unitdata_ind;	
	struct T_uderror_ind	uderror_ind;	
	struct T_optmgmt_ack	optmgmt_ack;	
	struct T_ordrel_ind	ordrel_ind;	
};


# 371 "/usr/include/sys/tihdr.h" 



# 18 "/usr/include/rpc/svc.h" 2

# 21 "/usr/include/rpc/svc.h" 
























# 47 "/usr/include/rpc/svc.h" 







# 56 "/usr/include/rpc/svc.h" 


enum xprt_stat {
	XPRT_DIED,
	XPRT_MOREREQS,
	XPRT_IDLE
};




struct svc_req {
	u_long		rq_prog;	
	u_long		rq_vers;	
	u_long		rq_proc;	
	struct opaque_auth rq_cred;	
	caddr_t		rq_clntcred;	
	struct __svcxprt *rq_xprt;	
};

# 97 "/usr/include/rpc/svc.h" 


struct xp_ops {
# 137 "/usr/include/rpc/svc.h" 

		bool_t	(*xp_recv)(); 
		enum xprt_stat (*xp_stat)(); 
		bool_t	(*xp_getargs)(); 
		bool_t	(*xp_reply)(); 
		bool_t	(*xp_freeargs)(); 
		void	(*xp_destroy)(); 
# 151 "/usr/include/rpc/svc.h" 

		bool_t	(*xp_control)(); 


};




























typedef struct __svcxprt {
# 228 "/usr/include/rpc/svc.h" 

	int		xp_fd;

	u_short		xp_port;
	





	struct	xp_ops	*xp_ops;
	int		xp_addrlen;	 
	char		*xp_tp;		 
	char		*xp_netid;	 
	struct netbuf	xp_ltaddr;	 
	struct netbuf	xp_rtaddr;	 
	char		xp_raddr[16];	 
	struct opaque_auth xp_verf;	 
	caddr_t		xp_p1;		 
	caddr_t		xp_p2;		 
	caddr_t		xp_p3;		 
	int		xp_type;	

} SVCXPRT;

# 265 "/usr/include/rpc/svc.h" 






# 273 "/usr/include/rpc/svc.h" 


















# 296 "/usr/include/rpc/svc.h" 










































# 344 "/usr/include/rpc/svc.h" 





# 369 "/usr/include/rpc/svc.h" 



# 377 "/usr/include/rpc/svc.h" 

extern bool_t	rpc_reg();














# 398 "/usr/include/rpc/svc.h" 

extern bool_t	svc_reg();











# 413 "/usr/include/rpc/svc.h" 

extern void	svc_unreg();










# 427 "/usr/include/rpc/svc.h" 

extern void	xprt_register();










# 441 "/usr/include/rpc/svc.h" 

extern void	xprt_unregister();





























# 481 "/usr/include/rpc/svc.h" 

extern bool_t	svc_sendreply();
extern void	svcerr_decode();
extern void	svcerr_weakauth();
extern void	svcerr_noproc();
extern void	svcerr_progvers();
extern void	svcerr_auth();
extern void	svcerr_noprog();
extern void	svcerr_systemerr();


















extern fd_set svc_fdset;







# 523 "/usr/include/rpc/svc.h" 


extern void	rpctest_service();
extern void	svc_getreqset();











# 547 "/usr/include/rpc/svc.h" 

extern int svc_create();








# 566 "/usr/include/rpc/svc.h" 

extern SVCXPRT	*svc_tp_create();





# 583 "/usr/include/rpc/svc.h" 

extern SVCXPRT *svc_tli_create();






# 605 "/usr/include/rpc/svc.h" 

extern SVCXPRT	*svc_vc_create();
extern SVCXPRT	*svc_dg_create();






# 621 "/usr/include/rpc/svc.h" 

extern SVCXPRT *svc_fd_create();





# 630 "/usr/include/rpc/svc.h" 

extern SVCXPRT *svc_raw_cr