开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
TransporterCallback.hpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：8k
源码类别：

MySQL数据库

开发平台：

Visual C++

TransporterCallback.hpp：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. //**************************************************************************** 
  18. // 
  19. //  AUTHOR 
  20. //      舠a Fransson 
  21. // 
  22. //  NAME 
  23. //      TransporterCallback 
  24. // 
  25. // 
  26. //***************************************************************************/ 
  27. #ifndef TRANSPORTER_CALLBACK_H 
  28. #define TRANSPORTER_CALLBACK_H 
  29.  
  30. #include <kernel_types.h> 
  31. #include "TransporterDefinitions.hpp" 
  32.  
  33.  
  34. /** 
  35.  * Call back functions 
  36.  */ 
  37.  
  38. /** 
  39.  * The execute function 
  40.  */ 
  41. void
  42. execute(void * callbackObj, 
  43. SignalHeader * const header,  
  44. Uint8 prio,  
  45. Uint32 * const signalData,
  46. LinearSectionPtr ptr[3]);
  48. /** 
  49.  * A function to avoid job buffer overflow in NDB kernel, empty in API 
  50.  * Non-zero return means we executed signals. This is necessary information 
  51.  * to the transporter to ensure that it properly uses the transporter after 
  52.  * coming back again. 
  53.  */ 
  54. int
  55. checkJobBuffer(); 
  57. /** 
  58.  * Report send length 
  59.  */ 
  60. void 
  61. reportSendLen(void * callbackObj,
  62.       NodeId nodeId, Uint32 count, Uint64 bytes); 
  63.  
  64. /** 
  65.  * Report average receive length 
  66.  */ 
  67. void 
  68. reportReceiveLen(void * callbackObj, 
  69.  NodeId nodeId, Uint32 count, Uint64 bytes); 
  70.  
  71. /** 
  72.  * Report connection established 
  73.  */ 
  74. void 
  75. reportConnect(void * callbackObj, NodeId nodeId); 
  76.  
  77. /** 
  78.  * Report connection broken 
  79.  */ 
  80.  
  81. void 
  82. reportDisconnect(void * callbackObj,
  83.  NodeId nodeId, Uint32 errNo); 
  84.  
  85. enum TransporterError { 
  86.   TE_NO_ERROR = 0,
  87.   /** 
  88.    * TE_ERROR_CLOSING_SOCKET 
  89.    * 
  90.    *   Error found during closing of socket 
  91.    * 
  92.    * Recommended behavior: Ignore 
  93.    */ 
  94.   TE_ERROR_CLOSING_SOCKET = 0x1, 
  95.  
  96.   /** 
  97.    * TE_ERROR_IN_SELECT_BEFORE_ACCEPT 
  98.    * 
  99.    *   Error found during accept (just before) 
  100.    *     The transporter will retry. 
  101.    * 
  102.    * Recommended behavior: Ignore  
  103.    *   (or possible do setPerformState(PerformDisconnect) 
  104.    */ 
  105.   TE_ERROR_IN_SELECT_BEFORE_ACCEPT = 0x2, 
  106.  
  107.   /** 
  108.    * TE_INVALID_MESSAGE_LENGTH 
  109.    * 
  110.    *   Error found in message (message length) 
  111.    * 
  112.    * Recommended behavior: setPerformState(PerformDisconnect) 
  113.    */ 
  114.   TE_INVALID_MESSAGE_LENGTH = 0x8003, 
  115.    
  116.   /** 
  117.    * TE_INVALID_CHECKSUM 
  118.    * 
  119.    *   Error found in message (checksum) 
  120.    * 
  121.    * Recommended behavior: setPerformState(PerformDisonnect) 
  122.    */ 
  123.   TE_INVALID_CHECKSUM = 0x8004, 
  124.  
  125.   /** 
  126.    * TE_COULD_NOT_CREATE_SOCKET 
  127.    * 
  128.    *   Error found while creating socket 
  129.    * 
  130.    * Recommended behavior: setPerformState(PerformDisonnect) 
  131.    */ 
  132.   TE_COULD_NOT_CREATE_SOCKET = 0x8005, 
  133.  
  134.   /** 
  135.    * TE_COULD_NOT_BIND_SOCKET 
  136.    * 
  137.    *   Error found while binding server socket 
  138.    * 
  139.    * Recommended behavior: setPerformState(PerformDisonnect) 
  140.    */ 
  141.   TE_COULD_NOT_BIND_SOCKET = 0x8006, 
  142.  
  143.   /** 
  144.    * TE_LISTEN_FAILED 
  145.    * 
  146.    *   Error found while listening to server socket 
  147.    * 
  148.    * Recommended behavior: setPerformState(PerformDisonnect) 
  149.    */ 
  150.   TE_LISTEN_FAILED = 0x8007, 
  151.  
  152.   /** 
  153.    * TE_ACCEPT_RETURN_ERROR 
  154.    * 
  155.    *   Error found during accept 
  156.    *     The transporter will retry. 
  157.    * 
  158.    * Recommended behavior: Ignore  
  159.    *   (or possible do setPerformState(PerformDisconnect) 
  160.    */ 
  161.   TE_ACCEPT_RETURN_ERROR = 0x8008 
  162.  
  163.   /** 
  164.    * TE_SHM_DISCONNECT  
  165.    * 
  166.    *    The remote node has disconnected 
  167.    * 
  168.    * Recommended behavior: setPerformState(PerformDisonnect) 
  169.    */ 
  170.   ,TE_SHM_DISCONNECT = 0x800b 
  171.  
  172.   /** 
  173.    * TE_SHM_IPC_STAT 
  174.    * 
  175.    *    Unable to check shm segment 
  176.    *      probably because remote node 
  177.    *      has disconnected and removed it 
  178.    * 
  179.    * Recommended behavior: setPerformState(PerformDisonnect) 
  180.    */ 
  181.   ,TE_SHM_IPC_STAT = 0x800c 
  182.  
  183.   /** 
  184.    * TE_SHM_UNABLE_TO_CREATE_SEGMENT 
  185.    * 
  186.    *    Unable to create shm segment 
  187.    *      probably os something error 
  188.    * 
  189.    * Recommended behavior: setPerformState(PerformDisonnect) 
  190.    */ 
  191.   ,TE_SHM_UNABLE_TO_CREATE_SEGMENT = 0x800d 
  192.  
  193.   /** 
  194.    * TE_SHM_UNABLE_TO_ATTACH_SEGMENT 
  195.    * 
  196.    *    Unable to attach shm segment 
  197.    *      probably invalid group / user 
  198.    * 
  199.    * Recommended behavior: setPerformState(PerformDisonnect) 
  200.    */ 
  201.   ,TE_SHM_UNABLE_TO_ATTACH_SEGMENT = 0x800e 
  202.  
  203.   /** 
  204.    * TE_SHM_UNABLE_TO_REMOVE_SEGMENT 
  205.    * 
  206.    *    Unable to remove shm segment 
  207.    * 
  208.    * Recommended behavior: Ignore (not much to do) 
  209.    *                       Print warning to logfile 
  210.    */ 
  211.   ,TE_SHM_UNABLE_TO_REMOVE_SEGMENT = 0x800f 
  212.  
  213.   ,TE_TOO_SMALL_SIGID = 0x0010 
  214.   ,TE_TOO_LARGE_SIGID = 0x0011 
  215.   ,TE_WAIT_STACK_FULL = 0x8012 
  216.   ,TE_RECEIVE_BUFFER_FULL = 0x8013 
  217.  
  218.   /** 
  219.    * TE_SIGNAL_LOST_SEND_BUFFER_FULL 
  220.    * 
  221.    *   Send buffer is full, and trying to force send fails 
  222.    *   a signal is dropped!! very bad very bad 
  223.    * 
  224.    */ 
  225.   ,TE_SIGNAL_LOST_SEND_BUFFER_FULL = 0x8014 
  226.  
  227.   /** 
  228.    * TE_SIGNAL_LOST 
  229.    * 
  230.    *   Send failed for unknown reason 
  231.    *   a signal is dropped!! very bad very bad 
  232.    * 
  233.    */ 
  234.   ,TE_SIGNAL_LOST = 0x8015 
  235.  
  236.   /** 
  237.    * TE_SEND_BUFFER_FULL 
  238.    *  
  239.    *   The send buffer was full, but sleeping for a while solved it 
  240.    */ 
  241.   ,TE_SEND_BUFFER_FULL = 0x0016 
  242.  
  243.   /** 
  244.    * TE_SCI_UNABLE_TO_CLOSE_CHANNEL 
  245.    *  
  246.    *  Unable to close the sci channel and the resources allocated by  
  247.    *  the sisci api. 
  248.    */ 
  249.   ,TE_SCI_UNABLE_TO_CLOSE_CHANNEL = 0x8016 
  250.  
  251.   /** 
  252.    * TE_SCI_LINK_ERROR 
  253.    *  
  254.    *  There is no link from this node to the switch.  
  255.    *  No point in continuing. Must check the connections. 
  256.    * Recommended behavior: setPerformState(PerformDisonnect) 
  257.    */ 
  258.   ,TE_SCI_LINK_ERROR = 0x8017 
  259.  
  260.   /** 
  261.    * TE_SCI_UNABLE_TO_START_SEQUENCE 
  262.    *  
  263.    *  Could not start a sequence, because system resources  
  264.    *  are exumed or no sequence has been created. 
  265.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  266.    */ 
  267.   ,TE_SCI_UNABLE_TO_START_SEQUENCE = 0x8018 
  268.    
  269.   /** 
  270.    * TE_SCI_UNABLE_TO_REMOVE_SEQUENCE 
  271.    *  
  272.    *  Could not remove a sequence 
  273.    */ 
  274.   ,TE_SCI_UNABLE_TO_REMOVE_SEQUENCE = 0x8019 
  275.  
  276.   /** 
  277.    * TE_SCI_UNABLE_TO_CREATE_SEQUENCE 
  278.    *  
  279.    *  Could not create a sequence, because system resources are 
  280.    *  exempted. Must reboot. 
  281.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  282.    */ 
  283.   ,TE_SCI_UNABLE_TO_CREATE_SEQUENCE = 0x801a 
  284.  
  285.   /** 
  286.    * TE_SCI_UNRECOVERABLE_DATA_TFX_ERROR 
  287.    *  
  288.    *  Tried to send data on redundant link but failed. 
  289.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  290.    */ 
  291.   ,TE_SCI_UNRECOVERABLE_DATA_TFX_ERROR = 0x801b 
  292.  
  293.   /** 
  294.    * TE_SCI_CANNOT_INIT_LOCALSEGMENT 
  295.    *  
  296.    *  Cannot initialize local segment. A whole lot of things has 
  297.    *  gone wrong (no system resources). Must reboot. 
  298.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  299.    */ 
  300.   ,TE_SCI_CANNOT_INIT_LOCALSEGMENT = 0x801c 
  301.  
  302.   /** 
  303.    * TE_SCI_CANNOT_MAP_REMOTESEGMENT 
  304.    *  
  305.    *  Cannot map remote segment. No system resources are left.  
  306.    *  Must reboot system. 
  307.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  308.    */ 
  309.   ,TE_SCI_CANNOT_MAP_REMOTESEGMENT = 0x801d 
  310.  
  311.    /** 
  312.    * TE_SCI_UNABLE_TO_UNMAP_SEGMENT 
  313.    *  
  314.    *  Cannot free the resources used by this segment (step 1). 
  315.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  316.    */ 
  317.   ,TE_SCI_UNABLE_TO_UNMAP_SEGMENT = 0x801e 
  318.  
  319.    /** 
  320.    * TE_SCI_UNABLE_TO_REMOVE_SEGMENT 
  321.    *  
  322.    *  Cannot free the resources used by this segment (step 2). 
  323.    *  Cannot guarantee that enough resources exist for NDB 
  324.    *  to map more segment 
  325.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  326.    */ 
  327.   ,TE_SCI_UNABLE_TO_REMOVE_SEGMENT = 0x801f 
  328.  
  329.    /** 
  330.    * TE_SCI_UNABLE_TO_DISCONNECT_SEGMENT 
  331.    *  
  332.    *  Cannot disconnect from a remote segment. 
  333.    *  Recommended behavior: setPerformState(PerformDisonnect) 
  334.    */ 
  335.   ,TE_SCI_UNABLE_TO_DISCONNECT_SEGMENT = 0x8020 
  336.  
  337. }; 
  338.  
  339. /** 
  340.  * Report error 
  341.  */ 
  342. void 
  343. reportError(void * callbackObj, NodeId nodeId, TransporterError errorCode); 
  344.  
  345. #endif