aboutsummaryrefslogtreecommitdiffstats
path: root/src/vcl
AgeCommit message (Expand)AuthorFilesLines
2018-09-14vcl: keep track of unexpected eventsFlorin Coras4-252/+299
2018-09-12vcl: add apis that expos fifo as bufferFlorin Coras6-53/+263
2018-09-12vcl: improve read and fifo event handlingFlorin Coras3-16/+19
2018-09-11remove libvlib from libvlibmemoryclient libsMatthew Smith1-1/+1
2018-09-10session: lock app worker mq for io eventsFlorin Coras3-72/+104
2018-09-08vcl: set worker pthread stop keyFlorin Coras3-1/+11
2018-09-08vcl: register workers in orderFlorin Coras4-5/+19
2018-09-07vcl: refactor test client to support workersFlorin Coras7-639/+588
2018-09-06vcl/session/svm: fix coverity warningsFlorin Coras1-1/+8
2018-09-06session: support multiple worker bindsFlorin Coras5-33/+59
2018-09-04vcl: refactor test apps to use multiple workersFlorin Coras3-324/+344
2018-09-02Switch to cmakeDamjan Marion1-0/+9
2018-08-30vcl: add support for multi-worker appsFlorin Coras8-594/+905
2018-08-28cmake: don't install some test executableDamjan Marion1-1/+2
2018-08-28vcl: remove session locksFlorin Coras3-318/+143
2018-08-28vcl/session: use mq for bind repliesFlorin Coras2-57/+63
2018-08-26cmake: add add_vpp_library and add_vpp_executable macrosDamjan Marion1-11/+8
2018-08-25cmake: add more headers to the install listDamjan Marion1-0/+6
2018-08-25vcl: remove unused binary api handlersFlorin Coras2-296/+73
2018-08-24session: add support for multiple app workersFlorin Coras1-1/+1
2018-08-17CMake as an alternative to autotools (experimental)Damjan Marion1-0/+53
2018-08-17vcl: unset fifo events only in read/writeFlorin Coras1-57/+21
2018-08-10vcl: support for eventfd mq signalingFlorin Coras8-599/+1063
2018-08-02vcl: fix debug messages output before heap cfgFlorin Coras1-5/+7
2018-07-31vcl: add read/write udp supportFlorin Coras5-72/+111
2018-07-27vcl: use events for epoll/select/read/writeFlorin Coras10-695/+1023
2018-07-18Add config option to use dlmalloc instead of mheapDave Barach4-8/+8
2018-07-17session: use msg queue for eventsFlorin Coras3-20/+19
2018-06-28vcl: move binary api and cfg to separate filesFlorin Coras5-1951/+2077
2018-06-28vcl: refactor vcl sessionFlorin Coras1-189/+185
2018-06-27vcl: refactor debuggingFlorin Coras2-1800/+755
2018-06-25VCL: Refactor VCL test (part 1)Dave Wallace5-322/+2161
2018-06-19VCL: Fix session peer and local addressesDave Wallace1-6/+20
2018-06-19VCL: refactor async & spinlocksDave Wallace5-544/+577
2018-05-31fix socket send() return size checkqchang1-1/+1
2018-04-12VCL IOEvent external API callbackKeith Burns (alagalah)6-90/+367
2018-04-12Fixes for 'make UNATTENDED=yes CC=clang CXX=clang verify'Neale Ranns1-4/+8
2018-03-26VCL: add IPv6 to socket_test.sh and make testDave Wallace4-41/+188
2018-03-19VCL: Fix Coverity CID183003Dave Wallace1-1/+1
2018-03-19VCL: Fix Coverity CID183009Dave Wallace1-1/+1
2018-03-14VCL: Handle epoll HUP events in sock_test_serverDave Wallace1-1/+10
2018-03-13VCL: Fix race condition in event thread functionDave Wallace1-11/+17
2018-03-09VCL API for external callback for listener/connect eventKeith Burns (alagalah)6-22/+312
2018-03-09VCL: add event registration to listen session in select()Dave Wallace1-5/+27
2018-03-08VCL event handling changesKeith Burns (alagalah)3-1/+27
2018-03-08VCL refactoringKeith Burns (alagalah)3-48/+55
2018-03-08VCL: cleanup namespace_secret env-var cfg code.Dave Wallace1-20/+1
2018-03-06VCL registration handler added to session for polling sessionsKeith Burns (alagalah)1-6/+9
2018-03-05VCL async event handlerKeith Burns (alagalah)3-202/+651
2018-02-24LDP: Refactor epoll_ctl wrapper.Dave Wallace4-48/+348
importing into */ fib_node_index_t faei_import_fib; } fib_ae_import_t; /** * A description of the need to export routes to one or more export tables */ typedef struct fib_ae_export_t_ { /** * The vector/list of import tracker indicies */ fib_node_index_t *faee_importers; /** * THe connected entry this export is acting on behalf of */ fib_node_index_t faee_ei; /** * Reference counting locks */ u32 faee_locks; } fib_ae_export_t; /* * memory pools for the importers and exportes */ static fib_ae_import_t *fib_ae_import_pool; static fib_ae_export_t *fib_ae_export_pool; static fib_ae_export_t * fib_entry_ae_add_or_lock (fib_node_index_t connected) { fib_entry_delegate_t *fed; fib_ae_export_t *export; fib_entry_t *entry; entry = fib_entry_get(connected); fed = fib_entry_delegate_get(entry, FIB_ENTRY_DELEGATE_ATTACHED_EXPORT); if (NULL == fed) { fed = fib_entry_delegate_find_or_add(entry, FIB_ENTRY_DELEGATE_ATTACHED_EXPORT); pool_get(fib_ae_export_pool, export); memset(export, 0, sizeof(*export)); fed->fd_index = (export - fib_ae_export_pool); export->faee_ei = connected; } else { export = pool_elt_at_index(fib_ae_export_pool, fed->fd_index); } export->faee_locks++; return (export); } static void fib_entry_import_remove (fib_ae_import_t *import, fib_node_index_t entry_index) { u32 index; /* * find the index in the vector of the entry we are removing */ index = vec_search(import->faei_importeds, entry_index); if (index < vec_len(import->faei_importeds)) { /* * this is an entry that was previsouly imported */ fib_table_entry_special_remove(import->faei_import_fib, fib_entry_get_prefix(entry_index), FIB_SOURCE_AE); fib_entry_unlock(entry_index); vec_del1(import->faei_importeds, index); } } static void fib_entry_import_add (fib_ae_import_t *import, fib_node_index_t entry_index) { fib_node_index_t *existing; const fib_prefix_t *prefix; /* * ensure we only add the exported entry once, since * sourcing prefixes in the table is reference counted */ vec_foreach(existing, import->faei_importeds) { if (*existing == entry_index) { return; } } /* * this is the first time this export entry has been imported * Add it to the import FIB and to the list of importeds */ prefix = fib_entry_get_prefix(entry_index); /* * don't import entries that have the same prefix the import entry */ if (0 != fib_prefix_cmp(prefix, &import->faei_prefix)) { const dpo_id_t *dpo; dpo = fib_entry_contribute_ip_forwarding(entry_index); if (dpo_id_is_valid(dpo) && !dpo_is_drop(dpo)) { fib_table_entry_special_dpo_add(import->faei_import_fib, prefix, FIB_SOURCE_AE, (fib_entry_get_flags(entry_index) | FIB_ENTRY_FLAG_EXCLUSIVE), load_balance_get_bucket(dpo->dpoi_index, 0)); fib_entry_lock(entry_index); vec_add1(import->faei_importeds, entry_index); } /* * else * the entry currently has no valid forwarding. when it * does it will export itself */ } } /** * Call back when walking a connected prefix's covered prefixes for import */ static int fib_entry_covered_walk_import (fib_entry_t *cover, fib_node_index_t covered, void *ctx) { fib_ae_import_t *import = ctx; fib_entry_import_add(import, covered); return (0); } /* * fib_entry_ae_import_add * * Add an importer to a connected entry */ static void fib_ae_export_import_add (fib_ae_export_t *export, fib_ae_import_t *import) { fib_entry_t *entry; import->faei_exporter = (export - fib_ae_export_pool); entry = fib_entry_get(export->faee_ei); fib_entry_cover_walk(entry, fib_entry_covered_walk_import, import); } void fib_attached_export_import (fib_entry_t *fib_entry, fib_node_index_t export_fib) { fib_entry_delegate_t *fed; fib_ae_import_t *import; fib_node_index_t fei; /* * save index for later post-realloc retreival */ fei = fib_entry_get_index(fib_entry); pool_get(fib_ae_import_pool, import); import->faei_import_fib = fib_entry->fe_fib_index; import->faei_export_fib = export_fib; import->faei_prefix = fib_entry->fe_prefix; import->faei_import_entry = fib_entry_get_index(fib_entry); import->faei_export_sibling = ~0; /* * do an exact match in the export table */ import->faei_export_entry = fib_table_lookup_exact_match(import->faei_export_fib, &import->faei_prefix); if (FIB_NODE_INDEX_INVALID == import->faei_export_entry) { /* * no exact matching entry in the export table. can't be good. * track the next best thing */ import->faei_export_entry = fib_table_lookup(import->faei_export_fib, &import->faei_prefix); import->faei_exporter = FIB_NODE_INDEX_INVALID; } else { /* * found the entry in the export table. import the * the prefixes that it covers. * only if the prefix found in the export FIB really is * attached do we want to import its covered */ if (FIB_ENTRY_FLAG_ATTACHED & fib_entry_get_flags_i(fib_entry_get(import->faei_export_entry))) { fib_ae_export_t *export; export = fib_entry_ae_add_or_lock(import->faei_export_entry); vec_add1(export->faee_importers, (import - fib_ae_import_pool)); fib_ae_export_import_add(export, import); } } /* * track the entry in the export table so we can update appropriately * when it changes. * Exporting prefixes will have allocated new fib_entry_t objects, so the pool * may have realloc'd. */ fib_entry = fib_entry_get(fei); import->faei_export_sibling = fib_entry_cover_track(fib_entry_get(import->faei_export_entry), fei); fed = fib_entry_delegate_find_or_add(fib_entry, FIB_ENTRY_DELEGATE_ATTACHED_IMPORT); fed->fd_index = (import - fib_ae_import_pool); } /** * \brief All the imported entries need to be pruged */ void fib_attached_export_purge (fib_entry_t *fib_entry) { fib_entry_delegate_t *fed; fed = fib_entry_delegate_get(fib_entry, FIB_ENTRY_DELEGATE_ATTACHED_IMPORT); if (NULL != fed) { fib_node_index_t *import_index; fib_entry_t *export_entry; fib_ae_import_t *import; fib_ae_export_t *export; import = pool_elt_at_index(fib_ae_import_pool, fed->fd_index); /* * remove each imported entry */ vec_foreach(import_index, import->faei_importeds) { fib_table_entry_delete(import->faei_import_fib, fib_entry_get_prefix(*import_index), FIB_SOURCE_AE); fib_entry_unlock(*import_index); } vec_free(import->faei_importeds); /* * stop tracking the export entry */ if (~0 != import->faei_export_sibling) { fib_entry_cover_untrack(fib_entry_get(import->faei_export_entry), import->faei_export_sibling); } import->faei_export_sibling = ~0; /* * remove this import tracker from the export's list, * if it is attached to one. It won't be in the case the tracked * export entry is not an attached exact match. */ if (FIB_NODE_INDEX_INVALID != import->faei_exporter) { fib_entry_delegate_t *fed; export_entry = fib_entry_get(import->faei_export_entry); fed = fib_entry_delegate_get(export_entry, FIB_ENTRY_DELEGATE_ATTACHED_EXPORT); ASSERT(NULL != fed); export = pool_elt_at_index(fib_ae_export_pool, fed->fd_index); u32 index = vec_search(export->faee_importers, (import - fib_ae_import_pool)); ASSERT(index < vec_len(export->faee_importers)); vec_del1(export->faee_importers, index); /* * free the exporter if there are no longer importers */ if (0 == --export->faee_locks) { pool_put(fib_ae_export_pool, export); fib_entry_delegate_remove(export_entry, FIB_ENTRY_DELEGATE_ATTACHED_EXPORT); } } /* * free the import tracker */ pool_put(fib_ae_import_pool, import); fib_entry_delegate_remove(fib_entry, FIB_ENTRY_DELEGATE_ATTACHED_IMPORT); } } void fib_attached_export_covered_added (fib_entry_t *cover, fib_node_index_t covered) { fib_entry_delegate_t *fed; fed = fib_entry_delegate_get(cover, FIB_ENTRY_DELEGATE_ATTACHED_EXPORT); if (NULL != fed) { /* * the covering prefix is exporting to other tables */ fib_node_index_t *import_index; fib_ae_import_t *import; fib_ae_export_t *export; export = pool_elt_at_index(fib_ae_export_pool, fed->fd_index); /* * export the covered entry to each of the importers */ vec_foreach(import_index, export->faee_importers) { import = pool_elt_at_index(fib_ae_import_pool, *import_index); fib_entry_import_add(import, covered); } } } void fib_attached_export_covered_removed (fib_entry_t *cover, fib_node_index_t covered) { fib_entry_delegate_t *fed; fed = fib_entry_delegate_get(cover, FIB_ENTRY_DELEGATE_ATTACHED_EXPORT); if (NULL != fed) { /* * the covering prefix is exporting to other tables */ fib_node_index_t *import_index; fib_ae_import_t *import; fib_ae_export_t *export; export = pool_elt_at_index(fib_ae_export_pool, fed->fd_index); /* * remove the covered entry from each of the importers */ vec_foreach(import_index, export->faee_importers) { import = pool_elt_at_index(fib_ae_import_pool, *import_index); fib_entry_import_remove(import, covered); } } } static void fib_attached_export_cover_modified_i (fib_entry_t *fib_entry) { fib_entry_delegate_t *fed; fed = fib_entry_delegate_get(fib_entry, FIB_ENTRY_DELEGATE_ATTACHED_IMPORT); if (NULL != fed) { fib_ae_import_t *import; u32 export_fib; /* * safe the temporaries we need from the existing import * since it will be toast after the purge. */ import = pool_elt_at_index(fib_ae_import_pool, fed->fd_index); export_fib = import->faei_export_fib; /* * keep it simple. purge anything that was previously imported. * then re-evaluate the need to import. */ fib_attached_export_purge(fib_entry); fib_attached_export_import(fib_entry, export_fib); } } /** * \brief If this entry is tracking a cover (in another table) * then that cover has changed. re-evaluate import. */ void fib_attached_export_cover_change (fib_entry_t *fib_entry) { fib_attached_export_cover_modified_i(fib_entry); } /** * \brief If this entry is tracking a cover (in another table) * then that cover has been updated. re-evaluate import. */ void fib_attached_export_cover_update (fib_entry_t *fib_entry) { fib_attached_export_cover_modified_i(fib_entry); } u8* fib_ae_import_format (fib_node_index_t impi, u8* s) { fib_node_index_t *index; fib_ae_import_t *import; import = pool_elt_at_index(fib_ae_import_pool, impi); s = format(s, "\n Attached-Import:%d:[", (import - fib_ae_import_pool)); s = format(s, "export-prefix:%U ", format_fib_prefix, &import->faei_prefix); s = format(s, "export-entry:%d ", import->faei_export_entry); s = format(s, "export-sibling:%d ", import->faei_export_sibling); s = format(s, "exporter:%d ", import->faei_exporter); s = format(s, "export-fib:%d ", import->faei_export_fib); s = format(s, "import-entry:%d ", import->faei_import_entry); s = format(s, "import-fib:%d ", import->faei_import_fib); s = format(s, "importeds:["); vec_foreach(index, import->faei_importeds) { s = format(s, "%d, ", *index); } s = format(s, "]]"); return (s); } u8* fib_ae_export_format (fib_node_index_t expi, u8* s) { fib_node_index_t *index; fib_ae_export_t *export; export = pool_elt_at_index(fib_ae_export_pool, expi); s = format(s, "\n Attached-Export:%d:[", (export - fib_ae_export_pool)); s = format(s, "export-entry:%d ", export->faee_ei); s = format(s, "importers:["); vec_foreach(index, export->faee_importers) { s = format(s, "%d, ", *index); } s = format(s, "]]"); return (s); }