Home
last modified time | relevance | path

Searched refs:fsm (Results 1 – 25 of 35) sorted by relevance

12

/third_party/iowow/src/fs/
Diwfsmfile.c84 struct fsm { struct
109 static iwrc _fsm_ensure_size_lw(struct fsm *fsm, off_t size); argument
134 IW_INLINE iwrc _fsm_ctrl_wlock(struct fsm *fsm) { in _fsm_ctrl_wlock() argument
135 int rci = fsm->ctlrwlk ? pthread_rwlock_wrlock(fsm->ctlrwlk) : 0; in _fsm_ctrl_wlock()
139 IW_INLINE iwrc _fsm_ctrl_rlock(struct fsm *fsm) { in _fsm_ctrl_rlock() argument
140 int rci = fsm->ctlrwlk ? pthread_rwlock_rdlock(fsm->ctlrwlk) : 0; in _fsm_ctrl_rlock()
144 IW_INLINE iwrc _fsm_ctrl_unlock(struct fsm *fsm) { in _fsm_ctrl_unlock() argument
145 int rci = fsm->ctlrwlk ? pthread_rwlock_unlock(fsm->ctlrwlk) : 0; in _fsm_ctrl_unlock()
149 IW_INLINE iwrc _fsm_bmptr(struct fsm *fsm, uint64_t **bmptr) { in _fsm_bmptr() argument
154 iwrc rc = fsm->pool.probe_mmap(&fsm->pool, fsm->mmap_all ? 0 : fsm->bmoff, &mm, &sp); in _fsm_bmptr()
[all …]
Diwfsmfile.h199 struct fsm *impl;
/third_party/lwip/src/include/netif/ppp/
Dfsm.h78 typedef struct fsm { struct
95 } fsm; argument
100 (fsm *);
102 (fsm *);
104 (fsm *, u_char *, int *);
106 (fsm *, u_char *, int);
108 (fsm *, u_char *, int, int);
110 (fsm *, u_char *, int);
112 (fsm *, u_char *, int *, int);
114 (fsm *);
[all …]
Dppp.h378 fsm lcp_fsm; /* LCP fsm structure */
395 fsm ccp_fsm; /* CCP fsm structure */
410 fsm ipcp_fsm; /* IPCP fsm structure */
418 fsm ipv6cp_fsm; /* IPV6CP fsm structure */
Decp.h49 extern fsm ecp_fsm[];
/third_party/iowow/src/fs/tests/
Diwfs_test2.c237 IWFS_FSM fsm; in test_fsm_open_close() local
238 rc = iwfs_fsmfile_open(&fsm, &opts); in test_fsm_open_close()
240 rc = iwfs_fsmdbg_state(&fsm, &state1); in test_fsm_open_close()
243 rc = fsm.close(&fsm); in test_fsm_open_close()
246 rc = iwfs_fsmfile_open(&fsm, &opts); in test_fsm_open_close()
248 rc = iwfs_fsmdbg_state(&fsm, &state2); in test_fsm_open_close()
261 rc = fsm.close(&fsm); in test_fsm_open_close()
302 IWFS_FSM fsm; in test_fsm_uniform_alloc_impl() local
303 rc = iwfs_fsmfile_open(&fsm, &opts); in test_fsm_uniform_alloc_impl()
306 rc = iwfs_fsmdbg_state(&fsm, &state1); in test_fsm_uniform_alloc_impl()
[all …]
Diwfs_test3.c91 IWFS_FSM fsm; in test_stress() local
104 iwrc rc = iwfs_fsmfile_open(&fsm, &opts); in test_stress()
123 rc = fsm.deallocate(&fsm, pr->alc_addr, pr->alc_len); in test_stress()
132 rc = fsm.reallocate(&fsm, nlen, &pr->alc_addr, &pr->alc_len, IWFSM_SOLID_ALLOCATED_SPACE); in test_stress()
135 rc = fsm.read(&fsm, pr->alc_addr, buf, pr->rsz, &sp); in test_stress()
141 rc = fsm.write(&fsm, pr->alc_addr + pr->alc_len - wsz, buf, wc, &sp); in test_stress()
158 rc = fsm.allocate(&fsm, r->rsz, &r->alc_addr, &r->alc_len, aflags); in test_stress()
162 rc = fsm.write(&fsm, r->alc_addr, buf, r->rsz, &sp); in test_stress()
170 rc = fsm.write(&fsm, r->alc_addr + r->alc_len - wsz, buf, wc, &sp); in test_stress()
177 CU_ASSERT_FALSE_FATAL(fsm.close(&fsm)); in test_stress()
[all …]
/third_party/libwebsockets/lib/misc/
Dfsmount.c60 lws_fsmount_mount(struct lws_fsmount *fsm) in lws_fsmount_mount() argument
75 c = fsm->mp[0]; in lws_fsmount_mount()
76 while (!lws_fsmount_unmount(fsm)) in lws_fsmount_mount()
77 fsm->mp[0] = c; in lws_fsmount_mount()
78 fsm->mp[0] = c; in lws_fsmount_mount()
88 fsm->overlay_path, fsm->ovname); in lws_fsmount_mount()
97 for (m = LWS_ARRAY_SIZE(fsm->layers) - 1; m >= 0; m--) in lws_fsmount_mount()
98 if (fsm->layers[m]) { in lws_fsmount_mount()
103 "%s/%s/%s", fsm->layers_path, in lws_fsmount_mount()
104 fsm->distro, fsm->layers[m]); in lws_fsmount_mount()
[all …]
/third_party/iowow/src/kv/
Diwkv.c478 IWFS_FSM *fsm = &dctx->iwkv->fsm; in _db_dispose_chain() local
484 rc = fsm->acquire_mmap(fsm, 0, &mm, 0); in _db_dispose_chain()
496 rc = fsm->release_mmap(fsm); in _db_dispose_chain()
502 if (!fsm->check_allocation_status(fsm, page, SBLK_PAGE_SZ_V2, true)) { in _db_dispose_chain()
503 rc = fsm->deallocate(fsm, page, SBLK_PAGE_SZ_V2); in _db_dispose_chain()
511 rc = fsm->release_mmap(fsm); in _db_dispose_chain()
514 rc = fsm->deallocate(fsm, sba, SBLK_SZ); in _db_dispose_chain()
519 rc = fsm->deallocate(fsm, BLK2ADDR(kvblkn), 1ULL << kvszpow); in _db_dispose_chain()
524 if (!fsm->check_allocation_status(fsm, page, SBLK_PAGE_SZ_V2, true)) { in _db_dispose_chain()
525 IWRC(fsm->deallocate(fsm, page, SBLK_PAGE_SZ_V2), rc); in _db_dispose_chain()
[all …]
/third_party/lwip/src/netif/ppp/
Dfsm.c63 static void fsm_rconfreq(fsm *f, u_char id, u_char *inp, int len);
64 static void fsm_rconfack(fsm *f, int id, u_char *inp, int len);
65 static void fsm_rconfnakrej(fsm *f, int code, int id, u_char *inp, int len);
66 static void fsm_rtermreq(fsm *f, int id, u_char *p, int len);
67 static void fsm_rtermack(fsm *f);
68 static void fsm_rcoderej(fsm *f, u_char *inp, int len);
69 static void fsm_sconfreq(fsm *f, int retransmit);
78 void fsm_init(fsm *f) { in fsm_init()
91 void fsm_lowerup(fsm *f) { in fsm_lowerup()
119 void fsm_lowerdown(fsm *f) { in fsm_lowerdown()
[all …]
Dccp.c214 static void ccp_resetci (fsm *);
215 static int ccp_cilen (fsm *);
216 static void ccp_addci (fsm *, u_char *, int *);
217 static int ccp_ackci (fsm *, u_char *, int);
218 static int ccp_nakci (fsm *, u_char *, int, int);
219 static int ccp_rejci (fsm *, u_char *, int);
220 static int ccp_reqci (fsm *, u_char *, int *, int);
221 static void ccp_up (fsm *);
222 static void ccp_down (fsm *);
223 static int ccp_extcode (fsm *, int, int, u_char *, int);
[all …]
Dlcp.c218 static void lcp_resetci(fsm *f); /* Reset our CI */
219 static int lcp_cilen(fsm *f); /* Return length of our CI */
220 static void lcp_addci(fsm *f, u_char *ucp, int *lenp); /* Add our CI to pkt */
221 static int lcp_ackci(fsm *f, u_char *p, int len); /* Peer ack'd our CI */
222 static int lcp_nakci(fsm *f, u_char *p, int len, int treat_as_reject); /* Peer nak'd our CI */
223 static int lcp_rejci(fsm *f, u_char *p, int len); /* Peer rej'd our CI */
224 static int lcp_reqci(fsm *f, u_char *inp, int *lenp, int reject_if_disagree); /* Rcv peer CI */
225 static void lcp_up(fsm *f); /* We're UP */
226 static void lcp_down(fsm *f); /* We're DOWN */
227 static void lcp_starting (fsm *); /* We need lower layer up */
[all …]
Dipv6cp.c179 static void ipv6cp_resetci(fsm *f); /* Reset our CI */
180 static int ipv6cp_cilen(fsm *f); /* Return length of our CI */
181 static void ipv6cp_addci(fsm *f, u_char *ucp, int *lenp); /* Add our CI */
182 static int ipv6cp_ackci(fsm *f, u_char *p, int len); /* Peer ack'd our CI */
183 static int ipv6cp_nakci(fsm *f, u_char *p, int len, int treat_as_reject); /* Peer nak'd our CI */
184 static int ipv6cp_rejci(fsm *f, u_char *p, int len); /* Peer rej'd our CI */
185 static int ipv6cp_reqci(fsm *f, u_char *inp, int *len, int reject_if_disagree); /* Rcv CI */
186 static void ipv6cp_up(fsm *f); /* We're UP */
187 static void ipv6cp_down(fsm *f); /* We're DOWN */
188 static void ipv6cp_finished(fsm *f); /* Don't need lower layer */
[all …]
Dipcp.c113 static void ipcp_resetci(fsm *f); /* Reset our CI */
114 static int ipcp_cilen(fsm *f); /* Return length of our CI */
115 static void ipcp_addci(fsm *f, u_char *ucp, int *lenp); /* Add our CI */
116 static int ipcp_ackci(fsm *f, u_char *p, int len); /* Peer ack'd our CI */
117 static int ipcp_nakci(fsm *f, u_char *p, int len, int treat_as_reject);/* Peer nak'd our CI */
118 static int ipcp_rejci(fsm *f, u_char *p, int len); /* Peer rej'd our CI */
119 static int ipcp_reqci(fsm *f, u_char *inp, int *len, int reject_if_disagree); /* Rcv CI */
120 static void ipcp_up(fsm *f); /* We're UP */
121 static void ipcp_down(fsm *f); /* We're DOWN */
122 static void ipcp_finished(fsm *f); /* Don't need lower layer */
[all …]
Decp.c131 fsm ecp_fsm[NUM_PPP];
162 fsm *f = &ecp_fsm[unit];
/third_party/iowow/src/kv/dbg/
Diwkvdbg.c11 IWFS_FSM *fsm = &kb->db->iwkv->fsm; in iwkvd_kvblk() local
16 iwrc rc = fsm->probe_mmap(fsm, 0, &mm, 0); in iwkvd_kvblk()
44 IWFS_FSM *fsm = &sb->db->iwkv->fsm; in iwkvd_sblk() local
46 iwrc rc = fsm->probe_mmap(fsm, 0, &mm, 0); in iwkvd_sblk()
102 return &kv->fsm; in iwkvd_fsm()
/third_party/rust/crates/aho-corasick/src/
Dahocorasick.rs1161 fsm: &'a Imp<S>, field
1170 FindIter { fsm: &ac.imp, prestate, haystack, pos: 0 } in new()
1181 let result = self.fsm.find_at_no_state( in next()
1218 fsm: &'a Imp<S>, field
1237 fsm: &ac.imp, in new()
1251 let result = self.fsm.overlapping_find_at( in next()
1323 fsm: &'a Imp<S>, field
1378 fsm: &ac.imp, in new()
1444 let result = self.fsm.earliest_find_at( in next()
1455 self.state_id = self.fsm.start_state(); in next()
Dtests.rs1079 let fsm = AhoCorasickBuilder::new() in stream_not_allowed_leftmost_first() localVariable
1082 assert_eq!(fsm.stream_find_iter(&b""[..]).count(), 0); in stream_not_allowed_leftmost_first()
1088 let fsm = AhoCorasickBuilder::new() in stream_not_allowed_leftmost_longest() localVariable
1091 assert_eq!(fsm.stream_find_iter(&b""[..]).count(), 0); in stream_not_allowed_leftmost_longest()
1097 let fsm = AhoCorasickBuilder::new() in overlapping_not_allowed_leftmost_first() localVariable
1100 assert_eq!(fsm.find_overlapping_iter("").count(), 0); in overlapping_not_allowed_leftmost_first()
1106 let fsm = AhoCorasickBuilder::new() in overlapping_not_allowed_leftmost_longest() localVariable
1109 assert_eq!(fsm.find_overlapping_iter("").count(), 0); in overlapping_not_allowed_leftmost_longest()
/third_party/node/deps/npm/node_modules/tar/lib/
Dcreate.js8 const fsm = require('fs-minipass') constant
40 const stream = new fsm.WriteStreamSync(opt.file, {
49 const stream = new fsm.WriteStream(opt.file, {
Dextract.js7 const fsm = require('fs-minipass') constant
73 const stream = new fsm.ReadStreamSync(file, {
95 const stream = new fsm.ReadStream(file, {
Dreplace.js9 const fsm = require('fs-minipass') constant
94 const stream = new fsm.WriteStreamSync(opt.file, {
176 const stream = new fsm.WriteStream(opt.file, {
Dlist.js12 const fsm = require('fs-minipass') constant
119 const stream = new fsm.ReadStream(file, {
/third_party/node/deps/npm/node_modules/fs-minipass/
DREADME.md33 const fsm = require('fs-minipass')
34 const readStream = new fsm.ReadStream('file.txt')
35 const writeStream = new fsm.WriteStream('output.txt')
/third_party/libwebsockets/include/libwebsockets/
Dlws-misc.h1107 lws_fsmount_mount(struct lws_fsmount *fsm);
1122 lws_fsmount_unmount(struct lws_fsmount *fsm);
/third_party/rust/crates/aho-corasick/
DDESIGN.md168 fn contains(fsm: &FiniteStateMachine, haystack: &[u8]) -> bool {
169 let mut state_id = fsm.start();
170 // If the empty pattern is in fsm, then state_id is a match state.
171 if fsm.is_match(state_id) {
184 match fsm.next_state(state_id, b) {
193 state_id = fsm.next_fail_state(state_id);
197 if fsm.is_match(state_id) {

12