Home
last modified time | relevance | path

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

12345678910>>...12

/titanic_50/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 …]
/titanic_50/usr/src/tools/onbld/Scm/
H A DWorkSpace.py81 def __init__(self, name, change): argument
82 self.name = name
83 self.change = intern(change)
85 assert change in (self.MODIFIED, self.ADDED, self.REMOVED)
87 self.parentname = None
89 self.renamed = False
90 self.comments = []
92 def __cmp__(self, other): argument
93 return cmp(self.name, other.name)
95 def is_added(self): argument
[all …]
H A DBackup.py95 def __init__(self, msg, name): argument
106 util.Abort.__init__(self, "%s: changeset '%s' is missing\n"
117 def __init__(self, *args, **kwargs): argument
118 tarfile.TarFile.__init__(self, *args, **kwargs)
119 self.errorlevel = 2
121 def members_match_fs(self, rootpath): argument
155 for elt in self:
161 def addfilectx(self, filectx, path=None): argument
205 self.addfile(t, data)
211 def __init__(self, backup, ws): argument
[all …]
/titanic_50/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.c275 ulwp_t *self = curthread; in trim_stack_cache() local
276 uberdata_t *udp = self->ul_uberdata; in trim_stack_cache()
281 ASSERT(udp->nthreads <= 1 || MUTEX_OWNED(&udp->link_lock, self)); in trim_stack_cache()
425 ulwp_t *self = curthread; in ulwp_alloc() local
426 uberdata_t *udp = self->ul_uberdata; in ulwp_alloc()
526 ulwp_t *self = curthread; in ulwp_broadcast() local
527 uberdata_t *udp = self->ul_uberdata; in ulwp_broadcast()
529 ASSERT(MUTEX_OWNED(ulwp_mutex(ulwp, udp), self)); in ulwp_broadcast()
540 ulwp_t *self = curthread; in find_lwp() local
541 uberdata_t *udp = self->ul_uberdata; in find_lwp()
[all …]
H A Dsigaction.c73 ulwp_t *self = curthread; in call_user_handler() local
74 uberdata_t *udp = self->ul_uberdata; in call_user_handler()
86 set_parking_flag(self, 0); in call_user_handler()
88 if (__td_event_report(self, TD_CATCHSIG, udp)) { in call_user_handler()
89 self->ul_td_evbuf.eventnum = TD_CATCHSIG; in call_user_handler()
90 self->ul_td_evbuf.eventdata = (void *)(intptr_t)sig; in call_user_handler()
115 if (self->ul_vfork || in call_user_handler()
147 if (self->ul_sigsuspend) { in call_user_handler()
148 ucp->uc_sigmask = self->ul_sigmask; in call_user_handler()
149 self->ul_sigsuspend = 0; in call_user_handler()
[all …]
H A Dsynch.c214 ulwp_t *self = curthread; in _ceil_mylist_del() local
218 for (mcpp = &self->ul_mxchain; in _ceil_mylist_del()
224 return (mcpp == &self->ul_mxchain); in _ceil_mylist_del()
237 ulwp_t *self = curthread; in _ceil_mylist_add() local
243 mcp->mxchain_next = self->ul_mxchain; in _ceil_mylist_add()
244 self->ul_mxchain = mcp; in _ceil_mylist_add()
252 set_rt_priority(ulwp_t *self, int prio) in set_rt_priority() argument
256 pcparm.pc_cid = self->ul_rtclassid; in set_rt_priority()
259 (void) priocntl(P_LWPID, self->ul_lwpid, PC_SETPARMS, &pcparm); in set_rt_priority()
269 ulwp_t *self = curthread; in _ceil_prio_inherit() local
[all …]
H A Dscalls.c153 ulwp_t *self = curthread; in forkx() local
154 uberdata_t *udp = self->ul_uberdata; in forkx()
157 if (self->ul_vfork) { in forkx()
171 self->ul_vfork = 0; in forkx()
176 sigoff(self); in forkx()
177 if (self->ul_fork) { in forkx()
181 sigon(self); in forkx()
185 self->ul_fork = 1; in forkx()
210 if (self->ul_siglink == NULL) in forkx()
224 block_all_signals(self); in forkx()
[all …]
H A Drwlock.c51 ulwp_t *self = curthread; in rwl_entry() local
57 ASSERT((self->ul_critical + self->ul_sigdefer) != 0); in rwl_entry()
59 if ((nlocks = self->ul_rdlockcnt) != 0) in rwl_entry()
60 readlockp = self->ul_readlock.array; in rwl_entry()
63 readlockp = &self->ul_readlock.single; in rwl_entry()
81 if ((nlocks = self->ul_rdlockcnt) == 0) { in rwl_entry()
86 self->ul_rdlockcnt = nlocks = NLOCKS; in rwl_entry()
91 *readlockp = self->ul_readlock.single; in rwl_entry()
92 self->ul_readlock.single.rd_count = 0; in rwl_entry()
93 self->ul_readlock.array = readlockp; in rwl_entry()
[all …]
H A Dsema.c86 ulwp_t *self = curthread; in sema_wait_impl() local
87 uberdata_t *udp = self->ul_uberdata; in sema_wait_impl()
101 self->ul_sp = stkptr(); in sema_wait_impl()
102 self->ul_wchan = lsp; in sema_wait_impl()
103 if (__td_event_report(self, TD_SLEEP, udp)) { in sema_wait_impl()
104 self->ul_td_evbuf.eventnum = TD_SLEEP; in sema_wait_impl()
105 self->ul_td_evbuf.eventdata = lsp; in sema_wait_impl()
118 set_parking_flag(self, 1); in sema_wait_impl()
119 if (self->ul_cursig != 0 || in sema_wait_impl()
120 (self->ul_cancelable && self->ul_cancel_pending)) in sema_wait_impl()
[all …]
H A Dassfail.c65 ulwp_t *self; in Abort() local
72 if ((self = __curthread()) != NULL) { in Abort()
73 panic_thread = self; in Abort()
74 lwpid = self->ul_lwpid; in Abort()
102 ulwp_t *self; in common_panic() local
105 if ((self = __curthread()) != NULL) in common_panic()
106 enter_critical(self); in common_panic()
178 ulwp_t *self; in lock_error() local
189 if ((self = __curthread()) != NULL) { in lock_error()
190 if (assert_thread == self) in lock_error()
[all …]
/titanic_50/usr/src/cmd/latencytop/common/
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 …]
/titanic_50/usr/src/cmd/perl/contrib/Sun/Solaris/Kstat/
H A DKstat.xs192 save_cpu_stat(HV *self, kstat_t *kp, int strip_str) in save_cpu_stat() argument
206 hv_store(self, "idle", 4, NEW_UV(sysinfop->cpu[CPU_IDLE]), 0); in save_cpu_stat()
207 hv_store(self, "user", 4, NEW_UV(sysinfop->cpu[CPU_USER]), 0); in save_cpu_stat()
208 hv_store(self, "kernel", 6, NEW_UV(sysinfop->cpu[CPU_KERNEL]), 0); in save_cpu_stat()
209 hv_store(self, "wait", 4, NEW_UV(sysinfop->cpu[CPU_WAIT]), 0); in save_cpu_stat()
210 hv_store(self, "wait_io", 7, NEW_UV(sysinfop->wait[W_IO]), 0); in save_cpu_stat()
211 hv_store(self, "wait_swap", 9, NEW_UV(sysinfop->wait[W_SWAP]), 0); in save_cpu_stat()
212 hv_store(self, "wait_pio", 8, NEW_UV(sysinfop->wait[W_PIO]), 0); in save_cpu_stat()
213 SAVE_UINT32(self, sysinfop, bread); in save_cpu_stat()
214 SAVE_UINT32(self, sysinfop, bwrite); in save_cpu_stat()
[all …]
/titanic_50/usr/src/test/test-runner/cmd/
H A Drun58 def __init__(self, filename, mode='a', encoding=None, delay=0, max_tries=5):
59 self.max_tries = max_tries
60 self.tries = 0
61 WatchedFileHandler.__init__(self, filename, mode, encoding, delay)
63 def emit(self, record):
66 WatchedFileHandler.emit(self, record)
67 self.tries = 0
70 if self.tries == self.max_tries:
72 self.stream.close()
73 self.stream = self._open()
[all …]
/titanic_50/usr/src/tools/scripts/
H A Dvalidate_pkg.py86 def __init__(self): argument
87 self.path = None
88 self.isdir = False
89 self.target = None
90 self.owner = None
91 self.group = None
92 self.mode = None
93 self.hardkey = None
94 self.hardpaths = set()
95 self.editable = False
[all …]
/titanic_50/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 …]
/titanic_50/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 …]
/titanic_50/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 …]
/titanic_50/usr/src/cmd/ssh/libssh/common/
H A Dnchan.c87 debug("channel %d: input %s -> %s", c->self, istates[c->istate], in chan_set_istate()
96 debug("channel %d: output %s -> %s", c->self, ostates[c->ostate], in chan_set_ostate()
108 debug("channel %d: rcvd oclose", c->self); in chan_rcvd_oclose1()
125 c->self, c->istate); in chan_rcvd_oclose1()
132 debug("channel %d: read failed", c->self); in chan_read_failed()
140 c->self, c->istate); in chan_read_failed()
147 debug("channel %d: ibuf empty", c->self); in chan_ibuf_empty()
150 c->self); in chan_ibuf_empty()
166 c->self, c->istate); in chan_ibuf_empty()
173 debug("channel %d: rcvd ieof", c->self); in chan_rcvd_ieof1()
[all …]
/titanic_50/usr/src/cmd/dtrace/test/tst/common/speculation/
H A Dtst.DataRecAftDiscard.d41 self->speculateFlag = 0;
42 self->discardFlag = 0;
43 self->spec = speculation();
47 /self->spec/
49 speculate(self->spec);
50 printf("Called speculate with id: %d\n", self->spec);
51 self->speculateFlag++;
55 /(self->spec) && (self->speculateFlag)/
57 discard(self->spec);
58 self->discardFlag++;
[all …]
H A Dtst.SpeculationCommit.d42 self->var = speculation();
43 printf("Speculation ID: %d\n", self->var);
44 self->speculate = 0;
45 self->commit = 0;
49 /1 > self->speculate/
51 speculate(self->var);
52 self->speculate++;
53 printf("Called speculate on id: %d\n", self->var);
57 /1 <= self->speculate/
59 commit(self->var);
[all …]
H A Dtst.SpeculationDiscard.d41 self->var = speculation();
42 printf("Speculation ID: %d\n", self->var);
43 self->speculate = 0;
44 self->discard = 0;
48 /1 > self->speculate/
50 speculate(self->var);
51 self->speculate++;
52 printf("Called speculate on id: %d\n", self->var);
56 /1 <= self->speculate/
58 discard(self->var);
[all …]
/titanic_50/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 …]

12345678910>>...12