Home
last modified time | relevance | path

Searched refs:self (Results 1 – 25 of 301) sorted by relevance

12345678910>>...13

/illumos-gate/usr/src/cmd/dtrace/demo/ip/
H A Dtcprst.d45 laddr[self->conn_id], lport[self->conn_id], \
46 faddr[self->conn_id], fport[self->conn_id], \
47 iss[self->conn_id], irs[self->conn_id], \
48 send_count[self->conn_id], recv_count[self->conn_id]))
56 probe_name[self->conn_id, i], \
57 conn_time[self->conn_id, i], \
58 send_recv[self->conn_id, i], \
59 seqno[self->conn_id, i], \
60 ack[self->conn_id, i], \
61 datalen[self->conn_id, i], \
[all …]
/illumos-gate/usr/src/lib/libc/port/threads/
H A Dcancel.c38 ulwp_t *self = curthread; in pthread_cancel() local
39 uberdata_t *udp = self->ul_uberdata; in pthread_cancel()
51 } else if (ulwp == self) { in pthread_cancel()
55 ulwp_unlock(self, udp); in pthread_cancel()
56 self->ul_nocancel = 0; /* cancellation is now possible */ in pthread_cancel()
57 if (self->ul_sigdefer == 0) in pthread_cancel()
60 self->ul_cancel_pending = 1; in pthread_cancel()
61 set_cancel_pending_flag(self, 0); in pthread_cancel()
94 ulwp_t *self = curthread; in pthread_setcancelstate() local
95 uberdata_t *udp = self->ul_uberdata; in pthread_setcancelstate()
[all …]
H A Dthr.c276 ulwp_t *self = curthread; in trim_stack_cache() local
277 uberdata_t *udp = self->ul_uberdata; in trim_stack_cache()
282 ASSERT(udp->nthreads <= 1 || MUTEX_OWNED(&udp->link_lock, self)); in trim_stack_cache()
426 ulwp_t *self = curthread; in ulwp_alloc() local
427 uberdata_t *udp = self->ul_uberdata; in ulwp_alloc()
527 ulwp_t *self = curthread; in ulwp_broadcast() local
528 uberdata_t *udp = self->ul_uberdata; in ulwp_broadcast()
530 ASSERT(MUTEX_OWNED(ulwp_mutex(ulwp, udp), self)); in ulwp_broadcast()
541 ulwp_t *self = curthread; in find_lwp() local
542 uberdata_t *udp = self->ul_uberdata; in find_lwp()
[all …]
H A Dsigaction.c77 ulwp_t *self = curthread; in call_user_handler() local
78 uberdata_t *udp = self->ul_uberdata; in call_user_handler()
90 set_parking_flag(self, 0); in call_user_handler()
92 if (__td_event_report(self, TD_CATCHSIG, udp)) { in call_user_handler()
93 self->ul_td_evbuf.eventnum = TD_CATCHSIG; in call_user_handler()
94 self->ul_td_evbuf.eventdata = (void *)(intptr_t)sig; in call_user_handler()
119 if (self->ul_vfork || in call_user_handler()
151 if (self->ul_sigsuspend) { in call_user_handler()
152 ucp->uc_sigmask = self->ul_sigmask; in call_user_handler()
153 self->ul_sigsuspend = 0; in call_user_handler()
[all …]
H A Dsynch.c216 ulwp_t *self = curthread; in _ceil_mylist_del() local
220 for (mcpp = &self->ul_mxchain; in _ceil_mylist_del()
226 return (mcpp == &self->ul_mxchain); in _ceil_mylist_del()
239 ulwp_t *self = curthread; in _ceil_mylist_add() local
245 mcp->mxchain_next = self->ul_mxchain; in _ceil_mylist_add()
246 self->ul_mxchain = mcp; in _ceil_mylist_add()
254 set_rt_priority(ulwp_t *self, int prio) in set_rt_priority() argument
258 pcparm.pc_cid = self->ul_rtclassid; in set_rt_priority()
261 (void) priocntl(P_LWPID, self->ul_lwpid, PC_SETPARMS, &pcparm); in set_rt_priority()
271 ulwp_t *self = curthread; in _ceil_prio_inherit() local
[all …]
H A Dscalls.c154 ulwp_t *self = curthread; in forkx() local
155 uberdata_t *udp = self->ul_uberdata; in forkx()
158 if (self->ul_vfork) { in forkx()
172 self->ul_vfork = 0; in forkx()
177 sigoff(self); in forkx()
178 if (self->ul_fork) { in forkx()
182 sigon(self); in forkx()
186 self->ul_fork = 1; in forkx()
211 if (self->ul_siglink == NULL) in forkx()
225 block_all_signals(self); in forkx()
[all …]
H A Drwlock.c53 ulwp_t *self = curthread; in rwl_entry() local
59 ASSERT((self->ul_critical + self->ul_sigdefer) != 0); in rwl_entry()
61 if ((nlocks = self->ul_rdlockcnt) != 0) in rwl_entry()
62 readlockp = self->ul_readlock.array; in rwl_entry()
65 readlockp = &self->ul_readlock.single; in rwl_entry()
83 if ((nlocks = self->ul_rdlockcnt) == 0) { in rwl_entry()
88 self->ul_rdlockcnt = nlocks = NLOCKS; in rwl_entry()
93 *readlockp = self->ul_readlock.single; in rwl_entry()
94 self->ul_readlock.single.rd_count = 0; in rwl_entry()
95 self->ul_readlock.array = readlockp; in rwl_entry()
[all …]
H A Dsema.c84 ulwp_t *self = curthread; in sema_wait_impl() local
85 uberdata_t *udp = self->ul_uberdata; in sema_wait_impl()
99 self->ul_sp = stkptr(); in sema_wait_impl()
100 self->ul_wchan = lsp; in sema_wait_impl()
101 if (__td_event_report(self, TD_SLEEP, udp)) { in sema_wait_impl()
102 self->ul_td_evbuf.eventnum = TD_SLEEP; in sema_wait_impl()
103 self->ul_td_evbuf.eventdata = lsp; in sema_wait_impl()
116 set_parking_flag(self, 1); in sema_wait_impl()
117 if (self->ul_cursig != 0 || in sema_wait_impl()
118 (self->ul_cancelable && self->ul_cancel_pending)) in sema_wait_impl()
[all …]
H A Dassfail.c70 ulwp_t *self; in Abort() local
74 if ((self = __curthread()) != NULL) { in Abort()
75 panic_thread = self; in Abort()
89 ulwp_t *self; in common_panic() local
92 if ((self = __curthread()) != NULL) in common_panic()
93 enter_critical(self); in common_panic()
165 ulwp_t *self; in lock_error() local
176 if ((self = __curthread()) != NULL) { in lock_error()
177 if (assert_thread == self) in lock_error()
179 enter_critical(self); in lock_error()
[all …]
/illumos-gate/usr/src/tools/onbld/Checks/
H A DComments_test.py47 def lookup(self, buglist): argument
48 return { bug: self.db[bug] for bug in buglist if bug in self.db }
52 def test_isBug(self): argument
53 self.assertTrue(Comments.isBug('10 this is a bug'))
54 self.assertTrue(Comments.isBug('12345 this is a bug'))
55 self.assertFalse(Comments.isBug('this is not a bug (no id)'))
56 self.assertFalse(Comments.isBug('10000000 this is too big to be a bug'))
58 def test_changeid_present(self): argument
59 self.assertTrue(Comments.changeid_present(
63 self.assertTrue(Comments.changeid_present(
[all …]
/illumos-gate/usr/src/test/test-runner/cmd/
H A Drun66 def __init__(self, filename, mode='a', encoding='utf-8', delay=0, max_tries=5):
67 self.max_tries = max_tries
68 self.tries = 0
69 WatchedFileHandler.__init__(self, filename, mode, encoding, delay)
71 def emit(self, record):
74 WatchedFileHandler.emit(self, record)
75 self.tries = 0
78 if self.tries == self.max_tries:
80 self.stream.close()
81 self.stream = self._open()
[all …]
/illumos-gate/usr/src/cmd/latencytop/
H A Dlatencytop.d78 self unsigned int lt_is_block_wakeable;
79 self unsigned long long lt_sleep_start;
80 self unsigned long long lt_sleep_duration;
81 self unsigned long long lt_sch_delay;
82 self unsigned int lt_counter; /* only used in low overhead */
83 self unsigned long long lt_timestamp; /* only used in low overhead */
84 self unsigned int lt_stackp;
85 self unsigned int lt_prio[int];
86 self string lt_cause[int];
98 self->lt_sleep_start = 0;
[all …]
/illumos-gate/usr/src/cmd/perl/contrib/Sun/Solaris/Kstat/
H A DKstat.xs181 save_cpu_stat(HV *self, kstat_t *kp, int strip_str) in save_cpu_stat() argument
195 hv_store(self, "idle", 4, NEW_UV(sysinfop->cpu[CPU_IDLE]), 0); in save_cpu_stat()
196 hv_store(self, "user", 4, NEW_UV(sysinfop->cpu[CPU_USER]), 0); in save_cpu_stat()
197 hv_store(self, "kernel", 6, NEW_UV(sysinfop->cpu[CPU_KERNEL]), 0); in save_cpu_stat()
198 hv_store(self, "wait", 4, NEW_UV(sysinfop->cpu[CPU_WAIT]), 0); in save_cpu_stat()
199 hv_store(self, "wait_io", 7, NEW_UV(sysinfop->wait[W_IO]), 0); in save_cpu_stat()
200 hv_store(self, "wait_swap", 9, NEW_UV(sysinfop->wait[W_SWAP]), 0); in save_cpu_stat()
201 hv_store(self, "wait_pio", 8, NEW_UV(sysinfop->wait[W_PIO]), 0); in save_cpu_stat()
202 SAVE_UINT32(self, sysinfop, bread); in save_cpu_stat()
203 SAVE_UINT32(self, sysinfop, bwrite); in save_cpu_stat()
[all …]
/illumos-gate/usr/src/tools/smatch/src/smatch_scripts/implicit_dependencies/
H A Dparser.py19 self, argument
26 self.impl_dep_file = file(impl_dep_file_str, 'r')
27 self.output_file = file(output_file_str + '.json', 'w+')
29 self.output_file_verbose = file(output_file_str + '_verbose.json', 'w+')
31 self.pretty_output_file = file(output_file_str + '.pretty', 'w+')
32 self.pretty_output_file_verbose = file(output_file_str + '_verbose.pretty', 'w+')
36 self.verbose = verbose
37 self.pretty = pretty
38 self.syscall_read_fields = defaultdict(set)
39 self.syscall_write_fields = defaultdict(set)
[all …]
/illumos-gate/usr/src/test/net-tests/tests/ipv6/
H A Ddup_bind.py69 def __init__(self, name: str, family: int, addr: SockAddr) -> None: argument
70 self.name = name
71 self.family = family
72 self.addr = addr
73 self.ifindex = None
75 def set_ifindex(self, ifindex: int) -> None: argument
77 self.ifindex = ifindex
79 def bind_ifindex(self) -> None: argument
82 if self.ifindex is not None:
83 print('bind to ifindex', self.ifindex)
[all …]
/illumos-gate/usr/src/tools/scripts/
H A Dvalidate_pkg.py87 def __init__(self): argument
88 self.path = None
89 self.isdir = False
90 self.target = None
91 self.owner = None
92 self.group = None
93 self.mode = None
94 self.hardkey = None
95 self.hardpaths = set()
96 self.editable = False
[all …]
/illumos-gate/usr/src/cmd/device_remap/
H A Ddevice_remap.pl48 my $self = {};
49 $self->{FILE} = undef;
50 $self->{MAJOR} = undef;
51 $self->{MINOR} = undef;
52 $self->{NODE_SEC_SZ} = undef;
53 $self->{NAME_SEC_SZ} = undef;
54 $self->{DATA_SEC_SZ} = undef;
55 $self->{NODES} = undef;
56 $self->{NAMES} = undef;
57 $self->{DATA} = undef;
[all …]
/illumos-gate/usr/src/lib/pyzfs/common/
H A Ddataset.py47 def __init__(self, t): argument
52 self.name = t[0]
53 self.number = t[1]
54 self.type = t[2]
55 if self.type == "string":
56 self.default = t[3]
58 self.default = t[4]
59 self.attr = t[5]
60 self.validtypes = t[6]
61 self.values = t[7]
[all …]
H A Dtable.py32 def __init__(self, fields, rjustfields=()): argument
34 self.fields = fields
35 self.rjustfields = rjustfields
36 self.maxfieldlen = dict.fromkeys(fields, 0)
37 self.lines = list()
39 def __updatemax(self, k, v): argument
40 self.maxfieldlen[k] = max(self.maxfieldlen.get(k, None), v)
42 def addline(self, sortkey, values): argument
46 for f in self.fields:
49 self.__updatemax(f, len(v))
[all …]
H A Dutil.py47 def default_repr(self): argument
49 if self.__slots__:
50 str = "<" + self.__class__.__name__
51 for v in self.__slots__:
52 str += " %s: %r" % (v, getattr(self, v))
56 (self.__class__.__name__, repr(self.__dict__))
68 def __init__(self, eno, task=None, why=None): argument
75 self.errno = eno
76 self.task = task
77 self.why = why
[all …]
/illumos-gate/usr/src/cmd/dtrace/demo/sched/
H A Dwhatfor.d33 self->sobj = curlwpsinfo->pr_stype;
34 self->bedtime = timestamp;
40 self->bedtime = timestamp;
44 /self->bedtime && !self->sobj/
46 @["preempted"] = quantize(timestamp - self->bedtime);
47 self->bedtime = 0;
51 /self->sobj/
53 @[self->sobj == SOBJ_MUTEX ? "kernel-level lock" :
54 self->sobj == SOBJ_RWLOCK ? "rwlock" :
55 self->sobj == SOBJ_CV ? "condition variable" :
[all …]
/illumos-gate/usr/src/cmd/perl/contrib/Sun/Solaris/Pg/
H A DPg.pm108 my $self = _init(@_);
114 for (; !$self && ($! == &Errno::EAGAIN) && $retry_count;
117 $self = _init(@_);
120 if ($self) {
121 bless($self, $class) if defined($class);
122 bless($self) unless defined($class);
125 return ($self);
144 my $self = shift;
146 return unless $self->{PGTREE};
158 my $self = shift;
[all …]
/illumos-gate/usr/src/uts/common/io/scsi/impl/
H A Dscsi_hba.c101 static int scsi_findchild(dev_info_t *self, char *name, char *addr,
214 dev_info_t *self,
221 dev_info_t *self,
228 dev_info_t *self,
239 dev_info_t *self,
245 dev_info_t *self,
257 dev_info_t *self,
261 dev_info_t *self,
267 dev_info_t *self,
274 dev_info_t *self,
[all …]
/illumos-gate/usr/src/test/smbsrv-tests/cmd/
H A Drun_smbtorture.py61 def __str__(self): argument
62 return self.name
64 def __len__(self): argument
65 return len(self.name)
72 def __init__(self, name): argument
73 self.name = name
74 self.result = TestResult.UNKNOWN
76 def __str__(self): argument
79 def run(self, rfd, wfd, timeout, cmd): argument
83 def finish(self, start, wfd): argument
[all …]
/illumos-gate/usr/src/lib/libc/sparc/threads/
H A Dmachdep.c95 _thrp_setup(ulwp_t *self) in _thrp_setup() argument
99 if (self->ul_fpuenv.fpu_en) in _thrp_setup()
100 _setfsr(&self->ul_fpuenv.fsr); in _thrp_setup()
102 self->ul_ustack.ss_sp = (void *)(self->ul_stktop - self->ul_stksiz); in _thrp_setup()
103 self->ul_ustack.ss_size = self->ul_stksiz; in _thrp_setup()
104 self->ul_ustack.ss_flags = 0; in _thrp_setup()
105 (void) setustack(&self->ul_ustack); in _thrp_setup()
107 update_sched(self); in _thrp_setup()
111 sigon(self); in _thrp_setup()
113 if (self->ul_cancel_pending == 2 && !self->ul_cancel_disabled) in _thrp_setup()
[all …]

12345678910>>...13