| /openbmc/linux/drivers/net/wireless/mediatek/mt76/ |
| H A D | agg-rx.c | 16 mt76_aggr_release(struct mt76_rx_tid *tid, struct sk_buff_head *frames, int idx) in mt76_aggr_release() argument
20 tid->head = ieee80211_sn_inc(tid->head); in mt76_aggr_release()
22 skb = tid->reorder_buf[idx]; in mt76_aggr_release()
26 tid->reorder_buf[idx] = NULL; in mt76_aggr_release()
27 tid->nframes--; in mt76_aggr_release()
32 mt76_rx_aggr_release_frames(struct mt76_rx_tid *tid, in mt76_rx_aggr_release_frames() argument
38 while (ieee80211_sn_less(tid->head, head)) { in mt76_rx_aggr_release_frames()
39 idx = tid->head % tid->size; in mt76_rx_aggr_release_frames()
40 mt76_aggr_release(tid, frames, idx); in mt76_rx_aggr_release_frames()
45 mt76_rx_aggr_release_head(struct mt76_rx_tid *tid, struct sk_buff_head *frames) in mt76_rx_aggr_release_head() argument
[all …]
|
| /openbmc/pldm/platform-mc/ |
| H A D | sensor_manager.cpp | 22 void SensorManager::startPolling(pldm_tid_t tid) in startPolling() argument
24 if (!termini.contains(tid)) in startPolling()
29 /* tid already initializes roundRobinSensors list */ in startPolling()
30 if (sensorPollTimers.contains(tid)) in startPolling()
32 lg2::info("Terminus ID {TID}: sensor poll timer already exists.", "TID", in startPolling()
33 tid); in startPolling()
37 auto terminus = termini[tid]; in startPolling()
40 roundRobinSensors[tid].push(sensor); in startPolling()
43 updateAvailableState(tid, true); in startPolling()
45 if (!roundRobinSensors[tid].size()) in startPolling()
[all …]
|
| H A D | platform_manager.cpp | 18 for (auto& [tid, terminus] : termini) in initTerminus()
31 "Failed to fetch PDRs for terminus with TID: {TID}, error: {ERROR}", in initTerminus()
32 "TID", tid, "ERROR", rc); in initTerminus()
49 tid, terminus->maxBufferSize, terminusMaxBufferSize); in initTerminus()
53 … "Failed to get message buffer size for terminus with TID: {TID}, error: {ERROR}", in initTerminus()
54 "TID", tid, "ERROR", rc); in initTerminus()
62 auto rc = co_await configEventReceiver(tid); in initTerminus()
66 "Failed to config event receiver for terminus with TID: {TID}, error: {ERROR}", in initTerminus()
67 "TID", tid, "ERROR", rc); in initTerminus()
75 exec::task<int> PlatformManager::configEventReceiver(pldm_tid_t tid) in configEventReceiver() argument
[all …]
|
| H A D | terminus_manager.cpp | 14 std::optional<MctpInfo> TerminusManager::toMctpInfo(const pldm_tid_t& tid) in toMctpInfo() argument
16 if (tid == PLDM_TID_UNASSIGNED || tid == PLDM_TID_RESERVED) in toMctpInfo()
21 if ((!this->transportLayerTable.contains(tid)) || in toMctpInfo()
22 (this->transportLayerTable[tid] != SupportedTransportLayer::MCTP)) in toMctpInfo()
27 auto mctpInfoIt = mctpInfoTable.find(tid); in toMctpInfo()
56 TerminusManager::storeTerminusInfo(const MctpInfo& mctpInfo, pldm_tid_t tid) in storeTerminusInfo() argument
58 if (tid == PLDM_TID_UNASSIGNED || tid == PLDM_TID_RESERVED) in storeTerminusInfo()
68 if (tidPool[tid]) in storeTerminusInfo()
103 pldm_tid_t tid = std::distance(tidPool.begin(), tidPoolIt); mapTid() local
107 unmapTid(const pldm_tid_t & tid) unmapTid() argument
183 auto tid = toTid(mctpInfo); discoverMctpTerminusTask() local
194 for (const auto& tid : addedTids) discoverMctpTerminusTask() local
230 pldm_tid_t tid = 0; initMctpTerminus() local
421 getTidOverMctp(mctp_eid_t eid,pldm_tid_t * tid) getTidOverMctp() argument
467 setTidOverMctp(mctp_eid_t eid,pldm_tid_t tid) setTidOverMctp() argument
505 getPLDMTypes(pldm_tid_t tid,uint64_t & supportedTypes) getPLDMTypes() argument
552 getPLDMCommands(pldm_tid_t tid,uint8_t type,ver32_t version,bitfield8_t * supportedCmds) getPLDMCommands() argument
602 sendRecvPldmMsg(pldm_tid_t tid,Request & request,const pldm_msg ** responseMsg,size_t * responseLen) sendRecvPldmMsg() argument
639 getPLDMVersion(pldm_tid_t tid,uint8_t type,ver32_t * version) getPLDMVersion() argument
[all...] |
| H A D | terminus_manager.hpp | 31 /** @brief Size of TID Pool in pldmd */
78 /** @brief Send request PLDM message to tid. The function will return when
83 * @param[in] tid - Destination TID
89 exec::task<int> sendRecvPldmMsg(pldm_tid_t tid, Request& request,
106 /** @brief member functions to map/unmap tid
108 std::optional<MctpInfo> toMctpInfo(const pldm_tid_t& tid);
110 /** @brief Member functions to response the TID of specific MCTP interface
114 * @return tid - Terminus tid
118 /** @brief Member functions to find the TID for MCTP interface. Response the
119 * Terminus TID when mctpInfo is already in the data base. Response
[all …]
|
| H A D | event_manager.cpp | 23 pldm_tid_t tid, uint16_t eventId, uint8_t eventClass, in handlePlatformEvent() argument
27 if (!termini.contains(tid)) in handlePlatformEvent()
29 lg2::error("Terminus ID {TID} is not in the managing list.", "TID", in handlePlatformEvent()
30 tid); in handlePlatformEvent()
46 …"Failed to decode sensor event data from terminus ID {TID}, event class {CLASS}, event ID {EVENTID… in handlePlatformEvent()
47 "TID", tid, "CLASS", eventClass, "EVENTID", eventId, "RC", rc); in handlePlatformEvent()
56 return processNumericSensorEvent(tid, sensorId, sensorData, in handlePlatformEvent()
63 … "Unsupported class type {CLASSTYPE} for the sensor event from terminus ID {TID} sensorId {SID}", in handlePlatformEvent()
64 "CLASSTYPE", sensorEventClassType, "TID", tid, "SID", in handlePlatformEvent()
73 return processCperEvent(tid, eventId, eventData, eventDataSize); in handlePlatformEvent()
[all …]
|
| H A D | manager.hpp | 76 /** @brief Helper function to start sensor polling of the terminus TID
78 void startSensorPolling(pldm_tid_t tid) in startSensorPolling() argument
80 sensorManager.startPolling(tid); in startSensorPolling()
84 * polling and event polling) of the terminus TID. The `false` state
88 void updateAvailableState(pldm_tid_t tid, Availability state) in updateAvailableState() argument
90 if (termini.contains(tid)) in updateAvailableState()
92 sensorManager.updateAvailableState(tid, state); in updateAvailableState()
93 eventManager.updateAvailableState(tid, state); in updateAvailableState()
97 /** @brief Helper function to stop sensor polling of the terminus TID
99 void stopSensorPolling(pldm_tid_t tid) in stopSensorPolling() argument
[all …]
|
| H A D | event_manager.hpp | 20 std::function<int(pldm_tid_t tid, uint16_t eventId,
50 {[this](pldm_tid_t tid, uint16_t eventId, const uint8_t* eventData, in EventManager()
52 return this->handlePlatformEvent(tid, eventId, in EventManager()
58 {[this](pldm_tid_t tid, uint16_t eventId, const uint8_t* eventData, in EventManager() argument
60 return this->handlePlatformEvent(tid, eventId, PLDM_CPER_EVENT, in EventManager()
67 * @param[in] tid - tid where the event is from
74 int handlePlatformEvent(pldm_tid_t tid, uint16_t eventId, argument
80 * @param[in] tid - terminus ID
83 void updateAvailableState(pldm_tid_t tid, Availability state) in updateAvailableState() argument
85 availableState[tid] = state; in updateAvailableState()
[all …]
|
| H A D | platform_manager.hpp | 45 * @param[in] tid - Destination TID
48 exec::task<int> configEventReceiver(pldm_tid_t tid);
60 * @param[in] tid - Destination TID
75 getPDR(const pldm_tid_t tid, const uint32_t recordHndl,
84 * @param[in] tid - Destination TID
93 const pldm_tid_t tid, uint8_t& repositoryState, uint32_t& recordCount,
98 * @param[in] tid - Destination TID
110 pldm_tid_t tid,
115 * @param[in] tid - Destination TID
120 exec::task<int> eventMessageBufferSize(pldm_tid_t tid,
[all …]
|
| /openbmc/linux/fs/smb/client/ |
| H A D | trace.h | 93 __u32 tid,
98 TP_ARGS(xid, fid, tid, sesid, offset, len, rc),
102 __field(__u32, tid)
111 __entry->tid = tid;
117 TP_printk("\txid=%u sid=0x%llx tid=0x%x fid=0x%llx offset=0x%llx len=0x%x rc=%d",
118 __entry->xid, __entry->sesid, __entry->tid, __entry->fid,
126 __u32 tid, \
131 TP_ARGS(xid, fid, tid, sesid, offset, len, rc))
144 __u32 tid,
148 TP_ARGS(xid, fid, tid, sesid, offset, len),
[all …]
|
| /openbmc/linux/net/mac80211/ |
| H A D | agg-tx.c | 62 const u8 *da, u16 tid, in ieee80211_send_addba_request() argument
100 capab |= u16_encode_bits(tid, IEEE80211_ADDBA_PARAM_TID_MASK); in ieee80211_send_addba_request()
109 ieee80211_tx_skb_tid(sdata, skb, tid, -1); in ieee80211_send_addba_request()
112 void ieee80211_send_bar(struct ieee80211_vif *vif, u8 *ra, u16 tid, u16 ssn) in ieee80211_send_bar() argument
132 bar_control |= (u16)(tid << IEEE80211_BAR_CTRL_TID_INFO_SHIFT); in ieee80211_send_bar()
138 ieee80211_tx_skb_tid(sdata, skb, tid, -1); in ieee80211_send_bar()
142 void ieee80211_assign_tid_tx(struct sta_info *sta, int tid, in ieee80211_assign_tid_tx() argument
147 rcu_assign_pointer(sta->ampdu_mlme.tid_tx[tid], tid_tx); in ieee80211_assign_tid_tx()
162 ieee80211_stop_queue_agg(struct ieee80211_sub_if_data *sdata, int tid) in __acquires()
164 int queue = sdata->vif.hw_queue[ieee80211_ac_from_tid(tid)]; in __acquires()
[all …]
|
| H A D | agg-rx.c | 58 void ___ieee80211_stop_rx_ba_session(struct sta_info *sta, u16 tid, in ___ieee80211_stop_rx_ba_session() argument
66 .tid = tid, in ___ieee80211_stop_rx_ba_session()
74 tid_rx = rcu_dereference_protected(sta->ampdu_mlme.tid_rx[tid], in ___ieee80211_stop_rx_ba_session()
77 if (!test_bit(tid, sta->ampdu_mlme.agg_session_valid)) in ___ieee80211_stop_rx_ba_session()
80 RCU_INIT_POINTER(sta->ampdu_mlme.tid_rx[tid], NULL); in ___ieee80211_stop_rx_ba_session()
81 __clear_bit(tid, sta->ampdu_mlme.agg_session_valid); in ___ieee80211_stop_rx_ba_session()
84 "Rx BA session stop requested for %pM tid %u %s reason: %d\n", in ___ieee80211_stop_rx_ba_session()
85 sta->sta.addr, tid, in ___ieee80211_stop_rx_ba_session()
91 "HW problem - can not stop rx aggregation for %pM tid %d\n", in ___ieee80211_stop_rx_ba_session()
92 sta->sta.addr, tid); in ___ieee80211_stop_rx_ba_session()
[all …]
|
| /openbmc/openbmc/poky/bitbake/lib/bb/ |
| H A D | runqueue.py | 36 def fn_from_tid(tid): argument
37 return tid.rsplit(":", 1)[0]
39 def taskname_from_tid(tid): argument
40 return tid.rsplit(":", 1)[1]
42 def mc_from_tid(tid): argument
43 if tid.startswith('mc:') and tid.count(':') >= 2:
44 return tid.split(':')[1]
47 def split_tid(tid): argument
48 (mc, fn, taskname, _) = split_tid_mcfn(tid)
57 def split_tid_mcfn(tid): argument
[all …]
|
| H A D | siggen.py | 114 def get_cached_unihash(self, tid): argument
117 def get_unihash(self, tid): argument
118 unihash = self.get_cached_unihash(tid)
121 return self.taskhash[tid]
124 return {tid: self.get_unihash(tid) for tid in tids}
126 def prep_taskhash(self, tid, deps, dataCaches): argument
129 def get_taskhash(self, tid, deps, dataCaches): argument
130 self.taskhash[tid] = hashlib.sha256(tid.encode("utf-8")).hexdigest()
131 return self.taskhash[tid]
258 tid = mcfn + ":" + task
[all …]
|
| /openbmc/libpldm/tests/ |
| H A D | instance-id.cpp | 92 const pldm_tid_t tid = 1; in TEST_F() local
96 EXPECT_EQ(pldm_instance_id_alloc(db, tid, &iid), 0); in TEST_F()
97 EXPECT_EQ(pldm_instance_id_free(db, tid, iid), 0); in TEST_F()
103 static constexpr pldm_tid_t tid = 1; in TEST_F() local
110 EXPECT_EQ(pldm_instance_id_alloc(db, tid, &first), 0); in TEST_F()
111 EXPECT_EQ(pldm_instance_id_free(db, tid, first), 0); in TEST_F()
112 EXPECT_EQ(pldm_instance_id_alloc(db, tid, &second), 0); in TEST_F()
113 EXPECT_EQ(pldm_instance_id_free(db, tid, second), 0); in TEST_F()
122 pldm_tid_t tid; in TEST_F() member
133 EXPECT_EQ(pldm_instance_id_alloc(db, instances[0].tid, &instances[0].iid), in TEST_F()
[all …]
|
| /openbmc/linux/drivers/net/ethernet/marvell/mvpp2/ |
| H A D | mvpp2_prs.c | 47 int tid) in mvpp2_prs_init_from_hw() argument
51 if (tid > MVPP2_PRS_TCAM_SRAM_SIZE - 1) in mvpp2_prs_init_from_hw()
55 pe->index = tid; in mvpp2_prs_init_from_hw()
367 int tid; in mvpp2_prs_flow_find() local
370 for (tid = MVPP2_PRS_TCAM_SRAM_SIZE - 1; tid >= 0; tid--) { in mvpp2_prs_flow_find()
373 if (!priv->prs_shadow[tid].valid || in mvpp2_prs_flow_find()
374 priv->prs_shadow[tid].lu != MVPP2_PRS_LU_FLOWS) in mvpp2_prs_flow_find()
377 mvpp2_prs_init_from_hw(priv, &pe, tid); in mvpp2_prs_flow_find()
382 return tid; in mvpp2_prs_flow_find()
392 int tid; in mvpp2_prs_tcam_first_free() local
[all …]
|
| /openbmc/linux/include/trace/events/ |
| H A D | jbd2.h | 137 TP_PROTO(dev_t dev, tid_t tid, unsigned int type,
140 TP_ARGS(dev, tid, type, line_no, requested_blocks),
144 __field( tid_t, tid )
152 __entry->tid = tid;
158 TP_printk("dev %d,%d tid %u type %u line_no %u "
160 MAJOR(__entry->dev), MINOR(__entry->dev), __entry->tid,
165 TP_PROTO(dev_t dev, tid_t tid, unsigned int type,
168 TP_ARGS(dev, tid, type, line_no, requested_blocks)
172 TP_PROTO(dev_t dev, tid_t tid, unsigned int type,
175 TP_ARGS(dev, tid, type, line_no, requested_blocks)
[all …]
|
| /openbmc/linux/tools/perf/scripts/python/ |
| H A D | futex-contention.py | 25 lock_waits = {} # long-lived stats on (tid,lock) blockage elapsed time
29 def syscalls__sys_enter_futex(event, ctxt, cpu, s, ns, tid, comm, callchain, argument
35 process_names[tid] = comm
36 thread_thislock[tid] = uaddr
37 thread_blocktime[tid] = nsecs(s, ns)
40 def syscalls__sys_exit_futex(event, ctxt, cpu, s, ns, tid, comm, callchain, argument
42 if tid in thread_blocktime:
43 elapsed = nsecs(s, ns) - thread_blocktime[tid]
44 add_stats(lock_waits, (tid, thread_thislock[tid]), elapsed)
45 del thread_blocktime[tid]
[all …]
|
| /openbmc/linux/drivers/net/wireless/ath/ath12k/ |
| H A D | hal_tx.c | 14 /* dscp_tid_map - Default DSCP-TID mapping
16 * DSCP TID
58 le32_encode_bits(ti->tid, HAL_TCL_DATA_CMD_INFO3_TID) | in ath12k_hal_tx_cmd_desc_setup()
73 u8 hw_map_val[HAL_DSCP_TID_TBL_SIZE], dscp, tid; in ath12k_hal_tx_set_dscp_tid_map() local
87 /* Configure each DSCP-TID mapping in three bits there by configure in ath12k_hal_tx_set_dscp_tid_map()
91 tid = dscp2tid(dscp); in ath12k_hal_tx_set_dscp_tid_map()
92 value = u32_encode_bits(tid, HAL_TCL1_RING_FIELD_DSCP_TID_MAP0); in ath12k_hal_tx_set_dscp_tid_map()
95 tid = dscp2tid(dscp); in ath12k_hal_tx_set_dscp_tid_map()
96 value |= u32_encode_bits(tid, HAL_TCL1_RING_FIELD_DSCP_TID_MAP1); in ath12k_hal_tx_set_dscp_tid_map()
99 tid = dscp2tid(dscp); in ath12k_hal_tx_set_dscp_tid_map()
[all …]
|
| /openbmc/pldm/oem/ampere/event/ |
| H A D | oem_event_manager.hpp | 252 * @param[in] tid - TID
258 uint8_t /* formatVersion */, pldm_tid_t tid,
263 * @param[in] tid - terminus ID
270 int processOemMsgPollEvent(pldm_tid_t tid, uint16_t eventId,
278 * @param[in] tid - TID
285 uint8_t /* formatVersion */, pldm_tid_t tid, size_t eventDataOffset);
290 * @param[in] tid - TID
295 std::string prefixMsgStrCreation(pldm_tid_t tid, uint16_t sensorId);
333 * @param[in] tid - TID
337 void handlePCIeHotPlugEvent(pldm_tid_t tid, uint16_t sensorId,
[all …]
|
| /openbmc/linux/drivers/net/wireless/marvell/mwifiex/ |
| H A D | 11n.h | 35 *priv, int tid,
37 void mwifiex_create_ba_tbl(struct mwifiex_private *priv, u8 *ra, int tid,
39 int mwifiex_send_addba(struct mwifiex_private *priv, int tid, u8 *peer_mac);
40 int mwifiex_send_delba(struct mwifiex_private *priv, int tid, u8 *peer_mac,
58 struct mwifiex_ra_list_tbl *ptr, int tid) in mwifiex_is_station_ampdu_allowed() argument
65 return (node->ampdu_sta[tid] != BA_STREAM_NOT_ALLOWED) ? true : false; in mwifiex_is_station_ampdu_allowed()
68 /* This function checks whether AMPDU is allowed or not for a particular TID. */
71 struct mwifiex_ra_list_tbl *ptr, int tid) in mwifiex_is_ampdu_allowed() argument
76 return mwifiex_is_station_ampdu_allowed(priv, ptr, tid); in mwifiex_is_ampdu_allowed()
79 return mwifiex_is_station_ampdu_allowed(priv, ptr, tid); in mwifiex_is_ampdu_allowed()
[all …]
|
| H A D | 11n.c | 99 int tid; in mwifiex_ret_11n_delba() local
104 tid = del_ba_param_set >> DELBA_TID_POS; in mwifiex_ret_11n_delba()
106 mwifiex_del_ba_tbl(priv, tid, del_ba->peer_mac_addr, in mwifiex_ret_11n_delba()
112 mwifiex_send_addba(priv, tx_ba_tbl->tid, in mwifiex_ret_11n_delba()
121 mwifiex_create_ba_tbl(priv, del_ba->peer_mac_addr, tid, in mwifiex_ret_11n_delba()
127 mwifiex_del_ba_tbl(priv, tx_ba_tbl->tid, tx_ba_tbl->ra, in mwifiex_ret_11n_delba()
145 int tid, tid_down; in mwifiex_ret_11n_addba_req() local
154 tid = (block_ack_param_set & IEEE80211_ADDBA_PARAM_TID_MASK) in mwifiex_ret_11n_addba_req()
157 tid_down = mwifiex_wmm_downgrade_tid(priv, tid); in mwifiex_ret_11n_addba_req()
165 mwifiex_del_ba_tbl(priv, tid, add_ba_rsp->peer_mac_addr, in mwifiex_ret_11n_addba_req()
[all …]
|
| /openbmc/linux/fs/jfs/ |
| H A D | namei.c | 66 tid_t tid; /* transaction id */ in jfs_create() local
98 tid = txBegin(dip->i_sb, 0); in jfs_create()
103 rc = jfs_init_acl(tid, ip, dip); in jfs_create()
107 rc = jfs_init_security(tid, ip, dip, &dentry->d_name); in jfs_create()
109 txAbort(tid, 0); in jfs_create()
115 txAbort(tid, 0); in jfs_create()
119 tblk = tid_to_tblock(tid); in jfs_create()
130 xtInitRoot(tid, ip); in jfs_create()
137 if ((rc = dtInsert(tid, dip, &dname, &ino, &btstack))) { in jfs_create()
140 txAbort(tid, 1); /* Marks Filesystem dirty */ in jfs_create()
[all …]
|
| /openbmc/linux/tools/perf/dlfilters/ |
| H A D | dlfilter-show-cycles.c | 29 __s32 tid; member
47 static struct entry *find_entry(__s32 tid) in find_entry() argument
49 __u32 pos = tid & MASK; in find_entry()
54 if (e->tid == tid) in find_entry()
68 e->tid = tid; in find_entry()
72 static void add_entry(__s32 tid, int pos, __u64 cnt) in add_entry() argument
74 struct entry *e = find_entry(tid); in add_entry()
83 __s32 tid = sample->tid; in filter_event_early() local
93 else if (tid != -1) in filter_event_early()
94 add_entry(tid, pos, sample->cyc_cnt); in filter_event_early()
[all …]
|
| /openbmc/openbmc/poky/bitbake/lib/bb/ui/ |
| H A D | uihelper.py | 25 def removetid(pid, tid): argument
26 self.running_pids.remove(tid)
27 del self.running_tasks[tid]
28 if self.pidmap[pid] == tid:
33 tid = event._fn + ":" + event._task
35 …self.running_tasks[tid] = { 'title' : "mc:%s:%s %s" % (event._mc, event._package, event._task), 's…
37 …self.running_tasks[tid] = { 'title' : "%s %s" % (event._package, event._task), 'starttime' : time.…
38 self.running_pids.append(tid)
39 self.pidmap[event.pid] = tid
42 tid = event._fn + ":" + event._task
[all …]
|