def reboot(self, id):
     """Reboot the instance."""
     dbaas = common.get_client()
     try:
         result = dbaas.management.reboot(id)
     except:
         print sys.exec_info()[1]

def getAll(IP=''):
    global myCursor, myConnection
    opType = "GET_ALL"
    allData = []
    count = 0
    retFlag = -1
    if not myCursor:
        startConnection()
    value = ''
    try:
        sqlSmt = "SELECT * FROM " + DBTABLE
        #msg(0, opType, "SQL: " + sqlSmt, IP)
        for row in myCursor.execute(sqlSmt):
            allData.append((row[0], row[1]))
            count = count + 1
        msg(0, opType, str(count) + " row(s) fetched", IP)
        if count == 0:
            retFlag = 1
        else:
            retFlag = 0
    except:
        retFlag = -1
        print sys.exec_info()
        msg(1, opType, "getting all key-value pairs failed!")
    return retFlag, count, allData

def server(listen_port):
    try:
        r.start_server(listen_port)
        stdin_thread = threading.Thread(target=stdin_listener, args=())
        stdin_thread.start()
        while True:
            # Server loop
            curr_time = time.time()
            for activity in activity_tracker:
                if curr_time - activity_tracker[activity] > 3600:
                    # Clean database of hosts with activity more than one hour ago.
                    with stdout_lock:
                        print("Remove host from database: {}".format(activity[0]))
                    database_remove_host(activity[0])
            try:
                message = r.receive_data()
                process_message(message)
            except queue.Empty:
                continue
            except:
                with stdout_lock:
                    print("Unexpected error:", sys.exec_info()[0])
    except KeyboardInterrupt:
        with stdout_lock:
            print("Goodbye!")
    except:
        with stdout_lock:
            print("Unexpected error:", sys.exec_info()[0])
    finally:
        r.close()
        os._exit(1)

def ANMIvrForOverdueServices_Exotel(mode=1, target=1):
    #mode = 1 Due
    #mode = 2 OverDue
    #mode = 3 Both
    if target == 1:
        benef_type = ANCBenef
    elif target == 2:
        benef_type = IMMBenef

    timezone = 'Asia/Kolkata'
    tz = pytz.timezone(timezone)
    today = utcnow_aware().replace(tzinfo=tz)
    date_then = today.replace(hour=12, minute=0, day=1, second=0).date()
    from sms.sender import SendVoiceCall

    #Voice call for ANC
    if mode == 1:
        benefs = benef_type.objects.filter(due_events__date=date_then).distinct()
    elif mode ==2:
        benefs = benef_type.objects.filter(odue_events__date=date_then).distinct()
    else:
        abenefs = benef_type.objects.filter(odue_events__date=date_then).distinct() & ANCBenef.objects.filter(due_events__date=date_then).distinct()
    anms = CareProvider.objects.filter(beneficiaries__in=benefs).distinct()
    
    callerid = ""
    app_url = settings.EXOTEL_APP_URL
    for anm in amns:
        try:
            connect_customer_to_app(customer_no=due_anms.notify_number, callerid=callerid, app_url=app_url)
        except:
            sys.exec_info()[0]

def receieData(s):
	data = ""
	try:
		data = s.recvfrom(65565)
	except timeout:
		data = ""
	except:
		print("an error occured")
		sys.exec_info()
	return data[0]

 def transfer(self, filename, servername, remotedir, userinfo):
     try:
         self.do_transfer(filename, servername, remotedir, userinfo)
         print("%s of %s successful" % (self.mode, filename))
     except:
         print("%s of %s has failed" % (self.mode, filename), end=" ")
         print(sys.exec_info()[0], sys.exec_info()[1])
     self.mutex.acquire()
     self.threads -= 1
     self.mutex.release()

 def sendSuccess(self, resp, command, data, prepend=None):
     logger.debug("SUCCESS! "+command+":"+data)
     #logger.debug("response: '%s'" % (resp,))
     if prepend:
         w = "%s:%s %s:%s\r\n" % (prepend, command, fencode(resp), data)
     else:
         w = "%s:%s:%s\r\n" % (command, fencode(resp), data)
     self.transport.write(w)
     self.commands[command][CONCURR] -= 1
     try:
         self.serviceQueue(command)
     except:
         print sys.exec_info()
     return resp

def ReadWebContent(UrlLink):

    try:

        ContentObj = urllib2.urlopen(UrlLink, timeout=120)

        WebContent = ContentObj.read()
    except:

        print 'Unable to open ' + UrlLink
        print sys.exec_info()
        WebContent = ''

    return WebContent

def convertvideo(video):
    if video is None:
        return "Kein Video im Upload gefunden"
    filename = video.videoupload
    print "Konvertiere Quelldatei: %s" + filename
    if filename is None:
        return "Video mit unbekanntem Dateinamen"
    sourcefile = "%s%s" % (settings.MEDIA_ROOT, filename)
    flvfilename = "%s.flv" % video.id
    thumbnailfilename = "%svideos/flv/%s.png" % (settings.MEDIA_ROOT, video.id)
    targetfile = "%svideos/flv/%s" % (settings.MEDIA_ROOT, flvfilename)
    ffmpeg = "ffmpeg -y -i %s -acodec mp3 -ar 22050 -ab 32 -f flv -s 320x240 %s" % (sourcefile, thumbnailfilename)
    grabimage = "ffmpeg -y -i %s -vframs 1 -ss 00:00:02 -an -vcodec png -f rawvideo -s 320x240 %s" % (sourcefile, thumbnailfilename)
    flvtool = "flvtool2 -U %s" % targetfile
    print ("Source: %s" % sourcefile)
    print ("Target: %s" % targetfile)
    print ("FFMPEG: %s" % ffmpeg)
    print ("FLVTOOL: %s" % flvtool)
    try:
        ffmpegresult = commands.getoutput(ffmpeg)
        print "-----------------FFMPEG------------------"
        print ffmpegresult
        # Check if file exists and is > 0 Bytes
        try:
            s = os.stat (targetfile)
            print s
            fsize = s.st_size
            if (fsize == 0):
                print "File is 0 Bytes gross"
                os.remove (targetfile)
                return ffmpegresult
            print "Dateigroesse ist %i" %fsize
        except:
            print sys.exec_info()
            print "File %s scheint nicht zu existieren" % targetfile
            return ffmpegresult
        flvresult = commands.getoutput(flvtool)
        print "--------------FLVTOOL----------------"
        print flvresult
        grab = commands.getoutput (grabimage)
        print "--------------GRAB IMAGE----------------"
        print grab
    except:
        print sys.exec_info()
        return sys.exec_info[1]
    video.flvfilename = flvfilename
    video.save()
    return None
            

def status_wifite(sWhat,sValue):
    if 'rab' in aToDisplay:
        del aToDisplay['rab']
    if sWhat=='Cracked':
        try:
            # sValue is the AP's ssid
            sKey=str(client.read('/cracked/from_reboot/'+sValue).value)
        except KeyError:
            print 'No key for AP "'+sValue+'"'
        except:
            print 'Unexpected error:',sys.exec_info()[0]
        else:
            lcd.backlight(ON)
            aToDisplay[sValue]=">"+sValue+':'+sKey+"\n"
            if 'wifite' in aToDisplay:
                del aToDisplay['wifite']
    elif sWhat == 'Attacking':
        aToDisplay['wifite']="Attacking:\n"+sValue+"\n"
    elif sWhat == 'Start cracking':
        aWStatus=string.split(str(client.read('/wifite/status').value),':')
        aToDisplay['wifite']="Cracking:\n"+sValue+"\n"+aWStatus[1]+"\n"
    else:
        # Wifite status
        aToDisplay['wifite']=sValue+"\n"
    return aToDisplay

	def write_raw(self):
		try:
			""" writes each condition in the rawFile in the following format
				Filename(line x):
					Condition: condition text
					Type: type of condition(IF,WHILE ...)
					#Branches: Number of branches in condition
					Multicond: 0 - not a part of a multiple condition
							   1 - a part of a multiple condition
					Expected: 0 - contition is EXPECTED to happend
							  1 - condition is UNEXPECTED to happend
							  2 - unknown expectation
					Branches:
							# : branch name - probability% (x times executed)
			"""
			for cond in self.execConditions :
				out = cond.to_string()
				self.rawFile.write(out)

			self.rawFile.write("\n\n---- Never Executed ----\n\n")
			for cond in self.neverConditions :
				out = cond.to_string()
				self.rawFile.write(out)
		except:
			print "Unexpected file writing error:",sys.exec_info()[0]
			raise

		try:
			self.rawFile.close()
		except:
			print "Error on closing file"
			raise

	def create_log_files(self):
		try:
			self.csvFile = open(self.csvFilename, 'w')
			self.rawFile = open(self.rawFilename, 'w')
		except:
			print "Unexpected file opening error:",sys.exec_info()[0]
			raise

def copy_lldbpy_file_to_lldb_pkg_dir( vDictArgs, vstrFrameworkPythonDir, vstrCfgBldDir ):
	dbg = utilsDebug.CDebugFnVerbose( "Python script copy_lldbpy_file_to_lldb_pkg_dir()" );
	bOk = True;
	bDbg = vDictArgs.has_key( "-d" );
	strMsg = "";
	
	strSrc = vstrCfgBldDir + "/lldb.py";
	strSrc = os.path.normcase( strSrc );
	strDst = vstrFrameworkPythonDir + "/__init__.py";
	strDst = os.path.normcase( strDst );
	
	if not os.path.exists( strSrc ):
		strMsg = strErrMsgLLDBPyFileNotNotFound % strSrc;
		return (bOk, strMsg);
	
	try:
		if bDbg:
			print(strMsgCopyLLDBPy % (strSrc, strDst));
		shutil.copyfile( strSrc, strDst );
	except IOError as e:
		bOk = False;
		strMsg = "I/O error( %d ): %s %s" % (e.errno, e.strerror, strErrMsgCpLldbpy);
		if e.errno == 2:
			strMsg += " Src:'%s' Dst:'%s'" % (strSrc, strDst);
	except:
		bOk = False;
		strMsg = strErrMsgUnexpected % sys.exec_info()[ 0 ];
	
	return (bOk, strMsg);

def ftp_down(oftp, fd_save, range_start, range_end, n_thread):
    ''' thread function: create ftp data connections, download FTP target with REST and RETR request '''

    try:
        fd_ftp = ftp_connect_login(oftp)

        fd_ftp.voidcmd('TYPE I')
        fd_ftp.sendcmd('REST %s' % range_start)
        fd_ftpdata = fd_ftp.transfercmd(
            'RETR %s' % oftp.ftp_path)  # ftp data fd

        offset = range_start
        while offset < range_end + 1:
            if offset > range_end + 1 - BUFFSIZE:
                content_block = fd_ftpdata.recv(range_end + 1 - offset)
            else:
                content_block = fd_ftpdata.recv(BUFFSIZE)
            global rlock_file
            with rlock_file:
                fd_save.seek(offset)
                fd_save.write(content_block)
                global size_down
                size_down += len(content_block)
                # print "Thread %d piece %d done: %d-%d" % (n_thread, i, offset,
                # offset+len(content_block)-1)
            offset += len(content_block)
        print "Thread %d all done: %d-%d" % (n_thread, range_start, range_end)

        fd_ftpdata.close()
        ftp_disconnect(fd_ftp)
        return 0
    except Exception as error:
        print error
        return traceback.format_exception(sys.exec_info())

def report_event_api(request):
    if not request.method == 'POST':
        return HttpResponse('{} Not Allowed'.format(request.method), status=405)
    
    print('Started view.')
    device = request.POST.get('device', '')
    event_type = request.POST.get('type', '')
    region_id = request.POST.get('region', None)
    event = models.FishingEvent(device=device, event_type=event_type, region_id=region_id, timestamp=now())
    # Optional stuff
    event.latitude = request.POST.get('latitude', None)
    event.longitude = request.POST.get('longitude', None)
    event.species = request.POST.get('species', None)
    event.size = request.POST.get('size', '')
    event.weight = request.POST.get('weight', '')
    event.notes = request.POST.get('notes', '')
    print('Built Event.')

    try:
        event.save()
    except Exception as ex:
        print(sys.exec_info())
        return HttpResponse('Data was missing or improperly formatted.', status=400)

    print('Saved Event.')

    return event_detail_api(request, event.pk)

 def processUpdatedData(self):
     del self.tv
     if self.source == "otr":
         complete = True
         for i in range(self.days):
             try:
                 if not self.is_complete(datadir + "/" + time.strftime("epg_%Y_%m_%d.csv",time.gmtime(time.time()+86400*i))):
                     complete = False
             except OSError: #FileNotFound
                 complete = False
         if not complete:
             self.tv = None
             self.bot.root.getServiceNamed('scheduler').callLater(30,self.processUpdatedData)
             self.bot.logger.info("tvdata is not loaded completely yet. TV-Plugin will be aviable as it's loading is done.")
         else:
             try:
                 self.tv = tv_otr(datadir, self.days, self.bot)
             except:
                 self.bot.logger.info(sys.exec_info())
     elif self.source == "xmltv":
         try:
             self.tv = tv_xmltv(self.xmltvfile)
             #reload data tomorrow
             self.bot.root.getServiceNamed('scheduler').callLater(86400, self.download_data)
         except IOError:
             self.logger.info("xmltv-file is not loaded completely yet. TV-Plugin will be aviable as it's loading is done.")
             #retry 30 seconds later
             self.bot.root.getServiceNamed('scheduler').callLater(30,self.processUpdatedData)

def copy_lldbpy_file_to_lldb_pkg_dir(
        vDictArgs,
        vstrFrameworkPythonDir,
        vstrCfgBldDir):
    dbg = utilsDebug.CDebugFnVerbose(
        "Python script copy_lldbpy_file_to_lldb_pkg_dir()")
    bOk = True
    bDbg = "-d" in vDictArgs
    strMsg = ""

    strSrc = os.path.join(vstrCfgBldDir, "lldb.py")
    strSrc = os.path.normcase(strSrc)
    strDst = os.path.join(vstrFrameworkPythonDir, "__init__.py")
    strDst = os.path.normcase(strDst)

    if not os.path.exists(strSrc):
        strMsg = strErrMsgLLDBPyFileNotNotFound % strSrc
        return (bOk, strMsg)

    try:
        if bDbg:
            print((strMsgCopyLLDBPy % (strSrc, strDst)))
        shutil.copyfile(strSrc, strDst)
    except IOError as e:
        bOk = False
        strMsg = "I/O error(%d): %s %s" % (e.errno,
                                           e.strerror, strErrMsgCpLldbpy)
        if e.errno == 2:
            strMsg += " Src:'%s' Dst:'%s'" % (strSrc, strDst)
    except:
        bOk = False
        strMsg = strErrMsgUnexpected % sys.exec_info()[0]

    return (bOk, strMsg)

def buildWget(in_file, out_file):

    try:
        ifile = open(in_file, 'r')
        ofile = open(out_file, 'w')

        comd = 'wget -P ./pdfs '
        comURL = 'http://gain.fas.usda.gov/Recent GAIN Publications/'

        ofile.write("#!/bin/bash" + os.linesep)

        for line in ifile:
            # a line is formatted: title \t date & time
            # split and just use the title
            nl1, nl2 = line.split('\t')

            ofile.write(comd + " \"" + comURL + nl1 + '.pdf\"' + os.linesep)


        ifile.close()
        ofile.close()
        return 0
    except:
        print "{}".format(sys.exec_info()[0])
        return 1

def main():
	try:
		filename = sys.argv
	except:
		print("Improper input") #don't think this line can be encountered
		sys.exit(0)
	try:
		f = open(filename[1], 'rb')
	except IndexError:
		print("No input was given")
		sys.exit(0)
	except IOError:
		print(filename[1] + " does not exist")
		sys.exit(0)
	except:
		print("Unknown Error", sys.exec_info()[0])
		sys.exit(0)
		
	
	counter = 0 #number of bytes read so far
	try:	
		line = f.read(16)
	except:
		print("No data could be read") #don't think this line can be encountered
	try:
		while(len(line) > 0):
			print(format(counter, 'x').zfill(8), end="  ") #print bytes read with at least 8 digits
		
			#iterate byte hex values
			for x in range (0,len(line)):	
				print(hex(line[x])[2:].zfill(2), end=" ")
				if (x == 7): #awkward space
					print(" ", end="")
				counter += 1 #increment amount of bytes readi
	
			#adjust spaces on last line
			if(len(line) < 16):
				for x in range (0, 16-len(line)):
					print("   ", end="")
				if(len(line) < 8): #awkward space
					print(" ", end="")
	
			print(" |", end="")

			for x in range (0,len(line)):
				if(line[x] > 31 and line[x] < 127): #print character if ascii
					print(chr(line[x]), end="")
				else:
					print(".", end="")	#print . if not ascii
			print("|")
	
			line = f.read(16)
		f.close
		print(format(counter, 'x').zfill(8)) #print total bytes
	except:
		print("Unknown error", sys.exc_info()[0])
		sys.exit(0)

def genCfg():
    # init a cfg obj
    try:
        cfg = ConfigParser.ConfigParser()
        cfg.read('../conf/crawler.ini')
        return cfg
    except Exception, e:

        print red(sys.exec_info())