Lines Matching defs:request
125 * This handler handles the mover_get_state request.
130 * body (input) - request message body.
171 * body (input) - request message body.
179 ndmp_mover_listen_request_v2 *request;
185 request = (ndmp_mover_listen_request_v2 *)body;
195 session->ns_mover.md_mode = request->mode;
197 if (request->addr_type == NDMP_ADDR_LOCAL) {
235 * body (input) - request message body.
269 * body (input) - request message body.
307 * body (input) - request message body.
348 * body (input) - request message body.
356 ndmp_mover_set_window_request *request;
360 request = (ndmp_mover_set_window_request *) body;
376 if (quad_to_long_long(request->length) == 0) {
379 quad_to_long_long(request->length));
383 quad_to_long_long(request->offset);
385 quad_to_long_long(request->length);
401 * request is sent notifying the client that a seek is required. If the
409 * body (input) - request message body.
417 ndmp_mover_read_request *request = (ndmp_mover_read_request *) body;
442 err = ndmpd_mover_seek(session, quad_to_long_long(request->offset),
443 quad_to_long_long(request->length));
470 * body (input) - request message body.
506 * body (input) - request message body.
514 ndmp_mover_set_record_size_request *request;
518 request = (ndmp_mover_set_record_size_request *) body;
520 session->ns_mover.md_record_size = request->len;
522 request->len);
544 * body (input) - request message body.
593 * body (input) - request message body.
601 ndmp_mover_listen_request_v3 *request;
607 request = (ndmp_mover_listen_request_v3 *)body;
612 if (request->mode != NDMP_MOVER_MODE_READ &&
613 request->mode != NDMP_MOVER_MODE_WRITE) {
615 NDMP_LOG(LOG_DEBUG, "Invalid mode %d", request->mode);
616 } else if (!ndmp_valid_v3addr_type(request->addr_type)) {
619 request->addr_type);
623 "Invalid mover state to process listen request");
627 "Invalid data state to process listen request");
631 } else if (request->mode == NDMP_MOVER_MODE_READ &&
643 switch (request->addr_type) {
667 request->addr_type);
671 session->ns_mover.md_mode = request->mode;
687 * body (input) - request message body.
722 * seek request. The handler is removed in mover_data_write().
784 * body (input) - request message body.
822 * body (input) - request message body.
830 ndmp_mover_set_window_request *request;
834 request = (ndmp_mover_set_window_request *) body;
857 if (quad_to_long_long(request->length) == 0) {
860 quad_to_long_long(request->length));
870 session->ns_mover.md_window_offset = quad_to_long_long(request->offset);
871 session->ns_mover.md_window_length = quad_to_long_long(request->length);
900 * is paused and a notify_mover_paused request is sent notifying the
909 * body (input) - request message body.
917 ndmp_mover_read_request *request = (ndmp_mover_read_request *)body;
934 } else if (quad_to_long_long(request->length) == 0 ||
935 (quad_to_long_long(request->length) == MAX_WINDOW_SIZE &&
936 quad_to_long_long(request->offset) != 0)) {
948 err = ndmpd_mover_seek(session, quad_to_long_long(request->offset),
949 quad_to_long_long(request->length));
981 * body (input) - request message body.
989 ndmp_mover_set_record_size_request *request;
994 request = (ndmp_mover_set_record_size_request *) body;
1000 } else if (request->len > (unsigned int)ndmp_max_mover_recsize) {
1004 request->len, ndmp_max_mover_recsize);
1005 } else if (request->len == session->ns_mover.md_record_size)
1007 else if (!(cp = realloc(session->ns_mover.md_buf, request->len))) {
1012 session->ns_mover.md_record_size = request->len;
1029 * body (input) - request message body.
1037 ndmp_mover_connect_request_v3 *request;
1041 request = (ndmp_mover_connect_request_v3*)body;
1045 if (request->mode != NDMP_MOVER_MODE_READ &&
1046 request->mode != NDMP_MOVER_MODE_WRITE) {
1048 NDMP_LOG(LOG_DEBUG, "Invalid mode %d", request->mode);
1049 } else if (!ndmp_valid_v3addr_type(request->addr.addr_type)) {
1052 request->addr.addr_type);
1060 } else if (request->mode == NDMP_MOVER_MODE_READ &&
1073 switch (request->addr.addr_type) {
1089 reply.error = mover_connect_sock(session, request->mode,
1090 request->addr.tcp_ip_v3, request->addr.tcp_port_v3);
1096 request->addr.addr_type);
1101 request->addr.addr_type;
1103 session->ns_mover.md_mode = request->mode;
1125 * body (input) - request message body.
1176 * body (input) - request message body.
1184 ndmp_mover_listen_request_v4 *request;
1191 request = (ndmp_mover_listen_request_v4 *)body;
1196 if (request->mode != NDMP_MOVER_MODE_READ &&
1197 request->mode != NDMP_MOVER_MODE_WRITE) {
1199 NDMP_LOG(LOG_DEBUG, "Invalid mode %d", request->mode);
1200 } else if (!ndmp_valid_v3addr_type(request->addr_type)) {
1203 request->addr_type);
1207 "Invalid mover state to process listen request");
1211 "Invalid data state to process listen request");
1218 } else if (request->mode == NDMP_MOVER_MODE_READ &&
1230 switch (request->addr_type) {
1264 request->addr_type);
1268 session->ns_mover.md_mode = request->mode;
1284 * body (input) - request message body.
1292 ndmp_mover_connect_request_v4 *request;
1296 request = (ndmp_mover_connect_request_v4 *)body;
1299 if (request->mode != NDMP_MOVER_MODE_READ &&
1300 request->mode != NDMP_MOVER_MODE_WRITE) {
1302 NDMP_LOG(LOG_DEBUG, "Invalid mode %d", request->mode);
1303 } else if (!ndmp_valid_v3addr_type(request->addr.addr_type)) {
1306 request->addr.addr_type);
1314 } else if (request->mode == NDMP_MOVER_MODE_READ &&
1330 switch (request->addr.addr_type) {
1346 reply.error = mover_connect_sock(session, request->mode,
1347 request->addr.tcp_ip_v4(0), request->addr.tcp_port_v4(0));
1353 request->addr.addr_type);
1358 request->addr.addr_type;
1360 session->ns_mover.md_mode = request->mode;
1568 * Read as many records as necessary to satisfy the request.
1590 "Sending notify_mover_paused request");
1597 * an abort or continue request.
1681 * request set the seek pointer to a position that is not a
1682 * record boundary. The seek request handler can only position
1720 ndmp_notify_data_read_request request;
1727 * send an ndmp_read request to the client.
1728 * The NDMP client will then send a mover_data_read request to
1748 request.offset =
1750 request.length =
1755 (void *) &request, 0) < 0) {
1757 "Sending notify_data_read request");
2021 * the mover is paused and a notify_mover_paused request is sent
2076 "Sending notify_mover_paused request");
2327 * Send a notify_pause request (protocol version 1) or
2328 * notify_mover_pause request (protocol version 2) to the
2344 ndmp_notify_mover_paused_request request;
2353 request.reason = session->ns_mover.md_pause_reason;
2354 request.seek_position = long_long_to_quad(0LL);
2361 (void *) &request, 0) < 0) {
2363 "Sending notify_mover_paused request");
2368 * an abort or continue request.
2455 "Sending notify_mover_paused request");
2481 * request set the seek pointer to a position that is not a
2482 * record boundary. The seek request handler can only position
2627 * function from getting called. The next mover_read request
2771 * reply of the request (which resulted in calling this function)
3142 * reply of the request (which resulted in calling this function)
3320 "Error sending notify_mover_halted request");
3327 "Error sending notify_mover_halted request");
3354 * Send an ndmp_notify_mover_paused request to the
3371 ndmp_notify_mover_paused_request request;
3378 request.reason = session->ns_mover.md_pause_reason;
3379 request.seek_position =
3383 NDMP_NO_ERR, (void *)&request, 0) < 0) {
3400 * an abort, continue, or close request .
3908 "Sending notify_mover_paused request");
3934 * request set the seek pointer to a position that is not a
3935 * record boundary. The seek request handler can only position
4021 * function from getting called. The next mover_read request
4258 * Read as many records as necessary to satisfy the request.
4360 * request set the seek pointer to a position that is not a
4361 * record boundary. The seek request handler can only position