From 53a7719131ff381866fd414cdeff4ac3dd354927 Mon Sep 17 00:00:00 2001 From: Mathieu Desnoyers Date: Fri, 21 Jun 2013 16:46:04 -0400 Subject: [PATCH] doc/examples: cds_wfs_pop_all_blocking Signed-off-by: Mathieu Desnoyers --- .gitignore | 1 + doc/examples/Makefile.am | 4 +- doc/examples/wfstack/Makefile | 2 + .../wfstack/Makefile.cds_wfs_pop_all_blocking | 21 +++++ .../wfstack/cds_wfs_pop_all_blocking.c | 77 +++++++++++++++++++ 5 files changed, 104 insertions(+), 1 deletion(-) create mode 100644 doc/examples/wfstack/Makefile.cds_wfs_pop_all_blocking create mode 100644 doc/examples/wfstack/cds_wfs_pop_all_blocking.c diff --git a/.gitignore b/.gitignore index 3346263..b16fffd 100644 --- a/.gitignore +++ b/.gitignore @@ -88,6 +88,7 @@ doc/examples/wfcqueue/cds_wfcq_splice doc/examples/wfstack/cds_wfs_push doc/examples/wfstack/cds_wfs_pop +doc/examples/wfstack/cds_wfs_pop_all_blocking #automake /config.h diff --git a/doc/examples/Makefile.am b/doc/examples/Makefile.am index 85d6158..5c3e76f 100644 --- a/doc/examples/Makefile.am +++ b/doc/examples/Makefile.am @@ -43,8 +43,10 @@ dist_doc_examples_wfstack_DATA = \ wfstack/Makefile \ wfstack/Makefile.cds_wfs_push \ wfstack/Makefile.cds_wfs_pop \ + wfstack/Makefile.cds_wfs_pop_all_blocking \ wfstack/cds_wfs_push.c \ - wfstack/cds_wfs_pop.c + wfstack/cds_wfs_pop.c \ + wfstack/cds_wfs_pop_all_blocking.c if NO_SHARED # Don't build examples if shared libraries support was explicitly diff --git a/doc/examples/wfstack/Makefile b/doc/examples/wfstack/Makefile index d98d995..b8be3f5 100644 --- a/doc/examples/wfstack/Makefile +++ b/doc/examples/wfstack/Makefile @@ -14,8 +14,10 @@ all: $(MAKE) -f Makefile.cds_wfs_push $(MAKE) -f Makefile.cds_wfs_pop + $(MAKE) -f Makefile.cds_wfs_pop_all_blocking .PHONY: clean clean: $(MAKE) -f Makefile.cds_wfs_push clean $(MAKE) -f Makefile.cds_wfs_pop clean + $(MAKE) -f Makefile.cds_wfs_pop_all_blocking clean diff --git a/doc/examples/wfstack/Makefile.cds_wfs_pop_all_blocking b/doc/examples/wfstack/Makefile.cds_wfs_pop_all_blocking new file mode 100644 index 0000000..452fd9c --- /dev/null +++ b/doc/examples/wfstack/Makefile.cds_wfs_pop_all_blocking @@ -0,0 +1,21 @@ +# Copyright (C) 2013 Mathieu Desnoyers +# +# THIS MATERIAL IS PROVIDED AS IS, WITH ABSOLUTELY NO WARRANTY EXPRESSED +# OR IMPLIED. ANY USE IS AT YOUR OWN RISK. +# +# Permission is hereby granted to use or copy this program for any +# purpose, provided the above notices are retained on all copies. +# Permission to modify the code and to distribute modified code is +# granted, provided the above notices are retained, and a notice that +# the code was modified is included with the above copyright notice. +# +# This makefile is purposefully kept simple to support GNU and BSD make. + +EXAMPLE_NAME = cds_wfs_pop_all_blocking + +SOURCES = $(EXAMPLE_NAME).c +OBJECTS = $(EXAMPLE_NAME).o +BINARY = $(EXAMPLE_NAME) +LIBS = -lurcu-common + +include ../Makefile.examples.template diff --git a/doc/examples/wfstack/cds_wfs_pop_all_blocking.c b/doc/examples/wfstack/cds_wfs_pop_all_blocking.c new file mode 100644 index 0000000..52bf0c0 --- /dev/null +++ b/doc/examples/wfstack/cds_wfs_pop_all_blocking.c @@ -0,0 +1,77 @@ +/* + * Copyright (C) 2013 Mathieu Desnoyers + * + * THIS MATERIAL IS PROVIDED AS IS, WITH ABSOLUTELY NO WARRANTY EXPRESSED + * OR IMPLIED. ANY USE IS AT YOUR OWN RISK. + * + * Permission is hereby granted to use or copy this program for any + * purpose, provided the above notices are retained on all copies. + * Permission to modify the code and to distribute modified code is + * granted, provided the above notices are retained, and a notice that + * the code was modified is included with the above copyright notice. + * + * This example shows how to pop all nodes from a wfstack. + */ + +#include +#include + +#include /* Wait-free stack */ +#include /* For CAA_ARRAY_SIZE */ + +/* + * Nodes populated into the stack. + */ +struct mynode { + int value; /* Node content */ + struct cds_wfs_node node; /* Chaining in stack */ +}; + +int main(int argc, char **argv) +{ + int values[] = { -5, 42, 36, 24, }; + struct cds_wfs_stack mystack; /* Stack */ + unsigned int i; + int ret = 0; + struct cds_wfs_node *snode; + struct cds_wfs_head *shead; + + cds_wfs_init(&mystack); + + /* + * Push nodes. + */ + for (i = 0; i < CAA_ARRAY_SIZE(values); i++) { + struct mynode *node; + + node = malloc(sizeof(*node)); + if (!node) { + ret = -1; + goto end; + } + + cds_wfs_node_init(&node->node); + node->value = values[i]; + cds_wfs_push(&mystack, &node->node); + } + + /* + * Pop all nodes from mystack into shead. The head can the be + * used for iteration. + */ + shead = cds_wfs_pop_all_blocking(&mystack); + + /* + * Show the stack content, iterate in reverse order of push, + * from newest to oldest. + */ + printf("mystack content:"); + cds_wfs_for_each_blocking(shead, snode) { + struct mynode *node = + caa_container_of(snode, struct mynode, node); + printf(" %d", node->value); + } + printf("\n"); +end: + return ret; +} -- 2.34.1