Changeset 8397 for branches/cu-security-branch/src/io/flow
- Timestamp:
- 06/18/10 20:02:50 (3 years ago)
- Location:
- branches/cu-security-branch
- Files:
-
- 9 modified
-
. (modified) (1 prop)
-
src/io/flow (modified) (1 prop)
-
src/io/flow/flow.h (modified) (1 diff)
-
src/io/flow/flowproto-bmi-cache (modified) (1 prop)
-
src/io/flow/flowproto-bmi-cache/flowproto-bmi-cache-server.c (modified) (2 diffs)
-
src/io/flow/flowproto-bmi-trove (modified) (1 prop)
-
src/io/flow/flowproto-bmi-trove/flowproto-multiqueue.c (modified) (3 diffs)
-
src/io/flow/flowproto-dump-offsets (modified) (1 prop)
-
src/io/flow/flowproto-template (modified) (1 prop)
Legend:
- Unmodified
- Added
- Removed
-
branches/cu-security-branch
- Property svn:ignore
-
old new 3 3 aclocal.m4 4 4 autom4te.cache 5 config.status6 Makefile7 pvfs2-config.h8 module.mk
-
- Property svn:ignore
-
branches/cu-security-branch/src/io/flow
- Property svn:ignore deleted
-
branches/cu-security-branch/src/io/flow/flow.h
r7941 r8397 100 100 101 101 /* function to be triggered upon completion */ 102 void(*callback)(struct flow_descriptor* flow_d );102 void(*callback)(struct flow_descriptor* flow_d, int cancel_path); 103 103 104 104 struct flow_endpoint src; /* src endpoint */ -
branches/cu-security-branch/src/io/flow/flowproto-bmi-cache
- Property svn:ignore deleted
-
branches/cu-security-branch/src/io/flow/flowproto-bmi-cache/flowproto-bmi-cache-server.c
r7941 r8397 490 490 free(flow_data); 491 491 flow_d->release(flow_d); 492 flow_d->callback(flow_d );492 flow_d->callback(flow_d, 0); 493 493 fprintf(stderr, "bmi_cache_request_init: exit with return 1. zero request.\n"); 494 494 return(1); … … 801 801 flow_d->state = FLOW_COMPLETE; 802 802 flow_d->release(flow_d); 803 flow_d->callback(flow_d );803 flow_d->callback(flow_d, 0); 804 804 fprintf(stderr, "bmi_recv_callback_fn: request is done\n"); 805 805 return; -
branches/cu-security-branch/src/io/flow/flowproto-bmi-trove
- Property svn:ignore deleted
-
branches/cu-security-branch/src/io/flow/flowproto-bmi-trove/flowproto-multiqueue.c
r7941 r8397 31 31 #define MAX_REGIONS 64 32 32 33 #define FLOW_CLEANUP (__flow_data)\33 #define FLOW_CLEANUP_CANCEL_PATH(__flow_data, __cancel_path) \ 34 34 do { \ 35 35 struct flow_descriptor *__flow_d = (__flow_data)->parent; \ … … 40 40 free(__flow_data); \ 41 41 __flow_d->release(__flow_d); \ 42 __flow_d->callback(__flow_d );\42 __flow_d->callback(__flow_d, __cancel_path); \ 43 43 } while(0) 44 45 #define FLOW_CLEANUP(___flow_data) FLOW_CLEANUP_CANCEL_PATH(___flow_data, 0) 44 46 45 47 struct result_chain_entry … … 480 482 { 481 483 gen_mutex_unlock(&flow_data->parent->flow_mutex); 482 FLOW_CLEANUP (flow_data);484 FLOW_CLEANUP_CANCEL_PATH(flow_data, 1); 483 485 return(0); 484 486 } -
branches/cu-security-branch/src/io/flow/flowproto-dump-offsets
- Property svn:ignore deleted
-
branches/cu-security-branch/src/io/flow/flowproto-template
- Property svn:ignore deleted
