Skip to content

Commit 90bbbe9

Browse files
authored
Doc fixes (#4229)
* fixes for doxygen doc batch_file.h * fixes for doxygen doc batch_queue.h * fixes for doxygen doc jx_parse.h * fixes for doxygen doc jx_parse.h * fixes for doxygen doc link.h * fixes for doxygen doc manager.py * fixes for doxygen doc task.py * fixes for doxygen doc taskvine.h
1 parent c949b0b commit 90bbbe9

File tree

8 files changed

+41
-28
lines changed

8 files changed

+41
-28
lines changed

batch_job/src/batch_file.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ struct batch_file *batch_file_create(const char *outer_name, const char *inner_n
4242
This includes freeing host_name and exe_name if defined.
4343
@param file A batch_file struct to be deleted.
4444
*/
45-
void batch_file_delete(struct batch_file *f);
45+
void batch_file_delete( struct batch_file *file );
4646

4747
/** Output batch_file as a string.
4848
* Format is "outer_name=inner_name" when renaming is needed.
@@ -51,21 +51,21 @@ void batch_file_delete(struct batch_file *f);
5151
* @return pointer to char * representing the flattened list.
5252
*/
5353

54-
char * batch_file_to_string( struct batch_file *f );
54+
char * batch_file_to_string( struct batch_file *file );
5555

5656
/** Output list of batch_files as a string.
5757
* Format is "FILE,FILE,...,FILE" where file is the result of batch_file_to_string.
5858
* @param files A list struct containing batch_file structs.
5959
* @return pointer to char * representing the flattened list.
6060
*/
61-
char * batch_file_list_to_string( struct list *file_list );
61+
char * batch_file_list_to_string( struct list *files );
6262

6363
/** Compare function for comparing batch_files based on outer_name.
6464
@param file1 First file to compare.
6565
@param file2 Second file to compare.
6666
@return Relative alphabetic order of files outer_name's
6767
*/
68-
int batch_file_outer_compare( struct batch_file *f1, struct batch_file *f2 );
68+
int batch_file_outer_compare( struct batch_file *file1, struct batch_file *file2 );
6969

7070
/** Generate a sha1 hash based on the file contents.
7171
@param f The batch_file whose checksum will be generated.

batch_job/src/batch_queue.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -87,15 +87,14 @@ typedef enum {
8787
/** Create a new batch queue.
8888
@param type The type of the queue.
8989
@param ssl_key_file The location of the queue manager's ssl key file, if it has one.
90-
@param ssl_key_file The location of the queue manager's ssl certiciate file, if it has one.
90+
@param ssl_cert_file The location of the queue manager's ssl certiciate file, if it has one.
9191
@return A new batch queue object on success, null on failure.
9292
*/
9393
struct batch_queue *batch_queue_create(batch_queue_type_t type, const char *ssl_key_file, const char *ssl_cert_file );
9494

9595
/** Submit a batch job.
9696
@param q The queue to submit to.
9797
@param task The job description to submit.
98-
@param resources The computational resources needed by the job.
9998
@return On success, returns a positive unique identifier for the batch job. On failure, returns a negative number.
10099
Zero is not a valid batch job id and indicates an internal failure.
101100
*/

batch_job/src/batch_wrapper.h

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ See: Nick Hazekamp, "An Algebra for Robust Workflow Transformations", eScience 2
3434
struct batch_wrapper *batch_wrapper_create(void);
3535

3636
/** Free a batch_wrapper.
37+
* @param w A wrapper structure from @ref batch_wrapper_create.
3738
* Any scripts written out will continue to work after
3839
* calling this function.
3940
*/
@@ -43,6 +44,7 @@ void batch_wrapper_delete(struct batch_wrapper *w);
4344
* Can be called multiple times to append multiple commands.
4445
* These commands run before the main wrapper command.
4546
* Each command must be a self-contained shell statement.
47+
* @param w A wrapper structure from @ref batch_wrapper_create.
4648
* @param cmd The shell command to add.
4749
*/
4850
void batch_wrapper_pre(struct batch_wrapper *w, const char *cmd);
@@ -51,19 +53,22 @@ void batch_wrapper_pre(struct batch_wrapper *w, const char *cmd);
5153
* The arguments in argv are executed as-is, with no shell interpretation.
5254
* This command executes after any pre commands.
5355
* It is undefined behavior to add another command after calling this.
56+
* @param w A wrapper structure from @ref batch_wrapper_create.
5457
* @param argv The command line to run.
5558
*/
5659
void batch_wrapper_argv(struct batch_wrapper *w, char *const argv[]);
5760

5861
/** Specify a command line to execute with shell interpretation.
5962
* Same as batch_wrapper_argv, but each arg is individually
6063
* interpreted by the shell for variable substitution and such.
64+
* @param w A wrapper structure from @ref batch_wrapper_create.
6165
* @param args The command line to run.
6266
*/
6367
void batch_wrapper_args(struct batch_wrapper *w, char *const args[]);
6468

6569
/** Specify a shell command to execute.
6670
* Same as batch_wrapper_argv, but takes a shell command.
71+
* @param w A wrapper structure from @ref batch_wrapper_create.
6772
* @param cmd The command line to run.
6873
*/
6974
void batch_wrapper_cmd(struct batch_wrapper *w, const char *cmd);
@@ -73,6 +78,7 @@ void batch_wrapper_cmd(struct batch_wrapper *w, const char *cmd);
7378
* The shell statement specified will be executed before exiting the wrapper,
7479
* even if previous commands failed. This is a good place for cleanup actions.
7580
* Can be called multiple times.
81+
* @param w A wrapper structure from @ref batch_wrapper_create.
7682
* @param cmd The shell command to add.
7783
*/
7884
void batch_wrapper_post(struct batch_wrapper *w, const char *cmd);
@@ -81,14 +87,15 @@ void batch_wrapper_post(struct batch_wrapper *w, const char *cmd);
8187
* The actual filename will consist of the prefix, an underscore,
8288
* and some random characters to ensure that the name is unique.
8389
* Defaults to "./wrapper"
90+
* @param w A wrapper structure from @ref batch_wrapper_create.
8491
* @param prefix The filename prefix to use.
8592
*/
8693
void batch_wrapper_prefix(struct batch_wrapper *w, const char *prefix);
8794

8895
/**
8996
* Write out the batch_wrapper as a shell script.
9097
* Does not consume the batch_wrapper.
91-
* @param prefix The prefix to use to generate a unique name for the wrapper.
98+
* @param w A wrapper structure from @ref batch_wrapper_create.
9299
* @returns The name of the generated wrapper, which the caller must free().
93100
* @returns NULL on failure, and sets errno.
94101
*/
@@ -97,6 +104,8 @@ char *batch_wrapper_write(struct batch_wrapper *w, struct batch_job *t);
97104
/** Generate one or more wrapper scripts from a JX command spec.
98105
* All generated scripts will be added as inputs to the given
99106
* batch task.
107+
* @param t A batch_job structure.
108+
* @param spec A command description.
100109
* @returns The name of the outermost wrapper script.
101110
* @returns NULL on failure, and sets errno.
102111
*/

dttools/src/jx_parse.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ void jx_parse_set_static_mode( bool mode );
3131
/** Parse a JSON string to a JX expression. @param str A null-terminated C string containing JSON data. @return A JX expression which must be deleted with @ref jx_delete. If the parse fails or no JSON value is present, null is returned. */
3232
struct jx * jx_parse_string( const char *str );
3333

34-
/** Parse a JSON string to a JX expression. @param str An unterminated string containing JSON data. @param Length of the string in bytes. @return A JX expression which must be deleted with @ref jx_delete. If the parse fails or no JSON value is present, null is returned. */
34+
/** Parse a JSON string to a JX expression. @param str An unterminated string containing JSON data. @param length of the string in bytes. @return A JX expression which must be deleted with @ref jx_delete. If the parse fails or no JSON value is present, null is returned. */
3535
struct jx * jx_parse_string_and_length( const char *str, int length );
3636

3737
/** Parse a standard IO stream to a JX expression. @param file A stream containing JSON data. @return A JX expression which must be deleted with @ref jx_delete. If the parse fails or no JSON value is present, null is returned. */

dttools/src/link.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,7 @@ struct link *link_serve_address(const char *addr, int port);
115115

116116
/** Prepare to accept connections on one network interface.
117117
Functions like @ref link_serve, except that the server will only be visible on the given network interface.
118+
@param addr IP address of the network interface.
118119
@param low The low port in a range to listen on (inclusive).
119120
@param high The high port in a range to listen on (inclusive).
120121
@return link A server endpoint that can be passed to @ref link_accept, or null on failure.

taskvine/src/bindings/python3/ndcctools/taskvine/manager.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -392,6 +392,7 @@ def set_category_autolabel_resource(self, category, resource, autolabel):
392392

393393
##
394394
# Get current task state. See @ref vine_task_state_t for possible values.
395+
# @param task_id The task_id returned from @ref ndcctools.taskvine.manager.Manager.submit.
395396
# @code
396397
# >>> print(q.task_state(task_id))
397398
# @endcode
@@ -559,7 +560,7 @@ def set_catalog_servers(self, catalogs):
559560
# This is helpful for distinguishing higher level information about the entire run,
560561
# such as the name of the framework being used, or the logical name of the dataset
561562
# being processed.
562-
# @param m A manager object
563+
# @param self Reference to the current manager object.
563564
# @param name The name of the property.
564565
# @param value The value of the property.
565566
def set_property(self, name, value):
@@ -1756,16 +1757,16 @@ def declare_chirp(self, server, source, ticket=None, env=None, cache=False, peer
17561757
##
17571758
# Adds a custom APPLICATION entry to the transactions log.
17581759
#
1759-
# @param self The manager to register this file.
1760-
# @param server A custom transaction message
1760+
# @param self The manager to register this file.
1761+
# @param entry A custom transaction message
17611762
def log_txn_app(self, entry):
17621763
cvine.vine_log_txn_app(self._taskvine, entry)
17631764

17641765
##
17651766
# Adds a custom APPLICATION entry to the debug log.
17661767
#
17671768
# @param self The manager to register this file.
1768-
# @param server A custom debug message
1769+
# @param entry A custom debug message
17691770
def log_debug_app(self, entry):
17701771
cvine.vine_log_debug_app(self._taskvine, entry)
17711772

taskvine/src/bindings/python3/ndcctools/taskvine/task.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -339,6 +339,7 @@ def add_feature(self, name):
339339
# @param self Reference to the current task object.
340340
# @param file A file object of class @ref ndcctools.taskvine.file.File, such as from @ref ndcctools.taskvine.manager.Manager.declare_file, @ref ndcctools.taskvine.manager.Manager.declare_buffer, @ref ndcctools.taskvine.manager.Manager.declare_url, etc.
341341
# @param remote_name The name of the file at the execution site.
342+
# @param mount_symlink Whether to mount file in task's sandbox as a symlink. The default (False) mounts it as a hard link.
342343
# @param strict_input Whether the file should be transfered to the worker
343344
# for execution. If no worker has all the input files already cached marked
344345
# as strict inputs for the task, the task fails.
@@ -450,8 +451,8 @@ def set_snapshot_file(self, filename):
450451
# The file given must refer to a (unpacked) package
451452
# containing libraries captured by the <tt>starch</tt> command.
452453
# The task will execute using this package as its environment.
453-
# @param t A task object.
454-
# @param f A file containing an unpacked Starch package.
454+
# @param self The current task object.
455+
# @param file A file containing an unpacked Starch package.
455456
def add_starch_package(self, file):
456457
return cvine.vine_task_add_starch_package(self._task, file._file)
457458

@@ -460,8 +461,8 @@ def add_starch_package(self, file):
460461
# The file given must refer to a (unpacked) PONCHO package,
461462
# containing a set of Python modules needed by the task.
462463
# The task will execute using this package as its Python environment.
463-
# @param t A task object.
464-
# @param f A file containing an unpacked Poncho package.
464+
# @param self The current task object.
465+
# @param file A file containing an unpacked Poncho package.
465466
def add_poncho_package(self, file):
466467
return cvine.vine_task_add_poncho_package(self._task, file._file)
467468

@@ -477,7 +478,7 @@ def add_poncho_package(self, file):
477478
# nested in the order given (i.e. first added is the first applied).
478479
# @see add_poncho_package
479480
# @see add_starch_package
480-
# @param t A task object.
481+
# @param self The current task object.
481482
# @param f The execution context file.
482483
def add_execution_context(self, f):
483484
return cvine.vine_task_add_execution_context(self._task, f._file)
@@ -899,7 +900,6 @@ def __init__(self, func, *args, **kwargs):
899900
# execution.
900901
#
901902
# @param self Reference to the current python task object
902-
# @param manager Manager to which the task was submitted
903903
def submit_finalize(self):
904904
super().submit_finalize()
905905
self._add_inputs_outputs(self.manager, *self._fn_def)

taskvine/src/manager/taskvine.h

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -361,7 +361,7 @@ the result VINE_RESULT_FORSAKEN.
361361
@param max_retries The number of retries.
362362
*/
363363

364-
void vine_task_set_max_forsaken(struct vine_task *t, int64_t max_forsaken);
364+
void vine_task_set_max_forsaken(struct vine_task *t, int64_t max_retries);
365365

366366
/** Specify the amount of disk space required by a task.
367367
@param t A task object.
@@ -707,7 +707,6 @@ int vine_task_add_environment(struct vine_task *t, struct vine_file *f);
707707
Typically used to examine an output buffer returned from a file.
708708
Note that the vfile contents may not be available unless @ref vine_fetch_file
709709
has previously been called on this object.
710-
@param m A manager object
711710
@param f A file object created by @ref vine_declare_buffer.
712711
@return A constant pointer to the buffer contents, or null if not available.
713712
*/
@@ -773,7 +772,7 @@ struct vine_file *vine_declare_url(
773772
@param proxy A proxy file object (e.g. from @ref vine_declare_file) of a X509 proxy to use. If NULL, the
774773
environment variable X509_USER_PROXY and the file "$TMPDIR/$UID" are considered
775774
in that order. If no proxy is present, the transfer is tried without authentication.
776-
@param env If not NULL, an environment file (e.g poncho or starch, see @ref vine_task_add_environment) that contains
775+
@param env If not NULL, an environment file (e.g poncho or starch, see @ref vine_task_add_execution_context) that contains
777776
the xrootd executables. Otherwise assume xrootd is available at the worker.
778777
@param cache Method for caching file at the workers: never, the default (VINE_CACHE_LEVEL_TASK), to cache only for the
779778
current manager (VINE_CACHE_LEVEL_WORKFLOW), to cache for the lifetime of the worker (VINE_CACHE_LEVEL_WORKER), or to
@@ -791,7 +790,7 @@ struct vine_file *vine_declare_xrootd(struct vine_manager *m, const char *source
791790
@param server The chirp server address of the form "hostname[:port"]"
792791
@param source The name of the file in the server
793792
@param ticket If not NULL, a file object that provides a chirp an authentication ticket
794-
@param env If not NULL, an environment file (e.g poncho or starch, see @ref vine_task_add_environment) that contains
793+
@param env If not NULL, an environment file (e.g poncho or starch, see @ref vine_task_add_execution_context) that contains
795794
the chirp executables. Otherwise assume chirp is available at the worker.
796795
@param cache Method for caching file at the workers: never, the default (VINE_CACHE_LEVEL_TASK), to cache only for the
797796
current manager (VINE_CACHE_LEVEL_WORKFLOW), to cache for the lifetime of the worker (VINE_CACHE_LEVEL_WORKER), or to
@@ -1007,9 +1006,9 @@ void vine_manager_remove_library(struct vine_manager *m, const char *name);
10071006

10081007
/** Find a library template on the manager
10091008
@param m A manager object
1010-
@param name The name of the library of interest
1009+
@param library_name The name of the library of interest
10111010
*/
1012-
struct vine_task *vine_manager_find_library_template(struct vine_manager *q, const char *library_name);
1011+
struct vine_task *vine_manager_find_library_template(struct vine_manager *m, const char *library_name);
10131012

10141013
/** Wait for a task to complete.
10151014
This call will block until either a task has completed, the timeout has expired, or the manager is empty.
@@ -1251,7 +1250,7 @@ int vine_set_category_mode(struct vine_manager *m, const char *category, vine_ca
12511250

12521251
/** Set a maximum number of tasks of this category that can execute concurrently. If less than 0, unlimited (this is the
12531252
default).
1254-
@param q A manager object.
1253+
@param m A manager object.
12551254
@param category A category name.
12561255
@param max_concurrent Number of maximum concurrent tasks.
12571256
*/
@@ -1503,19 +1502,19 @@ void vine_set_runtime_info_path(const char *path);
15031502
/** Sets the directory where a workflow-specific runtime logs are directly written into.
15041503
@param dir A directory
15051504
*/
1506-
void vine_set_runtime_info_template(const char *template);
1505+
void vine_set_runtime_info_template(const char *dir);
15071506

15081507
/** Adds a custom APPLICATION entry to the debug log.
15091508
@param m Reference to the current manager object.
15101509
@param entry A custom debug message.
15111510
*/
1512-
void vine_log_debug_app(struct vine_manager *q, const char *entry);
1511+
void vine_log_debug_app(struct vine_manager *m, const char *entry);
15131512

15141513
/** Adds a custom APPLICATION entry to the transactions log.
15151514
@param m Reference to the current manager object.
15161515
@param entry A custom transaction message.
15171516
*/
1518-
void vine_log_txn_app(struct vine_manager *q, const char *entry);
1517+
void vine_log_txn_app(struct vine_manager *m, const char *entry);
15191518

15201519
/** Display internal reference counts for troubleshooting purposes.
15211520
*/
@@ -1529,24 +1528,28 @@ char *vine_version_string();
15291528

15301529
/** Returns path relative to the logs runtime directory
15311530
@param m Reference to the current manager object.
1531+
@param path Target filename.
15321532
@return A string.
15331533
*/
15341534
char *vine_get_path_log(struct vine_manager *m, const char *path);
15351535

15361536
/** Returns path relative to the staging runtime directory
15371537
@param m Reference to the current manager object.
1538+
@param path Target filename.
15381539
@return A string.
15391540
*/
15401541
char *vine_get_path_staging(struct vine_manager *m, const char *path);
15411542

15421543
/** Returns path relative to the library logs runtime directory
15431544
@param m Reference to the current manager object.
1545+
@param path Target filename.
15441546
@return A string.
15451547
*/
15461548
char *vine_get_path_library_log(struct vine_manager *m, const char *path);
15471549

15481550
/** Returns path relative to the cache runtime directory
15491551
@param m Reference to the current manager object.
1552+
@param path Target filename.
15501553
@return A string.
15511554
*/
15521555
char *vine_get_path_cache(struct vine_manager *m, const char *path);

0 commit comments

Comments
 (0)