def Timer(*args, **kwargs):
return _Timer(*args, **kwargs)
from direct.fsm import FSM import random, sys, os, math from direct.showbase import Audio3DManager from threading import Timer from direct.gui.OnscreenText import OnscreenText from direct.gui.DirectGui import * from pandac.PandaModules import FontPool
self.soundfsm.playLevelCompleted()
tim=Timer(3.0,self.gamefsm.request, args=["GameOver",self.level+1])
self.timerItems.append(tim)
tim.start()
if(self.x < self.score_from_normal):
tim=Timer(0.2,self.countScore, args=[0])
self.timerItems.append(tim)
tim.start()
else:
if(self.x < self.score_from_mayor):
tim=Timer(0.2,self.countScore, args=[1])
self.timerItems.append(tim)
tim.start()
else:
if(self.x < self.score_from_dorothy):
tim=Timer(0.2,self.countScore, args=[2])
else:
self.x=-50
tim=Timer(0.2,self.countScore, args=[3])
self.timerItems.append(tim)
tim.start()
if(type==3):
self.total_score=self.score_from_normal+self.score_from_mayor+self.score_from_dorothy
tx = OnscreenText(text=(codecs.utf_8_encode("Total Score:.........."+str(self.total_score))[0]), fg=(1,0.7,0.4,1), scale = 0.12, pos=(0,-0.5),font=font, shadow= (0,0,0,1))
self.textItems.append(tx)
tim=Timer(4,self.clearScreenfromText)
def win_or_lose(self):
self.soundfsm.request('Stop')
if self.isCompleted():
if(self.final_level):
tim=Timer(5,self.playFinalVideo, args=[0])
else:
tim=Timer(5,self.levelCompleted, args=[])
else:
tim=Timer(5,self.playFinalVideo, args=[1])
self.level+=1
else:
self.level=3
tim=Timer(10.0,self.gamefsm.request, args=["GameOver", self.level])
self.timerItems.append(tim)
tim.start()
if (self.world.owned_bars_weak % 3 ==2):
self.icon = OnscreenImage(image = 'icons/Mayor_Happy.jpg', pos = (-1.2,0,-0.8), scale=0.15)
self.world.iconItems.append(self.icon)
self.tim=Timer(2,self.icon.destroy)
self.tim.start()
self.world.timerItems.append(self.tim)
self.world.soundfsm.playYeah()
if (self.world.owned_bars_fresh % 3 ==2):
self.icon = OnscreenImage(image = 'icons/Mayor_Happy.jpg', pos = (-1.2,0,-0.8), scale=0.15)
self.world.iconItems.append(self.icon)
self.tim=Timer(2,self.icon.destroy)
self.tim.start()
self.world.timerItems.append(self.tim)
self.world.soundfsm.playYuhu()
self.world.textItems.append(self.tx)
t-=1
if(t >= 0):
tim=Timer(1.0,countdown, args=[t,p])
self.world.timerItems.append(tim)
tim.start()
else:
def enterExplode(self):
if(self.exploded==False):
self.house.pose("Break",5)
if (self.dorothy==True):
self.icon = OnscreenImage(image = 'icons/Dorothy_Sad.jpg', pos = (-1.2,0,-0.4), scale=0.15)
self.world.iconItems.append(self.icon)
self.tim=Timer(2,self.icon.destroy)
self.tim.start()
self.world.timerItems.append(self.tim)
self.world.soundfsm.playAhh()
elif (self.mayor==True):
self.icon = OnscreenImage(image = 'icons/Mayor_Sad.jpg', pos = (-1.2,0,-0.8), scale=0.15)
self.world.iconItems.append(self.icon)
self.tim=Timer(2,self.icon.destroy)
else:
self.icon = OnscreenImage(image = 'icons/Woody_Sad.jpg', pos = (-1.2,0,0), scale=0.15)
self.world.iconItems.append(self.icon)
self.tim=Timer(2,self.icon.destroy)
self.tim.start()
self.world.timerItems.append(self.tim)
self.world.soundfsm.playOh_no()
src/y/a/yac163-HEAD/trunk/yac163-nox/Pic.py yac163(Download)
import tempfile import urlparse import string from threading import Timer import thread import signal
sys.stdout.write("\r%3d%% %s" % (portion*100,"#"*int(portion*50)))
sys.stdout.flush()
read_buffer = ""
t = Timer(10,check,args=[read_buffer])
try:
t.start()
read_buffer = fh.read(buffer_size)
data+=read_buffer
portion = float(len(data))/total_size
read_buffer=""
t = Timer(10,check,args=[read_buffer])
try:
t.start()
read_buffer = fh.read(buffer_size)
src/y/a/yac163-HEAD/yac163-nox/Pic.py yac163(Download)
import tempfile import urlparse import string from threading import Timer import thread import signal
sys.stdout.write("\r%3d%% %s" % (portion*100,"#"*int(portion*50)))
sys.stdout.flush()
read_buffer = ""
t = Timer(10,check,args=[read_buffer])
try:
t.start()
read_buffer = fh.read(buffer_size)
data+=read_buffer
portion = float(len(data))/total_size
read_buffer=""
t = Timer(10,check,args=[read_buffer])
try:
t.start()
read_buffer = fh.read(buffer_size)
src/p/y/pytralog-HEAD/schedule.py pytralog(Download)
from gettext import gettext as _
from threading import Timer
from datetime import datetime, timedelta
from time import time, mktime
class Job(object):
def __init__(self, aggregator, offset=timedelta(), **kwargs):
dt = mktime((self.next_sched() + offset).timetuple()) - time()
if 'title' not in kwargs:
kwargs['title'] = self.title
self.timer = Timer(dt, aggregator.make_report, kwargs=kwargs)
src/k/n/kninja-HEAD/plugins/awaymessaging.py kninja(Download)
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
"""
from threading import Timer
from time import strftime
global pirc; pirc = None
if cid not in self.channels:
self.channels[cid] = {}
if cid not in self.timers:
self.timers[cid] = Timer(15.0, self.capture, kwargs={'connection':connection,'cid':cid})
self.timers[cid].start()
# log nick
n = event.source().split('!')[0].lower()
src/u/a/uaskitd-HEAD/askitd/libs/timing.py uaskitd(Download)
"""
try:
from threading import Timer
import servicemanager
win32event.SetEvent( event )
t = Timer( interval, timer, (event, interval, offset) ) # this thread will exit get ready for a new one
def timer_getdata( interval, offset, *config_data ):
try:
from threading import Timer
import thread
import servicemanager
import getdata
#win32event.SetEvent( event )
#print repr( config_data )
thread.start_new_thread( getdata.getData, config_data )
t = Timer( interval, timer_getdata, (interval,offset, config_data[0]) ) # this thread will exit get ready for a new one
src/t/i/tiafc-HEAD/TiafCsd/TiafCPyBs/tiafcpybs.bak.py tiafc(Download)
import json import time import datetime from threading import Timer from socket import error as socketError
def exit(self, exitPass):
if (exitPass == self.mainClass.exitPass):
self.log('tiafcpybs:90', 1, 'shutdown server ...')
Timer(1.0, self.mainClass.server.shutdown, [], {'sysExit': True, })
return True
return False
src/a/p/apycotbot-1.10.0/server.py apycotbot(Download)
from os.path import exists, join, normpath from subprocess import Popen from tempfile import TemporaryFile from threading import Thread, Lock, Timer from traceback import format_exc from datetime import datetime, timedelta
cmd = Popen(command, bufsize=0, stdout=outfile, stderr=errfile)
if self['max-time']:
max_time = (self['max-time'] + (self['max-reprieve'] or 60) * 1.25)
timer = Timer(max_time, os.killpg, [cmd.pid, signal.SIGKILL])
timer.start()
else:
timer = None
src/p/y/pyff-HEAD/src/FeedbackBase/Feedback.py pyff(Download)
import datetime import sys import cPickle as pickle from threading import Event, Timer import traceback import socket import json
self._shouldQuit = False
# Initialize with dummy values so we cann call safely .cancel
self._triggerResetTimer = Timer(0, None)
self._triggerResetTime = 0.01
self.udp_markers_enable = False
else:
self._pport.setData(data)
if reset:
self._triggerResetTimer = threading.Timer(self._triggerResetTime, self.send_parallel, (0x0, False))
self._triggerResetTimer.start()
src/z/a/zamboni-lib-HEAD/lib/python/logilab/common/proc.py zamboni-lib(Download)
import stat from resource import getrlimit, setrlimit, RLIMIT_CPU, RLIMIT_AS from signal import signal, SIGXCPU, SIGKILL, SIGUSR2, SIGUSR1 from threading import Timer, currentThread, Thread, Event from time import time from logilab.common.tree import Node
def _time_out(self):
if self._abort_try < self._reprieve:
self._abort_try += 1
os.killpg(os.getpid(), SIGUSR2)
if self._limit_set > 0:
self._timer = Timer(1, self._time_out)
self._timer.start()
if self._limit_set <= 0:
if self.max_time is not None:
self._old_usr2_hdlr = signal(SIGUSR2, self._hangle_sig_timeout)
self._timer = Timer(max(1, int(self.max_time) - self._elapse_time),
self._time_out)
self._start_time = int(time())
self._timer.start()
1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 Next