Begin processing header.
// Identify and pocess first/last parameters.
if (main->program.parameters.array[kt_tacocat_parameter_line_first_no_e].result & f_console_result_found_e) {
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_print_first_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_print_first_e;
}
else {
main->setting.flag |= kt_tacocat_main_flag_print_first_e;
}
if (main->program.parameters.array[kt_tacocat_parameter_line_last_no_e].result & f_console_result_found_e) {
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_print_last_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_print_last_e;
}
else {
main->setting.flag |= kt_tacocat_main_flag_print_last_e;
main->setting.flag |= kt_tacocat_main_flag_help_e;
}
else {
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_help_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_help_e;
}
if (main->program.parameters.array[kt_tacocat_parameter_version_e].result & f_console_result_found_e) {
main->setting.flag |= kt_tacocat_main_flag_version_e;
}
else {
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_version_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_version_e;
}
if (main->program.parameters.array[kt_tacocat_parameter_copyright_e].result & f_console_result_found_e) {
main->setting.flag |= kt_tacocat_main_flag_copyright_e;
}
else {
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_copyright_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_copyright_e;
}
if (main->program.parameters.array[kt_tacocat_parameter_resolve_e].result & f_console_result_found_e) {
index = main->program.parameters.array[kt_tacocat_parameter_resolve_e].values.array[main->program.parameters.array[kt_tacocat_parameter_resolve_e].values.used - 1];
if (f_compare_dynamic(main->program.parameters.arguments.array[index], kt_tacocat_classic_s) == F_equal_to) {
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_resolve_kevux_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_resolve_kevux_e;
main->setting.flag |= kt_tacocat_main_flag_resolve_classic_e;
}
else if (f_compare_dynamic(main->program.parameters.arguments.array[index], kt_tacocat_kevux_s) == F_equal_to) {
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_resolve_classic_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_resolve_classic_e;
main->setting.flag |= kt_tacocat_main_flag_resolve_kevux_e;
}
else {
}
else {
#ifdef _kt_resolve_default_kevux_
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_resolve_classic_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_resolve_classic_e;
main->setting.flag |= kt_tacocat_main_flag_resolve_kevux_e;
#else
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_resolve_kevux_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_resolve_kevux_e;
main->setting.flag |= kt_tacocat_main_flag_resolve_classic_e;
#endif // _kt_resolve_default_kevux_
}
else if (main->setting.state.status == F_number_negative) {
if (number == 1) {
main->setting.max_buffer = 0;
- main->setting.flag -= main->setting.flag & kt_tacocat_main_flag_max_buffer_e;
+ main->setting.flag &= ~kt_tacocat_main_flag_max_buffer_e;
}
else {
main->setting.state.status = F_status_set_error(F_parameter);
} // for
}
else if (main->program.parameters.array[parameters[i]].result & f_console_result_found_e) {
- main->setting.flag -= main->setting.flag & flags[i];
+ main->setting.flag &= ~flags[i];
main->setting.state.status = F_status_set_error(F_parameter);
macro_setting_load_print_first();
continue;
}
else {
- main->setting.flag -= main->setting.flag & flags[i];
+ main->setting.flag &= ~flags[i];
}
} // for
#define kt_tacocat_allocation_large_d 0x800
#define kt_tacocat_allocation_small_d 0x80
- #define kt_tacocat_block_size_d 0xffff
+ #define kt_tacocat_block_size_d 0xffff // @todo set this to something small like 0xff to easily test and design sending and receiving multiple parts.
#define kt_tacocat_block_size_receive_d kt_tacocat_block_size_d
#define kt_tacocat_block_size_send_d kt_tacocat_block_size_d
* Intended to be used for handling an error during the receive process while not processing within flag kt_tacocat_socket_flag_receive_control_e.
* The parameter id_data and is set to 0 to disable and is otherwise an address pointer.
*
+ * macro_kt_receive_process_handle_error_exit_2:
+ * A version of macro_kt_receive_process_handle_error_exit_1 that uses a void return statement.
+ *
* macro_kt_receive_process_begin_handle_error_exit_1:
* Intended to be used for handling an error during the receive process while processing within flag kt_tacocat_socket_flag_receive_control_e.
*
return F_done_not; \
}
+ #define macro_kt_receive_process_handle_error_exit_2(main, method, network, status, name, flag, id_data) \
+ if (F_status_is_error(status)) { \
+ kt_tacocat_print_error_on(&main->program.error, macro_kt_tacocat_f(method), kt_tacocat_receive_s, network, status, name); \
+ \
+ if (id_data) { \
+ f_file_close_id(id_data); \
+ } \
+ \
+ flag = 0; \
+ \
+ return; \
+ }
+
#define macro_kt_receive_process_begin_handle_error_exit_1(main, method, network, status, name, flag) \
if (F_status_is_error(status)) { \
kt_tacocat_print_error_on(&main->program.error, macro_kt_tacocat_f(method), kt_tacocat_receive_s, network, status, name); \
* kt_tacocat_socket_flag_receive_*_e:
* - none: No flags set.
* - control: Reading and processing the Control block and Size block.
- * - packet: Reading and processing the rest of the Packet block (the Header and Payload).
- * - find: Find the Header block and everything else up until the Payload block.
- * - check: Process and check the loaded Payload block, processing the Header block.
+ * - packet: Reading and processing the rest of the Packet block (the Header and Payload sections).
+ * - find: Find the Header section and everything else up until the Payload section.
+ * - extract: Process the loaded data, extracting the Header and Signature sections.
+ * - check: Check the loaded data, doing size checks, interpreting the status, and performing any signature checks.
* - write: Save the loaded Payload block to the file (write to the file).
* - done: Done processing file.
*/
kt_tacocat_socket_flag_receive_control_e = 0x1,
kt_tacocat_socket_flag_receive_packet_e = 0x2,
kt_tacocat_socket_flag_receive_find_e = 0x4,
- kt_tacocat_socket_flag_receive_check_e = 0x8,
- kt_tacocat_socket_flag_receive_write_e = 0x10,
- kt_tacocat_socket_flag_receive_done_e = 0x20,
+ kt_tacocat_socket_flag_receive_extract_e = 0x8,
+ kt_tacocat_socket_flag_receive_check_e = 0x10,
+ kt_tacocat_socket_flag_receive_write_e = 0x20,
+ kt_tacocat_socket_flag_receive_done_e = 0x40,
}; // enum
#endif // _di_kt_tacocat_socket_flag_receive_e_
"fl_conversion_dynamic_partial_to_unsigned_detect",
"fl_conversion_dynamic_to_unsigned_detect",
"fl_fss_payload_header_map",
+ "fll_fss_extended_read",
+ "fll_fss_payload_read",
"fll_program_parameter_process_context",
"fll_program_parameter_process_verbosity",
"kt_tacocat_process_socket_set_error_has",
kt_tacocat_f_fl_conversion_dynamic_partial_to_unsigned_detect_e,
kt_tacocat_f_fl_conversion_dynamic_to_unsigned_detect_e,
kt_tacocat_f_fl_fss_payload_header_map_e,
+ kt_tacocat_f_fll_fss_extended_read_e,
+ kt_tacocat_f_fll_fss_payload_read_e,
kt_tacocat_f_fll_program_parameter_process_context_e,
kt_tacocat_f_fll_program_parameter_process_verbosity_e,
kt_tacocat_f_kt_tacocat_process_socket_set_error_has_e,
f_memory_array_resize(0, sizeof(f_range_t), (void **) &array[i].objects.array, &array[i].objects.used, &array[i].objects.size);
}
+ if (array[i].objects_header.size) {
+ f_memory_array_resize(0, sizeof(f_range_t), (void **) &array[i].objects_header.array, &array[i].objects_header.used, &array[i].objects_header.size);
+ }
+
+ if (array[i].objects_signature.size) {
+ f_memory_array_resize(0, sizeof(f_range_t), (void **) &array[i].objects_signature.array, &array[i].objects_signature.used, &array[i].objects_signature.size);
+ }
+
if (array[i].contents.size) {
f_memory_arrays_resize(0, sizeof(f_range_t), (void **) &array[i].contents.array, &array[i].contents.used, &array[i].contents.size, &f_rangess_delete_callback);
}
+ if (array[i].contents_header.size) {
+ f_memory_arrays_resize(0, sizeof(f_range_t), (void **) &array[i].contents_header.array, &array[i].contents_header.used, &array[i].contents_header.size, &f_rangess_delete_callback);
+ }
+
+ if (array[i].contents_signature.size) {
+ f_memory_arrays_resize(0, sizeof(f_range_t), (void **) &array[i].contents_signature.array, &array[i].contents_signature.used, &array[i].contents_signature.size, &f_rangess_delete_callback);
+ }
+
if (array[i].objects_delimits.size) {
f_memory_array_resize(0, sizeof(f_number_unsigned_t), (void **) &array[i].objects_delimits.array, &array[i].objects_delimits.used, &array[i].objects_delimits.size);
}
- if (array[i].objects_delimits.size) {
+ if (array[i].objects_delimits_header.size) {
+ f_memory_array_resize(0, sizeof(f_number_unsigned_t), (void **) &array[i].objects_delimits_header.array, &array[i].objects_delimits_header.used, &array[i].objects_delimits_header.size);
+ }
+
+ if (array[i].objects_delimits_signature.size) {
+ f_memory_array_resize(0, sizeof(f_number_unsigned_t), (void **) &array[i].objects_delimits_signature.array, &array[i].objects_delimits_signature.used, &array[i].objects_delimits_signature.size);
+ }
+
+ if (array[i].contents_delimits.size) {
f_memory_array_resize(0, sizeof(f_number_unsigned_t), (void **) &array[i].contents_delimits.array, &array[i].contents_delimits.used, &array[i].contents_delimits.size);
}
+ if (array[i].contents_delimits_header.size) {
+ f_memory_array_resize(0, sizeof(f_number_unsigned_t), (void **) &array[i].contents_delimits_header.array, &array[i].contents_delimits_header.used, &array[i].contents_delimits_header.size);
+ }
+
+ if (array[i].contents_delimits_signature.size) {
+ f_memory_array_resize(0, sizeof(f_number_unsigned_t), (void **) &array[i].contents_delimits_signature.array, &array[i].contents_delimits_signature.used, &array[i].contents_delimits_signature.size);
+ }
+
+ if (array[i].objects_quoted_header.size) {
+ f_memory_array_resize(0, sizeof(uint8_t), (void **) &array[i].objects_quoted_header.array, &array[i].objects_quoted_header.used, &array[i].objects_quoted_header.size);
+ }
+
+ if (array[i].objects_quoted_signature.size) {
+ f_memory_array_resize(0, sizeof(uint8_t), (void **) &array[i].objects_quoted_signature.array, &array[i].objects_quoted_signature.used, &array[i].objects_quoted_signature.size);
+ }
+
+ if (array[i].contents_quoted_header.size) {
+ f_memory_arrays_resize(0, sizeof(uint8_t), (void **) &array[i].contents_quoted_header.array, &array[i].contents_quoted_header.used, &array[i].contents_quoted_header.size, &f_uint8ss_delete_callback);
+ }
+
+ if (array[i].contents_quoted_signature.size) {
+ f_memory_arrays_resize(0, sizeof(uint8_t), (void **) &array[i].contents_quoted_signature.array, &array[i].contents_quoted_signature.used, &array[i].contents_quoted_signature.size, &f_uint8ss_delete_callback);
+ }
+
if (array[i].comments.size) {
f_memory_array_resize(0, sizeof(f_range_t), (void **) &array[i].comments.array, &array[i].comments.used, &array[i].comments.size);
}
* socket: Socket structure.
* status: The status of the socket operations.
*
- * range: A generic range, often used for FSS processing.
- * objects: An array of FSS Objects.
- * contents: An array of FSS Contents.
- * objects_delimits: An array of FSS Object delimits.
- * contents_delimits: An array of FSS Content delimits.
- * comments: An array of FSS comments.
- * state: Basic state information, usually passed to the FSS functions.
+ * range: A generic range, often used for FSS processing.
+ * objects: An array of FSS Objects.
+ * objects_header: An array of FSS Objects, for the Header section.
+ * objects_signature: An array of FSS Objects, for the Signature section.
+ * contents: An array of FSS Contents.
+ * contents_header: An array of FSS Contents, for the Header section.
+ * contents_signature: An array of FSS Contents, for the Signature section.
+ * objects_delimits: An array of FSS Object delimits.
+ * objects_delimits_header: An array of FSS Object delimits, for the Header section.
+ * objects_delimits_signature: An array of FSS Object delimits, for the Signature section.
+ * contents_delimits: An array of FSS Content delimits.
+ * contents_delimits_header: An array of FSS Content delimits, for the Header section.
+ * contents_delimits_signature: An array of FSS Content delimits, for the Signature section.
+ * objects_quoted_header: An array of FSS Objects quoted flags, for the Header section.
+ * objects_quoted_signature: An array of FSS Objects quoted flags, for the Header section.
+ * contents_quoted_header: An array of FSS Content quoted flags, for the Header section.
+ * contents_quoted_signature: An array of FSS Content quoted flags, for the Header section.
+ * comments: An array of FSS comments.
+ * state: Basic state information, usually passed to the FSS functions.
*
* buffer: A buffer for sending or receiving data between clients.
* cache: A cache used for various purposes, but primarily for the building of the send packet.
f_range_t range;
f_ranges_t objects;
+ f_ranges_t objects_header;
+ f_ranges_t objects_signature;
f_rangess_t contents;
+ f_rangess_t contents_header;
+ f_rangess_t contents_signature;
f_number_unsigneds_t objects_delimits;
+ f_number_unsigneds_t objects_delimits_header;
+ f_number_unsigneds_t objects_delimits_signature;
f_number_unsigneds_t contents_delimits;
+ f_number_unsigneds_t contents_delimits_header;
+ f_number_unsigneds_t contents_delimits_signature;
+ f_uint8s_t objects_quoted_header;
+ f_uint8s_t objects_quoted_signature;
+ f_uint8ss_t contents_quoted_header;
+ f_uint8ss_t contents_quoted_signature;
f_ranges_t comments;
f_state_t state;
f_status_t_initialize, \
f_range_t_initialize, \
f_ranges_t_initialize, \
+ f_ranges_t_initialize, \
+ f_ranges_t_initialize, \
+ f_rangess_t_initialize, \
f_rangess_t_initialize, \
+ f_rangess_t_initialize, \
+ f_number_unsigneds_t_initialize, \
f_number_unsigneds_t_initialize, \
f_number_unsigneds_t_initialize, \
+ f_number_unsigneds_t_initialize, \
+ f_uint8s_t_initialize, \
+ f_uint8s_t_initialize, \
+ f_uint8ss_t_initialize, \
+ f_uint8ss_t_initialize, \
f_ranges_t_initialize, \
f_state_t_initialize, \
f_string_dynamic_t_initialize, \
f_status_t_initialize, \
f_range_t_initialize, \
f_ranges_t_initialize, \
+ f_ranges_t_initialize, \
+ f_ranges_t_initialize, \
+ f_rangess_t_initialize, \
f_rangess_t_initialize, \
+ f_rangess_t_initialize, \
+ f_number_unsigneds_t_initialize, \
+ f_number_unsigneds_t_initialize, \
f_number_unsigneds_t_initialize, \
f_number_unsigneds_t_initialize, \
+ f_uint8s_t_initialize, \
+ f_uint8s_t_initialize, \
+ f_uint8ss_t_initialize, \
+ f_uint8ss_t_initialize, \
f_ranges_t_initialize, \
f_state_t_initialize, \
f_string_dynamic_t_initialize, \
f_status_t_initialize, \
f_range_t_initialize, \
f_ranges_t_initialize, \
+ f_ranges_t_initialize, \
+ f_ranges_t_initialize, \
f_rangess_t_initialize, \
+ f_rangess_t_initialize, \
+ f_rangess_t_initialize, \
+ f_number_unsigneds_t_initialize, \
+ f_number_unsigneds_t_initialize, \
f_number_unsigneds_t_initialize, \
f_number_unsigneds_t_initialize, \
+ f_uint8s_t_initialize, \
+ f_uint8s_t_initialize, \
+ f_uint8ss_t_initialize, \
+ f_uint8ss_t_initialize, \
f_ranges_t_initialize, \
f_state_t_initialize, \
f_string_dynamic_t_initialize, \
if (set->buffer.used == set->packet.size) {
// The packet is fully loaded and there is no "payload" section.
- set->flag = kt_tacocat_socket_flag_receive_check_e;
+ set->flag = kt_tacocat_socket_flag_receive_extract_e;
}
else {
// Seek the left-most new line from the current position to ensure that the next pass potentially reads a complete line.
while (set->range.start && set->buffer.string[set->range.start] != f_string_eol_s.string[0]) {
-
--set->range.start;
} // while
// Seek the left-most new line from the current position to ensure that the next pass potentially reads a complete line.
while (set->range.start && set->buffer.string[set->range.start] != f_string_eol_s.string[0]) {
-
--set->range.start;
} // while
case F_data_not_eos:
case F_data_not_stop:
case F_fss_found_object_content_not:
- set->flag = kt_tacocat_socket_flag_receive_check_e;
+ set->flag = kt_tacocat_socket_flag_receive_extract_e;
break;
}
}
- if (set->flag & kt_tacocat_socket_flag_receive_check_e) {
+ if (set->flag & kt_tacocat_socket_flag_receive_extract_e) {
+ kt_tacocat_receive_process_extract(main, set);
+ if (F_status_is_error(set->status)) return F_data_not;
- // @todo this probably should be in a separate function, similar to how kt_tacocat_receive_process_control() is.
- {
- uint8_t found_not = F_true;
-
- for (f_number_unsigned_t i = 0; i < set->objects.used; ++i) {
-
- if (f_compare_dynamic_partial_string(f_fss_payload_object_header_s.string, set->buffer, f_fss_payload_object_header_s.used, set->objects.array[i]) == F_equal_to) {
- // @todo walk through header, mapping it.
- }
- else if (f_compare_dynamic_partial_string(f_fss_payload_object_signature_s.string, set->buffer, f_fss_payload_object_signature_s.used, set->objects.array[i]) == F_equal_to) {
- // @todo walk through signature, mapping it.
- }
- else if (f_compare_dynamic_partial_string(f_fss_payload_object_payload_s.string, set->buffer, f_fss_payload_object_payload_s.used, set->objects.array[i]) == F_equal_to) {
- if (found_not) {
- set->packet.payload = set->contents.array[i].array[0];
- found_not = F_false;
- }
- }
- } // for
- }
+ set->flag = kt_tacocat_socket_flag_receive_write_e;
+ }
- // @todo walk through each set->objects and their respective set->contents, checking and processing the data.
+ if (set->flag & kt_tacocat_socket_flag_receive_check_e) {
+ // @todo
set->flag = kt_tacocat_socket_flag_receive_write_e;
}
}
#endif // _di_kt_tacocat_receive_process_control_
+#ifndef _di_kt_tacocat_receive_process_extract_
+ void kt_tacocat_receive_process_extract(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set) {
+
+ if (!main || !set) return;
+
+ set->status = f_memory_array_increase_by(kt_tacocat_packet_headers_d, sizeof(f_abstruse_map_t), (void **) &set->abstruses.array, &set->abstruses.used, &set->abstruses.size);
+
+ if (F_status_is_error(set->status)) {
+ macro_kt_receive_process_handle_error_exit_2(main, f_memory_array_increase_by, set->network, set->status, set->name, set->flag, &set->socket.id_data);
+ }
+
+ // 0x1 = did not find payload, 0x2 = did not find header.
+ uint8_t found_not = 0x3;
+
+ for (f_number_unsigned_t i = 0; i < set->objects.used; ++i) {
+
+ if (f_compare_dynamic_partial_string(f_fss_payload_object_header_s.string, set->buffer, f_fss_payload_object_header_s.used, set->objects.array[i]) == F_equal_to) {
+ kt_tacocat_receive_process_extract_header(main, set, i);
+
+ if (F_status_is_error(set->status)) {
+ ++set->retry;
+
+ return;
+ }
+
+ found_not &= ~0x2;
+ }
+ else if (f_compare_dynamic_partial_string(f_fss_payload_object_signature_s.string, set->buffer, f_fss_payload_object_signature_s.used, set->objects.array[i]) == F_equal_to) {
+ kt_tacocat_receive_process_extract_signature(main, set, i);
+
+ if (F_status_is_error(set->status)) {
+ ++set->retry;
+
+ return;
+ }
+ }
+ else if (f_compare_dynamic_partial_string(f_fss_payload_object_payload_s.string, set->buffer, f_fss_payload_object_payload_s.used, set->objects.array[i]) == F_equal_to) {
+ if (found_not & 0x1) {
+ set->packet.payload = set->contents.array[i].array[0];
+ found_not &= ~0x1;
+ }
+ }
+ } // for
+
+ set->status = F_okay;
+ }
+#endif // _di_kt_tacocat_receive_process_extract_
+
+#ifndef _di_kt_tacocat_receive_process_extract_header_
+ void kt_tacocat_receive_process_extract_header(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set, const f_number_unsigned_t at) {
+
+ if (!main || !set) return;
+
+ if (set->objects.array[at].start > set->objects.array[at].stop || !set->contents.array[at].used) {
+ set->status = F_data_not;
+
+ return;
+ }
+
+ set->range = set->contents.array[at].array[0];
+
+ fll_fss_extended_read(set->buffer, &set->range, &set->objects_header, &set->contents_header, &set->objects_quoted_header, &set->contents_quoted_header, &set->objects_delimits_header, &set->contents_delimits_header, &set->state);
+
+ if (F_status_is_error(set->state.status)) {
+ kt_tacocat_print_error_on(&main->program.error, macro_kt_tacocat_f(fll_fss_extended_read), kt_tacocat_receive_s, set->network, set->status, set->name);
+
+ set->status = set->state.status;
+
+ return;
+ }
+
+ switch (set->state.status) {
+ case F_okay:
+ case F_okay_stop:
+ case F_okay_eos:
+ break;
+
+ default:
+ set->status = F_data_not;
+
+ return;
+ }
+
+ for (f_number_unsigned_t i = 0; i < set->objects_header.used; ++i) {
+
+ // Index 0 is the status.
+ if (f_compare_dynamic_partial_string(f_fss_payload_object_status_s.string, set->buffer, f_fss_payload_object_status_s.used, set->objects_header.array[i]) == F_equal_to) {
+
+ // Require Content to exist.
+ if (!set->contents_header.array[i].used) {
+ set->abstruses.array[0].value.type = f_abstruse_none_e;
+
+ continue;
+ }
+
+ set->abstruses.array[0].key = f_fss_payload_object_status_s;
+ set->abstruses.array[0].value.type = f_abstruse_range_e;
+ set->abstruses.array[0].value.is.a_range = set->contents_header.array[i].array[0];
+ }
+
+ // Index 1 is the type.
+ else if (f_compare_dynamic_partial_string(f_fss_payload_object_type_s.string, set->buffer, f_fss_payload_object_type_s.used, set->objects_header.array[i]) == F_equal_to) {
+
+ // Require Content to exist.
+ if (!set->contents_header.array[i].used) {
+ set->abstruses.array[0].value.type = f_abstruse_none_e;
+
+ continue;
+ }
+
+ set->abstruses.array[0].key = f_fss_payload_object_type_s;
+ set->abstruses.array[0].value.type = f_abstruse_range_e;
+ set->abstruses.array[0].value.is.a_range = set->contents_header.array[i].array[0];
+ }
+
+ // Index 2 is the length.
+ else if (f_compare_dynamic_partial_string(f_fss_payload_object_length_s.string, set->buffer, f_fss_payload_object_length_s.used, set->objects_header.array[i]) == F_equal_to) {
+
+ // Require Content to exist.
+ if (!set->contents_header.array[i].used) {
+ set->abstruses.array[1].value.type = f_abstruse_none_e;
+
+ continue;
+ }
+
+ set->abstruses.array[1].key = f_fss_payload_object_length_s;
+ set->abstruses.array[1].value.type = f_abstruse_range_e;
+ set->abstruses.array[1].value.is.a_range = set->contents_header.array[i].array[0];
+ }
+
+ // Index 3 is the part.
+ else if (f_compare_dynamic_partial_string(f_fss_payload_object_part_s.string, set->buffer, f_fss_payload_object_part_s.used, set->objects_header.array[i]) == F_equal_to) {
+
+ // Require Content to exist.
+ if (!set->contents_header.array[i].used) {
+ set->abstruses.array[2].value.type = f_abstruse_none_e;
+
+ continue;
+ }
+
+ set->abstruses.array[2].key = f_fss_payload_object_part_s;
+ set->abstruses.array[2].value.type = f_abstruse_range_e;
+ set->abstruses.array[2].value.is.a_range = set->contents_header.array[i].array[0];
+ }
+
+ // Index 4 is the total number of packets (based on block size).
+ else if (f_compare_dynamic_partial_string(f_fss_payload_object_total_s.string, set->buffer, f_fss_payload_object_total_s.used, set->objects_header.array[i]) == F_equal_to) {
+
+ // Require Content to exist.
+ if (!set->contents_header.array[i].used) {
+ set->abstruses.array[3].value.type = f_abstruse_none_e;
+
+ continue;
+ }
+
+ set->abstruses.array[3].key = f_fss_payload_object_total_s;
+ set->abstruses.array[3].value.type = f_abstruse_range_e;
+ set->abstruses.array[3].value.is.a_range = set->contents_header.array[i].array[0];
+ }
+
+ // Index 5 is the name (file name).
+ else if (f_compare_dynamic_partial_string(f_fss_payload_object_name_s.string, set->buffer, f_fss_payload_object_name_s.used, set->objects_header.array[i]) == F_equal_to) {
+
+ // Require Content to exist.
+ if (!set->contents_header.array[i].used) {
+ set->abstruses.array[4].value.type = f_abstruse_none_e;
+
+ continue;
+ }
+
+ set->abstruses.array[4].key = f_fss_payload_object_name_s;
+ set->abstruses.array[4].value.type = f_abstruse_range_e;
+ set->abstruses.array[4].value.is.a_range = set->contents_header.array[i].array[0];
+ }
+
+ // Index 5 is the name (file name).
+ else if (f_compare_dynamic_partial_string(kt_tacocat_salt_s.string, set->buffer, kt_tacocat_salt_s.used, set->objects_header.array[i]) == F_equal_to) {
+
+ // Require Content to exist.
+ if (!set->contents_header.array[i].used) {
+ set->abstruses.array[5].value.type = f_abstruse_none_e;
+
+ continue;
+ }
+
+ set->abstruses.array[5].key = kt_tacocat_salt_s;
+ set->abstruses.array[5].value.type = f_abstruse_range_e;
+ set->abstruses.array[5].value.is.a_range = set->contents_header.array[i].array[0];
+ }
+ } // for
+
+ set->abstruses.used = 6;
+ set->status = F_okay;
+ }
+#endif // _di_kt_tacocat_receive_process_extract_header_
+
+#ifndef _di_kt_tacocat_receive_process_extract_signature_
+ void kt_tacocat_receive_process_extract_signature(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set, const f_number_unsigned_t at) {
+
+ if (!main || !set) return;
+
+ if (set->objects.array[at].start > set->objects.array[at].stop || !set->contents.array[at].used) {
+ set->status = F_data_not;
+
+ return;
+ }
+
+ set->range = set->contents.array[at].array[0];
+
+ fll_fss_extended_read(set->buffer, &set->range, &set->objects_signature, &set->contents_signature, &set->objects_quoted_header, &set->contents_quoted_header, &set->objects_delimits_signature, &set->contents_delimits_signature, &set->state);
+
+ if (F_status_is_error(set->state.status)) {
+ kt_tacocat_print_error_on(&main->program.error, macro_kt_tacocat_f(fll_fss_extended_read), kt_tacocat_receive_s, set->network, set->status, set->name);
+
+ set->status = set->state.status;
+
+ return;
+ }
+
+ // @todo maybe 7 and beyond in the abstruse shall represent signatures?
+
+ set->status = F_okay;
+ }
+#endif // _di_kt_tacocat_receive_process_extract_signature_
+
#ifdef __cplusplus
} // extern "C"
#endif
*
* F_interrupt (with error bit set) on interrupt received.
*
+ * Errors (with error bit) from: f_file_close().
+ * Errors (with error bit) from: f_file_poll().
+ * Errors (with error bit) from: kt_tacocat_receive_process().
+ *
* @return
* 0, always.
+ *
+ * @see f_file_close()
+ * @see f_file_poll()
+ * @see kt_tacocat_receive_process()
*/
#ifndef _di_kt_tacocat_receive_
extern void * kt_tacocat_receive(void * const main);
* Errors (with error bit) from: f_socket_read_stream().
* Errors (with error bit) from: kt_tacocat_receive_process_control().
*
+ * @see f_file_open()
+ * @see f_file_write()
+ * @see f_memory_array_increase_by()
+ * @see f_memory_array_resize()
* @see f_socket_read_stream()
+ * @see kt_tacocat_receive_process_control()
*/
#ifndef _di_kt_tacocat_receive_process_
extern f_status_t kt_tacocat_receive_process(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set);
* F_packet_too_large (with error bit) on total packet size is too large.
* F_payload_too_large (with error bit) on total payload size is too large.
*
+ * Errors (with error bit) from: f_fss_simple_packet_decode_range().
+ * Errors (with error bit) from: f_memory_array_increase_by().
+ * Errors (with error bit) from: f_memory_array_resize().
+ * Errors (with error bit) from: f_socket_accept().
+ * Errors (with error bit) from: f_socket_read_stream().
+ *
+ * @see f_fss_simple_packet_decode_range()
+ * @see f_memory_array_increase_by()
+ * @see f_memory_array_resize()
+ * @see f_socket_accept()
* @see f_socket_read_stream()
*/
#ifndef _di_kt_tacocat_receive_process_control_
extern void kt_tacocat_receive_process_control(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set);
#endif // _di_kt_tacocat_receive_process_control_
+/**
+ * Process the header and signature strings, extracting the data.
+ *
+ * Another function should perform some of the validation on the header.
+ * @todo This other function needs to return a status code such as F_continue to designate to continue to the next iteration.
+ * Ideally, the flag will be set to how to continue, such as "continue loading the entire payload".
+ * This situation would arise when the payload needs to be validated, such as the size.
+ *
+ * @param main
+ * The main program and settings data.
+ *
+ * This does not alter main.setting.state.status, except on interrupt signal.
+ * @param set
+ * The socket set to process.
+ * Must not be NULL.
+ *
+ * This alters set.status:
+ * F_okay on success.
+ *
+ * Errors (with error bit) from: f_memory_array_increase_by().
+ * Errors (with error bit) from: kt_tacocat_receive_process_extract_header().
+ * Errors (with error bit) from: kt_tacocat_receive_process_extract_signature().
+ *
+ * @see f_memory_array_increase_by()
+ * @see kt_tacocat_receive_process_extract_header()
+ * @see kt_tacocat_receive_process_extract_signature()
+ */
+#ifndef _di_kt_tacocat_receive_process_extract_
+ extern void kt_tacocat_receive_process_extract(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set);
+#endif // _di_kt_tacocat_receive_process_extract_
+
+/**
+ * Extract the header strings using the given index for an Object and Content.
+ *
+ * The positions in the abstruse are hard-coded with specific representations.
+ *
+ * Index Positions:
+ * - 0: Status string (such as F_okay).
+ * - 1: Type string (type of packet).
+ * - 2: Length number (the length of the Payload section).
+ * - 3: Packet part number.
+ * - 4: Total packet parts number.
+ * - 5: Name string (file name).
+ * - 6: Salt string (for making packet unique, if encrypted, signed, or something similar).
+ *
+ * @param main
+ * The main program and settings data.
+ *
+ * This does not alter main.setting.state.status, except on interrupt signal.
+ * @param set
+ * The socket set to process.
+ * Must not be NULL.
+ *
+ * This alters set.status:
+ * F_okay on success.
+ * F_data_not on success, but no data to process.
+ *
+ * Errors (with error bit) from: fll_fss_extended_read().
+ * @param at
+ * The index position representing which Object and Contents set to use.
+ *
+ * @see fll_fss_extended_read()
+ */
+#ifndef _di_kt_tacocat_receive_process_extract_header_
+ extern void kt_tacocat_receive_process_extract_header(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set, const f_number_unsigned_t at);
+#endif // _di_kt_tacocat_receive_process_extract_header_
+
+/**
+ * Extract the signature strings using the given index for an Object and Content.
+ *
+ * @param main
+ * The main program and settings data.
+ *
+ * This does not alter main.setting.state.status, except on interrupt signal.
+ * @param set
+ * The socket set to process.
+ * Must not be NULL.
+ *
+ * This alters set.status:
+ * F_okay on success.
+ * @param at
+ * The index position representing which Object and Contents set to use.
+ */
+#ifndef _di_kt_tacocat_receive_process_extract_signature_
+ extern void kt_tacocat_receive_process_extract_signature(kt_tacocat_main_t * const main, kt_tacocat_socket_set_t * const set, const f_number_unsigned_t at);
+#endif // _di_kt_tacocat_receive_process_extract_signature_
+
#ifdef __cplusplus
} // extern "C"
#endif
return F_done;
}
+ // @todo when total > 1, then this needs to build each part, incrementing part each time (every time this needs to be done, the entire header structure needs to be rebuilt until part == total - 1) (the receive code needs to also be sure to handle multiple parts).
if (set->flag & kt_tacocat_socket_flag_send_size_e) {
if (set->file.id == -1) {
set->status = f_file_open(set->name, F_file_mode_all_r_d, &set->file);
#include <fll/level_2/error.h>
#include <fll/level_2/fss.h>
#include <fll/level_2/fss/payload.h>
+#include <fll/level_2/fss/extended.h>
#include <fll/level_2/print.h>
#include <fll/level_2/program.h>
projects / kevux-tools / commitdiff