| /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 | platform_manager.cpp | 19 for (auto& [tid, terminus] : termini) in initTerminus()
32 co_await getFRURecordTableMetadata(tid, &totalTableRecords); in initTerminus()
36 "Failed to get FRU Metadata for terminus {TID}, error {ERROR}", in initTerminus()
37 "TID", tid, "ERROR", rc); in initTerminus()
50 co_await getFRURecordTables(tid, totalTableRecords, fruData); in initTerminus()
54 "Failed to get Fru Record table for terminus {TID}, error {ERROR}", in initTerminus()
55 "TID", tid, "ERROR", rc); in initTerminus()
65 "Failed to fetch PDRs for terminus with TID: {TID}, error: {ERROR}", in initTerminus()
66 "TID", tid, "ERROR", rc); in initTerminus()
79 updateInventoryWithFru(tid, fruData.data(), fruData.size()); in initTerminus()
[all …]
|
| 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 roundRobinSensorItMap[tid] = 0; in startPolling()
39 updateAvailableState(tid, true); in startPolling()
41 sensorPollTimers[tid] in startPolling()
58 startSensorPollTimer(pldm_tid_t tid) startSensorPollTimer() argument
79 disableTerminusSensors(pldm_tid_t tid) disableTerminusSensors() argument
95 stopPolling(pldm_tid_t tid) stopPolling() argument
116 doSensorPolling(pldm_tid_t tid) doSensorPolling() argument
167 doSensorPollingTask(pldm_tid_t tid) doSensorPollingTask() argument
281 auto tid = sensor->tid; getSensorReading() local
[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 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
135 auto tid = toTid(mctpInfo); updateMctpEndpointAvailability() local
207 auto tid = toTid(mctpInfo); discoverMctpTerminusTask() local
252 pldm_tid_t tid = 0; initMctpTerminus() local
443 getTidOverMctp(mctp_eid_t eid,pldm_tid_t * tid) getTidOverMctp() argument
489 setTidOverMctp(mctp_eid_t eid,pldm_tid_t tid) setTidOverMctp() argument
526 getPLDMTypes(pldm_tid_t tid,uint64_t & supportedTypes) getPLDMTypes() argument
574 getPLDMCommands(pldm_tid_t tid,uint8_t type,ver32_t version,bitfield8_t * supportedCmds) getPLDMCommands() argument
624 sendRecvPldmMsg(pldm_tid_t tid,Request & request,const pldm_msg ** responseMsg,size_t * responseLen) sendRecvPldmMsg() argument
684 getPLDMVersion(pldm_tid_t tid,uint8_t type,ver32_t * version) getPLDMVersion() argument
[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} with return code {RC}.", 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} sensorI in handlePlatformEvent()
109 processNumericSensorEvent(pldm_tid_t tid,uint16_t sensorId,const uint8_t * sensorData,size_t sensorDataLength) processNumericSensorEvent() argument
350 processCperEvent(pldm_tid_t tid,uint16_t eventId,const uint8_t * eventData,const size_t eventDataSize) processCperEvent() argument
521 callPolledEventHandlers(pldm_tid_t tid,uint8_t eventClass,uint16_t eventId,std::vector<uint8_t> & eventMessage) callPolledEventHandlers() argument
549 pollForPlatformEventTask(pldm_tid_t tid,uint32_t pollDataTransferHandle) pollForPlatformEventTask() argument
653 pollForPlatformEventMessage(pldm_tid_t tid,uint8_t formatVersion,uint8_t transferOperationFlag,uint32_t dataTransferHandle,uint16_t eventIdToAcknowledge,uint8_t & completionCode,uint8_t & eventTid,uint16_t & eventId,uint32_t & nextDataTransferHandle,uint8_t & transferFlag,uint8_t & eventClass,uint32_t & eventDataSize,uint8_t * & eventData,uint32_t & eventDataIntegrityChecksum) pollForPlatformEventMessage() argument
[all...] |
| H A D | terminus_manager.hpp | 31 /** @brief Size of TID Pool in pldmd */
79 /** @brief Send request PLDM message to tid. The function will return when
84 * @param[in] tid - Destination TID
90 exec::task<int> sendRecvPldmMsg(pldm_tid_t tid, Request& request,
107 /** @brief member functions to map/unmap tid
109 std::optional<MctpInfo> toMctpInfo(const pldm_tid_t& tid);
111 /** @brief Member functions to response the TID of specific MCTP interface
115 * @return tid - Terminus tid
[all...] |
| H A D | manager.hpp | 19 using PollHandler = std::function<exec::task<int>(pldm_tid_t tid)>;
88 /* Get TID of initialized terminus */ in updateMctpEndpointAvailability()
89 auto tid = terminusManager.toTid(mctpInfo); in updateMctpEndpointAvailability() local
90 if (tid) in updateMctpEndpointAvailability()
94 sensorManager.startSensorPollTimer(tid.value()); in updateMctpEndpointAvailability()
98 sensorManager.disableTerminusSensors(tid.value()); in updateMctpEndpointAvailability()
100 updateAvailableState(tid.value(), availability); in updateMctpEndpointAvailability()
105 /** @brief Helper function to start sensor polling of the terminus TID
107 void startSensorPolling(pldm_tid_t tid) in startSensorPolling() argument
109 sensorManager.startPolling(tid); in startSensorPolling()
117 updateAvailableState(pldm_tid_t tid,Availability state) updateAvailableState() argument
128 stopSensorPolling(pldm_tid_t tid) stopSensorPolling() argument
144 handleSensorEvent(const pldm_msg * request,size_t payloadLength,uint8_t,uint8_t tid,size_t eventDataOffset) handleSensorEvent() argument
167 handleCperEvent(const pldm_msg * request,size_t payloadLength,uint8_t,uint8_t tid,size_t eventDataOffset) handleCperEvent() argument
191 handlePldmMessagePollEvent(const pldm_msg * request,size_t payloadLength,uint8_t,uint8_t tid,size_t eventDataOffset) handlePldmMessagePollEvent() argument
221 handlePolledCperEvent(pldm_tid_t tid,uint16_t eventId,const uint8_t * eventData,size_t eventDataSize) handlePolledCperEvent() argument
[all...] |
| H A D | platform_manager.hpp | 46 * @param[in] tid - Destination TID
49 exec::task<int> configEventReceiver(pldm_tid_t tid);
61 * @param[in] tid - Destination TID
76 const pldm_tid_t tid, const uint32_t recordHndl,
85 * @param[in] tid - Destination TID
94 const pldm_tid_t tid, uint8_t& repositoryState, uint32_t& recordCount,
99 * @param[in] tid
[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, Availabilit argument
92 getAvailableState(pldm_tid_t tid) getAvailableState() argument
[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/pldm/oem/ampere/event/ |
| H A D | oem_event_manager.hpp | 255 * @param[in] tid - TID
261 uint8_t /* formatVersion */, pldm_tid_t tid,
266 * @param[in] tid - terminus ID
273 int processOemMsgPollEvent(pldm_tid_t tid, uint16_t eventId,
281 * @param[in] tid - TID
288 uint8_t /* formatVersion */, pldm_tid_t tid, size_t eventDataOffset);
292 * @param[in] tid - the destination TID
[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/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 …]
|