ndmpd/ndmp/ndmpd_comm.c

102     ndmp_message message);
103 static boolean_t ndmp_check_auth_required(ndmp_message message);
104 static ndmp_handler_t *ndmp_get_interface(ndmp_message message);
123  *   handler_tbl (input) - message handlers.
388  * Reads the next request message into the stream buffer.
417  * Send an NDMP request message.
421  *   message (input) - message number.
423  *   request_data (input) - message body.
424  *   reply (output) - reply message. If 0, reply will be
436 ndmp_send_request(ndmp_connection_t *connection_handle, ndmp_message message,
446 	if (!(handler = ndmp_get_handler(connection, message))) {
447 		NDMP_LOG(LOG_DEBUG, "Sending message 0x%x: not supported",
448 		    message);
456 	header.message = message;
463 		    "Sending message 0x%x: encoding request header", message);
471 			    "Sending message 0x%x: encoding request body",
472 			    message);
501 			if (message !=
502 			    connection->conn_msginfo.mi_hdr.message) {
505 				    connection->conn_msginfo.mi_hdr.message);
530  *   message (input) - message number.
532  *   request_data (input) - message body.
533  *   reply (output) - reply message. If 0, reply will be
546     ndmp_message message, ndmp_error err, void *request_data, void **reply)
553 	rv = ndmp_send_request(connection_handle, message, err, request_data,
563  * Send an NDMP reply message.
568  *   reply	     (input)  - reply message body.
590 	header.message = connection->conn_msginfo.mi_hdr.message;
596 		NDMP_LOG(LOG_DEBUG, "Sending message 0x%x: "
598 		    header.message);
608 			    "Sending message 0x%x: encoding reply body",
609 			    header.message);
621  * Free the memory of NDMP message body.
681  * each message handler via ndmp_get_client_data.
703  * each message handler via ndmp_get_client_data.
1039  * Read the next message.
1043  *   msg	(output) - received message.
1048  *  -1 - Error decoding the message header.
1062 	/* Lookup info necessary for processing this message. */
1064 	    connection->conn_msginfo.mi_hdr.message)) == 0) {
1066 		    connection->conn_msginfo.mi_hdr.message);
1078 		    connection->conn_msginfo.mi_hdr.message) &&
1082 			    connection->conn_msginfo.mi_hdr.message);
1093 				    connection->conn_msginfo.mi_hdr.message);
1114 				    connection->conn_msginfo.mi_hdr.message);
1129 	/* Decode message arguments if needed */
1134 			    "Processing message 0x%x: error decoding arguments",
1135 			    connection->conn_msginfo.mi_hdr.message);
1147  * Reads the next message into the stream buffer.
1154  * a message that had already been received and read into the stream buffer.
1158  * message handling table.
1160  * A reply message, if received, is placed in connection->conn_msginfo
1163  * more than one reply message is received
1167  *   reply_expected (output) - TRUE  - a reply message is expected.
1168  *			     FALSE - no reply message is expected and
1174  *   	error processing reply message.
1219 				 * the message or if the message was even
1220 				 * a request message.  To be safe, assume
1221 				 * that the message was a reply if a reply
1236 				    connection->conn_msginfo.mi_hdr.message);
1241 					    "Unexpected reply message: 0x%x",
1243 					    message);
1255 			    connection->conn_msginfo.mi_hdr.message);
1265 			    connection->conn_msginfo.mi_hdr.message);
1269 				    "Unexpected reply message: 0x%x",
1270 				    connection->conn_msginfo.mi_hdr.message);
1280 		    connection->conn_msginfo.mi_hdr.message);
1288 			NDMP_LOG(LOG_DEBUG, "No handler for message 0x%x",
1289 			    connection->conn_msginfo.mi_hdr.message);
1332  * specific message.
1335  *   message (input) - message number.
1338  *   NULL - message not found.
1342 ndmp_get_interface(ndmp_message message)
1344 	ndmp_handler_t *ni = &ndmp_msghdl_tab[(message >> 8) % INT_MAXCMD];
1346 	if ((message & 0xff) >= ni->hd_cnt)
1350 	if (ni->hd_msgs[message & 0xff].hm_message != message)
1359  * Return the handler info for the specified NDMP message.
1363  *   message (input) - message number.
1366  *   NULL - message not found.
1370 ndmp_get_handler(ndmp_connection_t *connection, ndmp_message message)
1374 	ndmp_handler_t *ni = ndmp_get_interface(message);
1378 		handler = &ni->hd_msgs[message & 0xff].hm_msg_v[ver - 2];
1387  * this message is being processed.
1390  *   message (input) - message number.
1397 ndmp_check_auth_required(ndmp_message message)
1400 	ndmp_handler_t *ni = ndmp_get_interface(message);
1403 		auth_req = ni->hd_msgs[message & 0xff].hm_auth_required;