• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Python bsdsocket.read_packet函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Python中spyderlib.utils.bsdsocket.read_packet函数的典型用法代码示例。如果您正苦于以下问题:Python read_packet函数的具体用法?Python read_packet怎么用?Python read_packet使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。



在下文中一共展示了read_packet函数的11个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。

示例1: saveglobals

    def saveglobals(self):
        """Save globals() into filename"""
        ns = self.get_current_namespace()
        from spyderlib.utils.iofuncs import iofunctions

        settings = read_packet(self.i_request)
        filename = read_packet(self.i_request)
        more_excluded_names = ["In", "Out"] if self.ipython_shell else None
        data = get_remote_data(ns, settings, mode="picklable", more_excluded_names=more_excluded_names).copy()
        return iofunctions.save(data, filename)
开发者ID:ChunHungLiu,项目名称:spyder,代码行数:10,代码来源:monitor.py


示例2: setglobal

 def setglobal(self, name):
     """
     Set global reference value
     """
     ns = self.get_reference_namespace(name)
     ns[name] = read_packet(self.i_request)
     self.refresh_after_eval = True
开发者ID:ChunHungLiu,项目名称:spyder,代码行数:7,代码来源:monitor.py


示例3: set_remote_view_settings

 def set_remote_view_settings(self):
     """
     Set the namespace remote view settings
     (see the namespace browser widget)
     """
     self.remote_view_settings = read_packet(self.i_request)
     self.enable_refresh_after_eval()
开发者ID:ChunHungLiu,项目名称:spyder,代码行数:7,代码来源:monitor.py


示例4: loadglobals

 def loadglobals(self):
     """Load globals() from filename"""
     glbs = self.mglobals()
     from spyderlib.utils.iofuncs import iofunctions
     filename = read_packet(self.i_request)
     ext = read_packet(self.i_request)
     load_func = iofunctions.load_funcs[ext]
     data, error_message = load_func(filename)
     if error_message:
         return error_message
     for key in data.keys():
         new_key = fix_reference_name(key, blacklist=glbs.keys())
         if new_key != key:
             data[new_key] = data.pop(key)
     try:
         glbs.update(data)
     except Exception, error:
         return str(error)
开发者ID:jromang,项目名称:retina-old,代码行数:18,代码来源:monitor.py


示例5: run

 def run(self):
     """Start server"""
     sock = socket.socket(socket.AF_INET)
     sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
     sock.bind( ("127.0.0.1", self.port) )
     
     while True:
         sock.listen(2)
         conn, _addr = sock.accept()
         shell_id = read_packet(conn)
         if shell_id is not None:
             self.send_socket(shell_id, conn)
开发者ID:jromang,项目名称:retina-old,代码行数:12,代码来源:introspection.py


示例6: run

 def run(self):
     while True:
         try:
             conn, _addr = self.sock.accept()
         except socket.error as e:
             badfd = errno.WSAEBADF if os.name == 'nt' else errno.EBADF
             extra = errno.WSAENOTSOCK if os.name == 'nt' else badfd
             if e.args[0] in [errno.ECONNABORTED, badfd, extra]:
                 return
             # See Issue 1275 for details on why errno EINTR is
             # silently ignored here.
             eintr = errno.WSAEINTR if os.name == 'nt' else errno.EINTR
             if e.args[0] == eintr:
                 continue
             raise
         if not self._initialized:
             server_port = read_packet(conn)
             if isinstance(server_port, int):
                 self._initialized = True
                 self.initialized.emit(server_port)
         else:
             self.request_handled.emit(read_packet(conn))
开发者ID:AungWinnHtut,项目名称:spyder,代码行数:22,代码来源:plugin_client.py


示例7: run

 def run(self):
     """Start notification thread"""
     while True:
         if self.notify_socket is None:
             continue
         output = None
         try:
             try:
                 cdict = read_packet(self.notify_socket)
             except:
                 # This except statement is intended to handle a struct.error
                 # (but when writing 'except struct.error', it doesn't work)
                 # Note: struct.error is raised when the communication has 
                 # been interrupted and the received data is not a string 
                 # of length 8 as required by struct.unpack (see read_packet)
                 break
             if cdict is None:
                 # Another notification thread has just terminated and 
                 # then wrote 'None' in the notification socket
                 # (see the 'finally' statement below)
                 continue
             if not isinstance(cdict, dict):
                 raise TypeError("Invalid data type: %r" % cdict)
             command = cdict['command']
             data = cdict.get('data')
             if command == 'pdb_step':
                 fname, lineno = data
                 self.emit(SIGNAL('pdb(QString,int)'), fname, lineno)
                 self.emit(SIGNAL('refresh_namespace_browser()'))
             elif command == 'refresh':
                 self.emit(SIGNAL('refresh_namespace_browser()'))
             elif command == 'remote_view':
                 self.sig_process_remote_view.emit(data)
             elif command == 'ipykernel':
                 self.emit(SIGNAL('new_ipython_kernel(QString)'), data)
             elif command == 'open_file':
                 fname, lineno = data
                 self.emit(SIGNAL('open_file(QString,int)'), fname, lineno)
             else:
                 raise RuntimeError('Unsupported command: %r' % command)
             if DEBUG_INTROSPECTION:
                 logging.debug("received command: %r" % command)
         except:
             log_last_error(LOG_FILENAME, "notification thread")
         finally:
             try:
                 write_packet(self.notify_socket, output)
             except:
                 # The only reason why it should fail is that Spyder is 
                 # closing while this thread is still alive
                 break
开发者ID:arvindchari88,项目名称:newGitTest,代码行数:51,代码来源:introspection.py


示例8: listen

 def listen(self):
     """Listen for requests"""
     while True:
         try:
             conn, _addr = self._server_sock.accept()
         except socket.error as e:
             badfd = errno.WSAEBADF if os.name == 'nt' else errno.EBADF
             extra = errno.WSAENOTSOCK if os.name == 'nt' else badfd
             if e.args[0] in [errno.ECONNABORTED, badfd, extra]:
                 return
             # See Issue 1275 for details on why errno EINTR is
             # silently ignored here.
             eintr = errno.WSAEINTR if os.name == 'nt' else errno.EINTR
             if e.args[0] == eintr:
                 continue
             raise
         self.queue.put(read_packet(conn))
开发者ID:AungWinnHtut,项目名称:spyder,代码行数:17,代码来源:plugin_server.py


示例9: run

    def run(self):
        self.ipython_shell = None
        while True:
            output = pickle.dumps(None, PICKLE_HIGHEST_PROTOCOL)
            glbs = self.mglobals()
            try:
                if DEBUG_MONITOR:
                    logging.debug("****** Introspection request /Begin ******")
                command = PACKET_NOT_RECEIVED
                try:
                    timeout = self.timeout if self.auto_refresh else None
                    command = read_packet(self.i_request, timeout=timeout)
                    if command is None:
                        continue
                    timed_out = False
                except socket.timeout:
                    timed_out = True
                except struct.error:
                    # This should mean that Spyder GUI has crashed
                    if DEBUG_MONITOR:
                        logging.debug("struct.error -> quitting monitor")
                    break
                if timed_out:
                    if DEBUG_MONITOR:
                        logging.debug("connection timed out -> updating remote view")
                    self.update_remote_view()
                    if DEBUG_MONITOR:
                        logging.debug("****** Introspection request /End ******")
                    continue
                if DEBUG_MONITOR:
                    logging.debug("command: %r" % command)
                lcls = self.mlocals()
                result = eval(command, glbs, lcls)
                if DEBUG_MONITOR:
                    logging.debug(" result: %r" % result)
                if self.pdb_obj is None:
                    lcls["_"] = result
                # old com implementation: (see solution (1) in Issue 434)
                output = pickle.dumps(result, PICKLE_HIGHEST_PROTOCOL)
            #                # new com implementation: (see solution (2) in Issue 434)
            #                output = pickle.dumps((command, result),
            #                                      PICKLE_HIGHEST_PROTOCOL)
            except SystemExit:
                break
            except:
                if DEBUG_MONITOR:
                    logging.debug("error!")
                log_last_error(LOG_FILENAME, command)
            finally:
                try:
                    if DEBUG_MONITOR:
                        logging.debug("updating remote view")
                    if self.refresh_after_eval:
                        self.update_remote_view()
                        self.refresh_after_eval = False
                    if DEBUG_MONITOR:
                        logging.debug("sending result")
                        logging.debug("****** Introspection request /End ******")
                    if command is not PACKET_NOT_RECEIVED:
                        if write_packet is None:
                            # This may happen during interpreter shutdown
                            break
                        else:
                            write_packet(self.i_request, output, already_pickled=True)
                except AttributeError as error:
                    if "'NoneType' object has no attribute" in str(error):
                        # This may happen during interpreter shutdown
                        break
                    else:
                        raise
                except TypeError as error:
                    if "'NoneType' object is not subscriptable" in str(error):
                        # This may happen during interpreter shutdown
                        break
                    else:
                        raise

        self.i_request.close()
        self.n_request.close()
开发者ID:ChunHungLiu,项目名称:spyder,代码行数:79,代码来源:monitor.py


示例10: setenv

 def setenv(self):
     """Set os.environ"""
     env = read_packet(self.i_request)
     os.environ = env
开发者ID:ChunHungLiu,项目名称:spyder,代码行数:4,代码来源:monitor.py


示例11: run

    def run(self):
        #print('run')
        """Start notification thread"""
        while True:
            #print('SBNWNotificationThread while True')

            # add layout signal if it doesn't already exist
            #if not hasattr(self, 'layout'):

            if self.notify_socket is None:
                continue
            output = None
            try:
                try:
                    cdict = read_packet(self.notify_socket)
                except:
                    # This except statement is intended to handle a struct.error
                    # (but when writing 'except struct.error', it doesn't work)
                    # Note: struct.error is raised when the communication has
                    # been interrupted and the received data is not a string
                    # of length 8 as required by struct.unpack (see read_packet)
                    break
                if cdict is None:
                    # Another notification thread has just terminated and
                    # then wrote 'None' in the notification socket
                    # (see the 'finally' statement below)
                    continue
                if not isinstance(cdict, dict):
                    raise TypeError("Invalid data type: %r" % cdict)
                command = cdict['command']
                data = cdict.get('data')
                if command == 'pdb_step':
                    fname, lineno = data
                    self.sig_pdb.emit(fname, lineno)
                    self.refresh_namespace_browser.emit()
                elif command == 'refresh':
                    self.refresh_namespace_browser.emit()
                elif command == 'remote_view':
                    self.sig_process_remote_view.emit(data)
                elif command == 'ipykernel':
                    self.new_ipython_kernel.emit(data)
                elif command == 'open_file':
                    fname, lineno = data
                    self.open_file.emit(fname, lineno)
                elif command == 'layout':
                    print('SBNWNotificationThread layout')
                    sbml = data
                    if sbml != '~::empty::~':
                      print('SBNWNotificationThread emit layout signal')
                      self.layout.emit(sbml)
                    else:
                      print('SBNWNotificationThread get sbml')
                      if hasattr(self, 'network_viewer_sbml_hook'):
                        output = self.network_viewer_sbml_hook()
                        print('output = {}'.format(output))
                      else:
                        print('no attr network_viewer_sbml_hook')
                else:
                    raise RuntimeError('Unsupported command: %r' % command)
                if DEBUG_INTROSPECTION:
                    logging.debug("received command: %r" % command)
            except:
                log_last_error(LOG_FILENAME, "notification thread")
            finally:
                try:
                    write_packet(self.notify_socket, output)
                except:
                    # The only reason why it should fail is that Spyder is
                    # closing while this thread is still alive
                    break
开发者ID:hsauro,项目名称:sbnw,代码行数:70,代码来源:p_pyfab.py



注:本文中的spyderlib.utils.bsdsocket.read_packet函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Python debug.log_last_error函数代码示例发布时间:2022-05-27
下一篇:
Python bsdsocket.communicate函数代码示例发布时间:2022-05-27
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap